一、引入场景启动器

 <dependency><groupId>org.apache.rocketmq</groupId><artifactId>rocketmq-spring-boot-starter</artifactId><version>2.2.3</version></dependency>或者<dependency><groupId>org.apache.rocketmq</groupId><artifactId>rocketmq-spring-boot-starter</artifactId><version>2.3.0</version></dependency>

 2、添加相关配置

rocketmq:name-server: ${ROCKETMQ_NAME_SERVER:192.168.0.24:30094}producer:group: ${ROCKETMQ_PRODUCER_GROUP:product_group}send-message-timeout: ${ROCKETMQ_SEND_MESSAGE_TIMEOUT:30000}max-message-size: ${ROCKETMQ_MAX_MESSAGE_SIZE:8388608}

 3、添加监听

package jnpf.qualifications.consummer;import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer;
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener;
import org.apache.rocketmq.spring.core.RocketMQPushConsumerLifecycleListener;
import org.springframework.stereotype.Component;@Component
@RocketMQMessageListener(topic = "permission-topic", consumerGroup = "consumer_group", replyTimeout = 600000)
@Slf4j
public class TestMQListener implements RocketMQListener<String>, RocketMQPushConsumerLifecycleListener {@Overridepublic void onMessage(String message) {log.error("原始数据入库消费消息为空，过期或者被清除，任务Id为:{}", message);}@Overridepublic void prepareStart(DefaultMQPushConsumer consumer) {// 重试次数consumer.setMaxReconsumeTimes(10);}}

 

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/918576.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！