当前位置: 软件>java软件
消息队列服务 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 identif...
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();
您可能感兴趣的文章:
本站(WWW.)旨在分享和传播互联网科技相关的资讯和技术，将尽最大努力为读者提供更好的信息聚合和浏览方式。
本站(WWW.)站内文章除注明原创外，均为转载、整理或搜集自网络。欢迎任何形式的转载，转载请注明出处。
本站(WWW.)站内文章除注明原创外，均为转载、整理或搜集自网络。欢迎任何形式的转载，转载请注明出处。