快捷導(dǎo)航

SpringBoot實現(xiàn)異步事件驅(qū)動的方法

更新時間：2021年06月28日 11:35:12 作者：飄渺Jam

本文主要介紹了SpringBoot實現(xiàn)異步事件驅(qū)動的方法，文中通過示例代碼介紹的非常詳細，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧

Spring事件驅(qū)動

spring事件驅(qū)動由3個部分組成

ApplicationEvent：表示事件本身，自定義事件需要繼承該類，用來定義事件
ApplicationEventPublisher：事件發(fā)送器，主要用來發(fā)布事件
ApplicationListener：事件監(jiān)聽器接口，監(jiān)聽類實現(xiàn)ApplicationListener 里onApplicationEvent方法即可，也可以在方法上增加@EventListener以實現(xiàn)事件監(jiān)聽。

實現(xiàn)Spring事件驅(qū)動一般只需要三步：

自定義需要發(fā)布的事件類，需要繼承ApplicationEvent類
使用ApplicationEventPublisher來發(fā)布自定義事件
使用@EventListener來監(jiān)聽事件

這里需要特別注意一點，默認情況下事件是同步的。即事件被publish后會等待Listener的處理。如果發(fā)布事件處的業(yè)務(wù)存在事務(wù)，監(jiān)聽器處理也會在相同的事務(wù)中。如果需要異步處理事件，可以onApplicationEvent方法上加@Aync支持異步或在有@EventListener的注解方法上加上@Aync。

源碼實戰(zhàn)

創(chuàng)建事件

public class ProductEvent extends ApplicationEvent {
    public ProductEvent(Product product) {
        super(product);
    }
}

發(fā)布事件

@Service
public class ProductServiceImpl implements IproductService {
 ...
    @Autowired
    private ApplicationEventPublisher publisher;
 
    @Override
    @Transactional(rollbackFor = Exception.class)
    public void saveProduct(Product product) {
  productMapper.saveProduct(product); 
        //事件發(fā)布
        publisher.publishEvent(product);
    }
    ...
}

事件監(jiān)聽

@Slf4j
@AllArgsConstructor
public class ProductListener {

 private final NotifyService notifyServcie;

 @Async
 @Order
 @EventListener(ProductEvent.class)
 public void notify(ProductEvent event) {
  Product product = (Product) event.getSource();
  notifyServcie.notify(product, "product");
 }
}

在SpringBoot啟動類上增加@EnableAsync 注解

@Slf4j
@EnableSwagger2
@SpringBootApplication
@EnableAsync
public class ApplicationBootstrap {
...
}

使用了Async后會使用默認的線程池SimpleAsyncTaskExecutor，一般我們會在項目中自定義一個線程池。

@Configuration
public class ExecutorConfig {
    /** 核心線程數(shù) */
    private int corePoolSize = 10;
    /** 最大線程數(shù)  */
    private int maxPoolSize = 50;
    /** 隊列大小  */
    private int queueCapacity = 10;
    /** 線程最大空閑時間   */
    private int keepAliveSeconds = 150;

    @Bean("customExecutor")
    public Executor myExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(corePoolSize);
        executor.setMaxPoolSize(maxPoolSize);
        executor.setQueueCapacity(queueCapacity);
        executor.setThreadNamePrefix("customExecutor-");
        executor.setKeepAliveSeconds(keepAliveSeconds);

        // rejection-policy：當(dāng)pool已經(jīng)達到max size的時候，如何處理新任務(wù)
        // CALLER_RUNS：不在新線程中執(zhí)行任務(wù)，而是由調(diào)用者所在的線程來執(zhí)行
        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
        executor.initialize();
        return executor;
    }
}

到此這篇關(guān)于SpringBoot實現(xiàn)異步事件驅(qū)動的方法的文章就介紹到這了,更多相關(guān)SpringBoot 異步事件驅(qū)動內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: