- 使用 Spring Initializr 创建 Spring Boot 应用程序
- 在Spring Boot中配置Cassandra
- 在 Spring Boot 上配置 Tomcat 连接池
- 将Camel消息路由到嵌入WildFly的Artemis上
先介绍一下 @Retention
和 @Target
这两个元注解
@Retention: 指定注解的生命周期(源码、class文件、运行时),其参考值见类的定义:java.lang.annotation.RetentionPolicy
RetentionPolicy.SOURCE
:在编译阶段丢弃。这些注解在编译结束之后就不再有任何意义,所以它们不会写入字节码。@Override、@SuppressWarnings都属于这类注解。
RetentionPolicy.CLASS
: 在类加载的时候丢弃。在字节码文件的处理中有用。注解默认使用这种方式。
RetentionPolicy.RUNTIME
: 始终不会丢弃,运行期也保留该注解,因此可以使用反射机制读取该注解的信息。我们自定义的注解通常使用这种方式。
@Target:指定注解使用的目标范围(类、方法、字段等),其参考值见类的定义:java.lang.annotation.ElementType
ElementType.CONSTRUCTOR
:用于描述构造器。
ElementType.FIELD
:成员变量、对象、属性(包括enum实例)。
ElementType.LOCAL_VARIABLE
: 用于描述局部变量。
ElementType.METHOD
: 用于描述方法。
ElementType.PACKAGE
:用于描述包。
ElementType.PARAMETER
:用于描述参数。
ElementType.ANNOTATION_TYPE
:用于描述参数
ElementType.TYPE
:用于描述类、接口(包括注解类型) 或enum声明。
自定义注解:
import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;
/**
* 自定义限流注解
*/
@Retention(RetentionPolicy.RUNTIME)
@Target(ElementType.METHOD)
public @interface AccessLimit {
// 限流的时间范围,默认值5
int second() default 5;
// 最大访问次数,默认值5
int maxCount() default 5;
}
根据上面@Retention 和 @Target的介绍,
我们可以知道我们自定义的@AccessLimit注解的生命周期是运行时,注解使用的目标范围是加在方法上
在接口方法上添加该注解
@RestController
public class TestController {
@AccessLimit(second = 6, maxCount = 6)
@GetMapping("/accessLimit")
public String accessLimitTest() {
return "hello hello";
}
}
计数器算法是限流算法里最简单也是最容易实现的一种算法。比如我们规定,对于A接口来说,我们1分钟的访问次数不能超过100个。那么我们可以这么做:在一开 始的时候,我们可以设置一个计数器counter,每当一个请求过来的时候,counter就加1,如果counter的值大于100并且该请求与第一个 请求的间隔时间还在1分钟之内,那么说明请求数过多;如果该请求与第一个请求的间隔时间大于1分钟,且counter的值还在限流范围内,那么就重置 counter,具体算法的示意图如下:
import com.hkd.seckill.config.AccessLimit;
import com.hkd.seckill.pojo.User;
import com.hkd.seckill.service.UserService;
import com.hkd.seckill.util.CookieUtil;
import com.hkd.seckill.vo.RespBean;
import com.hkd.seckill.vo.RespBeanEnum;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Component;
import org.springframework.util.StringUtils;
import org.springframework.web.method.HandlerMethod;
import org.springframework.web.servlet.HandlerInterceptor;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
import java.io.PrintWriter;
import java.util.concurrent.TimeUnit;
/**
* 自定义拦截器 拦截 @AccessLimit 注解
*/
@Component
public class AccessLimitInterceptor implements HandlerInterceptor {
@Autowired
private UserService userService;
@Autowired
private RedisTemplate redisTemplate;
/**
* 拦截 HandlerMethod 注解
* @param request
* @param response
* @param handler
* @return 该方法若返回 true 表示放行 返回false表示丢弃该请求
* @throws Exception
*/
@Override
public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {
if (handler instanceof HandlerMethod) {
HandlerMethod hm = (HandlerMethod) handler;
// 拿到AccessLimit这个注解的信息
AccessLimit accessLimit = hm.getMethodAnnotation(AccessLimit.class);
// 若没有加 @HandlerMethod 这个注解,则直接放行
if(accessLimit == null) {
return true;
}
// 获取注解中限流的时间范围
int second = accessLimit.second();
// 获取注解中最大访问次数
int maxCount = accessLimit.maxCount();
// 获取当前请求的URL
String key = request.getRequestURI();
// 从cookie中获取sessionId
String ticket = CookieUtil.getCookieValue(request, "userTicket");
if (!StringUtils.hasLength(ticket)) {
render(response, RespBeanEnum.SESSION_ERROR);
return false;
}
// 从redis中获取用户信息
User user = userService.getUserByCookie(ticket, request, response);
if (user == null) {
render(response, RespBeanEnum.SESSION_ERROR);
return false;
}
key += ":" + user.getId();
// 限流算法 计数器法 在second秒内 某个用户对于某个地址访问的次数不能超过 maxCount
Integer count = (Integer)redisTemplate.opsForValue().get(key);
if(count == null) {
// 以 url:userId 为key
// 初始值1为value
// 过期时间为second秒 存储到Redis中
redisTemplate.opsForValue().set(key, 1, second, TimeUnit.SECONDS);
} else if (count < maxCount) {
// 若未达到最大值 则累加
redisTemplate.opsForValue().increment(key);
} else { // 访问次数过多
// 若超过最大值 则返回自定义的提示信息 如: {"code":500504,"message":"访问过快,请稍后再试","obj":null}
render(response, RespBeanEnum.ACCESS_LIMIT_REAHCED);
return false;
}
}
return true;
}
/**
* 渲染,构建返回对象
* @param response
* @param respBeanEnum
*/
private void render(HttpServletResponse response, RespBeanEnum respBeanEnum) throws IOException {
response.setContentType("application/json");
response.setCharacterEncoding("UTF-8");
PrintWriter out = response.getWriter();
RespBean respBean = RespBean.error(respBeanEnum);
// 将数据以json字符串的方式返回
out.write(new ObjectMapper().writeValueAsString(respBean)); // 返回信息:{"code":500504,"message":"访问过快,请稍后再试","obj":null}
out.flush();
out.close();
}
}
实现步骤:
HandlerInterceptor
接口preHandle
方法, 该方法在被拦截接口方法执行前执行AccessLimit accessLimit = hm.getMethodAnnotation(AccessLimit.class)
获取接口方法的AccessLimit 注解,if(accessLimit == null){return true; }
若没有添加该注解 则返回true,表示放行(我们只对加了@AccessLimit 的接口方法操作)// 获取注解中限流的时间范围
int second = accessLimit.second();
// 获取注解中最大访问次数
int maxCount = accessLimit.maxCount();
// 获取当前请求的URL
String key = request.getRequestURI();
// 从cookie中获取sessionId
// 获取用户信息
.....
key += ":" + user.getId();
// 限流算法 计数器法 在second秒内 某个用户对于某个地址访问的次数不能超过 maxCount
Integer count = (Integer)redisTemplate.opsForValue().get(key);
if(count == null) {
// 以 url:userId 为key
// 初始值1为value
// 过期时间为second秒 存储到Redis中
redisTemplate.opsForValue().set(key, 1, second, TimeUnit.SECONDS);
} else if (count < maxCount) {
// 若未达到最大值 则累加
redisTemplate.opsForValue().increment(key);
} else { // 访问次数过多
// 若超过最大值 则返回自定义的提示信息 如: {"code":500504,"message":"访问过快,请稍后再试","obj":null}
render(response, RespBeanEnum.ACCESS_LIMIT_REAHCED);
return false;
}
/**
* MVC配置类
*/
@Configuration
public class WebConfig implements WebMvcConfigurer {
@Autowired
private AccessLimitInterceptor accessLimitInterceptor;
/**
* 添加拦截器
* @param registry
*/
@Override
public void addInterceptors(InterceptorRegistry registry) {
// 拦截 加@HandlerMethod的方法
registry.addInterceptor(accessLimitInterceptor);
}
}
正常访问:
6秒内请求超过6次:
若有不明白的,可以随时在评论区留言,希望能帮到你。
注解@CrossOrigin 出于安全原因,浏览器禁止Ajax调用驻留在当前原点之外的资源。例如,当你在一个标签中检查你的银行账户时,你可以在另一个选项卡上拥有EVILL网站。来自EVILL的脚本
CFSDN坚持开源创造价值,我们致力于搭建一个资源共享平台,让每一个IT人在这里找到属于你的精彩世界. 这篇CFSDN的博客文章深入理解Java高级特性——注解由作者收集整理,如果你对这篇文章有兴趣,
概述 在这个快速教程中,我们将探索 Spring 的 @RequestParam 注解。 简单地说,我们可以使用 @RequestParam 从请求中提取查询参数、表单参数甚至文件。我们将讨论如何使用
我有一个关于 Spring @Async 注释的问题。我有一个 Controller 自动连接了一个服务(GnInsuranceDetailsService) @RequestMapping(va
我在使用注释来调用注释所属的方法时遇到了一些麻烦......我将举一个例子: class MyEventHandlers { @handler(id=“1”) public doSom
我是.Net程序员,但是这次我正在从事Java项目,并且遇到了一些困难。这个 java 项目不是我的,它是由其他开发人员开发的,并且使用 Hibernate。 当我运行 Ant 构建器时,我收到此错误
我在 Grails 文档(第 9 章:测试)中读到过这个注解。但是我不明白这是什么... 问题是我需要模拟 GORM 的动态方法,有一种方法可以自动模拟它们,而不必编写我需要的所有方法吗? 最佳答案
这个问题在这里已经有了答案: How to get annotation class name, attribute values using reflection (2 个答案) 关闭 5 年前。
如何了解 Java EE 6 JMS 注释规范支持的所有有效属性集@ActivationConfigProperty Java EE 6 Documentation for @ActivationCo
我认为这是不可能的,但也许我错了。所以我问你,如果可能的话。 ;-) 如果我定义了一个注释,它只接受类引用,它扩展了一些可能的接口(interface)或类: Class serviceIFProv
我正在尝试使用 javax.validation 验证一些 DTO,但似乎注释 @NotEmpty 没有检查参数是否为 null。 这是我的类(class): Person.class public
我是 hibernate 新手,我正在尝试学习它,但在尝试使一对多关系正常工作时遇到了问题。我尝试了几个例子,但似乎没有一个起作用。 有人可以看一下下面的代码并告诉我哪里出了问题吗?我尝试了很多不同的
这个问题已经有答案了: Why doesn't Java offer operator overloading? (17 个回答) 已关闭 9 年前。 每个人都知道 Java 中的简单算术如何用于基元
有人知道如何用 Python 处理这种 XML 注释,这是我第一次看到。 <?link id="752760" resource-uuid="UUID-9f0575a3-1847-1cde-fd
我遇到了这个link这解释了如何继承 bean。假设此示例中的 HelloWorld 类使用 @Component 注释作为 bean 公开,如何创建另一个继承此 bean 的 bean?我可以使用
谁能告诉我这段代码是否: public class OvTester { @Override public int hashCode() { return toStri
我有一个实体,它有一个非键列,我已将其设置为在我的数据库中自动生成。 我不能使用 @GeneratedValue,因为据我所知,它仅适用于关键字段。 在这种情况下,如何指示非键列是自动生成的? 最佳答
所以可能像很多人一样,我通常会临时注释掉代码,主要是为了调试目的。我目前放了类似 **DEBUG** 或任何容易搜索的内容,但我认为让编译器在发现临时注释掉的代码时输出警告(甚至错误)可能很有用。我想
此组件解决的问题是: 「谁」在「什么时间」对「什么」做了「什么事」 本组件目前针对 Spring-boot 做了 Autoconfig,如果是 SpringMVC,也可自己在 xml 初始化 b
配置全局乱码过滤器 参数绑定注解@RequestParam 注解@RequestParam的参数使用说明 获得Restful风格的参数 自定义类型转换器 自定义转换器的开发步骤: 获得Servlet相
我是一名优秀的程序员,十分优秀!