RocketMQTemplate 注入失败的解决

 @Autowired
 private RocketMQTemplate rocketMQTemplate;

<dependency>
    <groupId>org.apache.rocketmq</groupId>
    <artifactId>rocketmq-spring-boot-starter</artifactId>
  <version>2.0.3</version>
</dependency>
<dependency>
    <groupId>org.apache.rocketmq</groupId>
    <artifactId>rocketmq-client</artifactId>
    <version>4.5.1</version>
</dependency>
<dependency>
    <groupId>org.apache.rocketmq</groupId>
    <artifactId>rocketmq-common</artifactId>
    <version>4.5.1</version>
</dependency>

# 必须配置
# 指定nameServer
rocketmq.nameServer=192.168.168.168:9876 
# 指定发送者组名 相当于rabbitmq的virtual host 逻辑上的划分
rocketmq.producer.group=my-group
# 其他可选配置
#rocketmq.producer.send-message-timeout=300000
#rocketmq.producer.compress-message-body-threshold=4096
#rocketmq.producer.max-message-size=4194304
#rocketmq.producer.retry-times-when-send-async-failed=0
#rocketmq.producer.retry-next-server=true
#rocketmq.producer.retry-times-when-send-failed=2

@Autowired
private RocketMQTemplate rocketMQTemplate;

//发送消息
public class ProducerController {
    @Autowired
    private RocketMQTemplate rocketMQTemplate;
    
 public void send(){
     //实体类User
     User user=new User(999L,"testUser");
     //发送自定义对象
     rocketMQTemplate.convertAndSend("test_topic",user);//会自动转换为json格式
 }
}

//接收消息
@Component  //必须注入spring容器
@RocketMQMessageListener(
        topic = "test_topic",      //topic：消息的发送者使用同一个topic
        consumerGroup = "test_my-consumer",     //group：不用和生产者group相同
        selectorExpression = "*")        //tag
  // 在RocketMQ中消费者和发送者组没有关系
  // 如果两个消费者groupname和topic都一样，则二者轮循接收消息
  // 如果两个消费者topic一样，而group不一样，则消息变成广播机制
// RocketMQListener<>泛型必须和接收的消息类型相同
public class TestListner implements RocketMQListener<User> {
 private static final ObjectMapper MAPPER = new ObjectMapper();
    @Override
    public void onMessage(User user) {
  JsonNode jsonNode = MAPPER.readTree(user);//可以使用mapper读取json格式数据
  Long userId = jsonNode.get("userId").asLong();
        System.out.println(user);
    }
}