java - JUnit 测试卡在 clientSocket.accept()？

Question

我需要使用 JUnit 测试一些客户端/服务器应用程序，但我在测试客户端与服务器的连接时遇到了问题。似乎测试卡在服务器类中的“Socket clientSocket = serverSocket.accept()”行，它不让我连接新客户端。

这是 JUnit 类:

 @Test
        public void testNetServerComm_1() throws Exception {
            server = new NetServerComm();
            assertNotNull(server);
        }

        @Test
        public void testAddMessageToQueue_1() throws Exception {
            NetServerComm fixture = new NetServerComm();
            NetServerSideMessage msg = new NetServerSideMessage(birdsong.comm.ServerSideMessage.Type.BIRDSONG_MESSAGE, "",
                    "");
            fixture.addMessageToQueue(msg);
            assertEquals(1, fixture.getMsgQueueSize());
        }

    @Test
        public void testClientIsConnected_1() throws Exception {
            NetServerComm fixture = new NetServerComm();
            fixture.start();

            //test doesn't go further that this..

            String nickname = "john";
            new NetClientComm().connect("127.0.0.1", nickname);
            boolean result = fixture.isClientConnected(nickname);
            assertTrue(result);
        }

客户端类:

//connects to the server
@Override
    public void connect(String host, String nickname) {
        try {
            clientNickname = nickname;
            System.out.println("Address= " + host + " and NickName = " + nickname);
            socket = new Socket(host, NetServerComm.PORTO); //8080
            System.out.println("Socket = " + socket);
            serverMsg = new NetServerSideMessage(ServerSideMessage.Type.CLIENT_CONNECTED, null, clientNickname);
            out = new ObjectOutputStream(socket.getOutputStream());
            out.writeObject(serverMsg);
            isConnected = true;
            messageHandler = new Thread(new MessageHandler(socket));
            messageHandler.start();
        } catch (IOException e) {
            System.out.println("Failed connecting to the server.");
            e.printStackTrace();
        }
    }

服务器类:

//starts the server
@Override
    public void start() {
        try {
            serverSocket = new ServerSocket(PORTO); //8080
            System.out.println("Servidor is online: " + serverSocket);
            try {
                while (true) {
                    Socket clientSocket = serverSocket.accept();

                     //test hangs at the method above^^^

                    checkNewClient(clientSocket);
                    if (nameCheck == true)
                        new Thread(new ClientHandler(clientSocket)).start();
                }
            } finally {
                System.out.println("Closing the server..");
                serverSocket.close();
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

Answer 1

看起来您的 start() 方法正由与测试相同的线程执行，因此它阻塞在那里(在 accept() 部分)。您能否尝试让这个方法由一个新的 Thread 来执行？ ——伯杰

这似乎已经完成了工作:) – JDev