Python 和 Java socket 通信问题请教

V2EX = way to explore

V2EX 是一个关于分享和探索的地方

现在注册

已注册用户请登录

V2EX 提问指南

这是一个创建于 2104 天前的主题，其中的信息可能已经有所发展或是发生改变。

我写了一个 python 的服务端程序, 和 java 的客户端进行通信. 但是我发现了一个问题,就是服务器在发送消息后 java 客户端会一直阻塞在接收消息这里, 但是我服务器早已经把消息发送完毕了.

然后我发现只有 python 服务器主动断开连接 java 端才能收到消息. 但是我是想要实现客户端和服务器的长连接, 如果服务器主动断开了连接, 下次通信时又需要建立一个新连接,这就不是长连接了. 有大佬知道这个问题怎么解决吗?

下面是我的代码:

python 服务器端

s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.bind(('0.0.0.0', 9999))
s.listen(5)
print('Waiting for connection...')

def tcplink(sock, addr):
    print('%s :Accept new connection from %s:%s...' % (time.strftime("%Y-%m-%d %H:%M:%S", time.localtime()), addr[0], addr[1]))
    sock.send('Welcome!'.encode())
    while True:
        data = sock.recv(1024).decode()
        time.sleep(0.5)
        if data == 'exit' or not data:
            break
        sock.send('Hello, %s!'.encode() % data)
        sock.close()  # 在这里断开连接才行
        break  #上面断开连接这里退出循环

    # sock.close()  # 写在这里 java 端就接收不到消息
    print('Connection closed.')

def main():
    while True:
        # 接受一个新连接:
        sock, addr = s.accept()
        # 创建新线程来处理 TCP 连接:
        t = threading.Thread(target=tcplink, args=(sock, addr))
        t.start()
      
if __name__ == '__main__':
    main()

java 客户端

public class Main {
    public static void main(String[] args) {
        try {
            Socket s = new Socket("192.168.199.121", 9999);

            //构建 IO
            InputStream is = s.getInputStream();
            OutputStream os = s.getOutputStream();

            /* 向服务器端发送一条消息 */
            BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(os));
            bw.write("这是一条消息");
            bw.flush();

            //读取服务器返回的消息
            BufferedReader br = new BufferedReader(new InputStreamReader(is));  // 服务器不主动断开连接就永远卡在这里
            String mess = br.readLine();  
            System.out.println("服务器：" + mess);
        } catch (UnknownHostException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

8 条回复 • 2019-03-22 10:07:29 +08:00