Python asyncore socket客户端开发基本使用教程

class SocketClient(asyncore.dispatcher):

asyncore.dispatcher.__init__(self)

self.create_socket()

address = (host, port)
self.connect(address)

def handle_connect(self):
    print('连接成功')

def writable(self):
    return False

def handle_write(self):
    # 内部实现对服务器发送数据
    # 调用 send 方法，参数是字节数据
    self.send('hello world'.encode('utf-8'))

def readable(self):
    # 表示有数据需要读取
    return True

def handle_read(self):
    # 主动读取接收数据 参数是需要接收数据长度
    result = self.recv(8000)
    print(result)

def handle_error(self):
    # 编写处理错误方法
    t, e, trace = sys.exc_info()
    print(t, e, trace)

def handle_close(self):
    print('连接关闭')
    # 执行关闭
    self.close()

client = SocketClient('127.0.0.1', 9000)
# 开始启动运行循环
asyncore.loop(timeout=10)

import asyncore
import socket
class EchoHandler(asyncore.dispatcher_with_send):
 
    def handle_read(self):
        data = self.recv(8192)
        if data:
            self.send(data)
 
 
class EchoServer(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))
        # 监听连接参数指定排队的最大连接数和应至少为1; 最大值取决于系统（通常为5）。
        self.listen(5)
 
    '''
    当与发起对本地端点的 connect() 调用的新远程端点已建立连接时会在侦听通道（被动打开方）上被调用。 
    sock 是可被用于在连接上发送和接收数据的 新建 套接字对象，
    而 addr 是绑定到连接另一端的套接字的地址。
    '''
    def handle_accept(self):
        pair = self.accept()
        if pair is not None:
            sock, addr = pair
            print('连接来自于 %s' % repr(addr))
            # 连接成功后 给客户端发送消息
            handler = EchoHandler(sock)
            handler.send('hello world'.encode('utf-8'))
 
if __name__ == '__main__':
    server = EchoServer('127.0.0.1', 9000)
    asyncore.loop()