TCP socket函数recv()阻塞程序

Question

我正在编写一个简单的 TCP 服务器程序。一切正常，但函数recv() 却不行。

import socket
import threading

def connectionHandler(sock):
    data="#1111#Welcome on Server!"
    sock.sendall(data.encode('ascii'))
    username = sock.recv(1024)
    password = sock.recv(1024)
    print('{}, {}'.format(username, password))
    conn.close()
HOST = socket.gethostname()
PORT = 8888
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
s.bind((HOST, PORT))
s.listen(10)
while True:
    conn, addr = s.accept()
    print('Connected by', addr)
    t = threading.Thread(target=connectionHandler, args=(conn,))
    t.start()
conn.close()

当我评论所有对recv() 的调用时，程序运行正常，但是当我想从我的客户端（智能手机上的 android 客户端）接收答案时，程序会自行阻塞（我认为 recv() 是等待消息）。我知道我必须设置超时，但这并不能解决我的问题。我想先发送消息，然后接收一些东西。为什么recv() 会屏蔽sendall()？

Android监听函数：

public String listener(Socket x) throws IOException{
    try {
        Log.d("Listener","Started");
        String inp;
        BufferedReader in = new BufferedReader(new InputStreamReader(x.getInputStream()));
        inp = in.readLine();
        Log.d("Listener","Ended");
        return inp;

    } catch (UnknownHostException e1) {
        e1.printStackTrace();
        return "ERROR";
    } catch (IOException e1) {
        e1.printStackTrace();
        return "ERROR";
    }
}`

Answer 1

在 Python 服务器上，你发送这个：

data="#1111#Welcome on Server!"
sock.sendall(data.encode('ascii'))

在 Java 客户端上，您可以这样阅读：

inp = in.readLine(); 

readLine 一直读取直到找到换行符。但是你永远不会发送换行符。所以它会一直读下去。

---

您还有其他问题需要在这里解决。

例如，当they're actually byte streams 时，您的 Python 代码假定 TCP 套接字是消息流，因此您的 username = sock.recv(1024) 可能会同时获得用户名和密码，导致下一个 recv 永远阻塞，或者它可能会获得一半用户名并导致虚假登录失败，或者您可以想象的任何其他事情。 （当然，Android 代码甚至不发送它们中的任何一个这一事实是一个更大的问题，但我假设您知道这一点，只是还没有编写该代码。）

这个问题实际上指向了解决这个问题的一种方法：如果您的任何消息都不允许包含换行符，您可以只使用换行符作为消息的终止符。您已经在 J​​ava 端这样做了；您只需要记住在发送时添加\n。在 Python 方面，套接字上的 makefile 方法为您提供了一个类似文件的对象，这与您在 Java 中所做的非常相似，后者具有 readline 方法，因此您可以在另一个方向上做同样的事情.