這篇“Python怎么使用select實現(xiàn)socket全雙工異步通信功能”文章的知識點大部分人都不太理解，所以小編給大家總結(jié)了以下內(nèi)容，內(nèi)容詳細(xì)，步驟清晰，具有一定的借鑒價值，希望大家閱讀完這篇文章能有所收獲，下面我們一起來看看這篇“Python怎么使用select實現(xiàn)socket全雙工異步通信功能”文章吧。

創(chuàng)新互聯(lián)建站制作網(wǎng)站網(wǎng)頁找三站合一網(wǎng)站制作公司,專注于網(wǎng)頁設(shè)計,成都做網(wǎng)站、網(wǎng)站制作,網(wǎng)站設(shè)計,企業(yè)網(wǎng)站搭建,網(wǎng)站開發(fā),建網(wǎng)站業(yè)務(wù),680元做網(wǎng)站,已為1000+服務(wù),創(chuàng)新互聯(lián)建站網(wǎng)站建設(shè)將一如既往的為我們的客戶提供最優(yōu)質(zhì)的網(wǎng)站建設(shè)、網(wǎng)絡(luò)營銷推廣服務(wù)!

select  -在單線程網(wǎng)絡(luò)服務(wù)中器程序中，管理多個套接字連接

select的原型為(rlist,wlist,xlist[,timeout])，其中rlist是等待讀取的對象，wlist是等待寫入的對象，xlist是等待異常的對象，最后一個是可選對象，指定等待的時間，單位是s.

select()方法的返回值是準(zhǔn)備好的對象的三元組，若在timeout的時間內(nèi)，沒有對象準(zhǔn)備好，那么返回值將是空的列表。

它采用的是輪詢的方式來實現(xiàn)異步通信的。

在下面程序中，目前主要支持1對1通信，當(dāng)雙方任何一方發(fā)送字符串‘88'時，表示結(jié)束通信。

下面我們來看看具體實現(xiàn)：

首先是服務(wù)器。

#!/usr/bin/python
'test TCP server'
from socket import *
from time import ctime
import select
import sys
HOST = ''
PORT = 21567
BUFSIZ = 1024
ADDR = (HOST, PORT)
tcpSerSock = socket(AF_INET, SOCK_STREAM)
tcpSerSock.bind(ADDR)
tcpSerSock.listen(5)
input = [tcpSerSock, sys.stdin]   #input是一個列表，初始有歡迎套接字以及標(biāo)準(zhǔn)輸入
while True:
  print 'waiting for connection...'
  tcpCliSock, addr = tcpSerSock.accept()
  print '...connected from:',addr
  input.append(tcpCliSock)  #將服務(wù)套接字加入到input列表中
  while True:
    readyInput,readyOutput,readyException = select.select(input,[],[]) #從input中選擇，輪流處理client的請求連接（tcpSerSock），client發(fā)送來的消息(tcpCliSock)，及服務(wù)器端的發(fā)送消息(stdin)
    for indata in readyInput:
      if indata==tcpCliSock:  #處理client發(fā)送來的消息
        data = tcpCliSock.recv(BUFSIZ)
        print data
        if data=='88':
          input.remove(tcpCliSock)
          break
      else:       #處理服務(wù)器端的發(fā)送消息
        data = raw_input('>')
        if data=='88':
          tcpCliSock.send('%s' %(data))
          input.remove(tcpCliSock)
          break
        tcpCliSock.send('[%s] %s' %(ctime(), data))
    if data=='88':
      break
  tcpCliSock.close()
tcpSerSock.close()

以下是客戶端的代碼，非常類似，只是與服務(wù)器相比不需要處理請求信息而已。

#!/usr/bin/python
'test tcp client'
from socket import *
from time import ctime
import select
import sys
HOST = 'localhost'
PORT = 21567
BUFSIZ = 1024
ADDR = (HOST, PORT)
tcpCliSock = socket(AF_INET, SOCK_STREAM)
tcpCliSock.connect(ADDR)
input = [tcpCliSock,sys.stdin]
while True:
  readyInput,readyOutput,readyException = select.select(input,[],[])
  for indata in readyInput:
    if indata==tcpCliSock:
      data = tcpCliSock.recv(BUFSIZ)
      print data
      if data=='88':
        break
    else:
      data = raw_input('>')
      if data=='88':
        tcpCliSock.send('%s' %(data))
        break
      tcpCliSock.send('[%s] %s' %(ctime(), data))
  if data=='88':
    break
tcpCliSock.close()

以上就是關(guān)于“Python怎么使用select實現(xiàn)socket全雙工異步通信功能”這篇文章的內(nèi)容，相信大家都有了一定的了解，希望小編分享的內(nèi)容對大家有幫助，若想了解更多相關(guān)的知識內(nèi)容，請關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道。