WSGI가 무엇인지 이해해야 합니다.

python 동영상 튜토리얼 칼럼에서는 WSGI를 소개합니다.

저는 몇 년 동안 Python 웹을 작성해 왔지만 여전히 WSGI가 무엇인지, 거기에 많은 사람들이 있는지 모릅니다. 개발자로서 웹 사이트를 구축하기 위해 wsgi가 무엇인지 이해할 필요가 거의 없기 때문에 이는 정상적인 현상입니다.

하지만 웹 프레임워크를 직접 작성하려면 wsgi에 대해 배워야 합니다.

복습하자면, 우리는 웹 개발에 Python을 사용할 때 일반적으로 django나 Flask와 같은 특정 웹 프레임워크 및 기타 프레임워크를 기반으로 개발합니다. 사업 개발이 완료된 후에는 서버에 배포하여 외부 접속을 제공해야 합니다.

이때 인터넷으로 검색해보면 gunicorn이나 uwsgi를 사용해서 배포해야 한다고 나옵니다. 그렇다면 gunicorn과 uwsgi는 무엇입니까?

이 사진을 보면 이해가 되실 겁니다.

여기서 uwsgi나 gunicorn이 하는 역할은 웹 서버입니다. , 전송된 HTTP 요청과 프런트엔드에 반환된 응답 결과를 처리하는 데 사용됩니다. 웹 프레임워크의 주요 작업은 비즈니스 로직을 처리하고 결과를 웹 서버에 생성한 다음 웹 서버가 이를 브라우저에 반환하는 것입니다.

웹 프레임워크와 웹 서버 간의 통신은 일련의 사양을 따라야 하는데, 이 사양이 WSGI입니다.

왜 이런 규정을 제정해야 할까요? 표준은 표준을 통일하고 모든 사람의 사용을 촉진하기 위한 것입니다

현재 휴대폰 충전 인터페이스가 Type-c라고 상상해 보세요. Type-c는 휴대폰 제조업체가 이 사양에 따라 휴대폰을 생산하고 충전기 제조업체는 Type-c를 따릅니다. 충전기는 c의 사양에 따라 생산되며, 서로 다른 제조사의 휴대폰은 서로 다른 제조사의 충전기를 사용하여 사용할 수 있습니다. 그러나 Apple에는 자체 규정이 있어 결국 Android 충전기로 Apple을 충전할 수 없게 됩니다.

![

](p9-juejin.byteimg.com/tos-cn-i-k3…)

그렇다면 WSGI 사양을 준수하는 응용(프레임워크) 프로그램과 서버를 어떻게 작성해야 할까요?

위 그림처럼 왼쪽이 웹 서버이고, 오른쪽이 웹 프레임워크, 즉 애플리케이션입니다.

Application

WSGI는 애플리케이션이 호출 가능 객체(호출 가능 객체는 __call__를 구현하는 함수, 클래스 또는 인스턴스 객체일 수 있음)여야 하며 두 개의 매개 변수를 허용해야 한다고 규정합니다. 객체의 반환 값은 다음과 같아야 합니다. 반복 가능한 객체.

가장 간단한 애플리케이션 예제를 작성할 수 있습니다.

HELLO_WORLD = b"Hello world!\n"def application(environ, start_response):
    status = '200 OK'
    response_headers = [('Content-type', 'text/plain')]
    start_response(status, response_headers)    return [HELLO_WORLD]复制代码

application은 호출 가능한 객체여야 하는 함수이며 두 개의 매개 변수는 environ과 start_response입니다.

• environ은 사전이며 모든 항목을 저장합니다. 헤더, 요청 매개변수 등 HTTP 요청과 관련된 콘텐츠.
• start_response는 WSGI 서버에서 전달하는 함수로, 응답 헤더와 상태 코드를 서버에 전달하는 데 사용됩니다.

start_response 함수를 호출하면 응답 헤더와 상태 코드가 서버에 전달됩니다. 응답 본문은 이 두 함수에 의해 서버에 반환됩니다.

wsgi를 구현하는 모든 웹 프레임워크에는 호출 가능한 객체가 있습니다.

Server

WSGI 서버가 하는 일은 매번 HTTP 요청을 수신하고 Environ 객체를 구축한 다음 애플리케이션 객체를 호출하고 마지막으로 HTTP 응답을 반환하는 것입니다. 브라우저에.

다음은 완전한 wsgi 서버의 코드입니다

