Python Language
웹 소켓

간단한 echo with aiohttp

aiohttp 는 비동기 웹 aiohttp 제공합니다.

import asyncio
from aiohttp import ClientSession

with ClientSession() as session:
    async def hello_world():

        websocket = await session.ws_connect("wss://echo.websocket.org")

        websocket.send_str("Hello, world!")

        print("Received:", (await websocket.receive()).data)

        await websocket.close()

    loop = asyncio.get_event_loop()
    loop.run_until_complete(hello_world())

aiohttp로 래퍼 클래스 만들기

aiohttp.ClientSession 은 사용자 정의 WebSocket 클래스의 부모로 사용될 수 있습니다.

import asyncio
from aiohttp import ClientSession

class EchoWebSocket(ClientSession):

    URL = "wss://echo.websocket.org"

    def __init__(self):
        super().__init__()
        self.websocket = None

    async def connect(self):
        """Connect to the WebSocket."""
        self.websocket = await self.ws_connect(self.URL)

    async def send(self, message):
        """Send a message to the WebSocket."""
        assert self.websocket is not None, "You must connect first!"
        self.websocket.send_str(message)
        print("Sent:", message)

    async def receive(self):
        """Receive one message from the WebSocket."""
        assert self.websocket is not None, "You must connect first!"
        return (await self.websocket.receive()).data

    async def read(self):
        """Read messages from the WebSocket."""
        assert self.websocket is not None, "You must connect first!"

        while self.websocket.receive():
            message = await self.receive()
            print("Received:", message)
            if message == "Echo 9!":
                break

async def send(websocket):
    for n in range(10):
        await websocket.send("Echo {}!".format(n))
        await asyncio.sleep(1)

loop = asyncio.get_event_loop()

with EchoWebSocket() as websocket:

    loop.run_until_complete(websocket.connect())

    tasks = (
        send(websocket),
        websocket.read()
    )

    loop.run_until_complete(asyncio.wait(tasks))

    loop.close()

Autobahn을 웹 소켓 공장으로 사용

Autobahn 패키지는 Python 웹 소켓 서버 팩토리에 사용할 수 있습니다.

Python Autobahn 패키지 문서

설치하려면 일반적으로 터미널 명령을 사용하면됩니다.

(Linux의 경우) :

sudo pip install autobahn

(Windows의 경우) :

python -m pip install autobahn

그런 다음 Python 스크립트에서 간단한 에코 서버를 만들 수 있습니다.

from autobahn.asyncio.websocket import WebSocketServerProtocol
class MyServerProtocol(WebSocketServerProtocol):
    '''When creating server protocol, the
    user defined class inheriting the 
    WebSocketServerProtocol needs to override
    the onMessage, onConnect, et-c events for 
    user specified functionality, these events 
    define your server's protocol, in essence'''
    def onMessage(self,payload,isBinary):
        '''The onMessage routine is called 
        when the server receives a message.
        It has the required arguments payload 
        and the bool isBinary. The payload is the 
        actual contents of the "message" and isBinary
        is simply a flag to let the user know that 
        the payload contains binary data. I typically 
        elsewise assume that the payload is a string.
        In this example, the payload is returned to sender verbatim.'''
        self.sendMessage(payload,isBinary)
if__name__=='__main__':
    try:
        importasyncio
    except ImportError:
        '''Trollius = 0.3 was renamed'''
        import trollius as asyncio
    from autobahn.asyncio.websocketimportWebSocketServerFactory
    factory=WebSocketServerFactory()
    '''Initialize the websocket factory, and set the protocol to the 
    above defined protocol(the class that inherits from 
    autobahn.asyncio.websocket.WebSocketServerProtocol)'''
    factory.protocol=MyServerProtocol
    '''This above line can be thought of as "binding" the methods
    onConnect, onMessage, et-c that were described in the MyServerProtocol class
    to the server, setting the servers functionality, ie, protocol'''
    loop=asyncio.get_event_loop()
    coro=loop.create_server(factory,'127.0.0.1',9000)
    server=loop.run_until_complete(coro)
    '''Run the server in an infinite loop'''
    try:
        loop.run_forever()
    except KeyboardInterrupt:
        pass
    finally:
        server.close()
        loop.close()

이 예에서 포트 9000의 로컬 호스트 (127.0.0.1)에 서버가 생성됩니다. 수신 대기중인 IP 및 포트입니다. 이것은 중요한 정보입니다.이 기능을 사용하면 컴퓨터에 연결된 라우터는 무엇이든간에 컴퓨터의 LAN 주소와 포트를 모뎀에서 식별 할 수 있습니다. 그런 다음 Google을 사용하여 WAN IP를 조사하면 WAN IP, 포트 9000 (이 예에서는)에서 WebSocket 메시지를 보내도록 웹 사이트를 설계 할 수 있습니다.

다시 모뎀에서 포트 포워드하는 것이 중요합니다. 즉, 라우터를 데이지 체인 방식으로 연결 한 경우 모뎀의 구성 설정을 입력하고 모뎀에서 연결된 라우터로 포트 등을 지정하여 컴퓨터의 최종 라우터가 될 때까지 기다려야합니다 (이 예에서) 모뎀 포트 9000에서 수신되는 정보를 갖는 것입니다.