广告
返回顶部
首页 > 资讯 > 后端开发 > Python >RocketMQTemplate 注入失败的解决
  • 154
分享到

RocketMQTemplate 注入失败的解决

2024-04-02 19:04:59 154人浏览 八月长安

Python 官方文档:入门教程 => 点击学习

摘要

RocketMQTemplate 注入失败 在使用rocketMQ 发送消息时,会发现 @Autowired private RocketMQtemplate rocketM

RocketMQTemplate 注入失败

在使用rocketMQ 发送消息时,会发现


 @Autowired
 private RocketMQtemplate rocketMQTemplate;

注入RocketMQTemplate 失败。

解决方案

究其原因是因为,配置文件中,我们没有添加

在这里插入图片描述

上图中蓝色的两行代码,指定发送的组名。写上后,问题解决。

好了,再来说说RocketMQTemplate 的基本使用吧~

RocketMQTemplate的使用

1、pom.xml依赖


<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>

2、配置文件


# 必须配置
# 指定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

3、RocketMQTemplate的基本方法

首先使用@Autowired注入MonGoTemplate(后面直接使用,就不特殊说明)


@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);
    }
}

以上为个人经验,希望能给大家一个参考,也希望大家多多支持编程网。

--结束END--

本文标题: RocketMQTemplate 注入失败的解决

本文链接: https://www.lsjlt.com/news/129669.html(转载时请注明来源链接)

有问题或投稿请发送至: 邮箱/279061341@qq.com    QQ/279061341

本篇文章演示代码以及资料文档资料下载

下载Word文档到电脑,方便收藏和打印~

