概述

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 socketimport threadingdef 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)                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.期待客户端的连贯申请        #每次客户端和服务器建设连贯胜利都会返回一个新的套接字    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()