代码拉取完成,页面将自动刷新
同步操作将从 JbootProjects/jboot 强制同步,此操作会覆盖自 Fork 仓库以来所做的任何修改,且无法恢复!!!
确定后同步将在后台操作,完成时将刷新页面,请耐心等待。
Jboot 内置了对MQ消息队列的功能支持,使用MQ需要以下几步步骤。
第一步:配置jboot.properties文件,内容如下:
# 默认为redis (支持: redis,activemq,rabbitmq,hornetq,aliyunmq等 )
jboot.mq.type = redis
jboot.mq.channel = channel1,channel2,channel3
jboot.mq.redis.host = 127.0.0.1
jboot.mq.redis.password =
jboot.mq.redis.database =
第二步:在服务器A中添加一个MQ消息监听器,用于监听 channel1 的消息
Jboot.getMq().addMessageListener(new JbootmqMessageListener(){
@Override
public void onMessage(String channel, Object obj) {
System.out.println(obj);
}
}, "channel1");
第三步:开始监听
Jboot.getMq().startListening();
配置完毕后,我们在其他服务器,就可以通过如下代码发送消息:
Jboot.getMq().publish(yourObject, "channel1");
需要注意的是,两个服务器的 mq 类型、和服务器信息一定是一致的。消息的接收端的 jboot.mq.channel
配置必须包含 "channel1" 才能正常接收数据 。
其他更多关于 rabbitmq、aliyunmq、qpidmq 等的配置,需要查看 这里。
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。