黑马程序员技术交流社区

标题: 【郑州校区】学成在线-第19天-讲义-分布式事务 八 [打印本页]

---

作者: 我是楠楠    时间: 2020-1-15 14:42
标题: 【郑州校区】学成在线-第19天-讲义-分布式事务 八

【郑州校区】学成在线-第19天-讲义-分布式事务 八

4.7 乐观锁取任务
考虑订单服务将来会集群部署，为了避免任务在1分钟内重复执行，这里使用乐观锁，实现思路如下：
1) 每次取任务时判断当前版本及任务id是否匹配，如果匹配则执行任务，如果不匹配则取消执行。
2) 如果当前版本和任务Id可以匹配到任务则更新当前版本加1.
1、在Dao中增加校验当前版本及任务id的匹配方法

[AppleScript] 纯文本查看 复制代码

 public interface XcTaskRepository extends JpaRepository<XcTask, String> {

//使用乐观锁方式校验任务id和版本号是否匹配，匹配则版本号加1

@Modifying

@Query("update XcTask t set t.version = :version+1 where t.id = :id and t.version =

:version")

public int updateTaskVersion(@Param(value = "id") String id,@Param(value = "version") int

version);

... 

2、在service中增加方法，使用乐观锁方法校验任务

[AppleScript] 纯文本查看 复制代码

 @Transactional

public int getTask(String taskId,int version){

int i = xcTaskRepository.updateTaskVersion(taskId, version);

return i;

}

3、执行任务类中修改

[AppleScript] 纯文本查看 复制代码

 ...

//任务id

String taskId = xcTask.getId();

//版本号

Integer version = xcTask.getVersion();

//调用乐观锁方法校验任务是否可以执行

if(taskService.getTask(taskId, version)>0){

//发送选课消息

taskService.publish(xcTask, xcTask.getMqExchange(),xcTask.getMqRoutingkey());

LOGGER.info("send choose course task id:{}",taskId);

}

... 

---

欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/)

黑马程序员IT技术论坛 X3.2