亚洲在线久爱草,狠狠天天香蕉网,天天搞日日干久草,伊人亚洲日本欧美

為了賬號安全,請及時綁定郵箱和手機立即綁定

python socket 網絡編程selector用法 實用

標簽:
Python

Server端:

import socket
import selectors

class Server(object):
def init(self,sel,sock):
self.sel = sel
self.sock = sock

def run(self,host,port):    self.sock.bind((host,port))    self.sock.listen(50)    self.sock.setblocking(False)#设置非阻塞    self.sel.register(sock,selectors.EVENT_READ,self.accept)    while True:        events = self.sel.select()#默认是阻塞,有活动连接就返回活动连接列表        for key,mask in events:            callback = key.data#创建一个回调函数并获取            callback(key.fileobj,mask)#调用回调函数def accept(self,sock,mask):    conn,addr = sock.accept()#已经就绪,等待接收    print ('连接来自于{}'.format(addr))    conn.setblocking(False)    # sock.send(str('thanks').decode())    sel.register(conn,selectors.EVENT_READ,self.read)#注册事件def read(self,conn,mask):    data = conn.recv(1024)#就绪,等待接收数据    if data:#判断是否有数据过来,有就执行        print ('来自客户端:',data)        conn.send(data)    else:        print ('准备关闭连接',conn)        sel.unregister(conn)        conn.close()

if name == 'main':
sel = selectors.DefaultSelector()#默认的选择方式
sock = socket.socket()
sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR,1)
host,port = '127.0.0.1',10011
server_obj = Server(sel,sock)
server_obj.run(host,port)

Client端:

import socket
import selectors
import random

sel = selectors.DefaultSelector()

def write(sock):
sock.send(str(random.randint(0,99)).encode('utf-8'))#发送必须是一个byts的数据,需要转码
sel.unregister(sock)#当发送成功后必须取消注册,用与接下来的接收(读)到数据的注册
sel.register(sock,selectors.EVENT_READ,read)#注册一个读的事件

def read(sock):
data = sock.recv(1024)
if not data:#判断接收到的数据是否为空数据
sel.unregister(sock)#当接收完成后,依然是取消注册
sock.close()#到此和服务器的请求基本处理完成,关闭套接字
return
print ('receiver server %s' %data)

for i in range(1000):#开1000个客户端测试
client = socket.socket()
client.setsockopt(socket.SOL_SOCKET,socket.SO_REUSEADDR,1)#防止编辑器的每次运行端口冲突问题
client.connect(('localhost',10011))
sel.register(client,selectors.EVENT_WRITE,write)#注册一个写的事件,接下来处理发送(写)事件的处理

while True:
all_event = sel.select()
print (allevent)
for event,
in all_event:
sock = event.fileobj
callback = event.data#创建一个回调函数,方便触发事务执行
callback(sock)#调用刚创建的回调函数

點擊查看更多內容
TA 點贊

若覺得本文不錯,就分享一下吧!

評論

作者其他優質文章

正在加載中
  • 推薦
  • 評論
  • 收藏
  • 共同學習,寫下你的評論
感謝您的支持,我會繼續努力的~
掃碼打賞,你說多少就多少
贊賞金額會直接到老師賬戶
支付方式
打開微信掃一掃,即可進行掃碼打賞哦
今天注冊有機會得

100積分直接送

付費專欄免費學

大額優惠券免費領

立即參與 放棄機會
微信客服

購課補貼
聯系客服咨詢優惠詳情

幫助反饋 APP下載

慕課網APP
您的移動學習伙伴

公眾號

掃描二維碼
關注慕課網微信公眾號

舉報

0/150
提交
取消