From b7e8c43b5f398bc02166a0ed66b77fe122a4e4b6 Mon Sep 17 00:00:00 2001
From: zhaolongfei <2651195677@qq.com>
Date: Wed, 21 Aug 2024 10:22:08 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A4=84=E7=90=86study=E6=8E=A5=E5=8F=A3,?=
=?UTF-8?q?=E6=B7=BB=E5=8A=A0=E6=8E=A5=E5=8F=A3=E8=AE=BF=E9=97=AE=E9=99=90?=
=?UTF-8?q?=E5=88=B6=E6=AC=A1=E6=95=B0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
servers/boe-server-all/pom.xml | 6 +++++-
.../src/main/java/com/xboe/api/vo/Result.java | 3 +++
.../xboe/school/study/api/StudyCourseApi.java | 19 ++++++++++++++++---
3 files changed, 24 insertions(+), 4 deletions(-)
diff --git a/servers/boe-server-all/pom.xml b/servers/boe-server-all/pom.xml
index 8e84c962..4b5efdba 100644
--- a/servers/boe-server-all/pom.xml
+++ b/servers/boe-server-all/pom.xml
@@ -84,7 +84,11 @@
xboe-module-es
1.0.0
-
+
+ net.jodah
+ expiringmap
+ 0.5.10
+
it.sauronsoftware
jave
diff --git a/servers/boe-server-all/src/main/java/com/xboe/api/vo/Result.java b/servers/boe-server-all/src/main/java/com/xboe/api/vo/Result.java
index 8f837786..a2c610f7 100644
--- a/servers/boe-server-all/src/main/java/com/xboe/api/vo/Result.java
+++ b/servers/boe-server-all/src/main/java/com/xboe/api/vo/Result.java
@@ -24,4 +24,7 @@ public class Result {
private int totalPage;
private List list;
+ public static Object error(String s) {
+ return "500 服务异常";
+ }
}
\ No newline at end of file
diff --git a/servers/boe-server-all/src/main/java/com/xboe/school/study/api/StudyCourseApi.java b/servers/boe-server-all/src/main/java/com/xboe/school/study/api/StudyCourseApi.java
index 9e875451..7991bd0c 100644
--- a/servers/boe-server-all/src/main/java/com/xboe/school/study/api/StudyCourseApi.java
+++ b/servers/boe-server-all/src/main/java/com/xboe/school/study/api/StudyCourseApi.java
@@ -6,13 +6,16 @@ import java.util.concurrent.TimeUnit;
import java.util.stream.Collectors;
import cn.hutool.core.util.ArrayUtil;
+import com.alibaba.nacos.shaded.com.google.common.util.concurrent.RateLimiter;
import com.xboe.api.ThirdApi;
import com.xboe.api.vo.*;
import com.xboe.module.course.vo.TeacherVo;
import com.xboe.module.usergroup.entity.UserGroupItem;
import com.xboe.module.usergroup.service.IUserGroupService;
+import com.xboe.school.aspect.LimitRequest;
import org.apache.commons.lang3.ArrayUtils;
import org.apache.commons.lang3.StringUtils;
+import org.aspectj.lang.annotation.Aspect;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.web.bind.annotation.GetMapping;
@@ -95,7 +98,12 @@ public class StudyCourseApi extends ApiBaseController{
@Autowired
StringRedisTemplate redisTemplate;
-
+ private static final RateLimiter rateLimiter = RateLimiter.create(1.0);
+ public void someApi() {
+ rateLimiter.acquire(); // 请求之前获取许可
+ // 你的业务逻辑
+ log.info("Request processed at " + System.currentTimeMillis());
+ }
/**
* 用于查询课程的学习记录
* @param pager
@@ -292,6 +300,7 @@ public class StudyCourseApi extends ApiBaseController{
* @param
* @return 返回学习条目的id
*/
+ @LimitRequest(count=5)
@PostMapping("/study")
public JsonResponse study(@RequestBody StudyContentDto sci, HttpServletRequest request){
@@ -321,7 +330,11 @@ public class StudyCourseApi extends ApiBaseController{
if (StringUtils.isEmpty(token)) {
token = request.getHeader("token");
}
- //检查是否已存在
+ StudyCourseApi example = new StudyCourseApi();
+ for (int i = 0; i < 10; i++) {
+ new Thread(() -> example.someApi()).start();
+ //检查是否已存在
+ }
StudyCourseItem item = studyService.checkHas(sci.getStudyId(),sci.getContentId());
if(item!=null) {
//如果记录存在，但是进度不100无成情况，就更新进度，一期不会有这种情况
@@ -334,7 +347,7 @@ public class StudyCourseApi extends ApiBaseController{
log.info("在线课学习记录"+allUserList);
return success(item.getId());
}
-
+
if(StringUtils.isBlank(sci.getCourseId())){
return error("无课程信息");
}