总体介绍
异步任务是非常常见的一种开发模式，它在分布式的开发模式中有很多应用场景如：
- 高并发场景中，我们一般采用把长流程切短，用异步方式去掉可以异步的非关键功能，缩小主流程响应时间，提升用户体验
- 异构系统的集成调用，通过异步任务完成解耦与自动重试
- 分布式系统最终一致性的可选方案
本文将介绍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调用异步任务
- 引入PetShopService
-
修改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独立部署则没有必要，因为全部走远程，不存在类找不到的问题
- 通过配置pamirs.zookeeper.rootPath，确保两组机器都能覆盖所有任务分片，这样不会漏数据
- 通过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
Oinone社区 作者：望闲原创文章，如若转载，请注明出处：https://doc.oinone.top/backend/11480.html
访问Oinone官网:https://www.oinone.top获取数式Oinone低代码应用平台体验
