死信 队列rocketmq消息
RocketMQ之管理与监控
前言 首先提出我们的监控诉求，出现如下情况时，希望能够及时接收到系统告警通知： RocketMQ服务宕机 RocketMQ消费者下线 RocketMQ消息出现长时间或者大量堆积 本文将通过修改rocketmq-console源码的方式，增加RocketMQ消费者下线和RocketMQ消息出现长时间或 ......
RocketMQ之水平扩展及负载均衡
前言 RocketMQ是一个分布式具有高度可扩展性的消息中间件。本文旨在探索在broker端，生产端，以及消费端是如何做到横向扩展以及负载均衡的。 NameServer集群 提供轻量级的服务发现和路由。每个NameServer 记录完整的路由信息，提供等效的读写服务，并支持快速存储扩展。 就是一个注 ......
【数据结构】单调队列专题（滑动窗口问题）
1091. 理想的正方形 #include <iostream> using namespace std; const int N = 1010; int n, m, k; int w[N][N], row_max[N][N], row_min[N][N]; int q[N]; void get_m ......
RocketMQ单机版安装
1、下载最新的安装包 github下载地址：https://github.com/apache/rocketmq/releases。本文安装版本为：rocketmq-all-5.1.0-bin-release.zip 2、安装JDK 3、上传并解压安装包 # 从本地电脑上传安装包到Linux服务器 ......
RabbitMQ - 消息中间件
RabbitMQ - 消息中间件 1 消息队列Rabbitmq介绍 1.0 什么是消息队列 消息：指的是两个应用间传递的数据【字符串、对象等等】 消息队列：在消息的传输过程中保存消息的容器，在消息队列中游生产者和消费者两个角色 生产者：生产者只负责发送数据到消息队列 消费者：消费者只负责从消息队列中 ......
c++构造函数之成员初始化队列member initialization list
1. member初始化最好在member initialization list中初始化 因为会constructor可能会扩张代码，会产生临时的object对象，然后将它初始化后，以一个assignment运算符将临时对象指定给类member，然后再销毁临时对象 以下情况会导致效率比较低： 初始 ......
消息队列Rabbitmq介绍、rabbitmq安装、基于queue实现生产者消费者、基本使用、消息安全(详见笔记)、持久化(详见笔记)、闲置消费(详见笔记)、发布订阅(详见笔记)、发布订阅高级之Routing(按关键字匹配)(详见笔记)
1 消息队列Rabbitmq介绍 # 消息队列 -中间件 （概念很大） 》准确一些叫消息队列中间件 -消息队列中间件 -使用redis当做消息队列来用 -blpop 阻塞式弹出，实现队列，先进先出 # MQ ,消息队列，MessageQueue 是什么 消息队列就是基础数据结构中的“先进先出”的一种 ......
RocketMQ之消息轨迹
一、概述 消息轨迹是用来跟踪记录消息发送、消息消费的轨迹。 如何启用消息轨迹？ broker端 需要在broker端的配置文件中添加配置项：traceTopicEnable=true，注意：对于消息轨迹数据量较大的场景，可以在RocketMQ集群中选择其中一个Broker节点专用于存储消息轨迹，使得 ......
RocketMQ之通信机制
一、概述 RocketMQ消息队列集群主要包括NameServer、Broker(Master/Slave)、Producer、Consumer4个角色，基本通讯流程如下： Broker启动后需要完成一次将自己注册至NameServer的操作；随后每隔30s时间定时向NameServer上报Topi ......
RocketMQ之重试机制
一、概述 Producer对发送失败的消息进行重新发送的机制，称为消息发送重试机制，也称为消息重投机制。 对于消息重投，需要注意以下几点： 生产者在发送消息时，若采用同步或异步发送方式，发送失败会重试，但oneway消息发送方式发送失败是没有重试机制的; 只有普通消息具有发送重试机制，顺序消息是没有 ......
RocketMQ Helm模板增加ACL认证
RocketMQ版本：4.9.2 具体请按实际场景进行修改 修改rocketmq/templates/broker/configmap.yaml data: broker-base.conf: | brokerClusterName = {{ .Values.clusterName }} aclEn ......
RocketMQ开启ACL认证Go连接测试
RocketMQ开启ACL认证连接测试 导入包 go get -u github.com/apache/rocketmq-client-go/v2 go get -u github.com/spf13/pflag 查看go.mod module your_module_name go 1.16 re ......
rocketmq启动nameserver的坑
当你启动rocketmq时可以启动但找不到日志时： 第一：减小JVM的内存 其次：要到bin目录中输入启动命令。 楼主就是第二步解决的 ......
本地消息表模式
分布式事务 | 使用 dotnetcore/CAP 的本地消息表模式 本地消息表模式 本地消息表模式，其作为柔性事务的一种，核心是将一个分布式事务拆分为多个本地事务，事务之间通过事件消息衔接，事件消息和上个事务共用一个本地事务存储到本地消息表，再通过定时任务轮询本地消息表进行消息投递，下游业务订阅消 ......
Rabbitmq 介绍 、安装、基于Queue实现生产者消费者模型、基本使用、消息安全之ack、durable持久化、利用闲置消费、发布订阅、发布订阅高级之Royting(按关键字匹配)、Topic关键字模糊匹配、基于rabbitmq实现rpc
==师承老刘llnb== ==一、消息队列介绍== 1.1介绍 消息队列就是基础数据结构中的“先进先出”的一种数据机构。想一下，生活中买东西，需要排队，先排的人先买消费，就是典型的“先进先出” 1.2MQ解决什么问题 MQ是一直存在，不过随着微服务架构的流行，成了解决微服务之间问题的常用工具。 应用 ......
消息中间件RabbitMQ
Rabbitmq 之前我是使用redis当做消息队列来使用，因为队列是先进先出的数据结构，有个方法 blpop阻塞式弹出实现队列，但是使用redis当做中间件是不专业的，而Rabbitmq来作为消息中间件是专业的 消息队列解决了 1.应用解耦 多个应用使用消息队列做缓存.任务存放在消息队列中。应 ......
开源项目消息推送平台Austin
开源项目消息推送平台Austin终于要上线了，迎来在线演示的第一版！ 🔥项目在线演示地址：http://139.9.73.20:3000/ 消息推送平台🔥推送下发【邮件】【短信】【微信服务号】【微信小程序】【企业微信】【钉钉】等消息类型。 https://gitee.com/zhongfuche ......
python dingtalk钉钉群告警消息发布
##python dingtalk钉钉群告警消息发布 公司用oprator部署的prometheus，理论上时可以直接通过alertmanager的配置。通过钉钉机器人的webhook向群里发送告警信息。但是想要格式化输出格式，并且规范化就成了问题。因为每个人都有部署exporter的权限，我不能保 ......
华为 OD 本篇题解：特异性双端队列
华为 OD 机试【4 大宝典】再次上新题！ ① Python 解华为机试题 ：https://dream.blog.csdn.net/article/details/129221789 ② C++ 解华为机试题：https://dream.blog.csdn.net/article/details/ ......
RocketMQ消费者是如何负载均衡的
摘要：RocketMQ 支持两种消息模式：集群消费（ Clustering ）和广播消费（ Broadcasting ）。 本文分享自华为云社区《一文讲透RocketMQ消费者是如何负载均衡的》，作者：勇哥java实战分享。 RocketMQ 支持两种消息模式：集群消费（ Clustering ）和 ......
消息订阅
填报接口修改： 每周填报和月季填报的差不多的，都是要相隔一周或者一个月来进行填写的。如果在短期内连续的两次填报的话，会出现消息填写，就是要写这个填报要在一周或者一个月后才能继续填报。但是其中的判断是挺多的，首先你要判断这个每周填报是否是第一次填写，就要去数据库中找到weeklyTime是否为空，否则 ......
RocketMQ笔记(十一)：消息存储删除机制
RocketMQ的消息采用文件进行持久化存储。 1、存储目录详情 RocketMQ中默认文件存储位置/root/store，文件详情如下 commitLog：消息存储目录 config：运行期间一些配置信息 consumerqueue：消息消费队列存储目录 index：消息索引文件存储目录 chec ......
RocketMQ笔记(十)：事务消息
事务消息官网：RocketMQ官网 - 事务消息。 一、什么是事务消息 事务消息是 RocketMQ 提供的一种消息类型，支持在分布式场景下保障消息生产和本地事务的最终一致性。 二、事务消息的原理 2.1、事务消息的生命周期 2.1.1、初始化 半事务消息被生产者构建并完成初始化，待发送到服务端的状 ......
RocketMQ笔记(九)：延时/定时消息
一、什么是延时/定时消息 定时/延时消息为 RocketMQ 中提供的一种消息类型。定时消息和延时消息本质相同，都是服务端根据消息设置的定时时间在某一固定时刻将消息投递给消费者消费。 Producer将消息发送到消息队列 RocketMQ 服务端，但并不期望这条消息立马投递（被消费者消费），而是延迟 ......
RocketMQ笔记(八)：顺序消息
一、什么是顺序消息 消息有序指的是可以按照消息的发送顺序来消费(FIFO)。 顺序消息是 RocketMQ 提供的一种消息类型，支持消费者按照发送消息的先后顺序获取消息。顺序消息在发送、存储和投递的处理过程中，强调多条消息间的先后顺序关系。RocketMQ 顺序消息的顺序关系通过消息组（Messag ......
RocketMQ笔记(七)：普通消息
普通消息为 RocketMQ 中最基础的消息，支持生产者和消费者的异步解耦通信。 一、普通消息的生命周期 1、初始化 消息被生产者构建并完成初始化，待发送到服务端的状态。 2、待消费 消息被发送到服务端，对消费者可见，等待消费者消费的状态。 3、消费中 消息被消费者获取，并按照消费者本地的业务逻辑进 ......
RocketMQ笔记(六)：示例代码工具类
引入RocketMQ客户端的maven依赖： <dependency> <groupId>org.apache.rocketmq</groupId> <artifactId>rocketmq-client</artifactId> <version>5.0.0</version> </depende ......
消息推送平台终于要发布啦！
我的开源项目消息推送平台Austin终于要上线了，迎来在线演示的第一版！ 🔥项目在线演示地址：http://139.9.73.20:3000/ 消息推送平台🔥推送下发【邮件】【短信】【微信服务号】【微信小程序】【企业微信】【钉钉】等消息类型。 https://gitee.com/zhongfuc ......
Redis定长队列设计与实现
业务背景： 只展示最近10条礼物打赏动态，用户名+礼物名称 不管在app端还是在web端，或多或少都有这样的需求，所谓技术方案的选型都是受限于实际的业务场景的，都是以解决实际业务为目的，由于刚开始这样的需求还是比较少的，所以采用了简单的方式实现了功能，但是随着业务扩大，重复的也会很多，再写一套代码就 ......
RocketMQ笔记(五)：搭建RocketMQ运行环境
详细部署方式可以参考官网：官网RocketMQ部署方式。 一、环境准备 1.1、JDK环境准备 详情参考：Linux搭建JDK环境。 1.2、RocketMQ准备 1、下载RocketMQ 下载RocketMQ地址：rocketmq-all-4.7.1-bin-release.zip。 2、将Roc ......