02select监听服务端[Python基础]
# can_read, can_write, _ = select.select(inputs, outputs, None, None)
#
# 第一个参数是我们需要监听可读的套接字, 第二个参数是我们需要监听可写的套接字, 第三个参数使我们需要监听异常的套接字, 第四个则是时间限制设置.
#
# 如果监听的套接字满足了可读可写条件, 那么所返回的can,read 或是 can_write就会有值了, 然后我们就可以利用这些返回值进行随后的操作了。相比较unix 的select模型, 其select函数的返回值是一个整型, 用以判断是否执行成功.
#
# 第一个参数就是服务器端的socket, 第二个是我们在运行过程中存储的客户端的socket, 第三个存储错误信息。
# 重点是在返回值, 第一个返回的是可读的list, 第二个存储的是可写的list, 第三个存储的是错误信息的
# list。
import select, socket, queue
from time import sleep
# 创造一个 TCP/IP连接
server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
# 设置socket为异步模式。
server.setblocking(False)
# 绑定IP地址和端口
# 创建一个IP，端口，本地IP
server_address = ("localhost", 8090)
print("starting up on %s port %s" % server_address)
# 绑定IP和端口
server.bind(server_address)
# 设置服务端监听数量
server.listen(3)
inputs = [server]
# 处理要发送的数据
outputs = []
# 输出的消息队列
message_queues = {}
while inputs:
# 等待至少一个连接开始调用线程
print("waiting for the next event")
# 开始select监听，对input_list中的服务器端的server开始进行监听
# 一旦调用socket的send，recv函数，将会再次调用此模块
# 这里监控三个参数，第一个返回的是可读的list, 第二个存储的是可写的list, 第三个存储的是错误信息的
readable, writable, exceptional = select.select(inputs, outputs, inputs)
# 处理输入
# 循环判断是否有客户端连接进来，当有客户端连接进来的时候select将进行触发
for s in readable:
# 判断当前触发的是不是服务端对象，当触发的是服务端对象， 说明有新的客户端连接进来了
if s is server:
# 和客户端建立连接
connection, client_address = s.accept()
# 打印客户端的链接
print("connection from", client_address)
# 设置socket为异步模式。
connection.setblocking(0)
# 将客户端对象也加入到监听列表中，当客户端发送消息的时候select也会触发。
inputs.append(connection)
# 为连接的客户端单独建立一个消息队列，用来保存客户端发送的消息
message_queues[connection] = queue.Queue()
else:
# 有老用户发送消息，处理接收
# 由于客户端连接进来的时候服务端接收客户端的请求，将客户端也加入到了监听列表。
# 客户端发送的消息将触发。
# 判断触发对象是否为客户端
# 接收客户端的信息
data = s.recv(1024)
# 客户端没有断开
if data != "":
# 一个可用的客户端发送了数据
print("received "%s" from %s" % (data, s.getpeername()))
# 将接受到的消息放到对应的客户端的消息队列中
message_queues[s].put(data)
# 将需要进行回复操作的socket放到output列表中，让select监听
# 这里我们如果收到消息将服务端添加进入输出列表。
# 然后select就会监听到，
if s not in outputs:
outputs.append(s)
else:
# 客户端被监听到有变化，不是有客户端传过来的消息，就是客户端断开了。
# 客户端断开了连接，将客户端的监听从input列表中移除
print("closing", client_address)
if s in outputs:
outputs.remove(s)
inputs.remove(s)
s.close()
# 移除对应的socket客户端对象的消息队列
del message_queues[s]
# 处理输出。
# 如果现在没有客户端的请求，也没有客户端发送消息时，开始对发送的消息列表进行处理。
# 判断是否需要发送消息。
# 存储哪个客户端发送了消息。
for s in writable:
try:
# 如果消息队列中有消息，就从消息队列中获取要发送的消息。
message_queue = message_queues.get(s)
sent_data = ""
if message_queues 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)
以上是 02select监听服务端[Python基础] 的全部内容， 来源链接： utcz.com/z/530063.html