import socketimport sysfrom io import StringIOclass WSGIServer(object):
    address_family = socket.AF_INET
    socket_type = socket.SOCK_STREAM
    request_queue_size = 1

    def __init__(self, server_address):
        # Create a listening socket
        self.listen_socket = listen_socket = socket.socket(
            self.address_family,
            self.socket_type
        )        # Allow to reuse the same address
        listen_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)        # Bind
        listen_socket.bind(server_address)        # Activate
        listen_socket.listen(self.request_queue_size)        # Get server host name and port
        host, port = self.listen_socket.getsockname()[:2]
        self.server_name = socket.getfqdn(host)
        self.server_port = port        # Return headers set by Web framework/Web application
        self.headers_set = []    def set_app(self, application):
        self.application = application    def serve_forever(self):
        listen_socket = self.listen_socket        while True:            # New client connection
            self.client_connection, client_address = listen_socket.accept()            # Handle one request and close the client connection. Then
            # loop over to wait for another client connection
            self.handle_one_request()    def handle_one_request(self):
        self.request_data = request_data = self.client_connection.recv(1024)        # Print formatted request data a la 'curl -v'
        print(''.join(            '< {line}\n&#39;.format(line=line)            for line in request_data.splitlines()
        ))
        self.parse_request(request_data)        # Construct environment dictionary using request data
        env = self.get_environ()        # It&#39;s time to call our application callable and get
        # back a result that will become HTTP response body
        result = self.application(env, self.start_response)        # Construct a response and send it back to the client
        self.finish_response(result)    def parse_request(self, text):
        request_line = text.splitlines()[0]
        request_line = request_line.rstrip(&#39;\r\n&#39;)        # Break down the request line into components
        (self.request_method,  # GET
         self.path,  # /hello
         self.request_version  # HTTP/1.1
         ) = request_line.split()    def get_environ(self):
        env = {}        # The following code snippet does not follow PEP8 conventions
        # but it&#39;s formatted the way it is for demonstration purposes
        # to emphasize the required variables and their values
        #
        # Required WSGI variables
        env[&#39;wsgi.version&#39;] = (1, 0)
        env[&#39;wsgi.url_scheme&#39;] = &#39;http&#39;
        env[&#39;wsgi.input&#39;] = StringIO.StringIO(self.request_data)
        env[&#39;wsgi.errors&#39;] = sys.stderr
        env[&#39;wsgi.multithread&#39;] = False
        env[&#39;wsgi.multiprocess&#39;] = False
        env[&#39;wsgi.run_once&#39;] = False
        # Required CGI variables
        env[&#39;REQUEST_METHOD&#39;] = self.request_method  # GET
        env[&#39;PATH_INFO&#39;] = self.path  # /hello
        env[&#39;SERVER_NAME&#39;] = self.server_name  # localhost
        env[&#39;SERVER_PORT&#39;] = str(self.server_port)  # 8888
        return env    def start_response(self, status, response_headers, exc_info=None):
        # Add necessary server headers
        server_headers = [
            (&#39;Date&#39;, &#39;Tue, 31 Mar 2015 12:54:48 GMT&#39;),
            (&#39;Server&#39;, &#39;WSGIServer 0.2&#39;),
        ]
        self.headers_set = [status, response_headers + server_headers]        # To adhere to WSGI specification the start_response must return
        # a &#39;write&#39; callable. We simplicity&#39;s sake we&#39;ll ignore that detail
        # for now.
        # return self.finish_response

    def finish_response(self, result):
        try:
            status, response_headers = self.headers_set
            response = &#39;HTTP/1.1 {status}\r\n&#39;.format(status=status)            for header in response_headers:
                response += &#39;{0}: {1}\r\n&#39;.format(*header)
            response += &#39;\r\n&#39;
            for data in result:
                response += data            # Print formatted response data a la &#39;curl -v&#39;
            print(&#39;&#39;.join(                &#39;> {line}\n'.format(line=line)                for line in response.splitlines()
            ))
            self.client_connection.sendall(response)        finally:
            self.client_connection.close()


SERVER_ADDRESS = (HOST, PORT) = 'localhost', 8080def make_server(server_address, application):
    server = WSGIServer(server_address)
    server.set_app(application)    return serverif __name__ == '__main__':
    httpd = make_server(SERVER_ADDRESS, application)
    print('WSGIServer: Serving HTTP on port {port} ...\n'.format(port=PORT))
    httpd.serve_forever()复制代码

물론 개발 환경용 서버만 작성한다면 휠을 직접 새로 만들기 위해 그런 수고를 할 필요는 없습니다. 모듈은 wsgi 서버의 기능을 제공합니다.

from wsgiref.simple_server import make_server
srv = make_server('localhost', 8080, application)
srv.serve_forever()复制代码

3줄의 코드만으로 wsgi 서버를 제공할 수 있어 정말 편리하지 않나요? 마지막으로 브라우저를 방문하여 요청을 시작하는 효과를 테스트해 보겠습니다.

위는 wsgi에 대한 소개입니다. wsgi에 대해 더 깊이 이해하면 PEP333

에 익숙해질 수 있습니다. 관련 무료 학습 권장사항: python 비디오 튜토리얼

위 내용은 WSGI가 무엇인지 이해해야 합니다.의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!