本文将对 RocketMQ-Exporter 的设计实现做一个简单的介绍，读者可以通过本文了解到 RocketMQ-Exporter 的实现过程，以及通过 RocketMQ-Exporter 来搭建自己的 RocketMQ 监控系统。该项目的 git 地址 https://github.com/ap ...
分类：
其他好文 时间：
2020-05-15 11:52:08
阅读次数：
74
高效原因 1. CommitLog顺序写, 存储了MessagBody、message key、tag等信息 2. ConsumeQueue随机读 + 操作系统的PageCache + 零拷贝技术ZeroCopy 2.1 零拷贝技术 例子：将一个File读取并发送出去（Linux有两个上下文，内核态 ...
分类：
其他好文 时间：
2020-05-14 22:43:10
阅读次数：
94
一：消息偏移量Offset 1. 什么是offset 1. message queue是无限长的数组，一条消息进来下标就会涨1，下标就是offset，消息在某个MessageQueue里的位置，通过offset的值可以定位到这条消息，或者指示Consumer从这条消息开始向后处理 2. messag ...
分类：
其他好文 时间：
2020-05-14 22:36:27
阅读次数：
112
ubuntu 安装 rocketmq 1、安装 rocketmq首先要有java以及maven环境，这里略过，可参考 https://www.cnblogs.com/xiaobaoTribe/p/11315011.html 安装JDK 1.8 https://www.cnblogs.com/xiao ...
分类：
系统相关 时间：
2020-05-14 19:19:41
阅读次数：
77
前言消息中间件本质上就是一种很简单的数据结构——队列，但是一条队列肯定是当不成中间件的，你必须要考虑性能、容灾、可靠性等等因素。这也给我的写作提供了一些思路，我将从队列开始，给你演示一条队列是如何进化成一个靠谱的中间件的。消息中间件的实现有很多，有新贵Kafka、RocketMq，也有老牌劲旅RabbitMq和ActiveMq，不过我最后选择了Nsq来讲解，因为它极简、清爽，用起来舒服，讲起来也好
分类：
其他好文 时间：
2020-05-14 01:54:02
阅读次数：
76
1、失败重试策略： 通过查看源码，消息消费的状态，有2种，一个是成功（CONSUME_SUCCESS），一个是失败&稍后重试（RECONSUME_LATER） 在启动broker的过程中，可以观察到上图日志，你会发现RECONSUME_LATER的策略：如果消费失败，那么1S后再次消费，如果失败，那 ...
分类：
其他好文 时间：
2020-05-11 18:25:37
阅读次数：
60
Spring Cloud Alibaba各组件版本关系 | Spring Cloud Alibaba Version | Sentinel Version | Nacos Version | RocketMQ Version | Dubbo Version | Seata Version | | | ...
分类：
编程语言 时间：
2020-05-08 09:33:23
阅读次数：
94
一、RocketMQ组成 1、NameServer 协调者，类似zookeeper，基于内存完成2、Broker 实例3、Topic 4、tag topic里的标签5、Message Queue topic里的队列6、offset 标记消息在Message Queue里的位置,标记消费读取时自增长 ...
分类：
其他好文 时间：
2020-05-07 19:30:48
阅读次数：
70
为什么使用spring stream ? spring stream 是用来做消息队列发送消息使用的。他隔离了各种消息队列的区别，使用统一的编程模型来发送消息。 目前支持： rabbitmq kafka rocketmq 启动rocketmq rocketmq 支持windows start mqn ...
分类：
编程语言 时间：
2020-05-06 18:05:55
阅读次数：
77
RabbitMQ 即一个消息队列，主要是用来实现应用程序的异步和解耦，同时也能起到消息缓冲，消息分发的作用。 消息中间件在互联网公司的使用中越来越多，刚才还看到新闻阿里将RocketMQ捐献给了apache，当然了今天的主角还是讲RabbitMQ。消息中间件最主要的作用是解耦，中间件最标准的用法是生 ...
分类：
编程语言 时间：
2020-05-05 18:09:04
阅读次数：
65
