辽宁国税报税软件下载:the5fire的技术博客

彩票开奖查询 www.8a72.cn 关注Python、Django、Vim、Linux、Web开发、团队管理和互联网--Life is short, we need Python.


PythonWebServer如何同时处理多个请求

作者:the5fire | 标签:       | 发布:2018-01-10 10:25 p.m. | 阅读量: 4155, 2158

源于知乎上一个问题: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('//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('//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()

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

参考

- from www.8a72.cn
----EOF-----

微信公众号:Python程序员杂谈

预售优惠价截止到7月8日23点59分。


其他分类:
  • 女子谎称刷单提成骗贫困大学生16万 用于买化妆品 2018-12-01
  • 西安体育学院体育传媒系与西部网签约校媒合作 2018-12-01
  • 网络投票刷礼物能不能帮孩子“争上游”? 2018-11-28
  • 中共山西省委组织部公示 2018-11-28
  • 【北京天气】最新北京今天天气,实时提供北京气温、空气质量、24小时天气预报、生活指数查询 2018-11-24
  • 格局生变 内容产业未来何去何从 2018-08-18
  • 土地不是劳动成果,而是一种自然资源,就像空气、阳光不是劳动成果而是自然资源一样,所以土地不具有价值,买房只应支付房屋费,不应该支付土地费。 2018-08-14
  • 安全生产月:铁路安全宣传走进车站 2018-08-02
  • 带动乡亲干 各自有实招——三位农村社区党组织书记的故事 2018-08-02
  • 长江中下游正式“入梅”!中东部高温降雨齐上阵 湖北中北部有大到暴雨 2018-07-31
  • 2018年4月27日划拨国家社科基金项目鉴定费名单(2) 2018-07-31
  • [微笑]未来的社会,必然是按需(基本需求)分配+按劳(劳动价值或劳动能力)分配相联合的混合分配方式。 2018-07-30
  • “一带一路”建设工作座谈会 2018-07-30
  • 只要等一等就能多“等”出8600万美元! 2018-07-29
  • 2017年秋季学期学员第十三支部风采 2018-07-18
  • 842| 947| 696| 928| 277| 362| 100| 670| 948| 59|