PythonWebServer如何同时处理多个请求

源于知乎上一个问题:https://www.zhihu.com/question/56472691/answer/293292349

对于初学Web开发,理解一个web server如何能同事处理多个请求很重要。当然更重要的是,理解你通过浏览器发送的请求web server是怎么处理的,然后怎么返回给浏览器,浏览器才能展示的。

我到现在还记得大概在2010年左右,看了tomcat源码之后,那种豁然开朗的感觉(对,当时我还在写Java)。搞技术的人,总是希望花点时间,能够更透彻的看透整个网络世界的构成,而不是那啥。

要理解web server如何能处理多个请求有两个基本要素

  • 第一,知道怎么通过socket编程,这也是我在视频中强调的一点,理解这点之后再去看看WSGI,你就知道Python世界中大部分的框架怎么运作了。
  • 第二,多线程编程,理解了这个,你才能知道怎么着我起了一个web server,就能处理多个请求。 多进程也是一样的逻辑。

通过这两段代码,应该很好理解:

  1. server.py 如果不太懂的话,建议保存到本地,运行下试试.
# coding:utf-8 
import socket  
EOL1 = '\n\n' 
EOL2 = '\n\r\n' 
body = '''Hello, world! <h1> from the5fire 《Django企业开发实战》</h1>''' 
response_params = [     'HTTP/1.0 200 OK',     'Date: Sat, 10 jun 2017 01:01:01 GMT',     'Content-Type: text/plain; charset=utf-8',     'Content-Length: {}\r\n'.format(len(body)),     body, ] 
response = b'\r\n'.join(response_params)  
def handle_connection(conn, addr): 
  request = ""     
  while EOL1 not in request and EOL2 not in request:         
    request += conn.recv(1024)    
  print(request)    
  conn.send(response)     
  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(1)     
  print('http://127.0.0.1:8080')      
  try:         
    while True:             
      conn, address = serversocket.accept()             
      handle_connection(conn, address)     
  finally:         
    serversocket.close() 
if __name__ == '__main__':    
  main()

python server.py 试试

  1. thread_server.py 开多个tab,同时打开试试.
# coding:utf-8 
import socket 
import threading 
import time  
EOL1 = '\n\n' 
EOL2 = '\n\r\n' 
body = '''Hello, world! <h1> from the5fire 《Django企业开发实战》</h1> - from {thread_name}''' 
response_params = [     'HTTP/1.0 200 OK',     'Date: Sat, 10 jun 2017 01:01:01 GMT',     'Content-Type: text/plain; charset=utf-8',     'Content-Length: {length}\r\n',     body, ] 
response = b'\r\n'.join(response_params)  
def handle_connection(conn, addr):     
  request = ""     
  while EOL1 not in request and EOL2 not in request:         
    request += conn.recv(1024)     
    # print(request)     
    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(10)     
    conn.send(response.format(thread_name=current_thread.name, length=content_length))     
    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()

试试吧,与其着急去学习框架不如先弄懂这个。

参考

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

扫码关注云+社区

领取腾讯云代金券