disruptor教程

     

使用LMAX/Disruptor构建高扩展性的交易引擎的经验分享

2705 1 2K
Koinex的贸易引擎使用LMAX架构的许多原则设计。这使我们能够在高峰时段承受大量负荷。在快速增长的财务系统中,清洁和可扩展架构的重要性对于更好的可扩展性和更快的执行非常重要。LMAX架构帮助我在K.

最快的微服务分布式事务?

1 4341 1 5K
本文介绍了Adaptive如何在应用层面实现分布式事务,也就是如何在应用服务之间的实现分布式共识算法,这对于微服务的分布式柔性事务有很大参考意义。Adaptive基于此技术研发了高性能、弹性、实时金融.

disruptor里的一个Event能由多个Handler处理么?

1 1380

请问disruptor里的一个Event能由多个Handler处理么?比如我现在触发一个注册Event,我需要有一个Handler来存储信息,一个Hanlder来发邮件等等。.

使用Disruptor 遇到问题,eventHander可能读不到事件

1369 9K

代码使用disruptor 3.2.1, 使用多生产者单消费者模式,目的是为把并发写通过disruptor转成单写刚开始没问题, 运行一会后,publish event 后,evenHandler不会.

Disruptor 可以动态增加消费者吗

4 3141

jdon里有不少关于Disruptor的讨论,我有一个问题就是:它可以动态增加消费者吗[该贴被abaddoncoder于2015-04-15 09:04修改过][该贴被abaddoncoder于201.

Disruptor单写原则的疑惑

5 2144 1

我的理解是:单写原则适用于单机情况,并且只能启动一个服务实例,这种情况下的确可以做到单线程写入操作。但是如果是集群的环境下,或者是单机启动多个服务实例,如何保证单写原则呢?进一步考虑如果是集群环境下,.

Disruptor牛在哪?

1 633

据说Disruptor一秒钟能处理600万订单,它为什么会这么快,一直不能理解,另外,这个框架不是对外宣称无锁的么,但是读了源码发现里面是有用到锁的。求banq大神解答.

akka接收返回结果

2 3216

最近在学习akka这个框架,有个地方不太明白,想寻求下帮助,在官方给的例子中(如下代码):public class Greeting implements Serializable { public.

如何让Java以光的速度跨线程通信?

6 3285 6 11K
一个比Disruptor吞吐量等性能指标更好的框架,使用Railway算法,将线程之间的消费发送参考现实生活中火车在站点之间搬运货物。目标起始于一个简单的想法:创建一个开发人员友好的,简单的,轻量级线.

Spring的reactor框架引入了Disruptor

5727 1

https://github.com/reactor/reactor/wiki/ProcessorSpring使用Processor 对LMAX Disruptor RingBuffer进行了抽象,看.

Disruptor中Sequencer过大怎么办?

2 1457

Sequencer的大小如果超过了Long.MAX_VALUE怎么办?这个只能靠重启解决吗?这个逻辑上总是有可能的啊.

Disruptor 问题请教

3 998 2K

bang ,你好:我在移植Disruptor到.net版本的是遇到个问题,如果你看到这个帖子望指教下哦,谢谢。问题描述:类,MultiProducerSequencer 代码片段如下:/** .

Log4j 2使用Disruptor实现异步日志

2 8277
Log4j 2 Asynchronous Loggers for Low-Latency Logging - Apache Log4j 2Log4j 2使用Disruptor实现异步日志,获得低延时和.

OneToOneConcurrentArrayQueue :单个producer/consumer队列的无锁高性能

3 3127 3
无锁算法能获得无限的性能Lock-Free Algorithms For Ultimate Performance一文阐述了在一个队列在单个producer/consumer(只有一个生产者和一个消费.

Scala + Akka 是处理架构的IaaS

1772

Scala和Go在互掐,夺取未来BIG thing话语权,前段时间看到一篇说,Scala已经suck吸干,Go才是并行编程王者,今天看到这篇High Scalability - High Scalab.