最近2018中文字幕在日韩欧美国产成人片_国产日韩精品一区二区在线_在线观看成年美女黄网色视频_国产精品一区三区五区_国产精彩刺激乱对白_看黄色黄大色黄片免费_人人超碰自拍cao_国产高清av在线_亚洲精品电影av_日韩美女尤物视频网站

如圖所示支付業(yè)務中，用戶支付成功之后，后續(xù)還有很多的業(yè)務流程，但是對于用戶來講是透明的，所以為了提高接口的響應速率，提高用戶體驗，后續(xù)操作都會選擇異步執(zhí)行。

新區(qū)網(wǎng)站建設公司創(chuàng)新互聯(lián),新區(qū)網(wǎng)站設計制作，有大型網(wǎng)站制作公司豐富經(jīng)驗。已為新區(qū)上千余家提供企業(yè)網(wǎng)站建設服務。企業(yè)網(wǎng)站搭建\成都外貿(mào)網(wǎng)站制作要多少錢，請找那個售后服務好的新區(qū)做網(wǎng)站的公司定做！

異步執(zhí)行方式

異步執(zhí)行主體

@Service
public class OrderService {
   public void orderSuccess(){

       // 訂單完成異步任務開啟 可以再統(tǒng)一封裝
       Order order = new Order();
       order.setOrderNo(String.valueOf(System.currentTimeMillis()));
       Map orderSuccessServiceMap = SpringContextUtil.getBeansOfType(OrderSuccessService.class);
       orderSuccessServiceMap.values().forEach(service -> {
           service.orderSuccess(order);
      });
  }
}

異步執(zhí)行接口

public interface OrderSuccessService {
   /**
    * 訂單支付成功
    * @param order
    */
   public CompletableFuture orderSuccess(Order order);
}

@Slf4j
@Service
public class MerchantNoticeServiceImpl implements OrderSuccessService {
   @Override
   @Async("taskExecutor")
   public CompletableFuture orderSuccess(Order order) {
       log.info("{}商戶通知:{}",Thread.currentThread(),order);
       // 返回異步調(diào)用的結(jié)果
       return CompletableFuture.completedFuture(true);
  }
}

@Slf4j
@Service
public class MerchantNoticeServiceImpl implements OrderSuccessService {
   @Override
   @Async("taskExecutor")
   public CompletableFuture orderSuccess(Order order) {
       log.info("{}商戶通知:{}",Thread.currentThread(),order);
       // 返回異步調(diào)用的結(jié)果
       return CompletableFuture.completedFuture(true);
  }
}

@Slf4j
@Service
public class MerchantNoticeServiceImpl implements OrderSuccessService {
   @Override
   @Async("taskExecutor")
   public CompletableFuture orderSuccess(Order order) {
       log.info("{}商戶通知:{}",Thread.currentThread(),order);
       // 返回異步調(diào)用的結(jié)果
       return CompletableFuture.completedFuture(true);
  }
}

自定義線程池，線程池隔離，開啟異步任務執(zhí)行

@Configuration // 配置類
@EnableAsync // @Async注解能夠生效
public class TaskConfiguration {
   @Bean("taskExecutor")
   public Executor taskExecutor(){
       ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
       // 線程池創(chuàng)建時候初始化的線程數(shù)
       executor.setCorePoolSize(5);
       // 線程池最大的線程數(shù)，只有在緩沖隊列滿了之后，才會申請超過核心線程數(shù)的線程
       executor.setMaxPoolSize(10);
       // 用來緩沖執(zhí)行任務的隊列
       executor.setQueueCapacity(200);
       // 當超過了核心線程之外的線程，在空閑時間到達之后會被銷毀
       executor.setKeepAliveSeconds(60);
       // 可以用于定位處理任務所在的線程池
       executor.setThreadNamePrefix("taskExecutor-orderSuccess-");
       // 這里采用CallerRunsPolicy策略，當線程池沒有處理能力的時候，該策略會直接在execute方法的調(diào)用線程中運行被拒絕的任務；
       // 如果執(zhí)行程序已關(guān)閉，則會丟棄該任務
       executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
       // 設置 線程池關(guān)閉 的時候 等待 所有任務都完成后，再繼續(xù) 銷毀 其他的 Bean，
       // 這樣這些 異步任務 的 銷毀 就會先于 數(shù)據(jù)庫連接池對象 的銷毀。
       executor.setWaitForTasksToCompleteOnShutdown(true);
       // 該方法用來設置線程池中 任務的等待時間，如果超過這個時間還沒有銷毀就 強制銷毀，以確保應用最后能夠被關(guān)閉，而不是阻塞住。
       executor.setAwaitTerminationSeconds(60);
       return executor;
  }
}

