python select.select模塊通信全過程詳解

来源:http://www.cnblogs.com/zhiyong-ITNote/archive/2017/09/19/7553694.html
-Advertisement-
Play Games

要理解select.select模塊其實主要就是要理解它的參數, 以及其三個返回值。select()方法接收並監控3個通信列表, 第一個是所有的輸入的data,就是指外部發過來的數據,第2個是監控和接收所有要發出去的data(outgoing data),第3個監控錯誤信息在網上一直在找這個sele ...


要理解select.select模塊其實主要就是要理解它的參數, 以及其三個返回值。
select()方法接收並監控3個通信列表, 第一個是所有的輸入的data,就是指外部發過來的數據,第2個是監控和接收所有要發出去的data(outgoing data),第3個監控錯誤信息

在網上一直在找這個select.select的參數解釋, 但實在是沒有, 哎...自己硬著頭皮分析了一下。
readable, writable, exceptional = select.select(inputs, outputs, inputs)

select 函數的參數其實很好理解, 前提是我們對unix 網路編程有瞭解. select 模型是unix 系統中的網路模型, python 將其封裝了,因此我們使用起來就比較方便, 但是面試官就不會這麼覺得了(最近被面試逼瘋了, 考慮問題都從面試官的角度考慮), 先說下unix 系統中的select 模型吧, 參數原型:
int select(int maxfdpl, fd_set * readset, fd_set *writeset, fd_set *exceptset, const struct timeval * tiomeout)

第一個是最大的文件描述符長度
第二個是監聽的可讀集合
第三個是監聽的可寫集合
第四個是監聽的異常集合
第五個是時間限制

對struct fd_set結構體操作的巨集
FD_SETSIZE 容量,指定fd_array數組大小,預設為64,也可自己修改巨集
FD_ZERO(*set) 置空,使數組的元素值都為3435973836,元素個數為0.
FD_SET(s, *set) 添加,向 struct fd_set結構體添加套接字s
FD_ISSET(s, *set) 判斷,判斷s是否為 struct fd_set結構體中的一員
FD_CLR(s, *set) 刪除,從 struct fd_set結構體中刪除成員s

因為此模型主要是在網路中應用, 我們不考慮文件, 設備, 單從套接字來考慮, 可讀條件如下:

可寫條件如下:

我看C 示例的時候, 看的有點懵逼, 應該需要跑一遍代碼就好, python 就簡單了, 直接調用封裝好的select , 其底層處理好了文件描述符的相關讀寫監聽(回頭再研究下), 我們在Python 中只需這麼寫:
can_read, can_write, _ = select.select(inputs, outputs, None, None)

第一個參數是我們需要監聽可讀的套接字, 第二個參數是我們需要監聽可寫的套接字, 第三個參數使我們需要監聽異常的套接字, 第四個則是時間限制設置.

如果監聽的套接字滿足了可讀可寫條件, 那麼所返回的can,read 或是 can_write就會有值了, 然後我們就可以利用這些返回值進行隨後的操作了。相比較unix 的select模型, 其select函數的返回值是一個整型, 用以判斷是否執行成功.

第一個參數就是伺服器端的socket, 第二個是我們在運行過程中存儲的客戶端的socket, 第三個存儲錯誤信息。
重點是在返回值, 第一個返回的是可讀的list, 第二個存儲的是可寫的list, 第三個存儲的是錯誤信息的
list。
網上所有關於select.select的代碼都是差不多的, 但是有些不能運行, 或是不全。我自己重新寫了一份能運行的程式, 做了很多註釋, 好好看看就能搞懂

伺服器端:

# coding: utf-8
import select
import socket
import Queue
from time import sleep


# Create a TCP/IP
server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
server.setblocking(False)

# Bind the socket to the port
server_address = ('localhost', 8090)
print ('starting up on %s port %s' % server_address)
server.bind(server_address)

# Listen for incoming connections
server.listen(5)

# Sockets from which we expect to read
inputs = [server]

# Sockets to which we expect to write
# 處理要發送的消息
outputs = []

# Outgoing message queues (socket: Queue)
message_queues = {}

