asyncores的手柄持续开火

Question

你知道吗self.handlers.append文件（连接手柄（短袜，自我管理者))我是python新手，我试着编写一个简单的socket服务器来测试一些东西，更好地了解python语言。你知道吗

import asyncore
import socket
import json

class ConnHandler(asyncore.dispatcher_with_send):

    def __init__(self, conn, handlerlist):
        asyncore.dispatcher_with_send.__init__(self, conn)
        self.handlers = handlerlist

    def handle_close(self):
        self.close()
        print 'Socket closed'
        if(self.handlers.count(self) > 0):
            self.handlers.remove(self);

    def handle_read(self):
        data = ''
        more = True
        while more:
            try:
                data += self.recv(1024)
            except socket.error, e:
                more = False

        if data == '':
            return

        try:
            message = json.loads(data)
        except ValueError:
            self.send('Invalid JSON\n')
            return

        print message


class TestServer(asyncore.dispatcher):

    def __init__(self, host, port):
        asyncore.dispatcher.__init__(self)
        self.create_socket(socket.AF_INET, socket.SOCK_STREAM)
        self.set_reuse_addr()
        self.bind((host, port))
        self.listen(5)
        self.handlers = []

    def handle_accept(self):
        pair = self.accept()
        if pair is not None:
            sock, addr = pair
            print 'Incoming connection from %s' % repr(addr)
            self.handlers.append(ConnHandler(sock, self.handlers))

    def sendToAll(self, string):
        for h in self.handlers:
            h.send(string + '\n')

server = TestServer('localhost', 55555)
asyncore.loop()

我的问题如下。 如果我用telnet连接到服务器，然后退出telnet以关闭连接，python只会在终端中垃圾邮件“socketclosed”。我怎样才能解决这个问题？以上代码中是否有明显的初学者错误？你知道吗

Answer 1

handle_close并不意味着检测对等机是否断开连接，如果handle_read调用返回空字符串，您将在.recv中获得此信息。然后可以关闭套接字，然后调用handle_close。你知道吗

以下是代码的修改版本：

def handle_close(self):
    print 'Socket closed'
    if(self.handlers.count(self) > 0):
        self.handlers.remove(self);

def handle_read(self):
    data = ''
    more = True
    while more:
        try:
            new_data = self.recv(1024)
            if not new_data:
                self.close()
                return
            else:
                data += new_data
        except socket.error, e:
            more = False

    if data == '':
        return

    try:
        message = json.loads(data)
    except ValueError:
        self.send('Invalid JSON\n')
        return

    print message