Java Socket重要参数讲解(Java Socket关键参数详解及使用指南)

原创

ithorizon 6个月前 (10-20) 阅读数 20 #后端开发

Java Socket重要参数讲解

一、Java Socket简介

Java Socket是Java提供的一种用于网络通信的API，它允许我们通过TCP/IP协议在网络上进行数据传输。Socket编程是Java网络编程的基础，掌握Socket编程对于开发网络应用程序至关重要。

二、Java Socket关键参数详解及使用指南

下面我们将详细介绍Java Socket中的重要参数，以及怎样正确使用这些参数。

1. ServerSocket类参数

ServerSocket类用于创建服务器端的Socket，以下是ServerSocket类的常用参数：

1.1 port参数

port参数用于指定服务器端Socket绑定的端口号。端口号是一个介于0到65535之间的整数，其中0到1023为系统保留端口。如果未指定端口号，系统会自动分配一个。

1.2 backlog参数

backlog参数用于设置服务器端Socket的连接队列长度。当客户端发起连接请求时，如果服务器端处理不过来，这些请求会暂时存储在连接队列中。当队列满时，新的连接请求会被拒绝。默认情况下，backlog的值为50。

1.3 bindAddress参数

bindAddress参数用于指定服务器端Socket绑定的IP地址。如果不指定，服务器端Socket会绑定到所有可用的本地地址。


ServerSocket serverSocket = new ServerSocket(port, backlog, bindAddress);

2. Socket类参数

Socket类用于创建客户端的Socket，以下是Socket类的常用参数：

2.1 address参数

address参数用于指定客户端Socket要连接的服务器端的IP地址。

2.2 port参数

port参数用于指定客户端Socket要连接的服务器端的端口号。

2.3 timeout参数

timeout参数用于设置Socket连接的超时时间。如果连接在指定的时间内未产生成就，将抛出SocketTimeoutException异常。默认情况下，timeout为0，即无限等待。


Socket socket = new Socket(address, port, localAddress, localPort);
socket.setSoTimeout(timeout);

3. Socket选项

Socket选项用于设置Socket的各种属性，以下是常用的Socket选项：

3.1 TCP_NODELAY选项

TCP_NODELAY选项用于禁用Nagle算法。Nagle算法是一种网络优化算法，它会在发送数据前等待更多的数据，以降低网络拥塞。但在某些场景下，我们期望立即发送数据，此时可以禁用Nagle算法。


socket.setOption(SocketOptions.TCP_NODELAY, true);

3.2 SO_REUSEADDR选项

SO_REUSEADDR选项用于设置Socket是否可以重用地址。默认情况下，当Socket关闭后，其绑定的地址和端口在一定时间内不能被其他Socket使用。如果设置了SO_REUSEADDR选项，那么在Socket关闭后，其他Socket可以立即使用这个地址和端口。


socket.setOption(SocketOptions.SO_REUSEADDR, true);

3.3 SO_TIMEOUT选项

SO_TIMEOUT选项用于设置Socket的读写超时时间。如果读写操作在指定的时间内未完成，将抛出SocketTimeoutException异常。默认情况下，SO_TIMEOUT为0，即无限等待。


socket.setOption(SocketOptions.SO_TIMEOUT, timeout);

4. 实例代码

下面是一个简洁的Socket服务器和客户端示例，展示了怎样使用上述参数和选项。

4.1 服务器端代码


public class Server {
    public static void main(String[] args) throws IOException {
        int port = 12345;
        int backlog = 10;
        InetAddress bindAddress = InetAddress.getByName("127.0.0.1");
        try (ServerSocket serverSocket = new ServerSocket(port, backlog, bindAddress)) {
            System.out.println("Server started on port " + port);
            while (true) {
                Socket clientSocket = serverSocket.accept();
                System.out.println("Client connected: " + clientSocket.getInetAddress());
                // 处理客户端请求
                handleClient(clientSocket);
            }
        }
    }
    private static void handleClient(Socket clientSocket) throws IOException {
        // 获取输入流和输出流
        BufferedReader input = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
        PrintWriter output = new PrintWriter(clientSocket.getOutputStream(), true);
        // 读取客户端发送的数据
        String line;
        while ((line = input.readLine()) != null) {
            System.out.println("Client says: " + line);
            output.println("Server received: " + line);
        }
        // 关闭连接
        clientSocket.close();
    }
}

4.2 客户端代码


public class Client {
    public static void main(String[] args) throws IOException {
        String host = "127.0.0.1";
        int port = 12345;
        int timeout = 5000;
        try (Socket socket = new Socket(host, port)) {
            socket.setSoTimeout(timeout);
            // 获取输入流和输出流
            PrintWriter output = new PrintWriter(socket.getOutputStream(), true);
            BufferedReader input = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            // 向服务器发送数据
            output.println("Hello, Server!");
            // 读取服务器响应的数据
            String response;
            while ((response = input.readLine()) != null) {
                System.out.println("Server says: " + response);
            }
        }
    }
}