zoukankan      html  css  js  c++  java
  • 多进程,线程并发服务器模板

     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()   # 启动线程
  • 相关阅读:
    2014/4/9-最近所想
    DNS坑爹呢?!
    c#委托使用
    sqlserver 获取一个月有多少天
    定时提醒模型
    sqlserver导入dbf文件
    json对象中根据主键判断是否有重复数据
    差异备份与恢复
    html编码和解码
    opendatasource问题
  • 原文地址:https://www.cnblogs.com/mxwei/p/9235933.html
Copyright © 2011-2022 走看看