日韩久久久精品,亚洲精品久久久久久久久久久,亚洲欧美一区二区三区国产精品 ,一区二区福利

python中協(xié)程實現(xiàn)TCP連接的實例分析

系統(tǒng) 1780 0

在網(wǎng)絡通信中,每個連接都必須創(chuàng)建新線程(或進程) 來處理,否則,單線程在處理連接的過程中, 無法接受其他客戶端的連接。所以我們嘗試使用協(xié)程來實現(xiàn)服務器對多個客戶端的響應。

與單一TCP通信的構(gòu)架一樣,只是使用協(xié)程來實現(xiàn)多個任務同時進行。

            
#服務端

import socket

from gevent import monkey

import gevent

monkey.patch_all()

def handle_conn(seObj):

  while True:

    re_Data = seObj.recv(1024).decode('utf-8')

    if re_Data == 'quit':

      break

    print('client>>',re_Data)

    value = input("server>>")

    se_Data = seObj.send(value.encode('utf-8'))

    if se_Data == 'quit':

      break

if __name__ == '__main__':

  server = socket.socket()

  server.bind(('192.168.1.227',9876))

  print("服務已開啟")

  server.listen(4)

  while True:

    seObj,add = server.accept()

    gevent.spawn(handle_conn,seObj)

  seObj.close()

  server.close()
          
            
import socket

 

# 1. 創(chuàng)建客戶端的socket對象

client = socket.socket()

# 2. 連接服務端, 需要指定端口和IP

client.connect(('192.168.1.227',9876))

while True:

  # 3. 給服務端發(fā)送數(shù)據(jù)

  send_data = input("client:>")

  client.send(send_data.encode('utf-8'))

  if send_data == 'quit':

    break

  # 4. 獲取服務端返回的消息

  recv_data = client.recv(1024).decode('utf-8')

  if recv_data == 'quit':

    break

  print("server:>%s" %(recv_data))

# 5. 關閉socket連接

client.close()
          

以上就是python中協(xié)程實現(xiàn)TCP連接的代碼示例的詳細內(nèi)容,感謝大家對腳本之家的支持。


更多文章、技術交流、商務合作、聯(lián)系博主

微信掃碼或搜索:z360901061

微信掃一掃加我為好友

QQ號聯(lián)系: 360901061

您的支持是博主寫作最大的動力,如果您喜歡我的文章,感覺我的文章對您有幫助,請用微信掃描下面二維碼支持博主2元、5元、10元、20元等您想捐的金額吧,狠狠點擊下面給點支持吧,站長非常感激您!手機微信長按不能支付解決辦法:請將微信支付二維碼保存到相冊,切換到微信,然后點擊微信右上角掃一掃功能,選擇支付二維碼完成支付。

【本文對您有幫助就好】

您的支持是博主寫作最大的動力,如果您喜歡我的文章,感覺我的文章對您有幫助,請用微信掃描上面二維碼支持博主2元、5元、10元、自定義金額等您想捐的金額吧,站長會非常 感謝您的哦!!!

發(fā)表我的評論
最新評論 總共0條評論
主站蜘蛛池模板: 麻江县| 彭水| 灵台县| 英德市| 张北县| 峨眉山市| 清苑县| 乌兰察布市| 左贡县| 图片| 喜德县| 平远县| 珲春市| 温州市| 乌拉特后旗| 元谋县| 鹤峰县| 九龙城区| 广宁县| 莫力| 邵武市| 东乌| 巩留县| 临泉县| 正阳县| 威信县| 会泽县| 邢台县| 凤山市| 黔东| 尼玛县| 安乡县| 公安县| 旌德县| 突泉县| 鄯善县| 临武县| 鸡泽县| 永定县| 宜兰市| 仁怀市|