diff --git a/servers/boe-server-all/src/main/java/com/xboe/school/aspect/LimitRequest.java b/servers/boe-server-all/src/main/java/com/xboe/school/conf/LimitRequest.java similarity index 87% rename from servers/boe-server-all/src/main/java/com/xboe/school/aspect/LimitRequest.java rename to servers/boe-server-all/src/main/java/com/xboe/school/conf/LimitRequest.java index 6ff03484..c943011c 100644 --- a/servers/boe-server-all/src/main/java/com/xboe/school/aspect/LimitRequest.java +++ b/servers/boe-server-all/src/main/java/com/xboe/school/conf/LimitRequest.java @@ -1,4 +1,4 @@ -package com.xboe.school.aspect; +package com.xboe.school.conf; import java.lang.annotation.*; diff --git a/servers/boe-server-all/src/main/java/com/xboe/school/aspect/LimitRequestAspect.java b/servers/boe-server-all/src/main/java/com/xboe/school/conf/LimitRequestAspect.java similarity index 98% rename from servers/boe-server-all/src/main/java/com/xboe/school/aspect/LimitRequestAspect.java rename to servers/boe-server-all/src/main/java/com/xboe/school/conf/LimitRequestAspect.java index 8e2368fa..d8efa0bf 100644 --- a/servers/boe-server-all/src/main/java/com/xboe/school/aspect/LimitRequestAspect.java +++ b/servers/boe-server-all/src/main/java/com/xboe/school/conf/LimitRequestAspect.java @@ -1,4 +1,4 @@ -package com.xboe.school.aspect; +package com.xboe.school.conf; import com.xboe.api.vo.Result; 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 29c2ec3e..f8d8f0d4 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 @@ -3,19 +3,14 @@ package com.xboe.school.study.api; import java.time.LocalDateTime; import java.util.*; 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.study.dao.StudyCourseDao; +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; @@ -68,9 +63,7 @@ import javax.servlet.http.HttpServletRequest; @RestController @RequestMapping(value="/xboe/school/study/course") public class StudyCourseApi extends ApiBaseController{ - - - + @Autowired IStudyCourseService service; @@ -100,7 +93,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 @@ -297,6 +295,7 @@ public class StudyCourseApi extends ApiBaseController{ * @param * @return 返回学习条目的id */ + @LimitRequest(count=5) @PostMapping("/study") public JsonResponse study(@RequestBody StudyContentDto sci, HttpServletRequest request){ @@ -326,7 +325,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无成情况,就更新进度,一期不会有这种情况 @@ -339,7 +342,7 @@ public class StudyCourseApi extends ApiBaseController{ log.info("在线课学习记录"+allUserList); return success(item.getId()); } - + if(StringUtils.isBlank(sci.getCourseId())){ return error("无课程信息"); } @@ -698,7 +701,6 @@ public class StudyCourseApi extends ApiBaseController{ return error("查询失败",e.getMessage()); } } - @RequestMapping(value="/study-course-content",method = {RequestMethod.GET,RequestMethod.POST}) public JsonResponse findStudyCourseItem(String studyId,String contentId, HttpServletRequest request){