对于页面上定时刷新显示的数据,之前一直都是比较“传统”的思想——那就是“页面通过ajax请求后台,后台响应后把数据返回给前台展示,如此反复……”,而自己也从来没有过“服务端主动向页面推送数据”的概念。
现在需要用到redis的发布/订阅,页面“订阅”某一channel,服务端在某一channel“发布”内容。服务端发布后,客户端可以通过订阅实时将刚刚发布的内容展示出来。
说说我探索的解决过程吧。。从用tomcat的WebSocketServlet,但发现已经不推荐使用(废弃)了,加上它必须依赖tomcat,并且前台订阅的逻辑也难以表达,所以不行;后来又想到用javax.websocket-api.jar的@ServerEndpoint,但是,还是卡住了。。因为也是难以体现redis的发布/订阅功能。
后来一直苦于用何种解决方案,这时,socket.io+redis+node.js实时聊天的例子让我眼前一亮。。
好了,说说我对nodejs的理解——Node是一个Javascript运行环境(runtime),就是Js的服务器,类似tomcat或weblogic是java代码的运行服务器一样。。安装nodejs之后,最新版已经带了npm,而npm是用于安装各种支持nodejs扩展的客户端的。比如你想要用到redis,就必须安装redis的nodejs客户端。把nodejs配好环境变量后,使用如下命令即可安装redis:
npm install redis
安装好后,它默认是在C:\Users\xxx\node_modules多一个redis的文件夹的,但如果你安装的nodejs不在C盘,最好是把刚刚安装的module拷贝至你安装包下的node_modules目录下。安装好后,就可以在Js中使用require('redis')了。
socket.io连接于browser和nodejs的http服务器之间,可用于二者之间同步数据。同样,它也需要通过npm命令安装。
解决过程如下:
编写pubsub.js作为前台页面订阅某一渠道的服务端(便与测试,我这里是把渠道写死的: var c = 'testchannel';):
var server = require('http').createServer(function (request, response) { response.writeHead(200, {'Content-Type': 'text/plain'}); response.end('Hello World\n'); }).listen(1379); var redis = require('redis'); var redisclient = redis.createClient(); var sub = function(c) { var c = 'testchannel'; redisclient.subscribe(c, function(e) { console.log('subscribe channel : ' + c); }); } sub(); console.log('Server running at http://127.0.0.1:1379/'); var io = require('socket.io')(server); io.on('connection', function(socket) { redisclient.on('message', function(error, msg) { console.log('connection'); console.log(msg); socket.emit('msgReceived', msg); }); })
然后,定义用来显示订阅消息的前台页面:
<html> <head> <script src="F:\nodejs\node_modules\socket.io\node_modules\socket.io-client\socket.io.js"></script> <script src="jquery-1.7.2.min.js"></script> </head> <body> <div style="width:100px; height:200px; border:1px solid red" id="show"></div> </script>hello world <script type="text/javascript"> var div = $("#show"); console.log("hello"); var socket = io('http://localhost:1379'); socket.on('connection', function() { console.log('connection setup for socket.io') }); socket.on('msgReceived', function(msg) { //alert(div.html()); div.append(msg + "<br/>"); //alert(msg); }) </script> </body> </html>
页面中var socket = io('http://localhost:1379');一行是关键,它和pubsub.js中 listen(1379)里对应。表明位于本地的Nodejs服务器的1379端口,在pubsub.js里listen(1379)被监听了。
用任一浏览器(我这里是谷歌的),打开刚定义的前台页面。
页面此时没内容,因为还未开启pubsub.js发起订阅请求。
OK,我们开始运行pubsub.js发起请求
接下来要用redis发布请求咯:
打开redis服务:
再打开一客户端,向testchannel发布消息:
运行pubsub.js: node pubsub.js
可以看到:
开启一redis客户端,可看到订阅内容:
重点来了,页面也可显示订阅的内容:
同理,你在java中写发布到渠道testchannel的的代码,前台页面一样可以显示。
而你开启另外一个浏览器(比如搜狗),也是可以看到实时订阅的消息的:
这说明,已经做到了redis主动向页面push数据,实时推送的效果。
总结:nodejs作为页面订阅的pubsub.js的运行服务端,socket.io则是类似websocket的功能,实现nodejs和浏览器之间交流的桥梁,是redis向页面推送数据的关键。另外注意nodejs用到redis和socket.io这2个module,必须要先用npm命令安装扩展。注意redis发布订阅思想在实时推送中的模型——前台页面订阅某一渠道的消息,而发布的话则是由redis来发布的。
相关推荐
主要介绍了Redis数据导入导出以及数据迁移的4种方法详解,需要的朋友可以参考下
redis增删改数据 redis增删改数据 redis增删改数据redis增删改数据 redis增删改数据
redis页面缓存html使用redis实现页面缓存.docx
1、新旧redis集群迁移 2、支持redis集群的存量和增量数据迁移 3、支持redis集群数据的离线迁移
Redis可以用于存储缓存数据,让项目更加快捷,可视化工具能清晰查看数据!
数据结构 数据结构Redis中数据类型对应的数据结构 中数据类型对应的数据结构 Redis Redis 是⼀种键值(Key-Value)数据库。相对于关系型数据库(⽐如 MySQL),Redis 也被叫作⾮关系型数据库。 像 MySQL 这样的关系...
例如: ./redis_to_json.py | gzip > redis_backup.json.gz这对于您正在使用但又不想丢失数据的应用程序也很不错,因为Redis RDB文件并不总是那么方便。注意事项和注意事项u()中的Unicode支持仅适用于Python2.x。...
Redis实战_Redis实战中文完整版,适合新手入门学习。本文档章节全面,不会有遗落章节。主要包括Redis快速入门、Redis数据类型及操作、Redis常用
主要介绍了Java 实现Redis存储复杂json格式数据并返回给前端操作,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧
最近有个哥们在群里问,有一个日志,里面存的是IP地址(一行一个),如何将这些IP快速导入到Redis中。 我刚开始的建议是Shell+redis客户端。 今天,查看Redis官档,发现文档的首页部分...
redis底层数据模型与数据结构,讲解redis的底层模型,以及数据存储格式
Redis是一个开源的使用ANSI C语言编写、支持网络、可基于内存亦可持久化的日志型、Key-Value数据库,并提供多种语言的API。从2010年3月15日起,Redis的开发工作由VMware主持。从2013年5月开始,Redis的开发由Pivotal...
3.Redis数据类型之List类型
RedisClient将redis数据以资源管理器的界面风格呈现给用户,可以帮助redis开发人员和维护人员方便的建立,修改,删除,查询redis数据,完全不需要了解redis命令。可以让用户方便的编辑数据,可以剪切,拷贝,粘贴...
Redis学习手册 Hash数据类型 doc Redis学习手册 Key操作命令 doc Redis学习手册 List数据类型 doc Redis学习手册 Set数据类型 doc Redis学习手册 Sorted Sets数据类型 doc Redis学习手册 String数据类型 doc Redis...
文件中 1、outputFs.js为读写数据自定义库。 2、outputRedis.js为保存值的方法。 3、outputRedisWithKey.js为保存键值对的方法。
hot-redis:为 Redis 提供 Python 丰富的数据类型
redis存储二进制数据测试代码
c++ 操作redis数据库
java实现对Redis数据的导入和导出,可以实现从这个服务器copy到另一台Redis服务器上。