2020-03-30 05:17:19 登录注册 RSS

当前位置: 公理网 >> 投诉不良 >> redis的发布订阅和利用Jedis简单演示

redis的发布订阅和利用Jedis简单演示
发布时间:02-18| 来源:公理网 | 点击发表评论

客户端1,先订阅。(和微信公众号一样,订阅了以后,才能收到消息)


redis127.0.0.1:6379subscribemy7003
Readingmessages...(pressCtrl-Ctoquit)


客户端2,发布消息


发布消息

publishchannel消息内容


redis127.0.0.1:6379publishmy7003"大家好"
(integer)1
redis127.0.0.1:6379publishmy7003hello
(integer)1


这边发完消息,订阅方(客户端1)就收到消息了


redis127.0.0.1:6379subscribemy7003
Readingmessages...(pressCtrl-Ctoquit)
1)"subscribe"
2)"my7003"
3)(integer)1
1)"message"
2)"my7003"
3)"\xe5\xa4\xa7\xe5\xae\xb6\xe5\xa5\xbd"
1)"message"
2)"my7003"
3)"hello"


同一网段下,登陆别的发布消息的服务器的时候,客户端需要登陆的时候,需要指定ip,不要登陆到自己本机的服务器了。

./redis-cli-hip地址-p端口号默认6379

Java利用jedis操作redis

目前大多使用SpringDataRedis操作redis,spring家族啥都有,整合方便。Jedis算是过时了。


导入依赖


dependencies
!--https://mvnrepository.com/artifact/redis.clients/jedis--
dependency
groupIdredis.clients/groupId
artifactIdjedis/artifactId
version3.0.1/version
/dependency
/dependencies


订阅消息


importredis.clients.jedis.Jedis;
importredis.clients.jedis.JedisPubSub;
publicclassDemosubextendsJedisPubSub{

publicvoidonMessage(Stringchannel,Stringmessage){
System.out.println("频道是:"+channel+",消息是:"+message);
publicstaticvoidmain(String[]args){
System.out.println("开始启动订阅者");
Jedisjedis=newJedis("192.168.111.140",6379);
//订阅消息,new自己,Demosub
jedis.subscribe(newDemosub(),"cctv5");

授予每个自然月内发布4篇或4篇以上原创或翻译IT博文的用户。不积跬步无以至千里,不积小流无以成江海,程序人生的精彩需要坚持不懈地积累!

授予每个自然周发布7篇到8篇原创IT博文的用户。本勋章将于次周周三上午根据用户上周的博文发布情况由系统自动颁发。

最新新闻

手机浏览

公理网 版权所有

公理网 Total 0.035079(s) query 6, 报料QQ:点击这里

给我发消息