下载Word文档
猜你喜欢
  • RocketMQTemplate 注入失败的解决
    RocketMQTemplate 注入失败 在使用rocketmq 发送消息时,会发现 @Autowired private RocketMQTemplate rocketM...
    99+
    2022-11-12
  • RocketMQTemplate 注入失败如何解决
    今天就跟大家聊聊有关RocketMQTemplate 注入失败如何解决,可能很多人都不太了解,为了让大家更加了解,小编给大家总结了以下内容,希望大家根据这篇文章可以有所收获。RocketMQTemplate 注入失败在使用rocketmq ...
    99+
    2023-06-20
  • SpringBoot @Componet注解注入失败如何解决
    今天小编给大家分享一下SpringBoot @Componet注解注入失败如何解决的相关知识点,内容详细,逻辑清晰,相信大部分人都还太了解这方面的知识,所以分享这篇文章给大家参考一下,希望大家阅读完这篇文章后有所收获,下面我们一起来了解一下...
    99+
    2023-07-05
  • 解决@FeignClient注入service失败问题
    目录@FeignClient注入service失败Feign注入失败之坑错误信息加上之后,问题解决@FeignClient注入service失败 在入口类上方加入注解 @Enable...
    99+
    2022-11-13
  • @FeignClient注入service失败怎么解决
    今天小编给大家分享一下@FeignClient注入service失败怎么解决的相关知识点,内容详细,逻辑清晰,相信大部分人都还太了解这方面的知识,所以分享这篇文章给大家参考一下,希望大家阅读完这篇文章后有所收获,下面我们一起来了解一下吧。@...
    99+
    2023-06-29
  • Spring 父类变量注入失败的解决
    目录Spring 父类变量注入失败下面小记下这个过程Spring通过父类注入公用属性的技巧XML配置方式提取父类Annotation方式提取父类Spring 父类变量注入失败 昨天遇...
    99+
    2022-11-12
  • Spring自动注入失败的解决方法
    目录Spring自动注入失败如何解决?回答注入你的bean使用@Configurable手动查找bean:不推荐Spring自动注入失败如何解决? 我有一个被Spring @Ser...
    99+
    2022-11-12
  • zuulFilter中注入bean失败如何解决
    今天就跟大家聊聊有关zuulFilter中注入bean失败如何解决,可能很多人都不太了解,为了让大家更加了解,小编给大家总结了以下内容,希望大家根据这篇文章可以有所收获。zuulFilter注入bean失败一、为什么要用到这个上周想实现在网...
    99+
    2023-06-20
  • 在zuulFilter中注入bean失败的解决方案
    zuulFilter注入bean失败 一、为什么要用到这个 上周想实现在网关层 zuul 实现用户认证操作,即需要在网关过滤器中调用其他的微服务,按常规做法在 filter 中用 @...
    99+
    2022-11-12
  • springboot使用@value注入配置失败的解决
    目录springboot使用@value注入配置文件失败问题解决方向一问题解决方向二@Value注入失败,注入值为null的问题大概就是下面这样结果不知道为什么,@Value注入一直...
    99+
    2022-11-12
  • SpringBoot@Componet注解注入失败的问题
    目录@Componet注解注入失败问题描述解决方法SpringBoot @component的作用介绍举例说明 总结@Componet注解注入失败 问题描述 在spring...
    99+
    2023-03-06
    SpringBoot @Componet @Componet注解 @Componet注解注入失败
  • 解决netty中spring对象注入失败的问题
    目录netty中spring对象注入失败发现了问题所在在netty中注入spring成份可以通过以下方式netty中spring对象注入失败 今天在做项目的时候发现在netty中注入...
    99+
    2022-11-13
  • 如何解决Spring自动注入失败的问题
    小编给大家分享一下如何解决Spring自动注入失败的问题,相信大部分人都还不怎么了解,因此分享这篇文章给大家参考一下,希望大家阅读完这篇文章后大有收获,下面让我们一起去了解一下吧!Spring自动注入失败如何解决?我有一个被Spring @...
    99+
    2023-06-15
  • netty中spring对象注入失败怎么解决
    本文小编为大家详细介绍“netty中spring对象注入失败怎么解决”,内容详细,步骤清晰,细节处理妥当,希望这篇“netty中spring对象注入失败怎么解决”文章能帮助大家解决疑惑,下面跟着小编的思路慢慢深入,一起来学习新知识吧。net...
    99+
    2023-06-29
  • @Autowired自动注入接口失败怎么解决
    这篇文章主要介绍了@Autowired自动注入接口失败怎么解决的相关知识,内容详细易懂,操作简单快捷,具有一定借鉴价值,相信大家阅读完这篇@Autowired自动注入接口失败怎么解决文章都会有所收获,下面我们一起来看看吧。@Autowire...
    99+
    2023-06-29
  • @Autowired自动注入接口失败的原因及解决
    目录@Autowired 自动注入接口失败可以这样做@Autowired 自动注入失败报空指针异常今天就遇到了这个问题 @Autowired 自动注入接口失败 有个自动注入...
    99+
    2022-11-13
  • SpringMVC@RequestBody属性名大写字母注入失败的解决
    目录@RequestBody属性名大写字母注入失败问题描述问题分析解决方案@RequestBody时第二个字母大写,映射不到解决办法总结@RequestBody属性名大写字母注入失败...
    99+
    2023-05-15
    SpringMVC @RequestBody @RequestBody属性名 @RequestBody大写字母注入失败
  • MyBatis Plus 导入IdType失败的解决
    目录MyBatis Plus 导入IdType失败MybatisPlus学习笔记一、MybatisPlus概述二、快速入门三、配置日志四、CRUD扩展1.Insert2.Updat&...
    99+
    2022-11-12
  • navicat导入Excel失败的解决方法
    小编给大家分享一下navicat导入Excel失败的解决方法,希望大家阅读完这篇文章后大所收获,下面让我们一起去探讨吧!最近刚安装完navicat ,准备导入工作数据进去,excel文件(xlsx格式),按...
    99+
    2022-10-18
  • Spring静态变量/构造函数注入失败的解决方案
    目录1、案例1:Spring对静态变量的注入为空2、案例2:在构造函数中使用Spring容器中的Bean对象,得到的结果为空补充1、案例1:Spring对静态变量的注入为空 案例代码...
    99+
    2022-11-12
软考高级职称资格查询
编程网,编程工程师的家园,是目前国内优秀的开源技术社区之一,形成了由开源软件库、代码分享、资讯、协作翻译、讨论区和博客等几大频道内容,为IT开发者提供了一个发现、使用、并交流开源技术的平台。
  • 官方手机版

  • 微信公众号

  • 商务合作