Python socket 同时响应多个请求

2019-10-16  本文已影响0人  自我实验室_村君
  1. 创建 socket 对象,监听地址
  2. while True: serversocket.accept() 不断接收请求
  3. conn 其实就是 socket 对象,接受到请求之后,conn.recv(1024) 不断拼接出 request,然后解析 request
  4. conn.send(response), conn.close() 响应请求,关掉
  5. 能同时响应多个请求是因为把 handler 部分新增线程来处理
    • 在 socket.accept() 之后,把 handle_connection() 放到线程处理。
import socket
import time
import threading

EOL1 = b'\n\n'
EOL2 = b'\n\r\n'
body = b'fuck the world'
response_params = [
    b'HTTP/1.0 200 OK',
    b'Date: Sat, 10 jun 2017 01:01:01 GMT',
    b'Content-Type: text/plain; charset=utf-8',
    'Content-Length: {}\r\n'.format(len(body)).encode('utf-8'),
    body
]

response = b'\r\n'.join(response_params)

def handle_connection(conn, addr):
    request = b""
    while EOL1 not in request and EOL2 not in request:
        request += conn.recv(1024)
    print(request)

    time.sleep(1)
    conn.send(response)
    conn.close()


def main():
    serversocket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    serversocket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
    serversocket.bind(('127.0.0.1', 8080))
    serversocket.listen(20)
    print('http://127.0.0.1:8080')

    try:
        while True:
            conn, addr = serversocket.accept()
            # handle_connection(conn, addr) 单线程
            t = threading.Thread(target=handle_connection,
                                 args=(conn, addr))
            t.start()
    finally:
        serversocket.close()

if __name__ == '__main__':
    main()

// 代码来自: https://www.the5fire.com/thread-socketserver.html
上一篇下一篇

猜你喜欢

热点阅读