R写给RocketMQ架构应用入门，内容涉及它的设计机理以及推到出来的应用注意事项，入门人员请看。稍微涉及技术细节，留以我设计中间件时参考，将来整理深度文档时会抽取走，入门人员可以无视。以下RocketMQ简称为 RQ，理论部分采用版本为 3.2.4，测试部分采用版本为 3.2.6。MQ 的需求我们对 MQ 的需求，……继续阅读 » dewbay 6年前 (2019-04-12) 2129浏览 0评论0个赞
刷盘机制支持同步刷盘和异步刷盘。为了了解其具体事项，我们以 Commitlog 的存储为例来说明RocketMQ是如何进行磁盘读写。Comitlog#putMessage 首先，主要是将消息写入到 MappedFile,内存映射文件。然后根据刷盘策略刷写到磁盘，入口：CommitLog#putMessage handleDiskFlushCommit……继续阅读 » dewbay 6年前 (2019-04-12) 2369浏览 0评论0个赞
摘要: 原创出处 http://www.iocoder.cn/RocketMQ/message-pull-and-consume-first/ 「芋道源码」欢迎转载，保留摘要，谢谢！本文主要基于 RocketMQ 4.0.x 正式版1、概述2、ConsumeQueue 结构3、ConsumeQueue 存储ReputMe……继续阅读 » dewbay 6年前 (2019-04-12) 2051浏览 0评论0个赞
为了实现分布式系统可扩展、可伸缩性的关键组件，需要具有高吞吐量、高可用等特点。我们很多时候都会考虑将消息系统纳入我们的选择中；比如我一个登录事件，有可能我登录之后需要做很多东西，比如日志，比如发布消息，比如推送，再比如发送代金券等等；这些事件与登录息息相关，但是本质上它们与登录这个事件没有直接的关系，只是在登录事件后，系统按照需求需要去初始化一些东西，或者……继续阅读 » dewbay 6年前 (2019-04-12) 3315浏览 0评论1个赞
1.pom 文件 com.alibaba.rocketmq rocketmq-client 3.2.6 生产者 ：package com.sun.rocketmq.qs;import com.alibaba.rocketmq.client.exception.MQClientExcept……继续阅读 » dewbay 6年前 (2019-04-12) 3134浏览 0评论1个赞
淘宝内部的交易系统使用了淘宝自主研发的 Notify 消息中间件，使用 Mysql 作为消息存储媒介，可完全水平扩容，为了进一步降低成本，我们认为存储部分可以进一步优化，2011 年初，Linkin 开源了 Kafka 这个优秀的消息中间件，淘宝中间件团队在对 Kafka 做过充分 Review 之后，Kafka 无限消息堆积，高效的持久化速度吸引了我们，……继续阅读 » dewbay 6年前 (2019-04-12) 2039浏览 0评论0个赞
普通消息普通消息也叫做无序消息，简单来说就是没有顺序的消息，producer 只管发送消息，consumer 只管接收消息，至于消息和消息之间的顺序并没有保证，可能先发送的消息先消费，也可能先发送的消息后消费。举个简单例子，producer 依次发送 order id 为 1、2、3 的消息到 broker，consumer 接到的消息顺序……继续阅读 » dewbay 6年前 (2019-04-12) 2353浏览 0评论0个赞
最近 RocketMQ 刚刚上生产环境，闲暇之时在这里做一些分享，主要目的是让初学者能快速上手RocketMQ。RocketMQ 是什么Github 上关于 RocketMQ 的介绍：RcoketMQ 是一款低延迟、高可靠、可伸缩、易于使用的消息中间件。具有以下特性：支持发布/订阅（Pub/Sub）和点对点（P2P）消息模型在一个……继续阅读 » dewbay 6年前 (2019-04-12) 1922浏览 0评论0个赞
一、整体介绍 在 RocketMQ 里，有以下几个核心的模块：Producer，Consumer，Broker，NameSrv。他们之间的关系如下： 先简单了解一下各个模块的功能，下面会有章节详细介绍各个模块的功能。Producer 和 Consumer 很好理解，顾名思义就是生产者和消费者，生产者负责生产消息，消费者负责消费消息……继续阅读 » dewbay 6年前 (2019-04-12) 3451浏览 0评论0个赞
Step 8: 使用 Kafka Stream 来处理数据Kafka Stream是kafka的客户端库，用于实时流处理和分析存储在kafka broker 的数据，这个快速入门示例将演示如何运行一个流应用程序。一个 WordCountDemo 的例子（为了方便阅读，使用的是 java8 lambda 表达式）KTable wordCoun……继续阅读 » dewbay 6年前 (2019-04-12) 3294浏览 0评论1个赞
