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):
    # 內(nèi)部實(shí)現(xiàn)對(duì)服務(wù)器發(fā)送數(shù)據(jù)
    # 調(diào)用 send 方法，參數(shù)是字節(jié)數(shù)據(jù)
    self.send('hello world'.encode('utf-8'))

def readable(self):
    # 表示有數(shù)據(jù)需要讀取
    return True

def handle_read(self):
    # 主動(dòng)讀取接收數(shù)據(jù) 參數(shù)是需要接收數(shù)據(jù)長(zhǎng)度
    result = self.recv(8000)
    print(result)

def handle_error(self):
    # 編寫(xiě)處理錯(cuò)誤方法
    t, e, trace = sys.exc_info()
    print(t, e, trace)

def handle_close(self):
    print('連接關(guān)閉')
    # 執(zhí)行關(guān)閉
    self.close()

client = SocketClient('127.0.0.1', 9000)
# 開(kāi)始啟動(dòng)運(yùn)行循環(huán)
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))
        # 監(jiān)聽(tīng)連接參數(shù)指定排隊(duì)的最大連接數(shù)和應(yīng)至少為1; 最大值取決于系統(tǒng)（通常為5）。
        self.listen(5)
 
    '''
    當(dāng)與發(fā)起對(duì)本地端點(diǎn)的 connect() 調(diào)用的新遠(yuǎn)程端點(diǎn)已建立連接時(shí)會(huì)在偵聽(tīng)通道（被動(dòng)打開(kāi)方）上被調(diào)用。 
    sock 是可被用于在連接上發(fā)送和接收數(shù)據(jù)的 新建 套接字對(duì)象，
    而 addr 是綁定到連接另一端的套接字的地址。
    '''
    def handle_accept(self):
        pair = self.accept()
        if pair is not None:
            sock, addr = pair
            print('連接來(lái)自于 %s' % repr(addr))
            # 連接成功后 給客戶端發(fā)送消息
            handler = EchoHandler(sock)
            handler.send('hello world'.encode('utf-8'))
 
if __name__ == '__main__':
    server = EchoServer('127.0.0.1', 9000)
    asyncore.loop()