Asynchronous Proxy Server From RabbitMQ to WebSocket
Project description
Asynchronous RMQ -> Websocket Proxy Server
Here is an implementation of typical websocket server which receives messages from RMQ and process them and send to connected websocket clients
In the current state WS server is capable of:
- Running a server instance which accepts websocket connections from clients and control them;
- connecting to RabbitMQ, creating Exchange and Queue and consume on it;
- receiving messages from RMQ Queue;
- processing received RMQ messages and send them to connected websocket clients.
Struct
Pip
- pip install aio-rmq-wss-proxy
Source
- Clone repository
- Run "cd aio_rmq_wss_proxy/"
- Run "make install"
- Run the commands "make run_server" & "make run_client" to see how does it works
Please, note that before running server and client you need to have installed and running Rabbit MQ broker.
This is how it works from the box.
Customization
You can see the "public_sample" in "_testing/public_sample" directory and use it for build your own proxy server
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
File details
Details for the file aio_rmq_wss_proxy-0.0.3.tar.gz
.
File metadata
- Download URL: aio_rmq_wss_proxy-0.0.3.tar.gz
- Upload date:
- Size: 8.2 kB
- Tags: Source
- Uploaded using Trusted Publishing? No
- Uploaded via: twine/4.0.2 CPython/3.10.9
File hashes
Algorithm | Hash digest | |
---|---|---|
SHA256 | 85214e3dc794a974eb645e2d89e9fc9d479cd65b42e1c4956ebe363c66e0e7ed |
|
MD5 | 0207d0e83f896fc52ca59cbabd650a2c |
|
BLAKE2b-256 | bc28dfeb7a64383e947826602458d972eb0aa79f3053d054419e5562515a2002 |
File details
Details for the file aio_rmq_wss_proxy-0.0.3-py3-none-any.whl
.
File metadata
- Download URL: aio_rmq_wss_proxy-0.0.3-py3-none-any.whl
- Upload date:
- Size: 10.9 kB
- Tags: Python 3
- Uploaded using Trusted Publishing? No
- Uploaded via: twine/4.0.2 CPython/3.10.9
File hashes
Algorithm | Hash digest | |
---|---|---|
SHA256 | e13477086619d27744607b506bf827b8b1205edde9195fca774be7d58eee7074 |
|
MD5 | 01ccc138f1468f84cfa10d7b6a2a3eaf |
|
BLAKE2b-256 | 188074cd4ea0a1975e7355bc76258968c0e61076d978c92c11e933e3871fbdc3 |