/ 
Beekeeper-0.01
River stage zero No dependents
⭐ Starred 9 GitHub stars
/ examples/chat/README.md

Chat example

This example implements a real world setup with isolated buses and redundancy:

Running this example

To run this example start worker pools:

cd beekeper/examples/chat
source setup.sh
./run.sh start

Then open chat.html in a browser, or use the command line client:

./chat.pl

The system can be stressed with:

./flood.pl -c 50 -r 500

When done, stop worker pools with:

./run.sh stop

Network traffic can be inspected with:

tcpflow -i any -C -g port 61613

This is bkpr-top showing this example running:

ActiveMQ setup

This example uses the internal ToyBroker to allow being run out of the box, but to use chat.html the WebSockets capabilities of ActiveMQ or RabbitMQ are required (chat.pl works fine though).

To run this example on a fresh install of ActiveMQ just set use_toybroker to false in config file pool.config.json. Also ensure that host addresses in bus.config.json and config.js match ActiveMQ one.

Note that ActiveMQ does not support virtual hosts, so this example will not use four different brokers as it should (it works anyway because queue names do not clash).

RabbitMQ setup

To run this example on a fresh install of RabbitMQ set use_toybroker to false in config file pool.config.json. Also ensure that host addresses in bus.config.json and config.js match RabbitMQ one.

Then configure RabbitMQ (enable STOMP and create the required users and virtual hosts) with the following commands:

rabbitmq-plugins enable rabbitmq_stomp
rabbitmq-plugins enable rabbitmq_web_stomp

rabbitmqctl add_user frontend abc123
rabbitmqctl add_user backend def456

rabbitmqctl add_vhost /frontend-A
rabbitmqctl add_vhost /frontend-B
rabbitmqctl add_vhost /backend-A
rabbitmqctl add_vhost /backend-B

rabbitmqctl set_permissions frontend -p /frontend-A ".*" ".*" ".*"
rabbitmqctl set_permissions frontend -p /frontend-B ".*" ".*" ".*"

rabbitmqctl set_permissions backend -p /backend-A  ".*" ".*" ".*"
rabbitmqctl set_permissions backend -p /backend-B  ".*" ".*" ".*"
rabbitmqctl set_permissions backend -p /frontend-A ".*" ".*" ".*"
rabbitmqctl set_permissions backend -p /frontend-B ".*" ".*" ".*"

rabbitmqctl set_policy expiry -p /backend-A  ".*" '{"expires":60000}' --apply-to queues
rabbitmqctl set_policy expiry -p /backend-B  ".*" '{"expires":60000}' --apply-to queues
rabbitmqctl set_policy expiry -p /frontend-A ".*" '{"expires":60000}' --apply-to queues
rabbitmqctl set_policy expiry -p /frontend-B ".*" '{"expires":60000}' --apply-to queues

rabbitmqctl set_topic_permissions frontend -p /frontend-A amq.topic "" "^msg.frontend.*"
rabbitmqctl set_topic_permissions frontend -p /frontend-B amq.topic "" "^msg.frontend.*"

This example uses the STOMP.js library Copyright 2010-2013 Jeff Mesnil, Copyright 2012 FuseSource, Inc., Copyright 2017 Deepak Kumar. Currently maintained at https://github.com/stomp-js/stomp-websocket.