0

这是一个我从来没有想过的问题。我问了很多人,他们都不知道。无论如何,让我们解决问题。这是我尝试做的... 创建一个客户端和一个服务器。客户端连接到服务器,每 3 分钟向它发送一条消息(我减少了测试时间)。然而,必须有两个独立的线程(一个用于客户端和服务器)。我发现,客户端会继续发送消息,但服务器不会再监听 1234 端口。

客户:

import java.io.PrintWriter;
import java.net.Socket;


public class Client {

        public Client(){
                startClient();
        }

        public void startClient(){
                new Thread(new Runnable(){
                        @Override
                        public synchronized void run(){
                                try{
                                        Socket sendChat = new Socket("localhost", 1234);
                                        PrintWriter writer = new      PrintWriter(sendChat.getOutputStream());

                                while(true){
                                        Thread.sleep(1000); // normally 180000

                                        writer.println("Hello Server!");
                                }
                                }catch(Exception err){
                                        err.printStackTrace();
                                }
                        }
                }).start();
        }

}

服务器:

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Date;


public class Server {

public Server(){
        startServer();
}

    public void startServer(){
            new Thread(new Runnable(){
                    @Override
                    public synchronized void run(){
                            try{
                                    @SuppressWarnings("resource")
                                    ServerSocket server = new ServerSocket(1234);

                                    while(true){
                                            final Socket test = server.accept();
                                            BufferedReader reader = new BufferedReader(new InputStreamReader(test.getInputStream()));

                                            while(!test.isClosed()) {
                                                    Date date = new Date();

                                                    System.out.println("Server got message from client " + date);
                                            }
                                            reader.close();
                                    }
                            }catch(Exception err){
                                    err.printStackTrace();
                            }
                    }
            }).start();
    }

}

开始:

public class Start {
    public static void main(String[] args){
        new Server();
        new Client();   
    }
}

如果有人能告诉我出了什么问题,我将不胜感激,因为我真的不知道。

4

3 回答 3

0

在 Server 类的循环外写下两行,while它将为您工作。

 final Socket test = server.accept();
 BufferedReader reader = new BufferedReader(new InputStreamReader(test.getInputStream()));

您的代码中发生了什么:在 while 循环完成后,服务器每次都会等待新客户端,但在该实例中没有客户端将与服务器连接。因此,服务器将等到新客户端到来,服务器将接受该新客户端并继续处理。

于 2013-08-23T12:59:23.783 回答
0

您处于循环堆栈中,请尝试在消息后关闭客户端中的连接。

于 2013-08-23T13:18:36.377 回答
0

查看他们使用的这些链接

socket.setKeepAlive(true);

java.net.Socket TCP keep-alive 用法

java中的永久和持久的Socket连接

于 2021-05-20T20:33:20.927 回答