rocketmq名字
如何保证RocketMQ消息不丢失
一、概述 一个消息从开始到结束会经历这么三个阶段：生产阶段、消息队列Broker存储阶段和消费阶段。一个消息在三个阶段中的任何一个阶段都有可能丢失，知道这个之后，我们只要保证这三个阶段不出现问题，消息自然就不会出现丢失了。接下来我们来细说一下如何保证这三个阶段不出现问题。 二、生产阶段 生产阶段的使 ......
rocketMq安装
# 拉取镜像 docker pull rocketmqinc/rocketmq # 创建一个文件夹用于存放相关文件 mkdir rocketMqAtHome01 && cd rocketMqAtHome01 # 创建namesrv数据卷文件夹 mkdir -p data/namesrv/logs d ......
docker+docker-compose部署rocketmq集群遇到的大坑
搭建时间为2023-11-22 环境：CentOS7、Docker24.0.6、Docker-Compose2.23.0、RocketMQ镜像为apache/rocketmq:5.1.2 部署说明：两台Linux服务器，先是尝试了传统2主2从，没有实现主备自动切换，一步一步部署下来没有特别大的问题。 ......
rocketmq部署
rocketmq部署 一、安装jdk 1. 上传jdkjdk-8u361-linux-x64.tar.gz 2.解压 tar xf jdk-8u361-linux-x64.tar.gz -C /data 3.配置环境变量 vim /etc/profile export JAVA_HOME=/data ......
RocketMQ【消息丢失】
一、流程图 二、消息丢失场景 2.1、场景1中生产者将消息发送给Rocket MQ的时候，如果出现了网络抖动或者通信异常等问题，消息就有可能会丢失。 2.2、场景2中消息需要持久化到磁盘中，这时会有两种情况导致消息丢失： 1、RocketMQ为了减少磁盘的IO，会先将消息写入到os cache中，而 ......
python从exec函数理解名字、对象及命名空间
第一层理解 exec函数基本使用 python中有个自建(builtin)函数 exec，这个函数支持动态执行 Python 代码，函数返回值永远是None。 这个函数是将存放起来的一串字符当作python的代码来执行，这串代码可以放在数据库中，在内存中，在文件中等等； 可以将任意字符串当作代码执行 ......
疑难杂症：conda create --prefix= 同时创建了两个相同名字的 环境
疑难杂症：conda create --prefix= 同时创建了两个相同名字的 环境 Anaconda3-2022.10-Windows-x86_64 但是 用普通的 不指定路径的 创建 环境指令没有问题，可以正常创建 一个环境 ......
docker-compose部署rocketmq集群
参考博文：https://blog.csdn.net/bacawa/article/details/130521794 1、安装docker-compose 2、通过docker search apache/rocketmq搜索镜像，本来想看一下镜像的版本，但是没有找到对应的命令，最后用了比较粗暴的 ......
【面试题】消息队列面试题总结（RocketMQ版）
自己整理、总结了一些消息队列相关面试题，并想了一些RocketMQ面试过程中可能会问的知识点。 使用消息队列的优点 系统解耦 比如系统A产生的某个事件，系统B需要感知，简单实现就是在系统A产生事件之后，调用系统B的接口通知系统B，如果此时再增加一个系统C，还需要修改系统A的代码，再加入调用系统C接口 ......
RocketMQ 使用注意事项
场景： 最近公司项目要用Rocket MQ，但是之前我没用过。所以在使用过程中遇到一些问题，做个记录。这篇主要是将注意事项，不涉及底层实现原理（还没学透）。 而且这里用的RocketMQ是指Apache的4.X，不是阿里云的，注意两者的不同。 解决： 1.保持订阅关系一致：订阅关系一致指的是同一消费 ......
聊聊 RocketMQ 消息轨迹
这篇文章，我们聊一聊 RocketMQ 的消息轨迹设计思路。 查询消息轨迹可作为生产环境中排查问题强有力的数据支持 ，也是研发同学解决线上问题的重要武器之一。 1 基础概念 消息轨迹是指一条消息从生产者发送到 Broker , 再到消费者消费，整个过程中的各个相关节点的时间、状态等数据汇聚而成的完整 ......
学生管理系统如何查找名字相同的学生
STU *search_link(STU *head, char *name) { if (NULL == head) { printf("链表不存在\n"); return NULL; }//判断链表是否存在 else { STU *pb = head; while ((strcmp(pb->na ......
获取摄像头名字和索引
# pip install wmi import wmi def get_camera_name(): camera_names = [] wmi_obj = wmi.WMI() cameras = wmi_obj.Win32_PnPEntity() for camera in cameras: i ......
docker 安装 RocketMQ
安装 rocketmq 拉取 rocketmq 镜像 docker pull apache/rocketmq 运行 namesrv docker run -d \ --name rmqnamesrv \ --privileged=true \ -p 9876:9876 \ -v /tool/rock ......
【RocketMQ】数据的清理机制
Broker在启动的时候会注册定时任务，定时清理过期的数据，默认是每10s执行一次，分别清理CommitLog文件和ConsumeQueue文件： public class DefaultMessageStore implements MessageStore { // CommitLog清理类 p ......
Springboot整合RocketMQ实现、消息生产、消息消费
前言： 这里我们需要准备两个Springboot项目，一个项目作为 消息生产，一个作为消费消息 window安装MQ，自行安装，可以参考教程： https://blog.csdn.net/qq_63815371/article/details/131032508 项目1：（生产消息） 项目结构： p ......
rocketmq记录
Rocketmq 生产者、消费者 maven引用<dependency><groupId>org.apache.rocketmq</groupId><artifactId>rocketmq-client</artifactId><version>4.7.0</version></dependency ......
Rocketmq使用
Rocketmq 生产者、消费者 maven引用 <dependency> <groupId>org.apache.rocketmq</groupId> <artifactId>rocketmq-client</artifactId> <version>4.7.0</version> </depen ......
RocketMQ 为什么会丢消息，如何保证消息不丢失
Producer 丢消息 1.同步发送 RocketMQ发送消息有三种模式，即同步发送，异步发送、单向发送。 同步发送消息时会同步阻塞等待Broker返回发送结果，如果发送失败不会收到发送结果SendResult,这种是最可靠的发送方式。 异步发送消息可以在回调方法中得知发送结果。 单向发送是消息发 ......
找出名字中包含S的人的信息 like '%S%'; 以S开头的值 like '%S';以S结尾的值 like 'S%';
# 模糊匹配 %包含的值%select * from emp where ENAME like '%S%'; # 找出名称以S开头的人的信息select * from emp where ENAME like 'S%'; # 找出名字以第二个字母是O的人的信息select * from emp wh ......
Prometheus监控RocketMQ
本文基于官方提供的RocketMQ Exporter来监控RocketMQ集群 1.Broker TPS/QPS的监控 2.消息积压监控 3.消费组消费演示监控 最终的Grafana面板效果图如下： 楼主RocketMQ环境是三主三从集群（只要在其中一台部署监控即可） 配置步骤 1.安装Rocket ......
【漏洞复现】Apache RocketMQ 代码注入漏洞（CVE-2023-37582）
产品介绍 Apache RocketMQ是美国阿帕奇（Apache）基金会的一款轻量级的数据处理平台和消息传递引擎。 漏洞概述 Apache RocketMQ 存在代码注入漏洞，该漏洞源于当 NameServer 地址在外网泄露且缺乏权限验证时，NameServer 组件仍然存在远程命令执行漏洞，在 ......
【RocketMQ】RocketMQ 5.0新特性（三）- Controller模式
在RocketMQ 5.0以前，有两种集群部署模式，分别为主从模式（Master-Slave模式）和Dledger模式。 主从模式 主从模式中分为Master和Slave两个角色，集群中可以有多个Master节点，一个Master节点可以有多个Slave节点。Master节点负责接收生产者发送的写入 ......
关于java开发项目中 使用上传文件 工具到 阿里云 时出现的 问题--工具类与properties文件中名字顺序不对应的问题
配置类文件中的 属性顺序 需要与 配置文件 中的属性顺序 保持一致 ......
博学谷学习记录 自我总结 用心分享 | RocketMQ刨析
RocketMQ是一个分布式开放消息中间件，底层基于队列模型来实现消息收发功能。RocketMQ集群中包含4个模块：Namesrv, Broker, Producer, Consumer。 主要功能 削峰填谷(主要解决瞬时写压力大于应用服务能力导致消息丢失、系统奔溃等问题) 系统解耦(解决不同重要程 ......
【RocketMQ】RocketMQ 5.0新特性（二）- Pop消费模式
Pop模式消费和消息粒度负载均衡 在RocketMQ 5.0之前，消费有两种方式可以从Broker获取消息，分别为Pull模式和Push模式。 Pull模式：消费需要不断的从阻塞队列中获取数据，如果没有数据就等待，这个阻塞队列中的数据由消息拉取线程从Broker拉取消息之后加入的，所以Pull模式下 ......
RocketMQ为什么要保证订阅关系一致
这篇文章，笔者想聊聊 RocketMQ 最佳实践之一：保证订阅关系一致。 订阅关系一致指的是同一个消费者 Group ID 下所有 Consumer 实例所订阅的 Topic 、Tag 必须完全一致。 如果订阅关系不一致，消息消费的逻辑就会混乱，甚至导致消息丢失。 1 订阅关系演示 首先我们展示正确 ......
C# 根据枚举名字获取值
try { var index = (int)Enum.Parse(typeof(Enums.DepartmentEnum), entity.Contract_No); this.contract_no.SelectedValue = index+""; }catch (Exception ex) ......
【RocketMQ】RocketMQ存储结构设计
CommitLog 生产者向Broker发送的消息，会以顺序写的方式，写入CommitLog文件，CommitLog文件的根目录由配置参数storePathRootDir决定，默认每一个CommitLog的文件大小为1G，如果文件写满会新建一个CommitLog文件，以该文件中第一条消息的偏移量为文 ......