为什么主机中止连接？

Question

我在自学Python网络，回想起我在自学线程时，碰到了该页面，所以我复制了脚本，将其更新为Python 3.1.1并运行了它们。他们工作得很好。

然后，我做了一些修改。我的目标是做一些简单的事情：

1. 客户端腌制一个整数并将其发送到服务器。
2. 服务器接收腌制的整数，对其进行腌制，将其加倍，然后腌制并将其发送回客户端。
3. 客户端接收腌制（并加倍）的整数，对其进行腌制并输出。

这是服务器：

import pickle
import socket
import threading

class ClientThread(threading.Thread):
    def __init__(self, channel, details):
        self.channel = channel
        self.details = details
        threading.Thread.__init__ ( self )

    def run(self):
        print('Received connection:', self.details[0])
        request = self.channel.recv(1024)
        response = pickle.dumps(pickle.loads(request) * 2)
        self.channel.send(response)
        self.channel.close()
        print('Closed connection:', self.details [ 0 ])

server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
server.bind(('', 2727))
server.listen(5)

while True:
    channel, details = server.accept()
    ClientThread(channel, details).start()

这是客户：

import pickle
import socket
import threading

class ConnectionThread(threading.Thread):
    def run(self):
        client = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        client.connect(('localhost', 2727))

        for x in range(10):
            client.send(pickle.dumps(x))
            print('Sent:',str(x))
            print('Received:',repr(pickle.loads(client.recv(1024))))

        client.close()

for x in range(5):
    ConnectionThread().start()

服务器运行良好，当我运行客户端时，它成功连接并开始发送整数，并按预期将接收到的整数加倍。但是，很快它就排除了：

Exception in thread Thread-2:
Traceback (most recent call last):
  File "C:\Python30\lib\threading.py", line 507, in _bootstrap_inner
    self.run()
  File "C:\Users\Imagist\Desktop\server\client.py", line 13, in run
    print('Received:',repr(pickle.loads(client.recv(1024))))
socket.error: [Errno 10053] An established connection was aborted by the softwar
e in your host machine

服务器继续运行，并接收连接。只有客户端崩溃。是什么原因造成的？

编辑：我让客户端使用以下代码：

import pickle
import socket
import threading

class ConnectionThread(threading.Thread):
    def run(self):
        for x in range(10):
            client = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
            client.connect(('localhost', 2727))
            client.send(pickle.dumps(x))
            print('Sent:',str(x))
            print('Received:',repr(pickle.loads(client.recv(1024))))
            client.close()

for x in range(5):
    ConnectionThread().start()

但是，我仍然不知道发生了什么。这不是只是多次打开和关闭插座吗？难道不应该有时间限制吗？（关闭插座后不久就不能打开插座）？

Answer 1

您的客户端现在是正确的-您要打开套接字发送数据，接收答复，然后关闭套接字。

错误原始错误是由服务器在发送第一个响应后关闭套接字导致的，当客户端尝试在同一连接上发送第二条消息时，该消息导致客户端收到连接关闭消息。

但是，我仍然不知道发生了什么。这不是只是多次打开和关闭插座吗？

是。即使不是性能最高的处理方法，这也是可以接受的。

难道不应该有时间限制吗？（关闭插座后不久就不能打开插座）？

您可以根据需要尽快打开客户端套接字，就像每次打开套接字一样，您将获得一个新的本地端口号，这意味着连接不会受到干扰。在上面的服务器代码中，它将为每个传入的连接启动一个新线程。

每个IP连接（source_address，source_port，destination_address，destination_port）有4个部分，并且必须不断更改此四边形（众所周知）。除source_port之外的所有内容都已固定用于客户端套接字，因此操作系统会为您更改。

打开服务器套接字比较麻烦-如果您想快速打开新的服务器套接字，

server.bind(('', 2727))

在上面，您需要阅读SO_REUSEADDR。