821 Unstar Star 2.6K Fork 815

GVPJbootProjects / jboot

Create your Gitee Account
Explore and code with more than 5 million developers,Free private repositories !:)
Sign up
Clone or download
mq.md 1.20 KB
Copy Edit Web IDE Raw Blame History
fuhai authored 2019-10-06 17:24 . v2.2.2 release (^.^)YYa!!

MQ 消息队列

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 等的配置,需要查看 这里

Comment ( 2 )

Sign in for post a comment

Java
1
https://git.oschina.net/JbootProjects/jboot.git
git@git.oschina.net:JbootProjects/jboot.git
JbootProjects
jboot
jboot
master

Search

132457 8cb2edc1 1899542 131848 70c8d3a4 1899542