【问题标题】:Socket verification from ServerSocket Java来自 ServerSocket Java 的套接字验证
【发布时间】:2012-07-06 09:17:22
【问题描述】:

我正在尝试创建“多客户端-单服务器”连接。 我的客户端打开连接并在服务器端创建了

     Client clt = new Client("127.0.0.1", 9000);
        clt.openConn();

...

public Client(String serverAddress, int serverPort) {
    this.serverAddress = serverAddress;
    this.serverPort = serverPort;
}
try {
        this.clientSocket = new Socket(this.serverAddress, this.serverPort);
        this.clientSocket.setKeepAlive(true);
        this.clientSocket.setSoTimeout(0);

            oos = new DataOutputStream(this.clientSocket.getOutputStream());
            ois = new DataInputStream(this.clientSocket.getInputStream());...}

...

在服务器端,我创建了 ServerSocket 的 ListArray,每一个都被我包裹在 Thread 上。

    ServerSocket serverSocket = null ;
        Socket clientSocket;
        boolean listening = true;
        ArrayList threadList = new ArrayList();
        Iterator itSrvThr;
    try {
            serverSocket = new ServerSocket(port);

        } catch (IOException e) {
            System.err.println("Could not listen on port: " + port + ".");
            System.exit(-1);
        }
        while (listening) {
            clientSocket = serverSocket.accept();
            ServerThread srvThread = new ServerThread(clientSocket);
            srvThread.start();
`...`
    }

在哪里

 ServerThread extends Thread
    {...
         public void run() {
           this.ois = new DataInputStream(socket.getInputStream());
           this.oos = new DataOutputStream(socket.getOutputStream());    
         }
    }

我的程序发送和接收对象(我称它们为“Datagramm”),它们是文件和字符串的某种包装器(假设它是客户端-服务器的某种语言)

现在关于我遇到的问题。每次需要从服务器端测试“活动”套接字时,我都必须进行验证...... 在那一刻,当 ArrayList 中出现新元素时,我正在尝试进行此验证,但这给我带来了“Datagramm”发送的问题

itSrvThr = threadList.iterator();
            while (itSrvThr.hasNext()) {
                ServerThread st = (ServerThread) itSrvThr.next();
                boolean stoppedSocket = st.getStopped();

                if (stoppedSocket) {
                    st.stop();
                    itSrvThr.remove();
                }else {??? resolution???}

stoppedSocket - 它是一个值,表示程序从客户端站点关闭了套接字。

老实说,我只使用了几周的套接字和线程,这就是为什么每个帮助和批评都是可以接受的。 ... 感谢您的回答,但我对心跳编码有疑问。首先,心跳的确切位置必须放在服务器端。

【问题讨论】:

  • 问题是什么?您似乎在问如果套接字没有“停止”该怎么办。这是正常情况——你只需继续使用它。困难的情况是决定它何时“停止”。是哪个?

标签: java sockets


【解决方案1】:

我建议您在一段时间(秒)未发送消息时从客户端和/或服务器发送心跳消息当您在这段时间内没有收到任何消息时,另一端可能会超时.

如果您有像 {message length} {message} 这样的协议,我会使用 message-length=0 作为心跳。

【讨论】:

    猜你喜欢
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 2011-06-22
    • 2012-08-05
    • 1970-01-01
    • 1970-01-01
    相关资源
    最近更新 更多