while inputs:
    # Wait for at least one of the sockets to be ready for processing
    print ('waiting for the next event')
    # 開始select 監聽, 對input_list 中的伺服器端server 進行監聽
# 一旦調用socket的send, recv函數,將會再次調用此模塊
readable, writable, exceptional = select.select(inputs, outputs, inputs) # Handle inputs # 迴圈判斷是否有客戶端連接進來, 當有客戶端連接進來時select 將觸發 for s in readable: # 判斷當前觸發的是不是服務端對象, 當觸發的對象是服務端對象時,說明有新客戶端連接進來了 # 表示有新用戶來連接 if s is server: # A "readable" socket is ready to accept a connection connection, client_address = s.accept() print ('connection from', client_address) # this is connection not server connection.setblocking(0) # 將客戶端對象也加入到監聽的列表中, 當客戶端發送消息時 select 將觸發 inputs.append(connection) # Give the connection a queue for data we want to send # 為連接的客戶端單獨創建一個消息隊列,用來保存客戶端發送的消息 message_queues[connection] = Queue.Queue() else: # 有老用戶發消息, 處理接受 # 由於客戶端連接進來時服務端接收客戶端連接請求,將客戶端加入到了監聽列表中(input_list), 客戶端發送消息將觸發 # 所以判斷是否是客戶端對象觸發 data = s.recv(1024) # 客戶端未斷開 if data != '': # A readable client socket has data print ('received "%s" from %s' % (data, s.getpeername())) # 將收到的消息放入到相對應的socket客戶端的消息隊列中 message_queues[s].put(data) # Add output channel for response # 將需要進行回覆操作socket放到output 列表中, 讓select監聽 if s not in outputs: outputs.append(s) else: # 客戶端斷開了連接, 將客戶端的監聽從input列表中移除 # Interpret empty result as closed connection print ('closing', client_address) # Stop listening for input on the connection if s in outputs: outputs.remove(s) inputs.remove(s) s.close() # Remove message queue # 移除對應socket客戶端對象的消息隊列 del message_queues[s] # Handle outputs # 如果現在沒有客戶端請求, 也沒有客戶端發送消息時, 開始對發送消息列表進行處理, 是否需要發送消息 # 存儲哪個客戶端發送過消息 for s in writable: try: # 如果消息隊列中有消息,從消息隊列中獲取要發送的消息 message_queue = message_queues.get(s) send_data = '' if message_queue is not None: send_data = message_queue.get_nowait() else: # 客戶端連接斷開了 print "has closed " except Queue.Empty: # 客戶端連接斷開了 print "%s" % (s.getpeername()) outputs.remove(s) else: # print "sending %s to %s " % (send_data, s.getpeername) # print "send something" if message_queue is not None: s.send(send_data) else: print "has closed " # del message_queues[s] # writable.remove(s) # print "Client %s disconnected" % (client_address) # # Handle "exceptional conditions" # 處理異常的情況 for s in exceptional: print ('exception condition on', s.getpeername()) # Stop listening for input on the connection inputs.remove(s) if s in outputs: outputs.remove(s) s.close() # Remove message queue del message_queues[s] sleep(1)

客戶端:

# coding: utf-8
import socket


messages = ['This is the message ', 'It will be sent ', 'in parts ', ]

server_address = ('localhost', 8090)

# Create aTCP/IP socket

socks = [socket.socket(socket.AF_INET, socket.SOCK_STREAM), socket.socket(socket.AF_INET,  socket.SOCK_STREAM), ]

# Connect thesocket to the port where the server is listening

print ('connecting to %s port %s' % server_address)
# 連接到伺服器
for s in socks:
    s.connect(server_address)

for index, message in enumerate(messages):
    # Send messages on both sockets
    for s in socks:
        print ('%s: sending "%s"' % (s.getsockname(), message + str(index)))
        s.send(bytes(message + str(index)).decode('utf-8'))
    # Read responses on both sockets

for s in socks:
    data = s.recv(1024)
    print ('%s: received "%s"' % (s.getsockname(), data))
    if data != "":
        print ('closingsocket', s.getsockname())
        s.close()

