Python 套接字在远程消耗所有数据之前关闭

我正在编写一个 Python 模块，它通过 unix 套接字与 go 程序进行通信。客户端（python 模块）将数据写入套接字，服务器使用它们。

# Simplified version of the code used
outputStream = socket.socket(socketfamily, sockettype, protocol)
outputStream.connect(socketaddress)
outputStream.setblocking(True)
outputStream.sendall(message)
....
outputStream.close()

我的问题是，Python 客户端往往会在服务器有效读取数据之前完成并关闭套接字，这会导致服务器端出现“管道损坏，连接由对等方重置”。无论我做什么，对于 Python 代码来说，所有内容都已发送，因此对 send() sendall() select() 的调用都成功......

提前致谢

编辑：由于 mac OS，我无法使用关机

EDIT2：我还尝试删除超时并调用 setblocking(True) 但它不会改变任何内容

EDIT3：准备好这个问题后http://bugs.python.org/issue6774 http://bugs.python.org/issue6774看来文档是不必要的可怕，所以我恢复了关闭，但我仍然有同样的问题：

# Simplified version of the code used
outputStream = socket.socket(socketfamily, sockettype, protocol)
outputStream.connect(socketaddress)
outputStream.settimeout(5)
outputStream.sendall(message)
....
outputStream.shutdown(socket.SHUT_WR)
outputStream.close()

IHMO 这最好使用异步 I/O 库/框架来完成。这是一个使用这样的解决方案circuits https://github.com/circuits/circuits:

服务器将收到的内容回显到标准输出，客户端打开一个文件并将其发送到服务器，等待它完成，然后关闭套接字并终止。这是通过异步 I/O 和协程的混合来完成的。

服务器.py：

from circuits import Component
from circuits.net.sockets import UNIXServer

class Server(Component):

    def init(self, path):
        UNIXServer(path).register(self)

    def read(self, sock, data):
        print(data)

Server("/tmp/server.sock").run()

客户端.py:

import sys

from circuits import Component, Event
from circuits.net.sockets import UNIXClient
from circuits.net.events import connect, close, write

class done(Event):
    """done Event"""

class sendfile(Event):
    """sendfile Event"""

class Client(Component):

    def init(self, path, filename, bufsize=8192):
        self.path = path
        self.filename = filename
        self.bufsize = bufsize

        UNIXClient().register(self)

    def ready(self, *args):
        self.fire(connect(self.path))

    def connected(self, *args):
        self.fire(sendfile(self.filename, bufsize=self.bufsize))

    def done(self):
        raise SystemExit(0)

    def sendfile(self, filename, bufsize=8192):
        with open(filename, "r") as f:
            while True:
                try:
                    yield self.call(write(f.read(bufsize)))
                except EOFError:
                    break
                finally:
                    self.fire(close())
                    self.fire(done())

Client(*sys.argv[1:]).run()

在我对此的测试中，它的行为完全符合我的预期，没有 错误，服务器在客户端关闭之前获取完整的文件 插座并关闭。