MQ 消息队列

优质

小牛编辑

188浏览

2023-12-01

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

Rabbitmq

#设置 mq 的相关信息
jboot.mq.type=rabbitmq
jboot.mq.channel=channel1


#以下可以不用配置，是默认信息
jboot.mq.rabbitmq.username=guest
jboot.mq.rabbitmq.password=guest
jboot.mq.rabbitmq.host=127.0.0.1
jboot.mq.rabbitmq.port=5672
jboot.mq.rabbitmq.virtualHost=

#非常重要，多个应用如果同时接受同一个 channel 的广播，必须配置此项，而且必须不能相同，否则广播的时候只有一个应用能够接受到
jboot.mq.rabbitmq.broadcastChannelPrefix=app1

Redis-mq

jboot.mq.type=redis
jboot.mq.channel=channel1,channel2,myChannel
jboot.mq.redis.host=127.0.0.1
jboot.mq.redis.port=6379
jboot.mq.redis.timeout=2000
jboot.mq.redis.password
jboot.mq.redis.database
jboot.mq.redis.clientName
jboot.mq.redis.testOnCreate
jboot.mq.redis.testOnBorrow
jboot.mq.redis.testOnReturn
jboot.mq.redis.testWhileIdle
jboot.mq.redis.minEvictableIdleTimeMillis
jboot.mq.redis.timeBetweenEvictionRunsMillis
jboot.mq.redis.numTestsPerEvictionRun
jboot.mq.redis.maxAttempts
jboot.mq.redis.maxTotal
jboot.mq.redis.maxIdle
jboot.mq.redis.minIdle
jboot.mq.redis.maxWaitMillis

Rocketmq

jboot.mq.type=rocketmq
jboot.mq.channel=channel1,channel2,myChannel
jboot.mq.rocket.namesrvAddr=127.0.0.1:9876
jboot.mq.rocket.namespace
jboot.mq.rocket.consumerGroup = "jboot_default_consumer_group";
jboot.mq.rocket.consumeMessageBatchMaxSize
jboot.mq.rocket.broadcastChannelPrefix "broadcast-";
jboot.mq.rocket.producerGroup "jboot_default_producer_group";