Disruptor+Spring的Event解耦业务

迷南。 2022-10-03 00:59 260阅读 0赞

1.  Disruptor: 开源的并发框架,能够在无锁的情况下实现网络的Queue并发操作,其他更多[详情介绍][Link 1]
2.  本common包封装的`Disruptor`与`Spring的Event`事件组合，实现业务在JVM内解耦。  
    
3.  引入disruptor pom依赖:  
    
    
        <disruptor.version>3.4.2</disruptor.version>
           
            <dependency>
                <groupId>com.lmax</groupId>
                <artifactId>disruptor</artifactId>
                <version>${disruptor.version}</version>
            </dependency>
4.  启动disruptor:  
    
    
        // spring容器初始化时，启动disruptor
        @Component
        public class ConfigInit implements InitializingBean
        {
            @Autowired
            private DisruptorProducer disruptorProducer;
        
            @Override
            public void afterPropertiesSet()
            {
                disruptorProducer.doStart();
            }
        }
5.  生产者调用:  
      
    `DisruptorProducer.send(BasisData data)`方法  
    
    
        // 数据数据定义
         public ServiceData extends BasisData{
            // field
            // setter and getter
         }
         
         // 注入DisruptorProducer
         @Autowired
         private DisruptorProducer disruptorProducer;
         
         @Test
         public void testSend(){
              ServiceData data = new ServiceData();
              // 设置事件类型，可预定义在EventEnum枚举类中，一个String类型
              data.setEvent(EventEnum.LOG_EVENT.getEvent());
              // 发送数据
              disruptorProducer.send(data);
         }
6.  业务消费者：  
      
    实现`org.springframework.context.ApplicationListener<ServiceEvent>`的`onApplicationEvent(ServiceEvent serviceEvent)`方法  
    
    
        // event消费者实现
         @Component
         public class LogEventEvent implements ApplicationListener<ServiceEvent>{
             
             // 可以使用spring的异步实现@Async注解，需要配合启动类中添加 @EnableAsync注解 开启异步的支持
             @Async
             @Override
             public void onApplicationEvent(ServiceEvent event)
             {
                 // 这个event事件名称要跟发送的时候事件名称一样的
                 if (EventEnum.LOG_EVENT.getEvent().equals(event.getEvent()))
                 {
                     ServiceData serviceData = (ServiceData) event.getSource();
                     // 进一步业务逻辑处理 todo
                 }
             }
         }

`严重警告：ringBufferSize的值设定需要保持理性的数量，环形队列是等着被替换而不是被回收，设置太大会撑爆你设定的JVM内存，最终导致OLD占满，接下来就是无限循环的FGC`  
源代码：[gitHub地址][gitHub]

[Link 1]: http://ifeve.com/disruptor/
[gitHub]: https://github.com/Xlinlin/SpringCloud-Demo/tree/master/SpringCloud-Common/src/main/java/com/xiao/springcloud/demo/common/disruptor