提交 0687038f authored 作者: 刘海泉's avatar 刘海泉

增加测试接口

Former-commit-id: 5e451815
上级 0c10a933
package com.clx.performance.controller.temp;
import com.clx.open.sdk.callback.message.OrderChildSyncMessage;
import com.clx.performance.constant.RedissonConstants;
import com.clx.performance.dto.OrderChildExpectDTO;
import com.clx.performance.extranal.transport.TransportService;
import com.clx.performance.feign.TransportFeignService;
......@@ -13,6 +14,8 @@ import com.msl.common.result.Result;
import com.msl.common.utils.DateUtils;
import io.swagger.v3.oas.annotations.Operation;
import lombok.extern.slf4j.Slf4j;
import org.redisson.api.RLock;
import org.redisson.api.RedissonClient;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
......@@ -21,6 +24,7 @@ import org.springframework.web.bind.annotation.RestController;
import jakarta.validation.constraints.NotBlank;
import java.time.LocalDateTime;
import java.util.concurrent.TimeUnit;
/**
* @Author: aiqingguo
......@@ -177,5 +181,33 @@ public class TempController {
}
@Autowired
RedissonClient redissonClient;
@Operation(summary = "测试tryLock", description = "<br>By:刘海泉")
@RequestMapping(value = "/testRealTrace", method = RequestMethod.GET)
public Result<Void> testRedisson() {
RLock lock = null;
try{
lock = redissonClient.getLock("1234567894561233");
boolean flag = lock.tryLock(15, 30, TimeUnit.SECONDS);
if(flag){
log.info("{} 拿到锁了",Thread.currentThread().getName());
}
}catch (Exception e){
log.info(e.getMessage());
}finally {
if (lock != null && lock.isLocked() && lock.isHeldByCurrentThread()) {
lock.unlock();
}
}
return Result.ok();
}
}
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论