分布式开放消息系统(RocketMQ)的原理与实践 RocketMQ基础:https://github.com/apache/rocketmq/tree/rocketmq-all-4.5.1/docs/cn 分布式消息系统作为实现分布式系统可扩展、可伸缩性的关键组件,需要具有高吞吐量、高可用等特点。 ...
分类:
其他好文 时间:
2019-12-02 17:13:07
阅读次数:
131
一.RabbitMQ的介绍 RabbitMQ是消息中间件的一种,消息中间件即分布式系统中完成消息的发送和接收的基础软件.这些软件有很多,包括ActiveMQ(apache公司的),RocketMQ(阿里巴巴公司的,现已经转让给apache). 消息中间件的工作过程可以用生产者消费者模型来表示.即,生 ...
分类:
编程语言 时间:
2019-12-01 20:37:14
阅读次数:
86
目录 一、消息中间件相关知识... 1 1、概述... 1 2、消息中间件的组成... 1 3 消息中间件模式分类... 2 4 消息中间件的优势... 3 5 消息中间件应用场景... 4 6 消息中间件常用协议... 6 7 常见消息中间件MQ介绍... 7 7.1 RocketMQ.. 7 7 ...
分类:
其他好文 时间:
2019-11-30 21:00:17
阅读次数:
120
@ "TOC" 1、抛出问题 一个新的消费组订阅一个已存在的Topic主题时,消费组是从该Topic的哪条消息开始消费呢? 首先翻阅DefaultMQPushConsumer的API时,setConsumeFromWhere(ConsumeFromWhere consumeFromWhere)API ...
分类:
其他好文 时间:
2019-11-28 01:01:44
阅读次数:
95
Notify(2007) >Napoli(2010) >MetaQ(2011) >RocketMQ(2012) 第一代的Notify主要使用了推模型,解决了事务消息。 第二代的MetaQ主要使用了拉模型,解决了顺序消息和海量堆积。 RocketMQ基于长轮询的拉取方式,兼有两者的优点。 ...
分类:
其他好文 时间:
2019-11-25 09:13:44
阅读次数:
44
MQ消息事务 RocketMQ 先说说MQ的分布式事务,RocketMq在4.3版本已经正式宣布支持分布式事务,在选择Rokcetmq做分布式事务请务必选择4.3以上的版本。 事务消息作为一种异步确保型事务, 将两个事务分支通过 MQ 进行异步解耦,RocketMQ 事务消息的设计流程同样借鉴了两阶 ...
分类:
其他好文 时间:
2019-11-23 16:42:17
阅读次数:
79
一、消息队列概述消息队列中间件是分布式系统中重要的组件,主要解决应用解耦,异步消息,流量削锋等问题,实现高性能,高可用,可伸缩和最终一致性架构。目前使用较多的消息队列有ActiveMQ,RabbitMQ,ZeroMQ,Kafka,MetaMQ,RocketMQ 二、消息队列应用场景以下介绍消息队列在 ...
分类:
其他好文 时间:
2019-11-20 19:18:21
阅读次数:
62
编者注:Netty是Java领域有名的开源网络库,特点是高性能和高扩展性,因此很多流行的框架都是基于它来构建的,比如我们熟知的Dubbo、Rocketmq、Hadoop等。本文就netty线程模型展开分析讨论下 : ) IO模型 BIO:同步阻塞IO模型; NIO:基于IO多路复用技术的“非阻塞同步 ...
分类:
编程语言 时间:
2019-11-17 10:28:47
阅读次数:
86
使用 netty 监听端口 接收请求 分发请求 broker 启动时,把不同类型的请求对应到各自的处理器 不同的线程池处理不同的请求,做了很好的隔离。 ...
分类:
其他好文 时间:
2019-11-16 19:21:25
阅读次数:
53