MQ 消息队列

Jboot 内置了对MQ消息队列的功能支持,使用MQ需要以下几步步骤。

第一步:配置jboot.properties文件,内容如下:

  1. # 默认为redis (支持: redis,activemq,rabbitmq,hornetq,aliyunmq等 )
  2. jboot.mq.type = redis
  3. jboot.mq.channel = channel1,channel2,channel3
  4. jboot.mq.redis.host = 127.0.0.1
  5. jboot.mq.redis.password =
  6. jboot.mq.redis.database =

第二步:在服务器A中添加一个MQ消息监听器,用于监听 channel1 的消息

  1. Jboot.getMq().addMessageListener(new JbootmqMessageListener(){
  2. @Override
  3. public void onMessage(String channel, Object obj) {
  4. System.out.println(obj);
  5. }
  6. }, "channel1");

第三步:开始监听

  1. Jboot.getMq().startListening();

配置完毕后,我们在其他服务器,就可以通过如下代码发送消息:

  1. Jboot.getMq().publish(yourObject, "channel1");

需要注意的是,两个服务器的 mq 类型、和服务器信息一定是一致的。消息的接收端的 jboot.mq.channel 配置必须包含 “channel1” 才能正常接收数据 。

其他更多关于 rabbitmq、aliyunmq、qpidmq 等的配置,需要查看 这里