rmq消息队列服务

联合创作 · 2023-10-01 03:32

rmq 是一个基于 Redis 的消息队列服务,体积小而且易用,客户端基于 Jedis

示例代码:

Producer p = new Producer(new Jedis("localhost"),"some cool topic");
p.publish("some cool message");

Consumer c = new Consumer(new Jedis("localhost"),"consumer identifier","some cool topic");
c.consume(new Callback() {
    public void onMessage(String message) {
        //do something here with the message
    }
});

Consumer c = new Consumer(new Jedis("localhost"),"consumer identifier","some cool topic");
String message = c.consume();

String message = c.read();
浏览 6
点赞
评论
收藏
分享

手机扫一扫分享

编辑 分享
举报
评论
图片
表情
推荐
点赞
评论
收藏
分享

手机扫一扫分享

编辑 分享
举报