始终使用相同端口的多个非同时 Java 客户端-服务器连接

Question

我正在尝试测试一种场景，其中一台服务器接受来自一个客户端的连接（每次一个），始终使用相同的端口（在服务器和客户端）。

目的是让 1 个客户端应用程序以大于 100/分钟的速率发送小块数据。显而易见的解决方案是在客户端和服务器之间建立始终连接的链接，但这是生产内容，这需要对已实现的代码进行更大的更改。使用我们今天实现的解决方案，TIME_WAIT 中始终有 +-1K 连接，我想摆脱它们。

我实现了一个简单的测试器，代码是：

public class Server {
    public static void main(String[] args) {
        ServerSocket ssock = null;
        try {
            ssock = new ServerSocket();
            ssock.bind(new InetSocketAddress(Common.SERVER_PORT));
        } catch (IOException e) {
            e.printStackTrace();
            System.exit(-1);
        }

        while(true){
            try{
                Socket cSock = ssock.accept();

                BufferedReader reader = new BufferedReader(new InputStreamReader(cSock.getInputStream()));
                reader.readLine();

                PrintWriter writer = new PrintWriter(cSock.getOutputStream());
                writer.println(Common.SERVER_SEND);
                writer.flush();

                reader.close();
                writer.close();
                cSock.close();

            }catch (Exception e) {
                System.out.println(e.getClass().getName() + ": " + e.getMessage());
            }
        }
    }
}


public class Client {

    public static void main(String[] args) throws Exception {
        InetSocketAddress cliAddr = new InetSocketAddress(
                InetAddress.getByName(args[0]), 
                Common.CLIENT_PORT);

        InetSocketAddress srvAddr = new InetSocketAddress(
                InetAddress.getByName(args[1]), 
                Common.SERVER_PORT);

        for(int j=1;j<=50;j++){
            Socket sock = null;
            try{
                sock = new Socket();
                sock.setReuseAddress(true);
                sock.bind(cliAddr);
                sock.connect(srvAddr);

                PrintWriter writer = 
                        new PrintWriter(
                                sock.getOutputStream());

                writer.println(Common.CLIENT_SEND);
                writer.flush();

                BufferedReader reader = 
                        new BufferedReader(
                                new InputStreamReader(
                                        sock.getInputStream()));
                reader.readLine();

            }catch (Exception e) {
                System.out.println(e.getClass().getName() + ": " + e.getMessage());
                System.exit(-1);
            }finally{
                if(sock!=null) sock.close();
                System.out.println("Done " + j);
            }
        }
    }
}

public class Common {
    public static final int SERVER_PORT = 9009;
    public static final int CLIENT_PORT = 9010;
    public static final String CLIENT_SEND = "Message";
    public static final String SERVER_SEND = "OK";
}

当在 Windows 主机上执行客户端和服务器时，在一个客户端执行中我总是得到

java.net.ConnectException: Connection timed out

当在 Linux 主机中执行客户端和服务器时，在某些客户端执行中我得到一个

java.net.NoRouteToHostException: Cannot assign requested address

I'我一直因为这种行为而伤透了脑筋。有人可以告诉我是否可以做我想做的事，以及我做错了什么？

Answer 1

如果您想摆脱 TIME_WAIT 状态，请不要成为接收关闭的对等方。成为发起关闭的对等方。在这种情况下，请在读取响应后立即关闭连接，并让服务器循环查找另一个请求，以便读取 EOF，而不是在发送响应后立即关闭连接。然而，这只会使问题变得更糟，因为所有 TIME_WAIT 状态都会在服务器而不是客户端累积。另一方面，服务器现在的结构是每个连接接受多个请求，因此您所要做的就是使客户端适应使用连接池，所有问题都得到解决。