寫代碼過程中遇到了兩個問題, 一是如何判斷客戶端已經關閉了socket連接, 後來自己分析了下, 如果關閉了客戶端socket, 那麼此時伺服器端接收到的data就是'', 加個這個判斷。二是如果伺服器端關閉了socket, 一旦在調用socket的相關方法都會報錯, 不管socket是不是用不同的容器存儲的(意思是說list_1存儲了socket1, list_2存儲了socket1, 我關閉了socket1, 兩者都不能在調用這個socket了)

伺服器端:

客戶端:


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 先是一個銀行類: 再是銀行卡類: 信用卡繼承自銀行卡類: 借記卡類沒有實現:寫了一部分。 ...
  • 將二叉樹拆成鏈表 描述 筆記 數據 評測 將一棵二叉樹按照前序遍歷拆解成為一個假鏈表。所謂的假鏈表是說,用二叉樹的 right 指針,來表示鏈表中的 next 指針。 註意事項 不要忘記將左兒子標記為 null,否則你可能會得到空間溢出或是時間溢出。 您在真實的面試中是否遇到過這個題? Yes 哪家 ...
  • 以下內容不包含maven的配置。。。 好,進入主題。 首先new一個項目,選擇Maven Project,點擊Next 選擇預設即可,繼續點Next 我這裡創建的是web工程,所以選擇webapp後點擊Next 填好 groupid和artifactId後會自動填寫package,填完後點擊fini ...
  • package com.swift; //這裡導入的包是java.sql.Connection而不是com.mysql.jdbc.Connection import java.sql.Connection; import java.sql.DriverManager; import java.sql ...
  • 4.三大範式: ...
  • ptyhon版本 Python 3.5.4 支持中文直接輸入和顯示,ptyhon2.x 中文支持需要轉碼 編輯器:pycharm hello world 註釋 單行註釋:用#作為單行註釋 多行註釋:使用3個單引號(''')或者3個雙引號(""")圍起來的內容將被註釋。如下 變數(var) 變數命名規 ...
  • 題目描述 形如2P-1的素數稱為麥森數,這時P一定也是個素數。但反過來不一定,即如果P是個素數,2P-1不一定也是素數。到1998年底,人們已找到了37個麥森數。最大的一個是P=3021377,它有909526位。麥森數有許多重要應用,它與完全數密切相關。 任務:從文件中輸入P(1000<P<310 ...
  • 上次我們講了Java中的一些基本的語法;今天我們就講一點內容,來說說Java中的方法和方法重載以及需要註意的一些地方; 方法: Java的方法類似與其他語言的函數,是一段用來完成特定功能的代碼片段, 聲明格式: [修飾符1 修飾符2 ....] ,返回值類型 方法名 (形式參數列表) { Java語 ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發(一):使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說,近來想嘗試開發一款安卓APP,考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP,畢竟是使用Visual Studio開發工具,使用起來也比較的順手,結合微軟官方的教程進行了安卓 ...
  • 前言 QuestPDF 是一個開源 .NET 庫,用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫,它徹底改變了我們生成 PDF 文檔的方 ...
  • 項目地址 項目後端地址: https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址: ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址: http://tree ...
  • 話不多說,直接開乾 一.下載 1.官方鏈接下載: https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe,運行開始下載SQL server; 二. ...
  • 前言 隨著物聯網(IoT)技術的迅猛發展,MQTT(消息隊列遙測傳輸)協議憑藉其輕量級和高效性,已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫,為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog支持多種接收器用於日誌存儲,增強器用於添加屬性,LogContext管理動態屬性,支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項,適用於不同需求。 ...
  • 目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據,爬取信息時需要模擬瀏覽器行為,否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下: 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • 1.前言 什麼是熱更新 游戲或者軟體更新時,無需重新下載客戶端進行安裝,而是在應用程式啟動的情況下,在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR,Xlua,ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles,Addressable, ...
  • 本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺,其實像阿裡雲,騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後,它會送 ...
  • 通過以下方式可以高效,並保證數據同步的可靠性 1.API設計 使用RESTful設計,確保API端點明確,並使用適當的HTTP方法(如POST用於創建,PUT用於更新)。 設計清晰的請求和響應模型,以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...