为什么主机中断连接？

Question

我正在自学Python网络编程，想起之前学习线程的时候，看到过这个页面，于是我把上面的代码复制下来，更新到Python 3.1.1版本并运行，结果一切都很顺利。

然后我做了一些修改。我的目标是实现一个简单的功能：

客户端将一个整数进行“腌制”（也就是把它转换成一种可以传输的格式），然后发送给服务器。
服务器接收到这个“腌制”的整数，解腌制（还原成原来的整数），将它乘以2，然后再腌制后发送回客户端。
客户端接收到这个“腌制”（并且已经乘以2的）整数，解腌制，最后输出结果。

这是服务器的代码：

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()

不过，我还是不太明白发生了什么。这不就是反复打开和关闭连接吗？难道这没有时间限制吗（关闭连接后不应该马上再打开吗）？

异常处理网络编程数据传输线程连接管理编码解码服务器客户端

为什么主机中断连接？

1 个回答

撰写回答