rmq 介绍
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();
rmq 官网
https://github.com/xetorthio/rmq
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。