日本免费高清视频-国产福利视频导航-黄色在线播放国产-天天操天天操天天操天天操|www.shdianci.com

學無先后，達者為師

網站首頁 編程語言 正文

Python?asyncore?socket客戶端實現方法詳解_python

作者：JSON_L ? 更新時間： 2023-01-26 編程語言

介紹

asyncore庫是python的一個標準庫，提供了以異步的方式寫入套接字服務的客戶端和服務器的基礎結構。操作網絡的時候可以直接使用socket等底層的庫，但是asyncore使得我們可以更加方便的操作網絡，避免直接使用socket，select，poll等工具時需要面對的復雜情況。

1.定義類并且繼承 asyncore.dispatcher

class SocketClient(asyncore.dispatcher):

2.實現類中的回調代碼

調用父類方法

asyncore.dispatcher.__init__(self)

創建socket對象

self.create_socket()

連接服務器

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

實現 handle_connect 回調函數

當socket 連接服務器成功時回調該函數

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

實現 writable 回調函數

描述是否有數據需要被發送到服務器。返回值為True表示可寫，False 表示不可寫。

如果不識閑默認返回為 True,當返回True時，回調函數handle_write將被觸發

def writable(self):
    return False

實現 handle_write 回調函數

當有數據需要發送時 （writable 回調函數返回 True時），

該函數被觸發，通常情況下在該函數中編寫send方法發送數據

def handle_write(self):
    # 內部實現對服務器發送數據
    # 調用 send 方法，參數是字節數據
    self.send('hello world'.encode('utf-8'))

實現 readable 回調函數

描述是否有數據從服務端讀取。返回True標識有數據需要讀取，

False表示沒有數據需要被讀取，當不實現默認返回True，

當返回True時，handle_read將被觸發

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

實現 handle_read回調函數

當有數據需要讀取時（readable 回調函數返回True時），

該函數被觸發，通常情況下在該函數中編寫recv方法接收數據

def handle_read(self):
    # 主動讀取接收數據 參數是需要接收數據長度
    result = self.recv(8000)
    print(result)

實現 handle_error回調函數

當程序運行過程發生異常時回調

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

實現 handle_close回調函數

當連接被關閉時觸發

def handle_close(self):
    print('連接關閉')
    # 執行關閉
    self.close()

3.創建對象并且執行asyncore.loop進入運行循環

timeout為一次循環所用的時間，也就是超時時間。

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

運行結果

服務端：

客戶端：

注意

本文章使用python3.7版本，3.10版本已經移除此模塊，之后可使用asyncio模塊。

至此結束，本文章只做了一個基本使用講解，可以查看借鑒使用，若想要做消息還差的很多。

原文鏈接：https://blog.csdn.net/json_ligege/article/details/128389493

欄目分類
最近更新