Websocket server using Twisted/Autobahn with an easy to use callback registry mechanism
See django-mease, django-mease-example or flask-mease-example for working examples.
Use pip to install the latest mease version :
pip install mease
mease
comes with two backends :
To use Redis backend, install these dependencies :
sudo apt-get install redis-server pip install redis
Refer to the Redis documentation to configure your server.
To use RabbitMQ backend, install these dependencies :
sudo apt-get install rabbitmq-server pip install kombu
Refer to the RabbitMQ documentation to configure your server.
Create a file where you can write your callbacks and register them :
from mease import Mease
from mease.backends.redis import RedisBackend
# OR from mease.backends.rabbitmq import RabbitMQBackend
from uuid import uuid4
mease = Mease(RedisBackend)
@mease.opener
def example_opener(client, clients_list):
# Do stuff on client connection
client.storage['uuid'] = str(uuid4())
@mease.closer
def example_closer(client, clients_list):
# Do stuff on client disconnection
print("Client {uuid} disconnected".format(uuid=client.storage.get('uuid')))
@mease.receiver(json=True)
def example_receiver(client, clients_list, message):
# Do stuff on incoming client message
pass
@mease.sender(routing='mease.demo')
def example_sender(routing, clients_list, my_tuple):
# Do stuff on outgoing message
pass
if __name__ == '__main__':
# Start websocket server
mease.run_websocket_server()
Remember to run the websocket server from the mease
instance where you registered your callbacks.
In your code, you can now call the mease publish
method to send a message to websocket clients :
from mease import Mease
from mease.backends.redis import RedisBackend
mease = Mease(RedisBackend)
# ...
mease.publish('mease.demo', my_tuple=("Hello", "World"))
That's it ! You are now able to send messages from your web server to your websocket server in a cool way !