MQ消息队列
Jboot 内置整个了MQ消息队列,使用MQ非常简单
第一步:配置jboot.properties文件,内容如下:
#默认为redis (支持: redis,activemq,rabbitmq,hornetq,aliyunmq等 )
jboot.mq.type = redis
jboot.mq.redis.host = 127.0.0.1
jboot.mq.redis.password =
jboot.mq.redis.database =
第二步:在服务器A中添加一个MQ消息监听器
Jboot.me().getMq().addMessageListener(new JbootmqMessageListener(){
@Override
public void onMessage(String channel, Object obj) {
System.out.println(obj);
}
}, channel);
第三步:服务器B发送一个消息
Jboot.me().getMq().publish(yourObject, toChannel);