Springboot2整合RocketMQ消费端

        <dependency>
            <groupId>org.apache.rocketmq</groupId>
            <artifactId>rocketmq-spring-boot-starter</artifactId>
            <version>2.0.4</version>
        </dependency>

rocketmq:
  name-server: 127.0.0.1:9876
  producer:
    group: base_group_syncMsg
    send-message-timeout: 5000
    retry-times-when-send-failed: 2
    max-message-size: 4194304

/**
 * @Author: Liu Yue
 * @Descripition: 排序消费
 * @Date; Create in 2020/11/22 19:30
 **/
@Component
@RocketMQMessageListener(topic = "base_topic", selectorExpression = "base_tags", consumerGroup = "base_group",consumeMode = ConsumeMode.ORDERLY)
@Slf4j
public class Consumer implements RocketMQListener<String> {

    @Override
    public void onMessage(String msg) {
        log.info("读取消息：{}",msg);

    }

}