当前位置：首页 > 编程日记 > 正文

Spring boot 3 集成rocketmq-spring-boot-starter解决版本不一致问题

编程日记 2024-01-10 17:58:27

安装RocketMQ根据上篇文章使用Docker安装RocketMQ并启动之后，有个隐患详情见下文

Spring Boot集成

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

rocketmq还没有支持spring boot 3。
rocketmq自动转配的方式是spring boot 2的方式解决方法：使用spring boot 3自动装配方式，这个需要去了解stater的写法通过源码发现RocketMQAutoConfiguration是需要自动装配的所以在resource文件夹下创建METAINF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports
```
org.apache.rocketmq.spring.autoconfigure.RocketMQAutoConfiguration
```

RocketMQ连接失败

RocketMQ yml配置： 隐患就是name-service这里启动会报错连接失败，如果你使用的是腾讯云服务器并且使用官方docker命令部署RocketMQ，问题就出在docker 命令使用了--net=host此时服务器内9876端口并未开放使用firewall-cmd --add-port=7896/tcp --permanent，注意重启网卡以及腾讯云控制台端口开放。Tip:-pdocker默认会修改防火墙规则

rocketmq:
  name-server: ip:9876
  # 生产者
  producer:
    group: test_group
    # 消息发送超时时间
    send-message-timeout: 10000
    # 消息最大长度4M
    max-message-size: 4096
    # 消息发送失败重试次数
    retry-times-when-send-failed: 3
    # 异步消息发送失败重试次数
    retry-times-when-send-async-failed: 2
  # 消费者
  consumer:
    group: test_group
    # 每次提取的最大消息数
    pull-batch-size: 5

RocketMQ Broker连接失败

接下来在启动： 发现还是报错发现是RocketMQ Broker端口连接失败问题，参照如下解决

如果是docker单节点部署，应该有两个容器，进入rocketmq容器中找到broker.conf

修改配置文件:只增加多出的配置，然后把这个配置文件复制出去重启这个容器

brokerClusterName = DefaultCluster
brokerName = broker-a
brokerId = 0
deleteWhen = 04
fileReservedTime = 48
brokerRole = ASYNC_MASTER
flushDiskType = ASYNC_FLUSH
brokerIP1=122.51.115.127
namesrvAddr=122.51.115.127:9876;localhost:9876
autoCreateTopicEnable=true

删除Broker容器,重新部署docker run -d --net=host --name=rocketmqBroker -v type=bind,source=/home/server/rocketmq,target=/home/rocketmq/store apache/rocketmq ./mqbroker -n localhost:9876 -C 配置文件路径配置文件路径是真实存在容器内的所以需要把配置文件放在映射的文件夹中

然后启动spring boot程序

发送/接收信息

接上文，这个类具有接收信息和发送信息，看以下类注释

@EnableAspectJAutoProxy
@EnableAsync
@EnableScheduling
@Slf4j
@Indexed
@SpringBootApplication
@EnableDiscoveryClient
@RestController
@Tag(name = "rocket测试控制器")
@RequiredArgsConstructor
//这个注解用于回调接收信息，你要接收那个TOPIC主题的信息，以及你所属哪个组
@RocketMQMessageListener(consumerGroup = "test_group",topic = TOPIC)
public class RocketMQApplication implements RocketMQListener<String> {
    public static final String TOPIC = "test_rocket";

    public static void main(String[] args) {
        try {
            //打开rockermq打印
            System.setProperty("rocketmq.client.logUseSlf4j", "true");
            SpringApplication.run(RocketMQApplication.class, args);
            log.info("项目启动成功(ง ˙o˙)ว");
        } catch (Exception e) {
            log.error("启动失败:",e);
        }
    }

    private final RocketMQTemplate rocketMQTemplate;

    @GetMapping("/send/msg")
    public String sendMsg1 (){
        try {
            Message<String> msg = MessageBuilder.withPayload("Hello,RocketMQ").build();
            //发送信息
            SendResult sendResult = rocketMQTemplate.syncSend(TOPIC, msg);
            log.error("发送结果 = {}",sendResult);
        } catch (Exception e) {
            e.printStackTrace();
        }
        return "OK" ;
    }

