Java Socket(套接字)通常也称作"套接字"，用于描述IP地址和端口，是一个通信链的句柄。应用程序通常通过"套接字"向网络发出请求或者应答网络请求。
使用Socket实现多个客户端和同一客户端通讯；首先客户端连接服务端发送一条消息，服务端接收到消息后进行处理，完成后再回复客户端一条消息。本人通过自己的思维编写了一份服务端和客户端实现的代码，望能与大家相互学习，共同进步。
服务端代码
public class Server {
public static void main(String[] args) throws IOException {
// 为了简单起见，所有的异常信息都往外抛
int port = 8899;
// 定义一个ServiceSocket监听在端口8899上
ServerSocket server = new ServerSocket(port);
System.out.println("等待与客户端建立连接...");
while (true) {
// server尝试接收其他Socket的连接请求，server的accept方法是阻塞式的
Socket socket = server.accept();
// 每接收到一个Socket就建立一个新的线程来处理它
new Thread(new Task(socket)).start();
}
// server.close();
}
static class Task implements Runnable {
private Socket socket;
public Task(Socket socket) {
this.socket = socket;
}
@Override
public void run() {
try {
handlerSocket();
}
catch (Exception e) {
e.printStackTrace();
}
}
private void handlerSocket() throws Exception {
// 跟客户端建立好连接之后，我们就可以获取socket的InputStream，并从中读取客户端发过来的信息了
BufferedReader br = new BufferedReader(
new InputStreamReader(socket.getInputStream(), "UTF-8"));
StringBuilder sb = new StringBuilder();
String temp;
int index;
while ((temp = br.readLine()) != null) {
if ((index = temp.indexOf("eof")) != -1) {
// 遇到eof时就结束接收
sb.append(temp.substring(0, index));
break;
}
sb.append(temp);
}
System.out.println("Form Cliect[port:" + socket.getPort()
+ "] 消息内容:" + sb.toString());
// 回应一下客户端
Writer writer = new OutputStreamWriter(socket.getOutputStream(),
"UTF-8");
writer.write(String.format("Hi,%d.天朗气清，惠风和畅！", socket.getPort()));
writer.flush();
writer.close();
System.out.println(
"To Cliect[port:" + socket.getPort() + "] 回复客户端的消息发送成功");
br.close();
socket.close();
}
}
}
客户端代码
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.Reader;
import java.io.Writer;
import java.net.Socket;
public class Client {
public static void main(String[] args) {
// 开启三个客户端，一个线程代表一个客户端
for (int i = 0; i < 3; i++) {
new Thread(new Runnable() {
@Override public void run() {
try {
TestClient client = TestClientFactory.createClient();
client.send(String.format("Hello,Server!I'm %d.这周末天气如何。", client.client.getLocalPort()));
client.receive();
}
catch (Exception e) {
e.printStackTrace();
}
}
}
).start();
}
}
static class TestClientFactory {
public static TestClient createClient() throws Exception {
return new TestClient("127.0.0.1", 8899);
}
}
static class TestClient {
public TestClient(String host, int port) throws Exception {
// 与服务端建立连接
this.client = new Socket(host, port);
System.out.println("Cliect[port:" + client.getLocalPort() + "] 与服务端建立连接...");
}
private Socket client;
private Writer writer;
public void send(String msg) throws Exception {
// 建立连接后就可以往服务端写数据了
if(writer == null) {
writer = new OutputStreamWriter(client.getOutputStream(), "UTF-8");
}
writer.write(msg);
writer.write("eofn");
writer.flush();
// 写完后要记得flush
System.out.println("Cliect[port:" + client.getLocalPort() + "] 消息发送成功");
}
public void receive() throws Exception {
// 写完以后进行读操作
Reader reader = new InputStreamReader(client.getInputStream(), "UTF-8");
// 设置接收数据超时间为10秒
client.setSoTimeout(10*1000);
char[] chars = new char[64];
int len;
StringBuilder sb = new StringBuilder();
while ((len = reader.read(chars)) != -1) {
sb.append(new String(chars, 0, len));
}
System.out.println("Cliect[port:" + client.getLocalPort() + "] 消息收到了，内容:" + sb.toString());
reader.close();
// 关闭连接
writer.close();
client.close();
}
}
}
接下来模拟一下：
1.首先运行服务端
2.接着运行客户端（开三个客户端请求）
为了演示有所区分，服务端我使用的是Eclipse工具,客户端使用的是IntelliJ IDEA工具。这时可以看到客户端在控制台打印出来的消息
一个Port端口号代表一个客户端，回过来看下服务端在控制台打印出来的消息
总结
以上就是本文关于Java编程Socket实现多个客户端连接同一个服务端代码的全部内容，希望对大家有所帮助。有问题可以留言，小编会及时回复大家的。
