使用一个套接字在 Python 中接收和发送消息

Question

我有一个python脚本，它已经使用套接字不时向对等方发送消息。我想添加一个功能，该套接字异步侦听入站消息，然后做出反应，例如处理内容并重新发送回复。是否可以仅使用一个插座？我必须使用一个套接字，因为我的对等方在本地主机：30000 上创建了它的套接字。

编辑：

这是我到目前为止所做的一些尝试代码。

侦听线程中的 Run() 方法：

def run(self):
print("Started listening to messages from peer...")
while True:
socketLock.acquire()
try:
self.listenToInboundMessages()
finally:
socketFlag.set()
socketLock.notify()
socketLock.release()
def listenToInboundMessages(self):
clientsocket.settimeout(1)
received = clientsocket.recv(BUFF)
print(received)

发送消息的线程的 Run() 方法：

def run(self):
print("Ready to send messages.")
while True:
print("Attempting to acquire lock...")
socketLock.acquire()
while not socketFlag.isAvailable():
socketLock.wait
print("Attempting to send message...")
clientsocket.send("Message for per")
socketLock.release()
time.sleep(1)

我使用条件变量socketLocksocketFlag类来协调两个线程。

Answer 1

对于 Windows，您可以使用 select 类将套接字连接列表筛选为 3 个列表，即准备就绪的套接字、准备写入的套接字和有错误的套接字。

下面是 p2p 套接字连接(不是基于类)的基本实现。

import socket, select, time
s = socket.socket()
s.bind(("10.48.72.71", 8080))
s.listen(10)
connections = [s]
while True:
time.sleep(.1)
recv,write,err = select.select(connections,connections,connections)
for socket in recv:
if socket == s:
client,address = socket.accept()
connections.append(client)
else:
msg = socket.recv(4096).decode("UTF-8")
print("Recieved message from a socket, message was: "+str(msg))
for socket in write:
socket.send(bytes("Hi", "UTF-8"))
for socket in err:
print("Error with a socket")
socket.close()
connections.remove(socket)