f(x)=f(f(x))
。幂等(idempotent、idempotence)是一个数学与计算机学概念,常见于抽象代数中。 在编程中一个幂等操作的特点是其任意多次执行所产生的影响均与一次执行的影响相同。幂等函数,或幂等方法,是指可以使用相同参数重复执行,并能获得相同结果的函数。这些函数不会影响系统状态,也不用担心重复执行会对系统造成改变。例如,“settrue()”函数就是一个幂等函数,无论多次执行,其结果都是一样的,更复杂的操作幂等保证是利用唯一交易号(流水号)实现.
@service public class tokenserviceimpl implements tokenservice { @autowired private stringredistemplate stringredistemplate; @override public string gettoken() { //获取全局唯一id long nextid = snowflakeutil.nextid(); //存入redis,设置10分钟失效 stringredistemplate.opsforvalue().set(string.valueof(nextid), uuid.randomuuid().tostring(),10, timeunit.minutes); return string.valueof(nextid); } /** * 删除记录,true表示第一次提交,false重复提交 */ @override public boolean checktoken(string token) { return stringredistemplate.delete(token); } }
/** * @description 幂等操作的注解 * @author cjb * @date 2020/3/25 10:19 */ @target({elementtype.type, elementtype.method}) @retention(retentionpolicy.runtime) @documented public @interface repeatlimiter { }
/** * @description 获取请求头的信息,具体校验逻辑读者自己实现 * @author cjb * @date 2020/3/25 11:09 */ @component public class headerintercept implements handlerinterceptor { @override public boolean prehandle(httpservletrequest request, httpservletresponse response, object handler) throws exception { //获取token string token = request.getheader(headerconstant.token); //校验逻辑 if (!validtoken(token)) throw new tokeninvalidexception("token失效"); //获取其他的参数..... requestheader header = requestheader.builder() .token(token) .build(); //放入request中 request.setattribute(headerconstant.header_info,header); return true; } /** * 校验token,逻辑自己实现 * @param token * @return */ private boolean validtoken(string token){ return boolean.true; } }
@component public class repeatintercept implements handlerinterceptor { @autowired private tokenservice tokenservice; @override public boolean prehandle(httpservletrequest request, httpservletresponse response, object handler) throws exception { if (handler instanceof handlermethod){ //获取方法上的参数 repeatlimiter repeatlimiter = annotationutils.findannotation(((handlermethod) handler).getmethod(), repeatlimiter.class); if (objects.isnull(repeatlimiter)){ //获取controller类上注解 repeatlimiter=annotationutils.findannotation(((handlermethod) handler).getbean().getclass(),repeatlimiter.class); } //使用注解,需要拦截验证 if (objects.nonnull(repeatlimiter)){ //获取全局token,表单提交的唯一id requestheader info = requestcontextutils.getheaderinfo(); //没有携带token,抛异常,这里的异常需要全局捕获 if (stringutils.isempty(info.gettoken())) throw new repeatexception(); //校验token boolean flag = tokenservice.checktoken(info.gettoken()); //删除失败,表示 if (boolean.false.equals(flag)) //抛出重复提交的异常 throw new repeatexception(); } } return true; } }
@restcontroller @requestmapping("/order") public class ordercontroller { @autowired private orderservice orderservice; /** * 下单 * @param order * @return */ @postmapping @repeatlimiter //幂等性保证 public commenresult add(@requestbody order order){ orderservice.save(order); return new commenresult("200","下单成功"); } }
如对本文有疑问, 点击进行留言回复!!
14、Ribbon整合断路器监控Hystrix Dashboard
网友评论