欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

多进程,线程并发服务器模板

程序员文章站 2022-06-20 08:40:30
1 import socket # 导入套接字模块 2 from multiprocessing import Process # 导入进程中的模块方法 3 from threading import Thread # 导入线程中的模块方法 4 5 6 server = socket.socket(... ......
 1 import socket   # 导入套接字模块
 2 from multiprocessing import Process   # 导入进程中的模块方法
 3 from threading import Thread    # 导入线程中的模块方法
 4 
 5 
 6 server = socket.socket()    # 创建服务端套接字
 7 server.bind(('', 6666))   # 服务端地址端口
 8 server.listen(1000)   # 侦听数
 9 
10 # 定义数据处理函数
11 def func(conn):
12     # 循环数据处理方法
13     while True:
14         recv_data = conn.recv(1024)   # 接收数据
15         if recv_data:   # 如果接收到数据
16             res = recv_data.decode()    # 对数据进行解码
17             print(res)  # 打印解码后的数据
18             conn.send(recv_data)    # 发送数据
19         else:
20             conn.close()    # 关闭套接字
21             break   # 结束循环
22 
23 while True:
24     conn, addr = server.accept()    # 创建套接字
25     p = Process(target=func, args=(conn, ))   # 创建进程
26     # t = Thread(target=func, args=(conn, ))    # 创建线程
27     p.start()   # 启动进程
28     # t.start()   # 启动线程