在项目中如何使用 Disruptor 做内部消息队列?

您所在的位置:网站首页 java消息队列实现订单 在项目中如何使用 Disruptor 做内部消息队列?

在项目中如何使用 Disruptor 做内部消息队列?

2022-08-11 05:55| 来源: 网络整理| 查看: 265

原创 在项目中如何使用 Disruptor 做内部消息队列? 发布时间:2022-04-29 14:03:28 浏览 826 来源:博学谷 作者:柚子

在项目中如何使用 Disruptor 做内部消息队列?工作中遇到项目使用Disruptor做消息队列 ,不是Kafka也不是rabbitmq;Disruptor有个最大的优点就是快,是开源的。其实生成者到消费者模式是很常见的,通过一些消息队列也可以轻松做到上述的效果。不同的地方在于,Disruptor 是在内存中以队列的方式去实现的,而且是无锁的。

1、Disruptor是什么?

Disruptor 是英国外汇交易公司LMAX开发的一个高性能队列,研发的初衷是解决内存队列的延迟问题。基于 Disruptor 开发的系统单线程能支撑每秒 600 万订单,2010 年在 QCon 演讲后,获得了业界关注。

Disruptor是一个开源的Java框架,它被设计用于在生产者—消费者问题上获得尽量高的吞吐量和尽量低的延迟。从功能上看Disruptor 是实现了“队列”的功能,而且是一个有界队列。那么它的应用场景自然就是“生产者-消费者”模型的应用场合了。

Disruptor是LMAX在线交易平台的关键组成部分,LMAX平台使用该框架对订单处理速度能达到600万TPS,除金融领域之外,其他一般的应用中都可以用到Disruptor,它可以带来显著的性能提升。

其实Disruptor与其说是一个框架不如说是一种设计思路,这个设计思路对于存在“并发、缓冲区、生产者—消费者模型、事务处理”这些元素的程序来说,Disruptor提出了一种大幅提升性能(TPS)的方案。

2、Disruptor 的核心对象是什么?

先从了解 Disruptor 的核心概念开始,来了解它是如何运作的。介绍的概念模型,既是领域对象也是映射到代码实现上的核心对象。

3、Ring Buffer

如其名环形的缓冲区。曾经 RingBuffer 是 Disruptor 中的最主要的对象,但从3.0版本开始,其职责被简化为仅仅负责对通过 Disruptor 进行交换的数据(事件)进行存储和更新。在一些更高级的应用场景中Ring Buffer 可以由用户的自定义实现来完全替代。

4、Sequence Disruptor

通过顺序递增的序号来编号管理通过其进行交换的数据对数据的处理过程总是沿着序号逐个递增处理。一个 Sequence 用于跟踪标识某个特定的事件处理者的处理进度。虽然一个 AtomicLong 也可以用于标识进度,但定义 Sequence 来负责该问题还有另一个目的,那就是防止不同的 Sequence 之间的CPU缓存伪共享问题。

5、Sequencer

Sequencer 是 Disruptor 的真正核心。此接口有两个实现类 SingleProducerSequencer、MultiProducerSequencer ,它们定义在生产者和消费者之间快速、正确地传递数据的并发算法。

6、Sequence Barrier

用于保持对RingBuffer的 main published Sequence 和Consumer依赖的其它Consumer的 Sequence 的引用。Sequence Barrier 还定义了决定 Consumer 是否还有可处理的事件的逻辑。

7、Wait Strategy

定义 Consumer 如何进行等待下一个事件的策略。Disruptor 定义了多种不同的策略,针对不同的场景,提供了不一样的性能表现。

8、Event

在 Disruptor 的语义中,生产者和消费者之间进行交换的数据被称为事件(Event)。它不是一个被 Disruptor 定义的特定类型,而是由 Disruptor 的使用者定义并指定。

9、EventProcessor

EventProcessor 持有特定消费者的 Sequence,并提供用于调用事件处理实现的事件循环。

10、EventHandler

Disruptor 定义的事件处理接口,由用户实现,用于处理事件,是 Consumer 的真正实现。扩展:接私活儿

11、Producer

即生产者只是泛指调用 Disruptor 发布事件的用户代码,Disruptor 没有定义特定接口或类型。

Java开发实战项目 —     申请免费试学名额     —

在职想转行提升,担心学不会?根据个人情况规划学习路线,闯关式自适应学习模式保证学习效果 讲师一对一辅导,在线答疑解惑,指导就业!

觉得不错,顺手分享一下 上一篇: 如何才能快速成为一名Java架构师? 下一篇: 从0搭建后端技术涉及到哪些知识点?

相关推荐 更多

Java是什么 Java是什么?Java开发是什么意思?

Java是什么?Java开发是什么意思?Java是一种开发语言,核心特点跨平台、面向对象。对于开发者来讲Java基本等于Jdk。Java由四部分组成:Java编程语言,即语法;Java文件格式,即各种文件夹、文件的后缀。Java文件格式,即各种文件夹、文件的后缀;Java虚拟机(JVM),即处理*.class文件的解释器;Java应用程序接口(Java API)。

6588

2019-08-08 18:04:13

Java开发Java入门在线学习

自学Java如何才能学好? 自学Java如何才能学好?

Java编程语言被广泛应用于互联网产品开发中,其开发人才需求量很大。很多高校毕业生以及在职人群都想通过学习Java,获得一份高薪的工作岗位。目前想进入Java开发岗位主要通过自学或者通过Java培训的方式。如果自学Java,如何获取相应的自学资源?如何才能学好Java呢?

2914

2019-10-30 18:47:49

Java开发在线学习自学Java

用Java查询个人信息 如何用Java查询个人信息?代码怎么写?

如何用Java查询个人信息?编程写好相应的规则,按照规则执行,在一定程度上大大提高了工作效率,在我们生活中的应用无处不在,当你面临公司大量的人员数据如何准确查询处理你想要的数据呢?

4721

2020-02-11 17:13:36

Java基础Java开发Java课程

Java项目实战心得体会 Java项目开发实战心得体会

企业开发一个项目都是有一整套标准化的可行性流程,这样才能最大程度节约Java项目开发的时间和成本。然而许多Java学习者在学习过程中无法接触到企业真实的开发流程,导致在面试过程中以及初入职场时碰壁。为了避免这种现象出现,博学谷除了进行理论知识的系统培训,还会进行企业级的大型项目实战演练。下面一起来看看学员在Java项目开发实战中的心得体会吧!

3819

2020-07-13 15:28:12

Java开发实战项目学员感言

Java开发工程师 一文说清楚应聘Java开发工程师的基本要求

很多同学来问小谷老师,程序员之间的工资差别为什么那么大,不同等级的程序员分别需要哪些不同的技能,这篇文章小谷老师就以Java为例,讲讲其中的区别。那根据技术水平不同,Java程序员可以分为初级、中级、高级、资深等。不同级别的Java程序员,企业的要求也是有区别。

1572

2021-08-16 18:26:48

Java程序员Java岗位Java开发



【本文地址】


今日新闻


推荐新闻


CopyRight 2018-2019 办公设备维修网 版权所有 豫ICP备15022753号-3