sb-rocketmq-provider-consumer rocketmq provider
rocketMq安装
# 拉取镜像 docker pull rocketmqinc/rocketmq # 创建一个文件夹用于存放相关文件 mkdir rocketMqAtHome01 && cd rocketMqAtHome01 # 创建namesrv数据卷文件夹 mkdir -p data/namesrv/logs d ......
Vue Provide/Inject 使用指南
两个inject工具函数轻松解决严格注入和Hook 返回值透传问题！ 痛苦的经历 自从使用了Provide/Inject代码的组织方式更加灵活了，但是这个灵活性的增加伴随着代码容错性的降低。相信只要是真的在项目中引入Provide/Inject的同学，一定一定有过或者正在经历下面的状况： 😢 注入 ......
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 ......
Vue3 provide和inject实现原理
Vue3 的 Provide / Inject 的实现原理其实就是巧妙利用了原型和原型链来实现的，所以在了解 Vue3 的 Provide / Inject 的实现原理之前，先复习一下原型和原型链的知识。 原型和原型链的知识回顾 prototype 与 __proto__ prototype 一般称 ......
RocketMQ【消息丢失】
一、流程图 二、消息丢失场景 2.1、场景1中生产者将消息发送给Rocket MQ的时候，如果出现了网络抖动或者通信异常等问题，消息就有可能会丢失。 2.2、场景2中消息需要持久化到磁盘中，这时会有两种情况导致消息丢失： 1、RocketMQ为了减少磁盘的IO，会先将消息写入到os cache中，而 ......
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.保持订阅关系一致：订阅关系一致指的是同一消费 ......
Uncaught SyntaxError: The requested module '/vue3-print/node_modules/.pnpm/dayjs@1.11.9/node_modules/dayjs/dayjs.min.js?v=b0e0e64f' does not provide an export named 'default' (at Upload.vue:10:8)
前提 在项目环境 vue3.3.4 + vite4.4.11 下，安装dayjs1.11.9 报错 Uncaught SyntaxError: The requested module '/vue3-print/node_modules/.pnpm/dayjs@1.11.9/node_modules ......
聊聊 RocketMQ 消息轨迹
这篇文章，我们聊一聊 RocketMQ 的消息轨迹设计思路。 查询消息轨迹可作为生产环境中排查问题强有力的数据支持 ，也是研发同学解决线上问题的重要武器之一。 1 基础概念 消息轨迹是指一条消息从生产者发送到 Broker , 再到消费者消费，整个过程中的各个相关节点的时间、状态等数据汇聚而成的完整 ......
Please take a look at the provided example service unit files in this directory, and adapt and install them. Sorry!
安装Redis，执行 install_server.s 脚本时，出现如下报错： 解决方案，注释掉 install_server.sh 中的部分代码，注释代码详情如下： 再次执行 install_server.sh 脚本，结果如下： ......
vue 中的provide和inject用法。
provide和inject 可以用作vue组件的通讯-父子/跨级 provide 选项应该是一个对象或返回一个对象的函数。该对象包含可注入其子孙的 property。 inject 选项应该是： 一个字符串数组，或 一个对象，对象的 key 是本地的绑定名，value 是： 在可用的注入内容中搜索 ......
关于 Angular Lazy loaded modules 中的 providers
懒加载模块中提供的注入标记对于根应用程序中提供的服务是不可见的。这尤其适用于多提供者标记，例如HttpInterceptors、各种处理程序等等。 为了减轻这个缺点，一些可组合的商店功能，例如PageMetaService（它使用PageMetaResolver标记）或ConverterServic ......
docker 安装 RocketMQ
安装 rocketmq 拉取 rocketmq 镜像 docker pull apache/rocketmq 运行 namesrv docker run -d \ --name rmqnamesrv \ --privileged=true \ -p 9876:9876 \ -v /tool/rock ......
java.security.provider.getservice blocked
bug： https://bugs.openjdk.org/browse/JDK-8206333 堆栈： "Osp-Common-Business-Thread-572" Id=1723 BLOCKED at java.security.Provider.getService(Provider.ja ......
【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 ......
Windows -- 关于报错：“In included file: too few arguments provided to function-like macro invocat”解决方法
遇到报错如下： 点进去minwindef.h里报错显示： 点进winnt.h报错显示： 关于图一的报错，网上搜了一些解决方法如下： https://www.coder.work/article/568385 https://blog.csdn.net/Lyn_B/article/details/10 ......
RocketMQ 为什么会丢消息，如何保证消息不丢失
Producer 丢消息 1.同步发送 RocketMQ发送消息有三种模式，即同步发送，异步发送、单向发送。 同步发送消息时会同步阻塞等待Broker返回发送结果，如果发送失败不会收到发送结果SendResult,这种是最可靠的发送方式。 异步发送消息可以在回调方法中得知发送结果。 单向发送是消息发 ......
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节点负责接收生产者发送的写入 ......
Vue3| 组合式 API——provide 和 inject
作用和场景：顶层组件向任意的底层组件 传递数据和方法，实现 跨层组件通信 跨层传递普通数据 步骤： 1. 顶层组件通过 provide 函数提供数据 provide ( ' key ' , 顶层组件中的数据 ) 2. 底层组件通过 inject 函数获取数据 const message = inje ......
提交代码遇到not allowed to push code git info detecting host provider for 网址解决办法
查看git 出错信息 > git push -u origin android info: detecting host provider for 'https://AA.com/'... warning: SECURITY WARNING warning: | TLS certificate ve ......
博学谷学习记录 自我总结 用心分享 | 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 订阅关系演示 首先我们展示正确 ......