Socket.IO 订阅 Redis Channel_html/css_WEB-ITnose-html教程-PHP中文网

Socket.IO 订阅 Redis Channel_html/css_WEB-ITnose

php中文网

发布： 2016-06-24 11:21:47

原创

1471人浏览过

在node.js程序中，可以借助 socket.io来构建实时应用。然而有时候后台与socket.io是异构的，比如java、python的web后台。这时可以利用 redis的订阅/发布机制作为中转，连接异构的后台和socket.io服务。本文介绍如何在socket.io中订阅redis channel。

小绿鲸英文文献阅读器

英文文献阅读器，专注提高SCI阅读效率

199

查看详情

至于如何在Java/Python/C#中发布消息到Redis Channel，请参照对应语言的Redis SDK。

安装软件

Redis。可以参照官网 http://redis.io/来安装，在这里可以下载。
Node.js。也可以在官网 https://nodejs.org/直接下载。

然后创建一个文件夹作为Socket.IO服务器项目，在其中安装 Socket.IO和Node.js的 redis客户端。

npm install Socket.IO redis --save

登录后复制

简单的Socket.IO服务

创建 app.js文件，写一个基于Node.js HTTP模块的Socket.IO服务器。我们创建两个命名空间，一个 notification，一个 chatting。

立即学习“前端免费学习笔记（深入）”；

var server = require('http').createServer();var io = require('Socket.IO')(server);io    .of('/notification')    .on('connection', socket => {        console.log('user connected to notification');        socket.on('disconnect', () => console.log('user disconnected'));    });io    .of('/chatting')    .on('connection', socket => console.log('user connected to message'));server.listen(3001, () => console.log('Socket.IO listen to port 3001'));

登录后复制

不同的浏览器端可以连接到不同的命名空间，例如连接到 notificaiton：

var socket = io('/notification');socket.on('message', function (msg) {    console.log(msg);});

登录后复制

需要在HTML中引入，见 http://Socket.IO/download/。更多Socket.IO的例子，请参考： http://Socket.IO/docs/#how-to-use

订阅Redis Channel

在上述服务器文件中引入 redis并创建一个客户端，可以收到所有频道的信息。可以通过 switch-case来分发各频道的消息。

var redis = require('redis');var redisClient = redis.createClient();var NOTIFICATION_CHANNEL = 'notification_channel', CHATTING_CHANNEL = 'chatting_channel';redisClient.on('message', function(channel, message) {    switch (channle){        case NOTIFICATION_CHANNEL:            console.log('notification received:', message);            io.of('/notification').emit('message', message);            break;        case CHATTING_CHANNEL:            console.log('chatting received:', message);            io.of('/chatting').emit('message', message);            break;    }});redisClient.subscribe(NOTIFICATION_CHANNEL);redisClient.subscribe(CHATTING_CHANNEL);

登录后复制

在 redis.createClient()的参数中可以设置Redis服务器的主机名、端口、密码等信息，参见对应的文档。

测试执行

启动Socket.IO服务器：

$ node app.jsSocket.IO listen to port 3001

登录后复制

在命令行（Bash、Zsh…）中打开 redis-cli，并发布一条消息：

$ redis-cli127.0.0.1:6379> publish notification "fuck you!"

登录后复制

然后Socket.IO便会输出 notification received: fuck you!，同时所有连接到 /message命名空间的浏览器端也会收到消息并输出到控制台。

大家都在看：

Mailchimp订阅者标签动态分配：基于表单下拉选择的实现教程针对大型表格的下拉切换器：屏幕阅读器用户的可访问性指南使用下拉选择器切换大型表格时的屏幕阅读器可访问性使用下拉选择器切换大型表格时屏幕阅读器的可访问性大表格内容切换的无障碍设计：下拉菜单与屏幕阅读器优化