java搭建一个Socket服务器响应多用户访问

1. 首先，了解什么是Socket服务器？

Socket服务器是一个能够接收并处理多个客户端请求的服务器程序，它使用Socket来实现网络通信。Java中，使用ServerSocket和Socket类来实现一个基本的Socket服务器程序。

1. 准备工作

在开始搭建Socket服务器之前，需要安装一个Java开发环境（JDK），下面以JDK11为例：

• 下载JDK11，并安装到本地计算机。

• 配置环境变量，在系统环境变量中添加JAVA_HOME，指向JDK11的安装路径。

• 编写Java代码

下面给出一个最基本的Java Socket服务器程序示例，代码实现了一个简单的“Echo服务”，即接收客户端发送的消息，并将其原封不动地返回给客户端。

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;

public class EchoServer {
    public static void main(String[] args) throws IOException {
        // 创建ServerSocket并监听指定端口
        ServerSocket serverSocket = new ServerSocket(8888);
        System.out.println("Socket服务器已启动，监听端口8888...");

        while (true) {
            // 等待客户端连接
            Socket clientSocket = serverSocket.accept();
            System.out.println("客户端已连接：" + clientSocket.getRemoteSocketAddress());

            // 处理客户端请求
            InputStream inputStream = clientSocket.getInputStream();
            OutputStream outputStream = clientSocket.getOutputStream();
            byte[] buffer = new byte[1024];
            int len;
            while ((len = inputStream.read(buffer)) != -1) { // 读取客户端发送的消息
                outputStream.write(buffer, 0, len); // 将消息原封不动地返回给客户端
            }

            // 关闭客户端连接
            clientSocket.close();
            System.out.println("客户端已断开连接：" + clientSocket.getRemoteSocketAddress());
        }
    }
}

1. 运行Socket服务器

在命令行中进入到代码所在的目录，然后使用以下命令编译并运行Java程序：

javac EchoServer.java
java EchoServer

此时，Socket服务器已经启动并在监听端口8888接收客户端的连接。可以使用telnet命令模拟多个客户端连接服务器：

telnet localhost 8888

连接成功后，可以输入任意字符串并按下Enter键，此时服务器会将输入的字符串原封不动地返回给客户端。

1. 示例2

下面给出另一个示例，实现了一个简单的聊天室程序，多个客户端可以在同一个聊天室中实现互相聊天。具体实现方式就是在服务器端维护一个客户端列表，并在接收到客户端消息时，将消息广播给所有连接到服务器的客户端。

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;
import java.util.List;

public class ChatRoomServer {
    private List<ClientHandler> clients = new ArrayList<>(); // 客户端列表

    public static void main(String[] args) throws IOException {
        // 创建ServerSocket并监听指定端口
        ServerSocket serverSocket = new ServerSocket(8888);
        System.out.println("Socket服务器已启动，监听端口8888...");
        ChatRoomServer chatRoomServer = new ChatRoomServer();

        while (true) {
            // 等待客户端连接
            Socket clientSocket = serverSocket.accept();
            System.out.println("客户端已连接：" + clientSocket.getRemoteSocketAddress());

            // 处理客户端请求
            ClientHandler clientHandler = chatRoomServer.new ClientHandler(clientSocket);
            clients.add(clientHandler); // 添加到客户端列表
            clientHandler.start(); // 启动客户端处理线程
        }
    }

    private class ClientHandler extends Thread {
        private Socket clientSocket;
        private InputStream inputStream;
        private OutputStream outputStream;
        private String nickname; // 客户端昵称

        public ClientHandler(Socket clientSocket) throws IOException {
            this.clientSocket = clientSocket;
            inputStream = clientSocket.getInputStream();
            outputStream = clientSocket.getOutputStream();
        }

        @Override
        public void run() {
            try {
                // 接收客户端昵称
                byte[] buffer = new byte[1024];
                int len = inputStream.read(buffer);
                nickname = new String(buffer, 0, len, "UTF-8");
                broadcast(nickname + "加入了聊天室\n"); // 广播消息

                while (true) {
                    // 读取客户端发送的消息
                    len = inputStream.read(buffer);
                    String message = new String(buffer, 0, len, "UTF-8");
                    if ("exit".equals(message)) {
                        broadcast(nickname + "离开了聊天室\n"); // 广播消息
                        clients.remove(this); // 从客户端列表中移除
                        clientSocket.close(); // 关闭客户端连接
                        System.out.println("客户端已断开连接：" + clientSocket.getRemoteSocketAddress());
                        break;
                    }
                    broadcast(nickname + "：" + message); // 广播消息
                }
            } catch (IOException e) {
                e.printStackTrace();
            }
        }

        private void broadcast(String message) throws IOException {
            System.out.println(message);
            for (ClientHandler client : clients) { // 遍历客户端列表广播消息
                if (client != this) {
                    client.outputStream.write(message.getBytes("UTF-8"));
                    client.outputStream.flush();
                }
            }
        }
    }
}

1. 运行聊天室服务器

同样的，在命令行中进入到代码所在的目录，使用以下命令编译并运行Java程序：

javac ChatRoomServer.java
java ChatRoomServer

此时，聊天室服务器已经启动并在监听端口8888接收客户端的连接。同样可以使用telnet命令模拟多个客户端连接到服务器，并在聊天室中互相通信。

以上就是Java搭建一个Socket服务器响应多用户访问的完整攻略，希望能对你有所帮助。