Python网络编程——TCP服务端多线程 python

概述 TCP服务端与多个客户端同时建立套接字，需要一个线程维护一个客户端。
实现步骤 1.导入socket包

import socket

2.创建服务端套接字 【Python网络编程——TCP服务端多线程】socket.socket(AddressFamily, Type)
socket.AF_INET表示IPv4类型
SOCK_STREAM表示tcp
需要设置端口复用实现服务多客户端

tcp_server_socket=socket.socket(socket.AF_INET,socket.SOCK_STREAM)#端口复用服务端退出端口立即释放 tcp_server_socket.setsockopt(socket.SOL_SOCKET,socket.SO_REUSEADDR,True)

3.绑定端口号 tcp_server_socket.bind
第一个参数表示ip地址，一般不用指定表示本机的任何一个ip
第二个参数表示端口号

tcp_server_socket.bind(('',9090))

4.设置监听表示最大等待建立链接的个数128

tcp_server_socket.listen(128)

5.等待客户端的连接请求每次客户端和服务器建立连接成功都会返回一个新的套接字

whileTrue: new_client , ip_port = tcp_server_socket.accept() sub_thresd = threading.Thread(target=handle,args=(ip_port,new_client)) sub_thresd.start()

6.接收数据收发消息使用新返回的套接字

rece_data = new_client.recv(1024) if rece_data: rece_data = rece_data.decode('utf-8') print("接收到的数据是",rece_data)

7.发送数据

send_content = "问题正在处理中" send_data = https://www.it610.com/article/send_content.encode('utf-8') new_client.send(send_data) new_client.close()

8.关闭套接字

tcp_server_socket.close()

代码实现：

import socket import threadingdef handle(ip_port,new_client): print("客户端的ip和端口号是：" , ip_port) whileTrue: # 5.接收数据 #收发消息使用新返回的套接字 rece_data = new_client.recv(1024) if rece_data: rece_data = rece_data.decode('utf-8') print("接收到的数据是",rece_data) # 6.发送数据 send_content = "问题正在处理中" send_data = https://www.it610.com/article/send_content.encode('utf-8') new_client.send(send_data) new_client.close() else: print("客户端下线了",ip_port) breakif __name__ == '__main__': # 1.创建服务端套接字 # socket.AF_INET表示IPv4类型 # SOCK_STREAM表示tcp tcp_server_socket=socket.socket(socket.AF_INET,socket.SOCK_STREAM) tcp_server_socket.setsockopt(socket.SOL_SOCKET,socket.SO_REUSEADDR,True) #端口复用服务端退出端口立即释放 #socket.SOL_SOCKET 表示当前套接字 #socket._RetAddress 复用选项 #True 确定复用 # 2.绑定端口号 # 第一个参数表示ip地址，一般不用置顶表示本机的任何一个ip #第二个参数表示端口号 tcp_server_socket.bind(('',9090)) # 3.设置监听 # 128:表示最大等待建立链接的个数 tcp_server_socket.listen(128) # 4.等待客户端的连接请求 #每次客户端和服务器建立连接成功都会返回一个新的套接字 whileTrue: new_client , ip_port = tcp_server_socket.accept() sub_thresd = threading.Thread(target=handle,args=(ip_port,new_client)) sub_thresd.start()# 7.关闭套接字 tcp_server_socket.close()