在聊天应用程序中使用单个客户端创建多个套接字

Question

我正在测试一个聊天应用程序的用户数量。所以我正在尝试如下：

我正在尝试通过登录来运行我的聊天应用程序，以便在 for 循环中只为一个用户进行 1000 次聊天。这是我的部分代码。

public void LoginChatConnect() {
    try {

        // while(true){
         for(int i=0;i<1000;i++){
        System.out.println("inside loginChatLogin");
        String userId = "Rahul";
        String password = "rahul";
        sockChatListen = new Socket("localhost", 5004);
        // /sockChatListen.
        dosChatListen = new DataOutputStream(
                sockChatListen.getOutputStream());
        disChatListen = new DataInputStream(sockChatListen.getInputStream());
        dosChatListen.writeUTF(userId);
        dosChatListen.writeUTF(password);
        // System.out.println(dosChatListen.toString());
        dosChatListen.flush();


        // sockChatListen.close();
        boolean b = sockChatListen.isClosed();

        System.out.println("connection open**********************" + b);
        sockChatListen.close();

        System.out.println("connection closed**********************" + b);
        count++;
        System.out.println("count" + count);
         }

    } catch (UnknownHostException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    } catch (IOException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    }

}

在上面的代码中，我只是想为一个用户登录 1000 次。但是在某些登录后它给了我这个套接字错误。

java.net.SocketException: Connection reset by peer: socket write error
    at java.net.SocketOutputStream.socketWrite0(Native Method)

我在这里尝试创建与单个端口 5004 的连接。为什么在 100 多个成功连接（登录）后出现错误。？

我应该如何恢复这个问题？

任何建议都会有所帮助。

Answer 1

我从您的帖子中了解到，您希望模拟 1000 个用户同时登录到聊天服务器。我相信您正在尝试测试聊天服务器上的负载。

但是，从您的代码中，我看到您每次都在循环中建立和关闭套接字连接。这类似于 1000 个用户在队列中等待并尝试一个接一个地登录到服务器。这不是模拟并发负载，而是对服务器的 1000 次连续调用，不适合对您的服务器进行负载测试。

我的 cmets 基于上述理解。如果不是这种情况，请纠正。

关于你得到的异常，我不知道为什么在 100 多次尝试后它不应该工作。可能您需要检查服务器端代码以找出问题所在。