0
点赞
收藏
分享

微信扫一扫

zookeeper分布式锁

静守幸福 2022-08-31 阅读 64

zookeeper分布式锁_apache

 

 

zookeeper分布式锁_apache_02

zookeeper分布式锁_spring_03

 

package cn.zh.distributedlock.controller;

import cn.zh.distributedlock.service.OrderService;
import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.recipes.locks.InterProcessMutex;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class TestController {
@Autowired
private OrderService orderService;
@Value("${server.port}")
private String port;
@Autowired
private CuratorFramework curatorFramework;

@PostMapping("/stock/deduct")
public Object reduceStock(Integer id) throws Exception {
InterProcessMutex interProcessMutex=new InterProcessMutex(curatorFramework,"/product_"+id);
try {
interProcessMutex.acquire();
orderService.reduceStock(id);
} catch (Exception e) {
if(e instanceof RuntimeException){
throw e;
}
}finally{
interProcessMutex.release();
}

return "ok:" + port;

}

}

 

举报

相关推荐

0 条评论