本文目录一览：
- 1、java中如何实现多个客户端与服务器连接
- 2、怎么用java代码连接到服务器？
- 3、怎么用java代码连接到服务器
- 4、kafka java 通过url连接服务器
- 5、本地java项目如何连接阿里云服务器上的mysql？
- 6、java.net.connectexception无法连接至服务器
java中如何实现多个客户端与服务器连接
服务器端可以采用多线程处理客户请求，例如：
package threadPool;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class ThreadPoolServer {
private int port = 8000;
private ServerSocket serverSocket;
private ExecutorService executorService; //线程池
private final int POOL_SIZE = 4; //单个CPU时线程池中的工作线程数目
public ThreadPoolServer() throws IOException{
serverSocket = new ServerSocket(port);
//创建线程池
//Runtime 的availableProcessors()方法返回当前系统CPU的数目
//系统CPU越多，线程池中的工作线程数目越多
executorService = Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors()*POOL_SIZE);
System.out.println("服务器已启动！！");
}
public void service(){
while(true){
Socket socket = null;
try{
socket = serverSocket.accept();
executorService.execute(new Handler(socket));
}catch(IOException e){
e.printStackTrace();
}
}
}
public static void main(String[] args) {
try {
new ThreadPoolServer().service();
} catch (IOException e) {
e.printStackTrace();
}
}
}
class Handler implements Runnable {
private Socket socket;
public Handler(Socket socket) {
this.socket = socket;
}
private PrintWriter getWriter(Socket socket) throws IOException {
OutputStream socketOut = socket.getOutputStream();
return new PrintWriter(socketOut, true);
}
private BufferedReader getReader(Socket socket) throws IOException {
InputStream socketIn = socket.getInputStream();
return new BufferedReader(new InputStreamReader(socketIn));
}
public String echo(String msg) {
return "echo:" + msg;
}
@Override
public void run() {
try {
System.out.println("New connection accepted:" + socket.getInetAddress() + ":" + socket.getPort());
BufferedReader br = getReader(socket);
PrintWriter pw = getWriter(socket);
String msg = null;
while ((msg = br.readLine()) != null) {
System.out.println(msg);
pw.println(echo(msg));
if (msg.equals("bye")) {
break;
}
}
} catch (IOException e) {
e.printStackTrace();
} finally {
try {
if (socket != null)
socket.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
怎么用java代码连接到服务器？
用Socket类去连接\x0d\x0a String ip = "192.168.0.57";\x0d\x0a int port=7000;\x0d\x0a InputStream in;\x0d\x0a OutputStream out;\x0d\x0aSocket sock = null; \x0d\x0a try {\x0d\x0a sock = new Socket(ip,port);\x0d\x0a sock.setSoTimeout(60*1000);//设置超时\x0d\x0a this.in = sock.getInputStream();\x0d\x0a this.out = sock.getOutputStream();\x0d\x0a } catch (Exception e) {\x0d\x0a throw new Exception("与终端连接失败!");\x0d\x0a }
怎么用java代码连接到服务器
首先就肯定要知道ServerSocket，服务端的服务端口以及服务器的地址。
然后再用 Socket socket=new Socket(port,address);
最后，如果你需要接收数据之类的，就用socket.getInputStream(),发送数据用socket.getOutputStream()
kafka java 通过url连接服务器
可以连接到一个网络服务器并且能够从这个服务器下载指定的URL，程序中直接使用HTTP协议。程序将定义一个输出流，下载的URL的内容将来被写入这个流，通过socket来获得输入和输出流：
view sourceprint?
01 import java.io.*;
02 import java.net.*;
03 public class HttpClient {
04 public static void main(String[] args) {
05 try {
06 // Demo参数:
07 if ((args.length != 1) (args.length != 2))
08 throw new IllegalArgumentException("Wrong number of args");
09 //定义输出流，下载的URL内容被写入这个流
10 OutputStream to_file;
11 if (args.length == 2) to_file = new FileOutputStream(args[1]);
12 else to_file = System.out;
13 //使用URL类来把用户指定的URL解析成几个部分
14 URL url = new URL(args[0]);
15 String protocol = url.getProtocol();
16 if (!protocol.equals("http")) // 检验是否满足支持的协议
17 throw new IllegalArgumentException("Must use 'http:' protocol");
18 String host = url.getHost();
19 int port = url.getPort();
20 if (port == -1) port = 80; //如果没有指定端口，用默认端口
21 String filename = url.getFile();
22 // 打开一个连接到指定主机和端口的网络socket连接
23 Socket socket = new Socket(host, port);
24 // 通过socket来获得输入和输出流
25 InputStream from_server = socket.getInputStream();
26 PrintWriter to_server = new PrintWriter(socket.getOutputStream());
27
28 // 发送HTTP GET命令给网络服务器，指定要下载的文件
29 // 使用了一个老版本非常简单的HTTP协议
30 to_server.print("GET " + filename + "\n\n");
31 to_server.flush(); // 立即发送
32 // 现在读取服务器的响应，把接收到的内容写入文件
33 byte[] buffer = new byte[4096];
34 int bytes_read;
35 while((bytes_read = from_server.read(buffer)) != -1)
36 to_file.write(buffer, 0, bytes_read);
37 // 当服务器关闭连接时，也关闭stuff
38 socket.close();
39 to_file.close();
40 }
41 catch (Exception e) { // 发布错误
42 System.err.println(e);
43 System.err.println("Usage: java HttpClient URL [filename]");
44 }
45 }
46 }
本地java项目如何连接阿里云服务器上的mysql？
首先您需要保证您本地Java项目是可以联网的，然后在mysql的连接中输入阿里云服务器的地址以及数据库名和密码就行。
java.net.connectexception无法连接至服务器
出现这个问题的原因，就是连接远程服务的网络不通或者是端口有问题导致的。
问题原因排查：
第一步：在黑窗口中输入 ：ping ip是否连通；如果没问题进行第二步。
第二步：在黑窗口中输入：telnet ip 端口，查看端口是否可以访问，如果没问题进行第三步。
第三步：在黑窗口输入：ping 地址（此地址就是conn的地址）。
备注：以上三步肯定能够排查出问题原因的。如果还是不行，那么就是代码编写的有问题。
