设计web服务器的思路
- 路由 2. 请求与响应
在这之前得建立通信,常用的就是socket
简单的web服务器
可以在此基顾进行扩展,封装,就成web架框,例如我们常用的flask, sanic, django....
# coding:utf-8
import socket
import threading
import time
EOL1 = b'\n\n'
EOL2 = b'\n\r\n'
body = '''Hello ,hugo!---{thread_name}'''
response_params = [
'HTTP/1.0 200 OK',
'Date: Sat, 10 jun 2018 01:01:01 GMT',
'Content-Type: Application/json; charset=utf-8',
'Content-Length: {length}\r\n',
body,
]
response = '\r\n'.join(response_params)
def handle_connection(conn, addr):
req = conn.recv(1024)
print(req, addr)
current_thread = threading.currentThread()
content_length = len(body.format(thread_name=current_thread.name))
print(current_thread.name, '-------', 'sleep 10', int(time.time()))
time.sleep(1)
conn.send(bytes(response.format(thread_name=current_thread.name, length=content_length), encoding="utf-8"))
conn.close()
def main():
# socket.AF_INET 用于服务器与服务器之间的网络通信
# socket.SOCK_STREAM 基于TCP的流式socket通信
serversocket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
# 设置端口可复用,保证我们每次Ctrl C之后,快速再次重启
serversocket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
serversocket.bind(('127.0.0.1', 8080))
# 可参考:https://stackoverflow.com/questions/2444459/python-sock-listen
serversocket.listen(10)
print('http://127.0.0.1:8080')
try:
i = 0
while True:
i += 1
conn, address = serversocket.accept()
t = threading.Thread(target=handle_connection, args=(conn, address), name='thread-%s' % i)
t.start()
finally:
serversocket.close()
if __name__ == '__main__':
main()