PythonWebServer如何同时处理多个请求

内容简介：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()

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

参考

• WSGI——Web框架基础 - 《Django企业开发实战草稿》
• Python官方库的socketserver源码

以上就是本文的全部内容，希望本文的内容对大家的学习或者工作能带来一定的帮助，也希望大家多多支持 码农网

查看所有标签

猜你喜欢:

• 同一页面多个ajax请求后台堵塞问题
• 监控多个Kubernetes集群
• 管理多个远端仓库
• Git 推送到多个仓库
• 运行多个 npm script
• Python：尝试反序列化文件中的多个JSON对象,每个对象跨越多个但一致的间隔数量的行

本站部分资源来源于网络，本站转载出于传递更多信息之目的，版权归原作者或者来源机构所有，如转载稿涉及版权问题，请联系我们。