Python网络编程——TCP服务端多线程
原创
概述
TCP服务端与多个客户端同时建立套接字，需要一个线程维护一个客户端。
实现步骤
1.导入socket包
import socket2.创建服务端套接字
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.等待客户端的连接请求
每次客户端和服务器建立连接成功都会返回一个新的套接字
while True:
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 = send_content.encode('utf-8')
new_client.send(send_data)
new_client.close()8.关闭套接字
tcp_server_socket.close()代码实现：
import socket
import threading
def handle(ip_port,new_client):
print("客户端的ip和端口号是：" , ip_port)
while True:
# 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 = send_content.encode('utf-8')
new_client.send(send_data)
new_client.close()
else:
print("客户端下线了",ip_port)
break
if __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.等待客户端的连接请求
#每次客户端和服务器建立连接成功都会返回一个新的套接字
while True:
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()
原创声明：本文系作者授权腾讯云开发者社区发表，未经许可，不得转载。
如有侵权，请联系 cloudcommunity@tencent.com 删除。
原创声明：本文系作者授权腾讯云开发者社区发表，未经许可，不得转载。
如有侵权，请联系 cloudcommunity@tencent.com 删除。
评论
登录后参与评论
推荐阅读
目录