zoukankan      html  css  js  c++  java
  • python gevent并发socket

    import queue
    import gevent
    from gevent import monkey; monkey.patch_socket()#猴子补丁代替python原有的socket
    selector = selectors.DefaultSelector()
    
    socket_server = socket.socket()
    address_server = ('0.0.0.0',8080)
    socket_server.bind(address_server)
    socket_server.listen(1000)
    q = queue.Queue(3)
    
    def conmuer(connect):
        while True:
            massage = connect.recv(1024)
            if massage:
                print(massage)
                connect.send(massage)
            else:
                connect.close()
                break
    
    while True:
        connect, address = socket_server.accept()
        print(connect)
        gevent.spawn(conmuer, connect)#创建协程
  • 相关阅读:
    Linux
    python 鸢尾花数据集报表展示
    python 词云
    毕业设计回顾
    editor.md
    杂记
    垃圾回收器
    杂记
    随笔
    杂记
  • 原文地址:https://www.cnblogs.com/arrow-kejin/p/8993415.html
Copyright © 2011-2022 走看看