TCP客户端增加多线程
(ps:仅有代码,小伙伴们利用百度,冲啊!!!)
from socket import *
from threading import Thread
def recv_data():
while True:
recv_data = client_socket.recv(1024)
recv_content = recv_data.decode('gbk')
print(f"服务器端说:{recv_content}")
if recv_content == "end":
print("结束接收消息")
break
def send_data():
while True:
msg = input(">")
client_socket.send(msg.encode("gbk"))
if msg == "end":
break
if __name__ == '__main__':
client_socket = socket(AF_INET, SOCK_STREAM)
client_socket.connect(("127.0.0.1", 8899))
t1 = Thread(target=recv_data)
t2 = Thread(target=send_data)
t1.start()
t2.start()
t1.join()
t2.join()
client_socket.close()
TCP服务端增加多线程
(ps:仅有代码,小伙伴们利用百度,冲啊!!!)
from socket import *
from threading import Thread
def recv_data():
while True:
recv_data = client_socket.recv(1024)
recv_content = recv_data.decode("gbk")
print(f"客户端说:{recv_content},来自:{client_info}")
if recv_content == "end":
print("结束接收消息!")
break
def send_data():
while True:
msg = input(">")
client_socket.send(msg.encode("gbk"))
if msg == "end":
print("结束发送消息!")
break
if __name__ == '__main__':
server_socket = socket(AF_INET, SOCK_STREAM)
server_socket.bind(("127.0.0.1", 8899))
server_socket.listen(5)
print("等待接收连接!")
client_socket, client_info = server_socket.accept()
print("一个客户端建立连接成功!")
t1 = Thread(target=recv_data)
t2 = Thread(target=send_data)
t1.start()
t2.start()
t1.join()
t2.join()
client_socket.close()
server_socket.close()
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)