springBoot整合RocketMQ及坑的示例代码

springBoot整合整合RocketMQ及坑的示例代码及坑的示例代码

主要介绍了springBoot整合RocketMQ及坑的示例代码，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧

版本：

JDK:1.8

springBoot:1.5.10

rocketMQ：4.2.0

pom 配置：

<parent>

<artifactId>rocketmq-client</artifactId>

<version>4.2.0</version>

</dependency>

application.properties 配置:

# 消费者的组名

apache.rocketmq.consumer.PushConsumer=PushConsumer

# 生产者的组名

apache.rocketmq.producer.producerGroup=Producer

# NameServer地址

apache.rocketmq.namesrvAddr=localhost:9876

import org.apache.rocketmq.remoting.common.RemotingHelper;

import org.springframework.beans.factory.annotation.Value;

import org.springframework.stereotype.Component;

import org.springframework.util.StopWatch;

import javax.annotation.PostConstruct;

@Component

public class RocketMQClient {

/**

* 生产者的组名

*/

private String namesrvAddr;

@PostConstruct

public void defaultMQProducer() {

//生产者的组名

DefaultMQProducer producer = new DefaultMQProducer(producerGroup);

//指定NameServer地址，多个地址以 ; 隔开

producer.setNamesrvAddr(namesrvAddr);

producer.setVipChannelEnabled(false);

try {

/**

Message message = new Message("TopicTest", "push", "发送消息----zhisheng-----".getBytes(RemotingHelper.DEFAULT_CHARSET));

StopWatch stop = new StopWatch();

stop.start();

for (int i = 0; i < 1; i++) {

SendResult result = producer.send(message);

System.out.println("发送响应：MsgId:" + result.getMsgId() + "，发送状态:" + result.getSendStatus());

}

stop.stop();

System.out.println("----------------发送一万条消息耗时：" + stop.getTotalTimeMillis());

} catch (Exception e) {

消费者：

import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer;