java-rocketmq标签_2048 AI社区

java-rocketmq

Claude Code / Codex / Gemini CLI 万能神器，完美解决程序员的痛点！

CC-Switch是一款专为AI编程工具设计的跨平台配置管理工具，可集中管理ClaudeCode、Codex和GeminiCLI的API配置、MCP服务器、Skills插件和系统提示词。它解决了开发者手动修改分散配置文件、多设备同步困难、热切换不直观等痛点，通过可视化界面实现一键切换配置并自动同步到各工具。支持Windows/macOS/Linux系统，提供云端同步、速度测试等功能，特别适合同时使

 xh2277659985
2026-01-27 13:17:51

 1765

 22

#人工智能 #java #windows +4
阻塞、非阻塞、多路复用、同步、异步、BIO、NIO、AIO 一锅端

本文对比分析了阻塞IO、非阻塞IO、IO多路复用和异步IO四种IO模型。阻塞IO会完全阻塞用户线程；非阻塞IO通过轮询减少等待时间；IO多路复用通过单线程管理多个IO流，介绍了select、poll和epoll三种实现方式及其优缺点；异步IO由内核完成所有操作无需等待。文章还区分了同步与异步的概念，指出同步需要用户线程参与数据拷贝，而异步由内核完成。最后介绍了Java中对应的BIO、NIO和AIO

x2277659985
2026-01-26 16:10:51

 433

 9

#nio #java #spring +4
20天拿到美团快手小米搜狐跟谁学offer

【面试经历总结】作者在4-5月期间密集面试了贝壳、脉脉、跟谁学等10家互联网公司，技术岗面试普遍包含3轮技术面+HR面。面试内容涵盖算法题（二叉树、字符串处理等）、系统设计（秒杀场景、分布式锁等）及技术八股文（MySQL、Redis、Kafka等）。建议准备面试时：1）先面非目标公司练手；2）注重项目描述和技能匹配；3）及时复盘面试问题。作者作为非科班出身（自动化专业）的Java/大数据开发者，分

 xh2277659985
2026-01-26 15:38:59

 1399

 10

#java #分布式 #java-rocketmq +3
【RocketMQ入门到精通 | 2】集群搭建：数据复制与刷盘策略，Broker集群模式，RAID磁盘阵列

摘要：消息中间件的数据复制策略分为同步和异步复制，同步保证数据强一致性但延迟高，异步提升吞吐量但可能丢数据。刷盘策略包括同步（直接落盘）和异步（先写入PageCache），后者性能更优。Broker集群模式包括多Master（配置简单）、多Master多Slave（异步复制存在延迟，同步双写更安全但性能低10%）。RAID技术通过镜像、条带和校验提升可靠性和性能，其中RAID10兼顾速度与安全。

Muyu1uz
2025-09-20 12:11:25

 1163

 18

#java-rocketmq #rocketmq #java
rocketmq 启动报错 creating bean with name org.apache.rocketmq.spring.support.DefaultRocketMQListener

rocketmq启动报错Error creating bean with name 'org.apache.rocketmq.spring.support.DefaultRocketMQListenerContainer_1'

xiaoai5324
2024-04-19 16:22:52

 2366

 10

#rocketmq #java-rocketmq
Spring Boot 集成 RocketMQ 全流程指南：从依赖引入到消息收发

本文将通过 **手动连接** 和 **配置连接** 两种方式，详细讲解如何在 Spring Boot 中集成 RocketMQ，实现消息的同步与异步发送，并提供完整示例代码

 qq_17153885
2025-04-14 23:40:41

 3500

 27

#java-rocketmq #spring boot #rocketmq
RocketMQ配置全解（含ACL、Dashboard配置）

RocketMQ配置全解（含ACL、Dashboard配置）NAME SERVER修改默认端口号BROKER SERVER支持的配置项如下，如果要使用身份鉴权必须开启ACL配置RocketMQ Dashboard下载源码https://github.com/apache/rocketmq-dash

Aubrey-J
2022-07-11 12:03:57

 2.1w

 10

#java-rocketmq #rocketmq #java
Springboot+RocketMQ（5）:实现批量消息

1.批量发送消息：批量发送消息能显著提高传递小消息的性能。限制是这些批量消息应该有相同的 topic，相同的 waitStoreMsgOK，而且不能是延时消息。此外，这一批消息的总大小不应超过 4MB。2.批量接收消息：批量接收消息能提高传递小消息的性能，同时与顺序消息配合的情况下，还能根据业务主键对顺序消息进行去重（是否可去重，需要业务来决定），减少消费者对消息的处理3.批量消息使用场景。

EvanDeveloper
2023-05-29 17:50:47

 3626

 1

#spring boot #java-rocketmq #rocketmq
【安装配置RocketMQ】

【安装配置RocketMQ】

java_wxid
2022-10-04 10:45:00

 2149

 7

#java-rocketmq #rocketmq #java
springboot RocketMQ 客户端日志配置 rocketmq_client.log过大

项目集成rocketMQ后，日志持续增大，导致磁盘空间逐渐减少，参考官方文档来正确配置。

Don't Look Down
2024-03-14 11:00:23

 2799

 22

#spring boot #java-rocketmq #rocketmq
RocketMQ 常见面试题（一）

RocketMQ 的消息存储是基于 CommitLog 实现的。CommitLog 是 RocketMQ 中最重要的组件之一，它是一个类似日志的存储系统，所有的消息在被存储之前都要写入到 CommitLog 中。具体来说，当一个生产者生产一条消息时，该消息会首先被写入到内存缓冲区中，然后再被异步刷写到磁盘上的CommitLog文件中。同样的，当消费者消费一条消息时，该消息的偏移量也会被记录在Com

路上阡陌
2023-06-23 09:55:55

 4901

 4

#java-rocketmq #rocketmq #java
RocketMQ 如何保证消息不丢失

发送消息阶段涉及到Producer到broker的网络通信，因此丢失消息的几率一定会有，那RocketMQ在此阶段用了哪些手段保证消息不丢失了（或者说降低丢失的可能性）。手段一：提供SYNC的发送消息方式，等待broker处理结果。我们在调用producer.send方法时，不指定回调方法，则默认采用同步发送消息的方式，这也是丢失几率最小的一种发送方式。手段二：发送消息如果失败或者超时，则重新发送

 是月月啊2023
2023-12-08 19:44:16

 702

#java-rocketmq #rocketmq #java
RocketMQ安装(超详细)

了解了mq的基本概念和角色以后，我们开始安装rocketmq，建议在linux上，我使用的是ubuntu。

陈路周clz
2023-05-29 19:46:25

 3774

 2

#java-rocketmq #rocketmq #java
19.RocketMQ之消息丢失的场景以及解决方案

highlight: arduino-light如果我们的项目中引入了MQ，势必要面对的一个问题，就是消息丢失问题，今天我们就来聊聊消息是怎么丢失的。现在假设我们的业务是这样的，用户通过订单系统下了一个订单，订单系统完成支付扣减余额后会发送消息给RocketMQ，然后积分系统会从RocketMQ中消费消息，去给用户增加积分。但是突然有一天有用户反映，支付订单扣减余额之后，自己的积分...

然而,然而
2023-06-29 20:54:23

 3265

#java-rocketmq #rocketmq #java +2
SpringBoot集成RocketMQ实现事务消息结合实际业务出发多业务多场景分析附带示例代码和解决方案

SpringBoot集成RocketMQ实现事务消息结合实际业务出发多业务多场景分析附带示例代码和解决方案

 kerwin_code
2023-04-02 09:58:10

 9701

 9

#spring boot #java-rocketmq #rocketmq +2
rocketmq报错的问题排查和记录 RemotingTooMuchRequestException

连续3天同一时间遇到rocketmq不可用。第一天持续1分钟，第二天持续10分钟，第三天持续40分钟。线上版本使用的4.9.2，以下源码均看的这个版本。

烤鸭的世界我们不懂
2023-01-16 08:15:00

 4981

 1

#java-rocketmq #rocketmq #java
RocketMQ 5.0 新版版本新特性总结

对于 Master-Slave 架构的升级，RocketMQ 5.0 引入了 BrokerContainer 的概念，一个 BrokerContainer 中可以部署多个 Broker，这些 Broker 拥有独立的端口，功能完全独立，可以通过 admin 来增加或减少 Broker。RocketMQ 5.0 专门增加了轻量级的 DLedgerControlller 选主组件，将选主的切换能力上移

 Young丶
2023-10-08 08:45:00

 4544

 1

#java-rocketmq #rocketmq #java
SpringBoot整合RocketMQ，高手都是这么玩的！

rocketmq:...enhance:# 启动隔离，用于激活配置类EnvironmentIsolationConfig# 启动后会自动在topic上拼接激活的配置文件，达到自动隔离的效果# 隔离环境名称，拼接到topic后，topic_dev，默认空字符串。

m0_68408835
2023-12-11 09:22:26

 2666

 23

#spring boot #java-rocketmq #rocketmq
RocketMQ在Linux中的安装教程

修改目录 /usr/local/rocketmq/rocketmq-all-4.7.1-bin-release/bin 下的 3 个配置文件： runserver.sh、runbroker.sh 、tools.sh不然会报insufficient memory。进入 RocketMQ 安装目录下的 /usr/local/rocketmq/rocketmq-all-4.7.1-bin-release

我就是我352
2023-06-07 16:48:06

 5318

#linux #java-rocketmq #rocketmq
Spring Boot集成RocketMQ全部种类消息实现+生产者和消费者配置信息介绍（内含5.x新增可自定义时间的定时/延时消息）

Spring Boot集成RocketMQ全部种类消息实现+生产者和消费者配置信息介绍（内含5.x新增可自定义时间的定时/延时消息）

kerwin_code
2023-04-01 23:03:16

 1.4w

 13

#spring boot #java-rocketmq #rocketmq +2
rocketmq 发送时异常：system busy 和 broker busy 解决方案

之前写的解决方案,都是基于测试环境测试的.到生产环境之后,正常使用没有问题,生产环境压测时,又出现了system busy异常(简直崩溃).最后在rocketmq群里大佬指导下,终于解决(希望是彻底解决).下面直接给出结果:目前通过生产环境各种参数修改测试得出:broker busy异常: 可通过增大 waitTimeMillsInSendQueue 解决system busy异常:可通过增大 o

炽热者
2023-11-23 19:22:42

 3336

 28

#java-rocketmq #rocketmq #java
rocketMq消息队列详细使用与实践整合spring

使用RocketMQ的原生API开发是最简单也是目前看来最牢靠的方式。这里用SpringBoot来搭建一系列消息生产者和消息消费者，来访问之前搭建的RocketMQ集群。

一路向北⁢
2023-08-04 08:30:00

 2955

 1

#java-rocketmq #rocketmq #spring +1
详解RocketMQ消息存储原理

RocketMQ存储的文件主要包括CommitLog文件、ConsumeQueue文件、Index文件。RocketMQ将所有topic的消息存储在同一个文件中，确保消息发送时按顺序写文件，尽最大的能力确保消息发送的高性能与高吞吐量。因为消息中间件一般是基于消息主题的订阅机制，所以给按照消息主题检索消息带来了极大的不便。为了提高消息消费的效率，RocketMQ引入了ConsumeQueue消息消费

 听到微笑
2023-10-15 20:16:51

 1.1w

 1

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

根据上篇文章使用Docker安装RocketMQ并启动之后，有个隐患详情见下文。如何解决rocketmq 和spring boot 3.x集成问题

 person想要改变
2024-01-06 16:08:24

 3147

 8

#java-rocketmq #spring boot #rocketmq +1
Springboot+RocketMQ（7）:实现事务消息

分布式事务通俗来说，一次操作由若干分支组成，这些分支操作分属于不同的应用，分布在不同的服务器上，分布式事务需要保证这些操作，分支事务与普通事务一样，就是为了保证操作结果的一致性。

EvanDeveloper
2023-05-30 17:07:15

 3849

 2

#spring boot #java-rocketmq #rocketmq
如何确定RocketMQ中消费者的线程大小

随着物联网行业的发展、智能设备数量越来越多，随着设备活跃量过大，常常存在一些高并发的请求，形成了流量尖峰，过多的请求会压垮服务器，影响其他服务运行。因此，为了保护云端服务，需要对请求进行缓冲，`RocketMQ`就是一款非常优秀消息队列的中间件，在互联网领域久经考验，也被各个行业广泛应用。

CodeJames
2023-02-25 18:35:52

 5438

 5

#java-rocketmq #rocketmq #java
SpringBoot集成RocketMQ实现各种消息类型

使用RocketMQ有两种方式，一种是引入rocketmq-client需要自己创建生产者和消费者，相对来说比较繁琐；另一种是引入rocketmq-spring-boot-starter(对rocketmq-client进行了封装)，发消息和消费消息都比较简洁。这里采用的集成方式是。

EvanDeveloper
2023-05-30 18:15:00

 3007

 2

#spring boot #java-rocketmq #rocketmq
SpringBoot整合RocketMQ

先看看每次发送消息或者消费消息消息发送成功或者失败要打印消息日志，用于业务排查问题。如果消息量较少，建议在消费入口方法打印消息，消费耗时等，方便后续排查问题。RocketMQ无法避免消息重复（），所以如果业务对消费重复非常敏感，务必要在业务层面进行去重处理。可以借助关系数据库进行去重。首先需要确定消息的唯一键，可以是msgId，也可以是消息内容中的唯一标识字段，例如订单Id等。接下来讨论的是在Ro

爱吃牛肉的大老虎
2023-05-08 13:41:23

 1w

 15

#spring boot #java-rocketmq #rocketmq
RocketMQ 11种消息类型，你知道几种？

RocketMQ事务消息的实现主要是先将消息存到这个中间Topic，有些资料会把这个消息称为半消息（half消息），这是因为这个消息不能被消费之后会执行本地的事务，提交本地事务的执行状态RocketMQ会根据事务的执行状态去判断commit或者是rollback消息，也就是是不是可以让消费者消费这条消息的意思在一些异常情况下，生产者无法及时正确提交事务执行状态RocketMQ会向生产者发送消息，让

 我真没有偷懒
2023-12-12 14:36:22

 3659

 9

#java #kafka #中间件 +2
RocketMQ保姆级教程

RocketMQ是阿里巴巴旗下一款开源的MQ框架，经历过双十一考验、Java编程语言实现，有非常好完整生态系统。RocketMQ作为一款纯java、分布式、队列模型的开源消息中间件，支持事务消息、顺序消息、批量消息、定时消息、消息回溯等，总之就是葛大爷的一句话通过上面的理论介绍和实际的环境搭建再加上代码的测试，相信应该可以对RocketMQ有个入门，有兴趣的小伙伴可以手动搭起来，整个过程顺利的话可

 十一技术斩
2022-08-28 16:13:16

 5188

 10

#java-rocketmq #rocketmq #java
springBoot整合RocketMq

项目地址：https://github.com/apache/rocketmq-spring在项目wiki界面你可获取相关示例，或者直接下载示例项目部分概念在我的上一篇文章中有说明，这里仅仅只演示示例代码，不做概念性说明写文章时rocketmq-spring-boot-starter最新版本是2.2.2对应的rocketmq-client版本是4.9.3这里我服务端安装的是5.0.0版本，不过5.

sry1201
2022-12-09 10:46:33

 7190

 1

#spring boot #java-rocketmq #rocketmq
kafka和rocketmq区别对比

Kafka和RocketMQ是目前非常流行的分布式消息系统，它们都能够高效地处理海量的消息数据。在本文中，我们将对Kafka和RocketMQ进行技术比较，分析它们在各方面的优缺点，以便读者在选择消息系统时能够做出更加明智的决策。一、架构设计Kafka和RocketMQ都是基于发布/订阅模式的消息系统，但是它们的架构设计有所不同。Kafka的架构设计比较简单，主要由生产者、消费者和Kafk...

—Phoenix
2023-04-28 16:06:00

 6351

 9

#kafka #java-rocketmq #rocketmq +2
RocketMQ架构、工作流程以及安装

消息是指，消息系统所传输信息的物理载体，生产和消费数据的最小单位，每条消息必须属于一个主题。

小白_学编程
2023-06-15 18:23:10

 6756

 8

#java-rocketmq #rocketmq #java
Springboot集成RocketMQ——简单使用

Springboot集成RocketMQ，进行简单使用

 tang_seven
2023-08-25 18:28:05

 3486

#spring boot #java-rocketmq #rocketmq
【Docker应用篇】Docker安装RocketMQ

2、foxiswho/rockermq镜像stars最多，所以拉取运行该镜像。创建NameServer容器并启动，端口使用 RecketMQ 默认端口。3、创建 broker 容器并启动，因为 Broker 有需要配置需要我们修改，所以在创建 broker 容器时，使用宿主机的配置文件，方便日后修改。5、docker 安装一下 RocketMQ 的可视化管理页面。1、搜索查询远程仓库中rocket

喜羊羊sk
2023-01-18 09:40:08

 6148

 9

#docker #java-rocketmq #rocketmq
SpringBoot整合RocketMQ，高手都是这么玩的

今天我们来讨论如何在项目开发中优雅地使用RocketMQ。本文分为三部分，第一部分实现SpringBoot与RocketMQ的整合，第二部分解决在使用RocketMQ过程中可能遇到的一些问题并解决他们，第三部分介绍如何封装RocketMQ以便更好地使用。

m0_68408835
2023-04-11 11:07:42

 4088

 6

#spring boot #java-rocketmq #rocketmq
【RocketMQ】安装与部署（Windows）

windows环境下尝试部署RocketMQ，以及处理一些可能出现的问题，包含一些处理思路等。

m0_52777015
2023-05-29 15:58:15

 1.2w

 18

#windows #java-rocketmq #rocketmq
Docker安装RocketMQ详细教程

Docker安装RocketMQ详细教程

 丷长玦遗墨
2022-10-25 11:18:03

 2.3w

 28

#java-rocketmq #docker #rocketmq
RocketMq常见面试题

rocketmq常见面试题

 Rooibos gron
2022-06-23 13:30:46

 2.3w

 26

#java-rocketmq #rocketmq #java
RocketMQ -- offset管理

正文首先来明确一下 Offset 的含义， RocketMQ 中，一种类型的消息会放到一个 Topic 里，为了能够并行，一般一个 Topic 会有多个 Message Queue (也可以设置成一个)， Offset是指某个 Topic下的一条消息在某个 Message Queue里的位置，通过 Offset的值可以定位到这条消息，或者指示 Consumer从这条消息开始向后继续

 码上得天下
2023-05-19 20:51:21

 4804

 7

#java-rocketmq #rocketmq #java
RocketMQ第4集集群的搭建（2主2从异步复制集群模式）

本案例采用2m-2s-async的方式搭建集群。实际项目中，为了达到高可用，一般会使用dleger。集群规划说明：nameserver是一个轻量级的注册中心，，直接启动即可。3台nameserver之间不需要通信，而是被请求方来关联3台nameserver的地址。机器角色配置在rocketmq的config目录下可以看到rocketmq建议的各种配置方式：2m-2s-async: 2主2从异步刷盘

 健康平安的活着
2023-06-05 22:24:17

 3027

 1

#java-rocketmq #rocketmq #java
【SpringBoot高级篇】SpringBoot集成RocketMQ消息队列

RocketMQ是阿里巴巴2016年MQ中间件，使用Java语言开发，在阿里内部，RocketMQ承接了例如“双11”等高并发场景的消息流转，能够处理万亿级别的消息。

喜羊羊sk
2023-01-18 17:58:47

 2w

 38

#java-rocketmq #spring boot #rocketmq
【Spring Boot】Spring Boot 集成 RocketMQ 实现简单的消息发送和消费

简单消息的发送顺序消息的发送RocketMQTemplate的API介绍环境搭建：RocketMQ的安装教程：在官网上下载bin文件，解压到本地，并配置环境变量，如下图所示：在 Spring boot 项目中引入 RocketMQ 依赖：

旭哥依旧-bjhxcc
2023-08-05 22:14:19

 4074

#java-rocketmq #spring boot #rocketmq