    @Override
    public void onMessage(String message) {
        log.error("我是消费者 = {}",message);
    }
}

，请求接口，然后就会收到信息

在这里插入图片描述

RocketMQ运行机制图解

在这里插入图片描述

java-rocketmqspring bootrocketmqspring boot 2.xspring boot 3.xdockerspringboot版本问题

https://www.dkcj.cn/info/659.html

spring.factories文件的作用

即spring.factories文件是帮助spring-boot项目包以外的bean（即在pom文件中添加依赖中的bean）注册到spring-boot项目的spring容器中。在Spring Boot启动时，它会扫描classpath下所有的spring.factories文件，加载其中的自动配置类，并将它们注入到Spring ApplicationContext中，使得项目能够自动运行。spring.factories文件是Spring Boot自动配置的核心文件之一，它的作用是。

编程日记2024/05/04 00:00:03

7min到40s：SpringBoot 启动优化实践

然后重点排查这些阶段的代码。先看下。

编程日记2024/04/21 00:30:05

SpringBoot系列教程之Bean之指定初始化顺序的若干姿势

之前介绍了@Order注解的常见错误理解，它并不能指定 bean 的加载顺序，那么问题来了，如果我需要指定 bean 的加载顺序，那应该怎么办呢？本文将介绍几种可行的方式来控制 bean 之间的加载顺序。

编程日记2024/04/21 00:30:05

SpringBoot接口防抖(防重复提交)的一些实现方案

作为一名老码农，在开发后端Java业务系统，包括各种管理后台和小程序等。在这些项目中，我设计过单/多租户体系系统，对接过许多开放平台，也搞过消息中心这类较为复杂的应用，但幸运的是，我至今还没有遇到过线上系统由于代码崩溃导致资损的情况。这其中的原因有三点：一是业务系统本身并不复杂；二是我一直遵循某大厂代码规约，在开发过程中尽可能按规约编写代码；三是经过多年的开发经验积累，我成为了一名熟练工，掌握了一些实用的技巧。啥是防抖所谓防抖，一是防用户手抖，二是防网络抖动。

编程日记2024/04/14 21:30:02

SpringBoot请求转发与重定向

但是可能由于B网址相对于A网址过于复杂，这样搜索引擎就会觉得网址A对用户更加友好，因而在重定向之后任然显示旧的网址A，但是显示网址B的内容。在平常使用手机的过程当中，有时候会发现网页上会有浮动的窗口，或者访问的页面不是正常的页面，这就可能是运营商通过某种方式篡改了用户正常访问的页面。重定向，是指在Nginx中，重定向是指通过修改URL地址，将客户端的请求重定向到另一个URL地址的过程，Nginx中实现重定向的方式有多种，比如使用rewrite模块、return指令等。使用场景：在返回视图的前面加上。

编程日记2024/04/07 22:30:03

SpringBoot 中实现订单30分钟自动取消的策略

在电商和其他涉及到在线支付的应用中，通常需要实现一个功能：如果用户在生成订单后的一定时间内未完成支付，系统将自动取消该订单。本文将详细介绍基于Spring Boot框架实现订单30分钟内未支付自动取消的几种方案，并提供实例代码。

编程日记2024/04/05 00:30:03

SpringBoot 优雅实现超大文件上传，通用方案

通俗的说，你把要上传的东西上传，服务器会先做MD5校验，如果服务器上有一样的东西，它就直接给你个新地址，其实你下载的都是服务器上的同一个文件，想要不秒传，其实只要让MD5改变，就是对文件本身做一下修改（改名字不行），例如一个文本文件，你多加几个字，MD5就变了，就不会秒传了。分片上传，就是将所要上传的文件，按照一定的大小，将整个文件分隔成多个数据块（我们称之为Part）来进行分别上传，上传完之后再由服务端对所有上传的文件进行汇总整合成原始的文件。

编程日记2024/03/18 22:30:02

Springboot + oauth2 单点登录 - 原理篇

