单向rocketmq消息
Windows启动RocketMQ
新增环境变量 新增环境变量ROCKETMQ_HOME 解压文件放置的目录，注意这个目录的下一级是有bin文件夹的，而不是还有一级rocketmq目录 启动mqnameserver服务 start mqnamesrv.cmd ## 指定ip start mqnamesrv.cmd -n 1 ......
高并发三大法宝之 缓存，消息队列，异步任务
1.缓存（常用redis） 将热点数据或者经常需要进行read的数据放到redis或者其他缓存中，可以极大的降低数据库的压力，遇到流量高峰时，不至于一下子就把数据库压垮了，使用springcache配合redis继续使用，也可以很方便的对数据进行缓存。 springcache 几个常用注解 @Cac ......
RocketMq消费原理及源码解析
消费原理概览 先简单说下常见的rocketMq的部署方式，上图中broker为真正计算和存储消息的地方，而nameServer负责维护broker地 图中右侧consume message部分即是本文重点描述的部分，主要分为ConsumerGroup和Consumer，consumerGroup可以 ......
C#中Socket编程，异步实现Server端定时发送消息
在最近项目需求中，要求服务端定时向客服端发送消息。由于客户端从机的特性，只能接收Server发送的消息后回复，不能主动向服务端发送消息。 起初，并未使用异步的方法进行编程，使用了Accept()、Revice()等方法。由于从机不能主动发送消息的特性，并未考虑到从机断电不能接收到Server消息的情 ......
数据结构与算法（三）：单向链表
# 链表定义 链表是一种物理存储单元上非连续、非顺序的存储结构，数据元素的逻辑是通过链表种的指针链接次序实现的。链表由一系列节点组成，每个节点包括两部分：一个是存储数据元素的数据域，一个是存储下一个节点地址的指针域。单向链表从头节点（也可以没有头节点）开始，指针指向下一个节点的位置，只能由上一个节点 ......
Apache RocketMQ 远程代码执行漏洞（CVE-2023-37582）
Apache RocketMQ是一款低延迟、高并发、高可用、高可靠的分布式消息中间件。CVE-2023-37582 中，由于对 CVE-2023-33246 修复不完善，导致在Apache RocketMQ NameServer 存在未授权访问的情况下，攻击者可构造恶意请求以RocketMQ运行的系... ......
反转单向链表 | 空间复杂度O(1)
## 反转单向链表 时间复杂度：O(N) 空间复杂度：O(1) ```c void reverse_list (node** head_ptr) { node* prev = NULL; node* curr = *head_ptr; node* next = NULL; while (curr ! ......
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 ......
从互联网到云时代，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中：  # ......
十六、RocketMQ5.0版本消费负载均衡
根据消费者类型的不同，消费者负载均衡策略分为以下两种模式： 1. 消息粒度负载均衡：RocketMQ5.x版本的PushConsumer和SimpleConsumer默认负载策略 2. 队列粒度负载均衡：PullConsumer默认负载策略 ### 消息粒度负载均衡 消息粒度负载均衡策略中，同一消费 ......
微信公众号模板消息源码实现，打破服务号群发推送次数限制
公众号服务号每个月只能群发推送四次文章，我们可以使用模板消息为公众号粉丝推送信息 下面是使用golang实现的模板消息发送类库封装，轻松实现模板消息发送 wechat.go package lib import ( "github.com/silenceper/wechat/v2" "github. ......
如何对接微信公众号模板消息
微信公众号的模板消息进行了更新，与之前比有了不少的变化，以前的一些类目也没有了，历史模板还是可以继续使用的，下面是新版模板消息的使用步骤 选择服务类目 前往【广告与服务】【模板消息】【模板库】【类目模板库】点击服务类目的详情，选择一个自己的服务类目 比如我选择的是：商业服务 > 软件/建站/技术开发 ......
十五、RocketMQ4.x消费者负载均衡策略
### 一、AllocateMessageQueueAveragely AllocateMessageQueueAveragely就是默认的负载均衡策略，在上个例子已经演示了，可以在[这里](https://www.cnblogs.com/shigongp/p/17575805.html)查看。先分 ......
rabbitmq php 发送延迟消息 java 进行消费
// 延迟队列 php 需要安装好几个扩展 php 生产者 $connection = new AMQPStreamConnection('xxxxx', 5672, 'guest', 'guest'); $channel = $connection->channel(); // 发送消息到交换机， ......
好烦呀为什么rocketmq监听打印的日志没有traceId啊
在使用springboot整合rocketmq使用方便使用注解即可实现消费，十分简洁。随之而来的是问题怎么追踪，一个链路的日志能看到是多么美好的事情。搜寻很久没有找到解决方案，于是自己搞吧！ 大前提：已经在使用spring-cloud-starter-sleuth，日志格式已经含有traceId、s ......
Redis实现消息队列
Redis基于内存,高性能并且提供多种数据结构供使用,那么对于Redis能不能作为消息队列?以及与专业的消息队列,如RocketMQ,Kafka等差距又在哪里? Redis提供多种方式实现消息队列,基于List,基于Pub/Sub等,如今基本广泛使用的是Redis5.0之后推出的Stream流格式, ......
php redis消息队列
1、php如何把key存储在不同的redis分片上 2、php怎么查看redis的key 3、用phpredis操作redis集群支持publish和subscribe吗 4、php2018怎么安装redis 5、redis使用php怎么进行更新 php如何把key存储在不同的redis分片上 ph ......
RocketMQ关键技术整理
form https://gitee.com/apache/rocketmq/tree/master/docs/cn 技术架构 RocketMQ架构上主要分为四部分，如上图所示： Producer：消息发布的角色，支持分布式集群方式部署。Producer通过MQ的负载均衡模块选择相应的Broker集 ......
如何在Java软件工程中使用消息队列和异步处理
摘要：本文将探讨在Java软件工程中如何使用消息队列和异步处理来提高应用程序的性能和可伸缩性。我们将详细介绍消息队列的概念，以及如何将其与Java开发中常用的技术和框架相结合，以实现高效的异步处理。通过本文的学习，读者将能够了解如何利用消息队列和异步处理来优化Java软件工程。 正文： 在当今的软件 ......
RocketMQ 生产端与消费端
参考： en_oc：https://www.cnblogs.com/enoc/p/rocketmq-so-no-roku.html 田守枝（rebalance）：https://cloud.tencent.com/developer/article/1554950 官方文档：https://rock ......