Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- var server = require ('http').Server();
- var io = require ('socket.io')(server);
- var Redis = require ('ioredis');
- var redis = new Redis();
- redis.subscribe('chat');
- redis.on('message', (channel, message) => {
- message = JSON.parse(message);
- // channel:event:to_id:to_type - message.data
- io.emit(channel + ':' + message.event + ':' + message.to_id + ':' + message.to_type, message.data);
- console.log(message +' '+ channel);
- });
- server.listen('6001');
- var io = require('socket.io-client')
- var socket = io.connect('http://localhost:6001', {reconnect: true});
- ...
- mounted() {
- console.log('check 1', socket.connected);
- socket.on('connect', function() {
- console.log('check 2', socket.connected);
- });
- socket.on('chat:newMessage:'+this.fromid+':'+this.fromtype, (data) => {
- console.log('new message');
- var message = {
- 'msg': data.message,
- 'type': 'received',
- 'color': 'green',
- 'pos': 'justify-content-start',
- }
- this.messages.push(message);
- });
- }
- upstream node1 {
- server 127.0.0.1:6001;
- }
- server {
- listen 80;
- server_name localhost;
- location / {
- #Configure proxy to pass data to upstream node1
- proxy_pass http://node1/socket.io/;
- #HTTP version 1.1 is needed for sockets
- proxy_http_version 1.1;
- proxy_set_header Upgrade $http_upgrade;
- proxy_set_header Connection "upgrade";
- }
- }
Add Comment
Please, Sign In to add comment