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();評論
圖片
表情
