【笔记】Redis订阅、发布

测试代码

public class RedisMsgPubSubListener extends JedisPubSub {/** * 接收消息* * @Date : 2018/09/06 09:37*/@Overridepublic void onMessage(String channel, String message) {System.out.println("channel:" + channel + "receives message :" + message);super.unsubscribe(channel);}}

public class TestSubPub {/** * @Date : 2018/09/06 09:41*/public static void main(String[] args) throws Exception {testSubscribe();//testPublish();}/*** 订阅测试** @Date : 2018/09/06 09:43*/@SuppressWarnings("resource")public static void testSubscribe() throws Exception{Jedis jedis = new Jedis("localhost");RedisMsgPubSubListener listener = new RedisMsgPubSubListener();jedis.subscribe(listener, "redisMsg");}/*** 发布消息测试* * @Date : 2018/09/06 09:44*/@SuppressWarnings("resource")public static void testPublish() throws Exception{Jedis jedis = new Jedis("localhost");jedis.publish("redisMsg", "666");}}

本文来自互联网用户投稿，文章观点仅代表作者本人，不代表本站立场，不承担相关法律责任。如若转载，请注明出处。 如若内容造成侵权/违法违规/事实不符，请点击【内容举报】进行投诉反馈！