python-gevent模块实现socket大并发

Posted 奔跑de孩子

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了python-gevent模块实现socket大并发相关的知识，希望对你有一定的参考价值。

服务器端：gevent_server.py

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
import sys
import socket
import time
import gevent
 
from gevent import socket, monkey
 
monkey.patch_all()
 
 
def server(port):
    s = socket.socket()
    s.bind((‘0.0.0.0‘, port))
    s.listen(500)
    while True:
        cli, addr = s.accept()
        gevent.spawn(handle_request, cli)#启动一个协程
 
 
def handle_request(conn):
    try:
        while True:
            data = conn.recv(1024)
            print("recv:", data)
            conn.send(data)
            if not data:
                conn.shutdown(socket.SHUT_WR)
 
    except Exception as  ex:
        print(ex)
    finally:
        conn.close()
 
 
if __name__ == ‘__main__‘:
        server(8001)
 
 客户端:socket_client.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
import socket
 
HOST = ‘localhost‘  # The remote host
PORT = 8001  # The same port as used by the server
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.connect((HOST, PORT))
while True:
    msg = bytes(input(">>:"), encoding="utf8")
    s.sendall(msg)
    data = s.recv(1024)
 
    #
    print(‘Received‘, data)
s.close()
 
import sys
import socket
import time
import gevent
 
from gevent import socket, monkey
 
monkey.patch_all()
 
 
def server(port):
    s = socket.socket()
    s.bind((‘0.0.0.0‘, port))
    s.listen(500)
    while True:
        cli, addr = s.accept()
        gevent.spawn(handle_request, cli)#启动一个协程
 
 
def handle_request(conn):
    try:
        while True:
            data = conn.recv(1024)
            print("recv:", data)
            conn.send(data)
            if not data:
                conn.shutdown(socket.SHUT_WR)
 
    except Exception as  ex:
        print(ex)
    finally:
        conn.close()
 
 
if __name__ == ‘__main__‘:
        server(8001)

以上是关于python-gevent模块实现socket大并发的主要内容，如果未能解决你的问题，请参考以下文章

python-gevent模块（自动切换io的协程）

python-gevent?????????????????????io????????????

python模块——socket (实现简单的C/S架构端通信操作CMD）

Electron - 实现 http 模块和 socket.io

在 ExpressJS 中将 socket.io 实现为子模块的最佳方法是啥？

用python socket模块实现简单的文件下载