Simple sockjs server for django.
- sockjs-tornado >= 1.0.0
- pika >= 0.9.12
- django >= 1.4
- redis >= 2.9.1
pip install django-sockjs-server
Add django-sockjs-server to your INSTALLED_APPS in settings.py
INSTALLED_APPS = (
...
'django_sockjs_server',
...
)
Define DJANGO_SOCKJS_SERVER in settings.py.
DJANGO_SOCKJS_SERVER = {
'rabbitmq_server_host': 'localhost',
'rabbitmq_user': 'guest',
'rabbitmq_password': 'guest',
'rabbitmq_server_port': 5672,
'rabbitmq_server_vhost': '/',
'rabbitmq_exchange_name': 'sockjs',
'rabbitmq_queue_name': 'ws01',
'rabbitmq_exchange_type': 'direct',
'redis_host': 'localhost',
'redis_port': '6379',
'redis_db': 0,
'listen_addr': '0.0.0.0',
'listen_port': 8083,
'listen_location': '/ws'
'secret_key': 'xe4pa7gysp4phe2rhyd',
'sockjs_url': ['http://localhost:8083/ws']
}
- rabbitmq_server_host - rabbitmq server
- rabbitmq_user - rabbitmq user
- rabbitmq_password - rabbitmq password
- rabbitmq_server_port - rabbitmq port
- rabbitmq_server_vhost - rabbitmq vhost
- rabbitmq_exchange_name - exchange name
- rabbitmq_exchange_type - type exchange
- listen_addr - listen sockjs server address
- listen_port - listen sockjs server port
- listen_location - listen sockjs server location
- secret_key - salt for subscribe
- sockjs_url - path for client sockjs
- redis_host - redis server host
- redis_port - redis server port
- redis_db - redis db
Run sockjs-server
./manage.py sockjs_server
Append sockjs client library to your page
<head>
<script src="http://cdn.sockjs.org/sockjs-0.3.min.js">
...
Open page in browser and connect to sockjs-tornado server
{% load sockjs_server_tags %}
window.sockjs_action_pull = new Array();
var new_conn = function() {
window.connection_sockjs = new SockJS('{% sockjs_server_url %}');
window.connection_sockjs.onmessage = function(e) {
document.write(e.data);
document.write("<br/ >");
};
connection_sockjs.onclose = function(e) {
setTimeout(function() { new_conn(); }, 5000);
};
connection_sockjs.onopen = function(e) {
};
};
new_conn();
To get this messages you need to subscribe by token
SockJS.prototype.emit = function (token, data) {
var meta_dict = {
token:token,
data:data
};
this.send(JSON.stringify(meta_dict))
};
connection_sockjs.addEventListener("open", function() {
connection_sockjs.emit('{% sockjs_auth_token 'user' %}', {'channel': 'user'});
}
);
or
connection_sockjs.addEventListener("open", function() {
connection_sockjs.emit('{% sockjs_auth_token 'user' '1' %}', {'channel': 'user'+ '1'});
}
);
Send a message from django
client = SockJsServerClient()
test_message = dict()
room = 'user'
data = dict()
data['user_name'] = "Sergey Kravchuk"
data['user_id'] = 1
connections = client.get_connections(room)
for conn in connections:
conn_id = conn.get('id')
host = conn.get('host')
if conn_id and host:
message = {
'uid': conn_id,
'host': host,
'data': data,
'room': room
}
client.publish_message(message)
Get websocket stats
curl http://localhost:8083/stats/
uptime_seconds: 5
memory_use_byte: 0
memory_resident_use_byte: 0
memory_stack_size_byte: 0
last_rabbitmq_reconnect: 2013-09-26 13:04:16.302877+00:00
connect_rabbitmq_time_seconds: 5
connects: 0
channel_count: 0
http://localhost:8083/stats/debug
uptime_seconds: 5
memory_use_byte: 0
memory_resident_use_byte: 0
memory_stack_size_byte: 0
last_rabbitmq_reconnect: 2013-09-26 13:04:16.302877+00:00
connect_rabbitmq_time_seconds: 5
connects: 0
channel_count: 0
channels: [u'user']