Spring Event實現(xiàn)發(fā)布/訂閱模式

自定義事件：通過繼承ApplicationEve?

nt，并重寫構(gòu)造函數(shù)，實現(xiàn)事件擴展。

public class OrderApplicationEvent extends ApplicationEvent {
   public OrderApplicationEvent(OrderData orderData){
       super(orderData);
  }
}

定義事件的消息體

@Data
public class OrderData {
   /**
    * 訂單號
    */
   private String orderNo;
}

事件監(jiān)聽

@Slf4j
@Service
public class MerchantNoticeListener {
   @Async("asyncEventTaskExecutor")
   @EventListener
   public CompletableFuture orderSuccess(OrderApplicationEvent event) {
       log.info("{}商戶通知:{}",Thread.currentThread(),event);
       // 返回異步調(diào)用的結(jié)果
       return CompletableFuture.completedFuture(true);
  }
}

@Slf4j
@Service
public class UserNoticeListener implements ApplicationListener {
   @Override
   @Async("asyncEventTaskExecutor")
   public void onApplicationEvent(OrderApplicationEvent event) {
       log.info("{}用戶通知:{}",Thread.currentThread(),event);
  }
}

@Slf4j
@Service
public class UserNoticeListener implements ApplicationListener {
   @Override
   @Async("asyncEventTaskExecutor")
   public void onApplicationEvent(OrderApplicationEvent event) {
       log.info("{}用戶通知:{}",Thread.currentThread(),event);
  }
}

@Slf4j
@Service
public class UserNoticeListener implements ApplicationListener {
   @Override
   @Async("asyncEventTaskExecutor")
   public void onApplicationEvent(OrderApplicationEvent event) {
       log.info("{}用戶通知:{}",Thread.currentThread(),event);
  }
}

自定義線程池

@Configuration
@Slf4j
@EnableAsync // @Async注解能夠生效
public class AsyncConfiguration implements AsyncConfigurer {
   @Bean("asyncEventTaskExecutor")
   public ThreadPoolTaskExecutor executor(){
       //Spring封裝的一個線程池
       ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
       executor.setCorePoolSize(5);
       executor.setMaxPoolSize(50);
       executor.setQueueCapacity(30);
       executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
       executor.setThreadNamePrefix("asyncEventTaskExecutor--orderSuccess-");
       executor.initialize();
       return executor;
  }

   @Override
   public Executor getAsyncExecutor(){
       return executor();
  }

   /**
    * 異常處理
    * @return
   @Override
   public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler(){
       return (ex, method, params) -> log.error(String.format("[async] task{} error:", method), ex);
  }
}

事件發(fā)布

@Service
@Slf4j
public class OrderEventService {
   private final ApplicationEventPublisher applicationEventPublisher;

   public OrderEventService(ApplicationEventPublisher applicationEventPublisher){
       this.applicationEventPublisher = applicationEventPublisher;
  }
   public void success(){
       OrderData orderData = new OrderData();
       orderData.setOrderNo(String.valueOf(System.currentTimeMillis()));
       // 消息
       OrderApplicationEvent orderApplicationEvent = new OrderApplicationEvent(orderData);
       // 發(fā)布事件
       applicationEventPublisher.publishEvent(orderApplicationEvent);
  }
}

寫在最后：不管是否基于spring boot 的發(fā)布訂閱模型，最終都是開啟了線程執(zhí)行任務，和使用第三方的MQ消息組件，問題在于重啟服務器或者未知原因崩潰的時候，消息的恢復機制要自行處理。

建議使用在一些邊緣業(yè)務，比如記錄日志，這些要求沒有那么高的業(yè)務。

網(wǎng)頁題目：SpringBoot：Event實現(xiàn)發(fā)布/訂閱模式
本文URL：http://m.fisionsoft.com.cn/article/cooiigo.html