Advertisement
Guest User

Untitled

a guest
Mar 27th, 2017
49
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 1.06 KB | None | 0 0
  1. var fs = require('fs');
  2. var express = require("express");
  3. var Server = require("http").Server;
  4. var session = require("express-session");
  5. var RedisStore = require("connect-redis")(session);
  6. var app = express();
  7. var server = Server(app);
  8. var sio = require("socket.io")(server);
  9. var Redis = require('ioredis');
  10. var ioredis = new Redis({
  11. port: 6379, // Redis port
  12. host: '127.0.0.1', // Redis host
  13. family: 4, // 4 (IPv4) or 6 (IPv6)
  14. });
  15. var sessionMiddleware = session({
  16. store: new RedisStore({
  17. client: ioredis
  18. }),
  19. secret: 'blahblah'
  20. });
  21. app.use(sessionMiddleware);
  22. sio.sockets.on("connection", function(socket) {});
  23. var sioredis = new Redis({
  24. port: 6379, // Redis port
  25. host: '127.0.0.1', // Redis host
  26. family: 4, // 4 (IPv4) or 6 (IPv6),
  27. });
  28. sioredis.subscribe('mychannel', function (err, count) { });
  29. sioredis.on('message', function (channel, message) {
  30. //How to get session information here?
  31. if(message === session.variable) {
  32. sio.sockets.emit();
  33. }
  34. });
  35. server.listen(8080);
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement