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

Question

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

目的是让 1 个客户端应用程序以大于 100/min 的速率发送少量数据。显而易见的解决方案是在客户端和服务器之间建立一个始终连接的链接，但这是生产的东西，需要对已经实现的代码进行更大的更改。使用我们今天实施的解决方案，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

我一直对这种行为感到头疼。有人可以告诉我是否可以做我想做的事，以及我做错了什么？

Answer 1

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