函数之异步执行

总体介绍

异步任务是非常常见的一种开发模式，它在分布式的开发模式中有很多应用场景如：

• 高并发场景中，我们一般采用把长流程切短，用异步方式去掉可以异步的非关键功能，缩小主流程响应时间，提升用户体验
• 异构系统的集成调用，通过异步任务完成解耦与自动重试
• 分布式系统最终一致性的可选方案

本文将介绍oinone是如何结合Spring+TbSchedule来完成异步任务

构建第一个异步任务

新建PetShopService和PetShopServiceImpl

1、 新建PetShopService定义updatePetShops方法

package pro.shushi.pamirs.demo.api.service;

import pro.shushi.pamirs.demo.api.model.PetShop;
import pro.shushi.pamirs.meta.annotation.Fun;
import pro.shushi.pamirs.meta.annotation.Function;

import java.util.List;

@Fun(PetShopService.FUN_NAMESPACE)
public interface PetShopService {
    String FUN_NAMESPACE = "demo.PetShop.PetShopService";

    @Function
    void updatePetShops(List<PetShop> petShops);
}

2、PetShopServiceImpl实现PetShopService接口并在updatePetShops增加@XAsync注解

package pro.shushi.pamirs.demo.core.service;

import org.springframework.stereotype.Component;
import pro.shushi.pamirs.demo.api.model.PetShop;
import pro.shushi.pamirs.demo.api.service.PetShopService;
import pro.shushi.pamirs.meta.annotation.Fun;
import pro.shushi.pamirs.meta.annotation.Function;
import pro.shushi.pamirs.trigger.annotation.XAsync;
import java.util.List;

@Fun(PetShopService.FUN_NAMESPACE)
@Component
public class PetShopServiceImpl implements PetShopService {
    @Override
    @Function
    @XAsync(displayName = "异步批量更新宠物商店",limitRetryNumber = 3,nextRetryTimeValue = 60)
    public void updatePetShops(List<PetShop> petShops) {
        new PetShop().updateBatch(petShops);
    }
}

a. displayName = "异步批量更新宠物商店"，定义异步任务展示名称
b. limitRetryNumber = 3，定义任务失败重试次数，，默认：-1不断重试
c. nextRetryTimeValue = 60，定义任务失败重试的时间数，默认：3
d. nextRetryTimeUnit，定义任务失败重试的时间单位，默认：TimeUnitEnum.SECOND
e. delayTime，定义任务延迟执行的时间数，默认：0
f. delayTimeUnit，定义任务延迟执行的时间单位，默认：TimeUnitEnum.SECOND

修改PetShopBatchUpdateAction调用异步任务

1. 引入PetShopService

2. 修改conform方法，调用petShopService.updatePetShops方法

   package pro.shushi.pamirs.demo.core.action;
   @Model.model(PetShopBatchUpdate.MODEL_MODEL)
   @Component
   public class PetShopBatchUpdateAction {
   @Autowired
   private PetShopService petShopService;
   
   @Action(displayName = "确定",bindingType = ViewTypeEnum.FORM,contextType = ActionContextTypeEnum.SINGLE)
   public PetShopBatchUpdate conform(PetShopBatchUpdate data){
           List<PetShop> shops = ArgUtils.convert(PetShopProxy.MODEL_MODEL, PetShop.MODEL_MODEL,proxyList);
          // 调用异步任务
           petShopService.updatePetShops(shops);
       });
       return data;
   }
   }

不同应用如何隔离执行单元

在schedule跟模块部署一起的时候，多模块独立boot的情况下，需要做必要的配置。如果schedule独立部署则没有必要，因为全部走远程，不存在类找不到的问题

1. 通过配置pamirs.zookeeper.rootPath，确保两组机器都能覆盖所有任务分片，这样不会漏数据
2. 通过pamirs.event.schedule.ownSign来隔离。确保两组机器只取各自产生的数据，这样不会重复执行数据

   pamirs:
   zookeeper:
   zkConnectString: 127.0.0.1:2181
   zkSessionTimeout: 60000
   rootPath: /demo
   event:
   enabled: true
   schedule:
     enabled: true
     ownSign: demo
   rocket-mq:
     namesrv-addr: 127.0.0.1:9876