死信 队列rocketmq消息
RocketMq消费原理及源码解析
消费原理概览 先简单说下常见的rocketMq的部署方式，上图中broker为真正计算和存储消息的地方，而nameServer负责维护broker地 图中右侧consume message部分即是本文重点描述的部分，主要分为ConsumerGroup和Consumer，consumerGroup可以 ......
剑指 Offer 59 - II. 队列的最大值（中等）
题目：  ``` class MaxQueue { public: deque que1; //使用两个双端栈（deq ......
C#中Socket编程，异步实现Server端定时发送消息
在最近项目需求中，要求服务端定时向客服端发送消息。由于客户端从机的特性，只能接收Server发送的消息后回复，不能主动向服务端发送消息。 起初，并未使用异步的方法进行编程，使用了Accept()、Revice()等方法。由于从机不能主动发送消息的特性，并未考虑到从机断电不能接收到Server消息的情 ......
Apache RocketMQ 远程代码执行漏洞（CVE-2023-37582）
Apache RocketMQ是一款低延迟、高并发、高可用、高可靠的分布式消息中间件。CVE-2023-37582 中，由于对 CVE-2023-33246 修复不完善，导致在Apache RocketMQ NameServer 存在未授权访问的情况下，攻击者可构造恶意请求以RocketMQ运行的系... ......
RocketMQ学习
rabbitMQ（ons）特性 0拷贝 顺序写盘 随机读 延迟消息 事务消息 顺序消息 （rabbit没有这个） 基于netty nio框架 NameServer代替Zookeeper，寻址方式，更轻量级。 集群架构无单点，扩展性强。 消息重试机制，消息查询（rabbit不支持重试） 社区活跃、成熟 ......
Topic太多，RocketMQ炸了！
网上博客常说，kafka的topic数量过多会影响kafka，而RocketMQ不会受到topic数量影响。 但是，果真如此吗？ 最近排查一个问题，发现RocketMQ稳定性同样受到topic数量影响！！ 好了，一起来回顾下这次问题排查吧，最佳实践和引申思考放在最后，千万不要错过。 1、问题描述 我 ......
判断evpp的发送消息是post 还是get
struct evhttp_request结构体定义了HTTP请求的各个字段，如请求行、请求头、请求正文等。 struct evhttp_request { int major; // 主版本号 int minor; // 次版本号 enum evhttp_cmd_type type; // 请求方 ......
redis做消息队列学习
转自：https://juejin.cn/post/7094272373930590245#heading-9，https://zhuanlan.zhihu.com/p/344269737 1、消息队列基本 作用：应用解耦（作为中介）、削峰填谷。redis做mq的优点：轻量级，使用和运维成本低。 m ......
栈和队列
栈：先进后出(子弹压樘)，栈顶插入，栈顶删除，常见的应用是递归调用的实现 队列：先进先出(做核酸)，队尾插入，队头删除 栈和队列顺序存储更为常见 栈 栈是向低地址增长的 如果a和b紧挨着，b一定在a的左边 如果b和c紧挨着，c一定在b的左边 ......
.NET中使用RabbitMQ延时队列和死信队列
# RabbitMQ延时队列和死信队列 # 延时队列和死信队列 > 延时队列是RabbitMQ中的一种特殊队列，它可以在消息到达队列后延迟一段时间再被消费。 > > 延时队列的实现原理是通过使用消息的过期时间和死信队列来实现。当消息被发送到延时队列时，可以为消息设置一个过期时间，这个过期时间决定了消 ......
从互联网到云时代，Apache RocketMQ 是如何演进的？
*作者：隆基* 2022 年，RocketMQ 5.0 的正式版发布。相对于 4.0 版本而言，架构走向云原生化，并且覆盖了更多业务场景。 ## 消息队列演进史 操作系统、数据库、中间件是基础软件的三驾马车，而消息队列属于最经典的中间件之一，已经有 30 多年的历史。消息队列的发展主要经历了以下几个 ......
在同一个Java进程中连接多个RocketMQ集群
RocketMQ使用场景： 作为消费者：用户应用 --> MQ集群A --> 权益应用 消息内容:客户开户/销户相关消息 作为生产者：权益应用 --> MQ集群B --> 信贷应用 消息内容:卡券事件消息 问题现象： 一个Java进程要连接多个RocketMQ集群时，作为消费者功能无法正常使用，作为 ......
二十、RocketMQ5.x消费重试
消费重试指的是，消费者在消费某条消息失败后，Apache RocketMQ 服务端会根据重试策略重新消费该消息，超过一次定数后若还未消费成功，则该消息将不再继续重试，直接被发送到死信队列中。Apache RocketMQ 的消费重试主要解决的是业务处理逻辑失败导致的消费完整性问题，是一种为业务兜底的 ......
十九、消息查询
RocketMQ支持按照下面两种维度（“按照Message Id查询消息”、“按照Message Key查询消息”）进行消息查询。在RocketMQ dashboard中：  # ......
学习 linux 的工作队列机制
入职后导师给的第二篇文章，让学习驱动的编写和工作队列，可能主要是想培养一下阅读源码和分析能力吧，做一个驱动的入门。 在公司和学校都习惯用 onenote，但是这个东西带不走的，因此希望在博客上记录一点。 在学习别人的文章时，demo 那部分的代码可以看懂，但是很多东西别人记录和自己记录的逻辑和行文完 ......
十六、RocketMQ5.0版本消费负载均衡
根据消费者类型的不同，消费者负载均衡策略分为以下两种模式： 1. 消息粒度负载均衡：RocketMQ5.x版本的PushConsumer和SimpleConsumer默认负载策略 2. 队列粒度负载均衡：PullConsumer默认负载策略 ### 消息粒度负载均衡 消息粒度负载均衡策略中，同一消费 ......
.netcore 中高性能队列Channel的应用与封装
Channel存在于命名空间System.Threading.Channels中，是.net一种新型的线程安全集合，提供了发布和订阅消息处理功能，在一个服务中若接收消息和处理消息都很频繁，且处理消息耗时较长时，Channel是一种好的处理方式。 1、创建Channel方式（支持泛型消息格式） 支持5 ......
LeetCode 239. Sliding Window Maximum 单调队列
You are given an array of integers `nums`, there is a sliding window of size `k` which is moving from the very left of the array to the very right. Yo ......
链表/栈/队列/KMP
- ### 链表 - 用数组模拟，不同于结构体加指针 - 调用new关键字开上万级别的节点非常慢，基本会超时 - #### 单链表 - 来构造邻接表 - 用于存图与树 - ##### 基本结构： - head 表示头结点的下标 - e[i] 表示节点i的值 - ne[i] 表示节点i的下一个节点的下 ......
数据结构中队列的存储和应用
队列： 只有两个口进出数据，一个专门进入数据，另一个专门出数据，先进先出，FIFO表 一、 顺序队列： 存储元素的连续内存的首地址 容量 队头位置 (出队) 队尾位置 (入队) [元素数量] 运算：创建、销毁、清空、出队、入队、队空、队满、队头、队尾、元素数量 #include <stdio.h> ......
微信公众号模板消息源码实现，打破服务号群发推送次数限制
公众号服务号每个月只能群发推送四次文章，我们可以使用模板消息为公众号粉丝推送信息 下面是使用golang实现的模板消息发送类库封装，轻松实现模板消息发送 wechat.go package lib import ( "github.com/silenceper/wechat/v2" "github. ......
如何对接微信公众号模板消息
微信公众号的模板消息进行了更新，与之前比有了不少的变化，以前的一些类目也没有了，历史模板还是可以继续使用的，下面是新版模板消息的使用步骤 选择服务类目 前往【广告与服务】【模板消息】【模板库】【类目模板库】点击服务类目的详情，选择一个自己的服务类目 比如我选择的是：商业服务 > 软件/建站/技术开发 ......
十五、RocketMQ4.x消费者负载均衡策略
### 一、AllocateMessageQueueAveragely AllocateMessageQueueAveragely就是默认的负载均衡策略，在上个例子已经演示了，可以在[这里](https://www.cnblogs.com/shigongp/p/17575805.html)查看。先分 ......
剑指 Offer 09. 用两个栈实现队列（简单）
题目：  ``` class CQueue { public: stack st1; stack st2; CQu ......
rabbitmq php 发送延迟消息 java 进行消费
// 延迟队列 php 需要安装好几个扩展 php 生产者 $connection = new AMQPStreamConnection('xxxxx', 5672, 'guest', 'guest'); $channel = $connection->channel(); // 发送消息到交换机， ......
痛失网易30K之二：看你牛逼轰轰，请写一个阻塞队列
文章很长，且持续更新，建议收藏起来，慢慢读！[**疯狂创客圈总目录 博客园版**](https://www.cnblogs.com/crazymakercircle/p/9904544.html) 为您奉上珍贵的学习资源 ： 免费赠送 :[**《尼恩Java面试宝典》**](https://www. ......