asyncws

KO | EN

gitlite — search

#javascript #react #golang #android #rust #deep-learning #linux #docker #nodejs #windows #cli #awesome-list #security #ios

(★ 9)

Library for developing websocket applications in Python 3 and asyncio.

asyncws 최신버젼 다운로드

최종 버전 다운로드 (.zip)

// repository documentation

Was this content helpful?

★ 0 (0 ratings)

# async-websockets

<h3>About</h3>

``asyncws`` is a library for developing coroutine based websocket applications in Python 3.

It implements [RFC 6455](https://tools.ietf.org/html/rfc6455), passes the [Autobahn Testsuite](http://autobahn.ws/testsuite/) and supports SSL/TSL out of the box. Based on [PEP 3156](https://www.python.org/dev/peps/pep-3156/) and coroutines it makes it easy to write highly concurrent websocket based applications.

<h3>Installation</h3>

To install the package: ``python3 setup.py install``

<h3>API Documentation</h3>
Refer to [API Documentation](https://async-websockets.readthedocs.io/) for more information.

<h3>Example</h3>

Echo server:
`````python
import asyncio
import asyncws

@asyncio.coroutine
def echo(websocket):
    while True:
        frame = yield from websocket.recv()
        if frame is None:
            break
        yield from websocket.send(frame)

loop = asyncio.get_event_loop()
server = loop.run_until_complete(
    asyncws.start_server(echo, '127.0.0.1', 8000))
try:
    loop.run_forever()
except KeyboardInterrupt as e:
    server.close()
    loop.run_until_complete(server.wait_closed())
finally:
    loop.close()
`````

Corresponding echo client:
`````python
import asyncio
import asyncws

@asyncio.coroutine
def echo(websocket):
    while True:
        yield from websocket.send('hello')
        msg = yield from websocket.recv()
        if msg is None:
            break
        print(msg)

loop = asyncio.get_event_loop()
websocket = loop.run_until_complete(
    asyncws.connect('ws://localhost:8000'))
try:
    loop.run_until_complete(echo(websocket))
except KeyboardInterrupt as e:
    loop.run_until_complete(websocket.close())
    loop.run_until_complete(websocket.wait_closed())
finally:
    loop.close()
`````
<h3>SSL/TSL Example</h3>

The first step is to create the certificate and key files. A self-signed certificate can be created with a command like:

``openssl req -newkey rsa:2048 -nodes -keyout example.key -x509 -days 365 -out example.crt``

Create an SSLContext with the certificate and key just generated and then pass the context to start_server():

`````python
import asyncio
import asyncws
import ssl

@asyncio.coroutine
def echo(websocket):
    while True:
        frame = yield from websocket.recv()
        if frame is None:
            break
        yield from websocket.send(frame)

ssl_context = ssl.create_default_context(ssl.Purpose.CLIENT_AUTH)
ssl_context.check_hostname = False
ssl_context.load_cert_chain('example.crt', 'example.key')

loop = asyncio.get_event_loop()
loop.set_debug(True)
server = loop.run_until_complete(
    asyncws.start_server(echo, '127.0.0.1', 8000, ssl=ssl_context))
try:
    loop.run_forever()
except KeyboardInterrupt as e:
    server.close()
    loop.run_until_complete(server.wait_closed())
finally:
    loop.close()
`````

An SSLContext is needed to secure the client-side of the socket:

`````python
import asyncio
import asyncws
import ssl

@asyncio.coroutine
def echo(websocket):
    while True:
        yield from websocket.send('hello')
        echo = yield from websocket.recv()
        if echo is None:
            break
        print(echo)

ssl_context = ssl.create_default_context(ssl.Purpose.SERVER_AUTH)
ssl_context.check_hostname = False
ssl_context.verify_mode = ssl.CERT_NONE
ssl_context.load_verify_locations('example.crt')

loop = asyncio.get_event_loop()
websocket = loop.run_until_complete(
    asyncws.connect('wss://localhost:8000', ssl=ssl_context))
try:
    loop.run_until_complete(echo(websocket))
except KeyboardInterrupt as e:
    loop.run_until_complete(websocket.close())
    loop.run_until_complete(websocket.wait_closed())
finally:
    loop.close()
`````

Now you have a fully encrypted websocket connection!

asyncws

asyncws 최신버젼 다운로드

오늘의 추천 프로젝트

Was this content helpful?

Recent Feedback

asyncws

asyncws 최신버젼 다운로드

오늘의 추천 프로젝트

Was this content helpful?

Recent Feedback

Download README