开发者社区> 胡临任> 正文
阿里云
为了无法计算的价值
打开APP
阿里云APP内打开

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

简介: TCP服务端与多个客户端同时建立套接字,需要一个线程维护一个客户端。
+关注继续查看

概述

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()

版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

相关文章
Python 面向对象 9: 模块和包
Python 面向对象 9: 模块和包
29 0
python爬虫——request模块讲解
python爬虫——request模块讲解
71 0
python爬虫urllib3模块详解
python爬虫urllib3模块详解
78 0
Python 之设计模式、异常处理、模块与包、文件操作及编码
Python 之设计模式、异常处理、模块与包、文件操作及编码
24 0
Python编程:importlib.import_module动态导入模块
Python编程:importlib.import_module动态导入模块
57 0
+关注
111
文章
1
问答
文章排行榜
最热
最新
相关电子书
更多
低代码开发师(初级)实战教程
立即下载
阿里巴巴DevOps 最佳实践手册
立即下载
冬季实战营第三期:MySQL数据库进阶实战
立即下载