V2EX = way to explore
V2EX 是一个关于分享和探索的地方
现在注册
已注册用户请  登录
V2EX 提问指南
pakro888
V2EX  ›  问与答

Python 和 Java socket 通信问题请教

  •  
  •   pakro888 · 2019-03-21 12:38:58 +08:00 · 1966 次点击
    这是一个创建于 2075 天前的主题,其中的信息可能已经有所发展或是发生改变。

    我写了一个 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
    pakro888
        1
    pakro888  
    OP
       2019-03-21 12:40:42 +08:00
    顺便一提, python 和 python 通信, java 和 java 通信都没有出现这个问题.
    wwqgtxx
        2
    wwqgtxx  
       2019-03-21 12:58:16 +08:00 via iPhone   ❤️ 1
    用 sendall 试试?
    pakro888
        3
    pakro888  
    OP
       2019-03-21 12:59:51 +08:00
    @wwqgtxx #2 我自闭了,找到问题所在了.python 需要主动加一个 \n 换行符在消息最后才行
    pakro888
        4
    pakro888  
    OP
       2019-03-21 13:00:51 +08:00
    @wwqgtxx #2 sendall 也是一样的效果.
    wwqgtxx
        5
    wwqgtxx  
       2019-03-21 13:00:58 +08:00 via iPhone
    顺便提一下,你 java 那边用的是 readline 但是 python 那边从来没有发送过换行符
    pakro888
        6
    pakro888  
    OP
       2019-03-21 13:52:53 +08:00
    @wwqgtxx #5 是的,就是这个问题
    mangoDB
        7
    mangoDB  
       2019-03-21 14:06:22 +08:00
    我理解 socket 通信除了正常的 close 连接,其他情况下需要你人为的控制读多少数据。

    例如:

    1. 以换行符为标志。

    2. 消息第一字节表示数据长度。
    pakro888
        8
    pakro888  
    OP
       2019-03-22 10:07:29 +08:00 via Android
    @mangoDB 受教了,之前都是同种语言进行通信测试,没考虑过这种问题
    关于   ·   帮助文档   ·   博客   ·   API   ·   FAQ   ·   实用小工具   ·   2847 人在线   最高记录 6679   ·     Select Language
    创意工作者们的社区
    World is powered by solitude
    VERSION: 3.9.8.5 · 32ms · UTC 00:06 · PVG 08:06 · LAX 16:06 · JFK 19:06
    Developed with CodeLauncher
    ♥ Do have faith in what you're doing.