共计 1915 个字符,预计需要花费 5 分钟才能阅读完成。
概述
TCP 服务端与多个客户端同时建设套接字,须要一个线程保护一个客户端。
实现步骤
1. 导入 socket 包
import socket
2. 创立服务端套接字
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()
正文完