OAuth 协议为用户资源的授权提供了一个安全的、开放而又简易的标准，允许用户授权第三方移动应用访问他们存储在另外的服务提供者上的信息，而不需要将用户名和密码提供给第三方移动应用或分享他们数据的所有内容，OAuth2.0是OAuth协议的延续版本，但不向后兼容OAuth 1.0即完全废止了OAuth1.0。授权码模式（authorization code）密码模式（resource owner password credentials）客户端模式（client credentials）不常用。

编程日记2024/03/11 22:30:03

Springboot整合HBase——大数据技术之HBase2.x

Apache HBase 是以hdfs为数据存储的，一种分布式、可扩展的noSql数据库。是一个高可靠性、高性能、面向列、可伸缩的分布式存储系统，利用HBase技术可在廉价PC Server上搭建起大规模结构化存储集群。HBase使用与BigTable（BigTable是一个稀疏的、分布式的、持久化的多维排序map）非常相似的数据模型。用户将数据行存储在带标签的表中。数据行具有可排序的键和任意数量的列。该表存储稀疏，因此如果用户喜欢，同一表中的行可以具有疯狂变化的列。

编程日记2024/02/15 23:30:03

Docker部署SpringBoot项目详细部署过程

Docker可比喻成一个装应用的容器，将应用及其依赖文件、数据等打包在容器内，直接运行容器即可把应用运行起来，而无需关心环境配置问题。本文记录个人学习Docker的总结内容，安装、配置和部署等内容，在过程中，应注意命令不要写错，加上Docker插件等问题，若出现理解不到位的地方，请多指出。

编程日记2024/02/03 00:30:01

Docker ps命令

docker ps命令可以用来列出Docker容器相关信息。docker ps 命令可以用来列出容器相关信息。

编程日记2024/02/02 22:30:03

[Ubuntu 22.04] Docker安装及使用

容器的生命周期由用户控制，用户可以选择手动删除容器或让其保留在系统中以供之后使用。选项允许你在容器内部创建一个交互式的终端会话，使你可以像在本地终端一样与容器进行交互。你可以在容器内执行命令，查看输出并输入命令。镜像拉取完成后，可以使用以下命令创建并启动一个基于 Ubuntu 20.04 镜像的容器。列出所有正在运行的容器，并显示它们的容器ID、镜像、命令、创建时间、状态等信息。以下命令可以中止容器，改命令将向容器发送一个停止信号，使其正常停止并退出。这将显示所有容器的列表，包括正在运行的和已停止的容器。

编程日记2024/02/02 22:30:03

Docker网络详解

如何自定义一个网络？查看新创键的mynet详细信息：# 创建两个使用相同自定义网络的容器# 测试容器互连^C^C。

编程日记2024/02/01 23:00:02

Docker exec命令详细使用指南

Docker exec命令是Docker提供的一个强大工具，用于在正在运行的容器中执行命令。本文将详细介绍Docker exec命令的用法和示例，帮助大家更好地理解和使用这个命令。Docker是一种流行的容器化平台，允许我们在容器中运行应用程序。有时候，在容器内执行命令可以帮助我们调试、排查问题或进行其他操作。这就是Docker exec命令发挥作用的时候。本文详细介绍了Docker exec命令的用法和示例。

编程日记2024/02/01 23:00:02

使用DockerFile构建镜像与镜像上传

首先Dockerfile 是一个文本格式的配置文件，用户可以使用 Dockerfile 来快速创建自定义的镜像。

编程日记2024/01/23 18:03:36

spring和springboot、springMVC有什么区别？

今天来聊一下，刚在面试中被问到的一个经典问题Spring 提供了广泛的功能用于企业级应用开发Spring Boot 简化了 Spring 应用的开发和部署Spring MVC 则是专注于构建 Web 应用的 MVC 框架在使用时，你可以根据项目需求选择合适的组件或组合使用它们。在很多现代的 Spring 应用中，特别是微服务架构中，Spring Boot 和 Spring MVC 经常一起使用。好了，以上就是本文的全部内容，如有问题欢迎留言讨论。

编程日记2024/01/23 13:58:47

使用docker部署RStudio容器并结合内网穿透实现公网访问

