Springboot使用rocketmq-spring-boot-starter集成阿里云ONS（RocketMQ）

最近在抽离专用工具模块，发现一个问题，就是使用阿里云的队列产品ONS，也就是rocketmq,因为ons-client有臭名昭著的fastjson依赖，且最新版的ons-clinet还用着老版本的fastjson,有一两个漏洞，为了安全起见，就用apache官方的组件rocketmq-spring-boot-starter依赖，这里记录一下。

一、准备依赖

使用最新依赖，没有漏洞的：

<!-- https://mvnrepository.com/artifact/org.apache.rocketmq/rocketmq-spring-boot-starter -->
<dependency>
    <groupId>org.apache.rocketmq</groupId>
    <artifactId>rocketmq-spring-boot-starter</artifactId>
    <version>2.2.3</version>
</dependency>

二、编写配置文件

这里编写配置文件有个很大的坑，一不留神就G了：

server:
  port: 10222
rocketmq:
  name-server: MQ_INST_111111111111111_AAAAAAA.mq-internet-access.mq-internet.aliyuncs.com:80
  producer:
    group: MQ_INST_111111111111111_AAAAAAA%GID_ffffff_local_test
    access-key: aaaaaaaAAAAAAAAAAAAAAAA
    secret-key: AAAAAAAAAAAAAAaaaaaaaaaaaaaaaa
  consumer:
    group: MQ_INST_111111111111111_AAAAAAA%GID_ffffff_local_test
    access-key: aaaaaaaAAAAAAAAAAAAAAAA
    secret-key: AAAAAAAAAAAAAAaaaaaaaaaaaaaaaa
  access-channel: CLOUD

讲一下吧：

• name-server这个属性是公网TCP地址，在后台管理可以找到，是一个http://开头的，把它删喽，只保留后面一部分即可。
• producer生产者组配置，AK和SK就不多少了，直接按照阿里云的配置给就好了，但是有一定要写对，你写错了控制台也不会报错，但是一直显示未上线（消费者），有点坑的是这个群组名称，群组名称如果连接普通rocketmq,直接写群组名称即可，但是你连ONS就必须要带上实例的ID，也就是name-server的子域名第一段，然后用%连接，再接群组名称，下面消费者亦是如此，这点必须要写对，不然也连不上。

三、编写生产者端的代码

生产者代码网上一大堆，随便找一下就可以搜到，这里放个简单demo即可:

import lombok.RequiredArgsConstructor;
import org.apache.rocketmq.spring.core.RocketMQTemplate;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
@RequiredArgsConstructor
public class TestCtrl {

    private static final String TOPIC = "MQ_INST_111111111111111_AAAAAAA%ffffff_local_test";
    private final RocketMQTemplate rocketMQTemplate;

    @GetMapping("/test")
    public void test() {
        rocketMQTemplate.convertAndSend(TOPIC.concat(":tag01"), "testMessage");
    }
}

上面的TOPIC也要实例的ID + % + topic名字,否则也有问题，发送消息的时候记得带上tag即可，其余的就没啥，该咋咋整。

四、编写消费者端代码

监听代码也很简单，但是配置一定要整对，不然在阿里云后台的GROUP会一直处于离线，导致消费不到消息：

import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener;
import org.springframework.stereotype.Service;

/**
 * mq
 *
 * @author Protected User
 * @date 2023/04/01 10:00
 **/
@Slf4j
@Service
@RocketMQMessageListener(consumerGroup = "MQ_INST_111111111111111_AAAAAAA%GID_ffffff_local_test", topic = "MQ_INST_111111111111111_AAAAAAA%ffffff_local_test")
public class RocketListener implements RocketMQListener<String> {

    @Override
    public void onMessage(String message) {
        log.info("message:==========> {}", message);
    }
}

五、总结

所有配置要严格按照格式编写，否则容易出不可预知错误。