买完网站怎么建设,网站开发和网络设计有什么区别,简述建立网站的步骤,国内seo排名Disruptor 是苹国外厂本易公司LMAX开发的一个高件能列#xff0c;研发的初夷是解决内存队列的延识问顾在性能测试中发现竟然与10操作处于同样的数量级)#xff0c;基于Disruptor开发的系统单线程能支撑每秒600万订单#xff0c;2010年在QCn演讲后#xff0c;获得了业界关注… Disruptor 是苹国外厂本易公司LMAX开发的一个高件能列研发的初夷是解决内存队列的延识问顾在性能测试中发现竟然与10操作处于同样的数量级)基于Disruptor开发的系统单线程能支撑每秒600万订单2010年在QCn演讲后获得了业界关注201年企业应用软件专家Martin Fower专门撰写长文介绍。同年它还获得了Oradle官方的Duke大奖。目前包括Apache StomCame、 L0g4 2在内的很多知名项目都应用了Disrupior以获取高性能。注意这里所说的队列是系统内部的内存队列而不是Kaka这样的分布式队列。 前两篇介绍了Disruptor【数据结构】Disruptor环形数组无锁并发框架阅读_wenchun001的博客-CSDN博客
【并发编程】ShenyuAdmin里面数据同步用到的无锁环形队列LMAX Disruptor并发框架_wenchun001的博客-CSDN博客
今天开始依次从引用包到编码步骤说明如下
引用依赖 dependenciesdependencygroupIdcom.lmax/groupIdartifactIddisruptor/artifactIdversion3.3.4/version/dependency/dependencies 1.构建消息载体(事件)
单生产者单消费者模式
1创建Event(消息载体/事件)和EventFactory (事件工厂)
2创建 OrderEvent类这个类将会被放入环形队列中作为消息内容。创建OrderEventFactory类用于创建OrderEvent 事件
Data
public class OrderEvent2 {private long value;private String name:
}
public class OrderEventFactory implements EventFactoryorderEvent {Overridepublic OrderEvent newInstance(){return new OrderEvent();}
}2.构建生产者
创建 OrderEventProducer 类它将作为生产者使 用
public class OrderEventProducer {//事件队列private RingBufferOrderEvent ringBuffer;public OrderEventProducer(RingBufferOrderEvent ringBuffer)( this,ringBuffer ringBuffer;}public void onData(long value,String name) {// 获取事件队列 的下一个槽long sequence ringBuffer.next();try {//获取消息 (事件)OrderEvent orderEvent ringBuffer.get(sequence);// 写入消息数据orderEvent.setValue(value):orderEvent.setName(name);}catch (Exception e){//异常}finally {//发布事件rringBuffer.publish(sequence);}}
}3.构建消费者 4.生产消息消费消息的测试 public static void main(String[] args) throws Exception {//创建disruptorDisruptorOrderEvent disruptor new Disruptor(new OrderEventFactory()ringBufferSize:124 * 124Executors.defaultThreadFactory(), ProducerType.SINGLE,//单生产者new YieldingwaitStrategy() //等待策略);//设置消费者用于处理RingBuffer的事件 disruptor.handleEventswith(new OrderEventHandler());//设置多消费者,消息会被重复消费//disruptor.handleEventswith(new OrderEventHandler(),new OrderEventHandler());//设置多消费者 消费者要实现workHandLer接口一条消息只会被一个消费者消费//disruptor.handleEventsWithworkerPool(new OrderEventHandler() new OrderEventHandler());//启动disruptordisruptor.start();//创建ringbuffer容器RingBufferOrderEvent ringBuffer disruptor.getRingBuffer();//创建生产者OrderEventProducer eventProducer new OrderEventProducer(ringBuffer);// 发送消息for(int i0;i10;i){eventProduceronData(i, 消息1);}disruptor.shutdown();} 多生产者的案例
//创建disruptorDisruptorOrderEvent disruptor new Disruptor(new OrderEventFactory()ringBufferSize:124 * 124Executors.defaultThreadFactory(), ProducerType.MULIT,//多生产者new YieldingwaitStrategy() //等待策略); 消费者优先级模式 在实际场景中我们通常会因为业务逻而形成一条消费链比如一个消息必须由 消费者A-消费者B-消费者C 的顺序依次进行消费。在配置消费者时可以通过.then 方法去实现顺序消费。 I disruptor.handleEventswith(new OrderEventHandler()) then(new OrderEventHandler()) then(new OrderEventHandler()); handleEventsWith 与 handleEventsWithworkerPool 都是支持hen 的它们可以结合使用。比可以按照消费者A 消费者B 消费者C)-消费者D 的消费项序 1 disruptor.handleEventswith(new OrderEventHandler()) thenHandleEventsWithworkerPool(new OrderEventHandler() new OrderEventHandler()) then(new OrderEventHandler());