RStudio Server 使你能够在 Linux 服务器上运行你所熟悉和喜爱的 RStudio IDE，并通过 Web 浏览器进行访问，从而将 RStudio IDE 的强大功能和工作效率带到基于服务器的集中式环境中。下面介绍在Linux docker中安装RStudio Server并结合cpolar内网穿透工具,实现远程访问,docker方式安装可以避免很多问题,一键安装,如设备没有安装docker,需提前安装docker。

编程日记2024/01/19 10:42:58

Spring Boot整合日期转换器（Converter）和拦截器（HandlerInterceptor）

配置文件形式针对框架进行个性化定制，例如：拦截器，类型转化器等等。WebMvcConfigurer配置类其实是。内部的一种配置方式，采用。

编程日记2024/01/18 23:41:46

Docker网络配置&网络模式

网络相关概念，子网掩码、网关、规则的介绍及网络模式bridge、host详解，Dockers自定义网络配置

编程日记2024/01/18 12:31:47

SpringBoot 使用过滤器、拦截器、切面(AOP)，及其之间的区别和执行顺序

Servlet(Server Applet)，全称是Java Servlet，是提供基于协议请求/响应服务的Java类。在JavaEE中是Servlet规范，即是指Java语言实现的一个接口，广义的Servlet是指任何实现了这个Servlet接口的Java类，一般人们理解是后者。是什么。

编程日记2024/01/14 01:00:02

【总结】SpringBoot 中过滤器、拦截器、监听器的基本使用

拦截器是在面向切面编程中应用的，就是在你的service或者一个方法前调用一个方法，或者在方法后调用一个方法。是基于JAVA的反射机制。1）预处理preHandle()方法用户发送请求时，先执行preHandle()方法。会先按照顺序执行所有拦截器的preHandle方法，一直遇到return false为止，比如第二个preHandle方法是return false，则第三个以及以后所有拦截器都不会执行。若都是return true，则执行用户请求的url方法。2）后处理postHandle()方法。

编程日记2024/01/14 01:00:02

SpringBoot--过滤器/拦截器/AOP--区别/使用/顺序

本文介绍SpringMVC（SpringBoot）中的过滤器、拦截器、AOP的区别及其用法。如果监听器、过滤器、拦截器、 AOP都存在，则它们的执行顺序为：监听器 => 过滤器=> 拦截器=> AOP。

编程日记2024/01/13 00:00:03

Docker的介绍及安装&基本操作命令

在讲到Docker之前，我们先了解虚拟机与容器之间的区别VM(VMware)在宿主机器、宿主机器操作系统的基础上创建虚拟层、虚拟化的操作系统、虚拟化的仓库，然后再安装应用；容器，在宿主机器、宿主机器操作系统上创建Docker引擎，在引擎的基础上再安装应用。特性容器虚拟机启动秒级分钟级硬盘使用一般为MB一般为GB性能接近原生弱于系统支持量单机支持上千个容器一般几十个。

编程日记2024/01/11 22:57:29

docker-宿主机与容器的命令执行方法

宿主机命令容器执行程序、容器命令宿主机执行程序的方法。

编程日记2024/01/10 16:01:22

RocketMQ5-03RocketMQ-Dashboard和Java客户端访问示例

接上篇已经完成 RocketMQ5.0 环境的部署，就需要对这个环境进行测试，查看集群、写入消息、读取消息等。Docker部署 Dashboard：获取镜像并下载，部署服务。客户端连接：pom文件，生产者代码，消费者代码，接口测试，问题: broker资源不足无法提供服务

编程日记2024/01/08 19:33:33

基于SpringBoot的校园二手闲置交易平台

基于SpringBoot的校园二手闲置交易平台的设计与实现~

编程日记2024/01/03 11:57:03

SpringBoot 中获取 Request 的四种方法

Controller中获取request对象后，如果要在其他方法中（如service方法、工具类方法等）使用request对象，需要在调用这些方法时将request对象作为参数传入。如果其他方法（如工具类中static方法）需要使用request对象，则需要在调用这些方法时将request参数传递进去。下面介绍的方法4，则可以直接在诸如工具类中的static方法中使用request对象（当然在各种Bean中也可以使用）。该方法实现的原理是，在Controller方法开始处理请求时，对象是方法参数，相当于。

编程日记2024/01/03 09:44:59