SpringBoot使用异步线程池实现生产环境批量数据推送

 

前言

---

• 编写异步服务

  /**
   * 异步方法的服务, 不影响主程序运行。
   */
  @Service
  public class AsyncService {
  
      private final Logger log = LoggerFactory.getLogger(AsyncService.class);
  
      /**
       * 发送短信
       */
      @Async("sendMsgExecutor")
      public void sendMsg(String access_token, Consult item, Map<String, String> configMap) {
          // 此处编写发送短信业务
          // 1、buildConsultData();
          // 2、sendMsg();
      }
  
      /**
       * 发送微信订阅消息
       */
      @Async
      public void sendSubscribeMsg(String access_token, Consult item, Map<String, String> configMap) {
          // 此处编写发送微信订阅消息业务
          // 1、buildConsultData();
          // 2、sendSubscribeMsg();
      }
  
      /**
       * 数据并上报
       */
      @Async("dataCollectionExecutor")
      public void buildAndPostData(String access_token, Consult item, Map<String, String> configMap) {
          // 此处编写上报业务，如拼接数据，然后执行上报。
          // 1、buildConsultData();
          // 2、postData();
      }
  }