我写了一个 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();
}
}
}
1
pakro888 OP 顺便一提, python 和 python 通信, java 和 java 通信都没有出现这个问题.
|
2
wwqgtxx 2019-03-21 12:58:16 +08:00 via iPhone 1
用 sendall 试试?
|
5
wwqgtxx 2019-03-21 13:00:58 +08:00 via iPhone
顺便提一下,你 java 那边用的是 readline 但是 python 那边从来没有发送过换行符
|
7
mangoDB 2019-03-21 14:06:22 +08:00
我理解 socket 通信除了正常的 close 连接,其他情况下需要你人为的控制读多少数据。
例如: 1. 以换行符为标志。 2. 消息第一字节表示数据长度。 |