有没有办法停止 while 循环,直到客户端连接到该服务器?服务器应该为每个新的客户端连接创建一个新线程,这可能吗?
import socket
import threading
def clientdialog(myS):
conn, addr = myS.accept()
print ("Connection from: " + str(addr))
while 1:
data = conn.recv(1024).decode("utf-8")
if not data or data == 'q':
break
print ("from connected user: " + str(data))
host = "192.168.1.3"
port = 1998
mySocket = socket.socket()
mySocket.bind((host,port))
while True:
mySocket.listen(10)
#whait until socket don't connect
try:
threading._start_new_thread(clientdialog, (mySocket))
except:
print("error starting thread")
该socket.listen
函数将被调用一次,因为它设置了连接队列的大小。
调用的另一个函数socket.accept
将阻塞,直到建立连接。像这样修改你的代码:
mySocket = socket.socket()
mySocket.bind((host,port))
mySocket.listen(10)
while True:
client_socket, client_address = mySocket.accept() # blocking call
.... # do something with the connection
有关更多信息,请访问文档。
此外,您可能希望将客户端套接字的详细信息传递给线程。不需要服务器套接字。实际上,是这样的:
def handle_client(client_socket, client_address):
.... # do something with client socket
client_socket.close()
...
while True:
client_socket, client_address = mySocket.accept()
T = threading.Thread(target=handle_client, args=(client_socket, client_address))
T.start()
您在主循环中接受连接,然后将客户端详细信息传递给线程进行处理。
本文收集自互联网,转载请注明来源。
如有侵权,请联系[email protected] 删除。
我来说两句