重庆分公司,新征程启航
为企业提供网站建设、域名注册、服务器等服务
redis中怎么实现发布订阅,针对这个问题,这篇文章详细介绍了相对应的分析和解答,希望可以帮助更多想解决这个问题的小伙伴找到更简单易行的方法。
创新互联于2013年成立,先为萨尔图等服务建站,萨尔图等地企业,进行企业商务咨询服务。为萨尔图企业网站制作PC+手机+微官网三网同步一站式服务解决您的所有建站问题。
1、开启五个redis客户端,其中两个主节点,三个从节点
主节点2 订阅configserver频道
主节点3 订阅configserver频道
127.0.0.1:6379> subscribe configserver
Reading messages... (press Ctrl-C to quit)
1) "subscribe"
2) "configserver"
3) (integer) 1
从节点1 订阅configserver频道
从节点2 订阅configserver频道
从节点3 订阅configserver频道
127.0.0.1:6379> subscribe configserver
Reading messages... (press Ctrl-C to quit)
1) "subscribe"
2) "configserver"
3) (integer) 1
2、主节点一发送消息,测试其他节点能否收到订阅
主节点发布 "test subscribe"消息
127.0.0.1:6379> publish configserver "test subscribe"
(integer) 2
主节点2 主节点3 打印
1) "message"
2) "configserver"
3) "test subscribe"
正常接收到消息
从节点1 从节点2 从节点3 打印
1) "message"
2) "configserver"
3) "test subscribe"
正常接收到消息
说明主从同步也一样可以支持发布订阅的功能。具体性能还需进一步测试。
1、创建100个线程,订阅test2
public class RedisSubScribeTask implements Runnable { private String Name; public RedisSubScribeTask(String name) { Name = name; } @Override public void run() { RedisDaoImpl redis = new RedisDaoImpl(); redis.init(); Jedis jedis = redis.pool.getResource(); if (jedis != null) { RedisMsgSubListener redisMsgSubListener = new RedisMsgSubListener(); System.out.println("线程" + Name + "启动"); jedis.subscribe(redisMsgSubListener, "test2"); } } } public static void main(String[] args) { for (int i = 0; i <= 100; i++) { RedisSubScribeTask redisSubScribeTask = new RedisSubScribeTask(String.valueOf(i)); new Thread(redisSubScribeTask).start(); } }
public class RedisMsgSubListener extends JedisPubSub { public void onMessage(String channel, String message) { System.out.println(channel + " is:" + message); } public void onPMessage(String pattern, String channel, String message) { } public void onSubscribe(String channel, int subscribedChannels) { } public void onUnsubscribe(String channel, int subscribedChannels) { } public void onPUnsubscribe(String pattern, int subscribedChannels) { } }
2、定义main方法,发布消息
public static void main(String[] args) { RedisDaoImpl redis = new RedisDaoImpl(); redis.init(); redis.pool.getResource().publish("test2", "test"); }
3、测试结果为秒回
4、将线程改为300个,测试结果也为秒回
5、将连件数升为500,依旧没有延迟
info clients # Clients connected_clients:500 client_longest_output_list:0 client_biggest_input_buf:0 blocked_clients:0 127.0.0.1:6379> |
6、连接数升为1000,其余两个为主从同步。看是否存在延迟
info clients # Clients connected_clients:1002 client_longest_output_list:0 client_biggest_input_buf:0 blocked_clients:0 |
7、发现依旧没有延迟。并且主从同步的订阅test2的消息,也正常接受。
127.0.0.1:6379> subscribe test2
Reading messages... (press Ctrl-C to quit)
1) "subscribe"
2) "test2"
3) (integer) 1
1) "message"
2) "test2"
3) "test"
1) "message"
2) "test2"
3) "test"
8、针对1000个客户端,并且进行连续发布100个消息
for (int i = 0; i <= 100; i++) { redis.pool.getResource().publish("test2", "test" + i); // try { // Thread.sleep(1000); // } catch (InterruptedException e) { // e.printStackTrace(); // } } |
关于redis中怎么实现发布订阅问题的解答就分享到这里了,希望以上内容可以对大家有一定的帮助,如果你还有很多疑惑没有解开,可以关注创新互联行业资讯频道了解更多相关知识。