python socketserver偶尔会停止发送（和接收？）消息

Question

我编写的套接字服务器遇到了一个问题，其中套接字服务器似乎停止在它使用的一个端口上发送和接收数据（而另一个端口继续正常处理数据）。有趣的是，等待一分钟（或长达一个小时左右）后，套接字服务器将再次开始发送和接收消息，而无需任何可观察到的干预。

我正在使用 Eventlet 套接字框架 python 2.7，所有内容都在 ubuntu aws 实例上运行，外部应用程序打开与套接字服务器的持久连接。

从我一直在做的一些阅读来看，看起来我可能没有正确实现我的套接字服务器。 根据 http://docs.python.org/howto/sockets.html：

套接字的基本事实：消息必须是固定长度（恶心），或者是分隔的> > （耸耸肩），或者指出它们有多长（更好），或者通过关闭连接来结束。

我不完全确定我在这里使用的是固定长度消息（或者我是吗？）

这就是我接收数据的方式：

def socket_handler(sock, socket_type):
    logg(1,"socket_handler:initializing")
    while True:
        recv = sock.recv(1024)
        if not recv:
            logg(1,"didn't recieve anything")
            break
        if len(recv) > 5:
            logg(1,"socket handler: %s" % recv )
            plug_id, phone_sid, recv_json = parse_json(recv)
            send = 1 
            if "success" in recv_json and recv_json["success"] == "true" and socket_type == "plug":
                send = 0
            if send == 1:
                send_wrapper(sock, message_relayer(recv, socket_type))
        else:
            logg(2, 'socket_handler:Ignoring received input: ' + str(recv)  )
    logg(1,  'Closing socket handle: [%s]' % str(sock))
    sock.shutdown(socket.SHUT_RDWR)
    sock.close()

“sock”是由listener.accept（）函数返回的套接字对象。

socket_handler 函数的调用方式如下：

new_connection, address = listener.accept()
...<code omitted>...
pool.spawn_n(socket_handler, new_connection, socket_type)

我的实现对任何人来说都是不正确的吗？我基本上是在实施固定长度的对话协议吗？我可以做些什么来帮助调查问题或使我的代码更加健壮？

预先感谢，

T

Answer 1

如果您请求在服务器上接收的字节数 (1024) 多于实际从客户端发送的字节数，则可能会遇到与缓冲相关的问题。

为了解决这个问题，通常要做的就是首先对消息的长度进行编码，然后对消息本身进行编码。这样，接收方可以获得长度字段（大小已知），然后根据解码后的长度读取消息的其余部分。

注意：长度字段通常是协议中需要的字节数。有些协议是 4 字节对齐的，并为此使用 32 位字段，但如果您发现 1 或 2 字节就足够了，那么您可以使用它。这里的要点是客户端和服务器都知道该字段的大小。