JAVA实现SOCKET多客户端通信的案例

首先，我们需要明确一下什么是Socket，Socket是一种抽象的概念，是对地址和端口的封装。在计算机网络中，Socket指的就是TCP/IP协议网络编程接口，它是应用层与传输层之间的连接门户，使得网络应用程序能够访问传输层协议，进行数据传输。本文将详细讲解如何用Java实现Socket多客户端通信的案例。

1. 服务器端的实现

1.1 创建ServerSocket对象

首先，我们需要创建ServerSocket对象作为服务器端的接口，监听本机的指定端口号，以便可以与客户端建立TCP连接。这里以创建端口号为8888的ServerSocket对象为例，代码如下：

int port = 8888;
ServerSocket serverSocket = new ServerSocket(port);

1.2 接收客户端请求

接下来，我们需要创建一个循环，不断地接收客户端请求，根据客户端请求的不同，采取不同的处理方式。代码如下：

while (true) {
    //等待客户端的连接请求
    Socket socket = serverSocket.accept();
    //创建一个新的线程处理客户端请求
    new ServerThread(socket).start();
}

1.3 创建线程处理客户端请求

为了同时处理多个客户端请求，我们需要创建一个线程处理每个客户端请求。代码如下：

public class ServerThread extends Thread {
    private Socket socket;
    public ServerThread(Socket socket) {
        this.socket = socket;
    }
    @Override
    public void run() {
        try {
            //获取输入流
            BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            //获取输出流
            PrintWriter out = new PrintWriter(socket.getOutputStream());
            //读取客户端发送的数据
            String s = in.readLine();
            //处理客户端请求，并将响应发送回客户端
            out.println("Hello, " + s);
            out.flush();
            //关闭流和客户端连接
            in.close();
            out.close();
            socket.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

2. 客户端的实现

2.1 创建Socket对象

客户端需要创建一个Socket对象，指定服务器的IP地址和端口号，代码如下：

String host = "127.0.0.1";
int port = 8888;
Socket socket = new Socket(host, port);

2.2 发送请求并接收响应

客户端需要向服务器发送请求，并接收服务器的响应。代码如下：

//获取输入流
BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
//获取输出流
PrintWriter out = new PrintWriter(socket.getOutputStream());
//向服务器发送请求
String s = "world";
out.println(s);
out.flush();
//接收服务器的响应
String res = in.readLine();
System.out.println("服务器响应：" + res);
//关闭流和客户端连接
in.close();
out.close();
socket.close();

3. 完整代码示例

下面是一个完整的Java Socket多客户端通信的案例代码示例：

3.1 服务器端代码

public class Server {
    public static void main(String[] args) throws IOException {
        int port = 8888;
        ServerSocket serverSocket = new ServerSocket(port);
        System.out.println("服务器启动成功！");
        while (true) {
            //等待客户端的连接请求
            Socket socket = serverSocket.accept();
            System.out.println("客户端连接成功！");
            //创建一个新的线程处理客户端请求
            new ServerThread(socket).start();
        }
    }
    public static class ServerThread extends Thread {
        private Socket socket;
        public ServerThread(Socket socket) {
            this.socket = socket;
        }
        @Override
        public void run() {
            try {
                //获取输入流
                BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
                //获取输出流
                PrintWriter out = new PrintWriter(socket.getOutputStream());
                //读取客户端发送的数据
                String s = in.readLine();
                System.out.println("接收到客户端发送的数据：" + s);
                //处理客户端请求，并将响应发送回客户端
                out.println("Hello, " + s);
                out.flush();
                //关闭流和客户端连接
                in.close();
                out.close();
                socket.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}

3.2 客户端代码

public class Client {
    public static void main(String[] args) throws IOException {
        String host = "127.0.0.1";
        int port = 8888;
        Socket socket = new Socket(host, port);
        //获取输入流
        BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
        //获取输出流
        PrintWriter out = new PrintWriter(socket.getOutputStream());
        //向服务器发送请求
        String s = "world";
        out.println(s);
        out.flush();
        System.out.println("发送数据：" + s);
        //接收服务器的响应
        String res = in.readLine();
        System.out.println("服务器响应：" + res);
        //关闭流和客户端连接
        in.close();
        out.close();
        socket.close();
    }
}

以上就是Java实现Socket多客户端通信的完整攻略，我们通过创建ServerSocket对象监听客户端请求，创建线程处理客户端请求，并通过Socket对象实现客户端与服务器之间的通信。