MQ消息队列

Jboot 内置整个了MQ消息队列,使用MQ非常简单

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

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

第二步:在服务器A中添加一个MQ消息监听器

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

第三步:服务器B发送一个消息

  1. Jboot.me().getMq().publish(yourObject, toChannel);

注意:服务器A和服务器B在jboot.properties上应配置相同的内容。

RedisMQ

ActiveMQ