Spring AOPr如何打通两个切面之间的通信

网友投稿 285 2022-08-17


Spring AOPr如何打通两个切面之间的通信

目录场景描述解决方案跳转过程其他方案

场景描述

在秒杀微服务中,笔者在需要各种校验前端传来的参数后,通过 Redis 加锁限流(切面A)并返回,最后封装订单数据推送到 RabbitMQ 消息队列(切面B)做善后工作。

问题:如何将 切面 A 的数据传递 给切面B 处理呢?

/**

* 添加到秒杀流程

*

* @param killId 秒杀商品缓存键 sessionId_skuId

* @param key 随机码 randomCode

* @param num 数量

* @return {@link R}

*/

@GetMapping("/kill")

public R addToSeckill(

@RequestParam("killId") String killId,

@RequestParam("key") String key,

@RequestParam("num") Integer num) {

// 实现类只是带有两个注解方法,返回 null(因为全部交给切面托管了)

String orderSn = seckillService.kill(killId, key, num);

if (StringUtils.isEmpty(orderSn)) {

return R.error();

}

return R.ok().setData(orderSn);

}

解决方案

通过参数传递数据,通过捕获异常保证业务逻辑(离谱但有用)

// 强制http://修改参数,通过异常返回正常流程,而通过AOP消息队列处理收尾动作

try {

return pjp.proceed(new Object[]{orderTo, null, null});

} catch (Throwable e) {

return orderSn;

}

注意事项:

参数一致性:必须伪造和方法签名的数量相等的参数 ⇒ 否则线程会抛出异常 I 就返回了,无法执行 pjp.proceed 原始方法 ⇒ 无法跳转第二个切面java.lang.IllegalArgumentException: Expecting 3 arguments to proceed, but was passed 1 arguments捕获异常不抛出,直接执行正常业务逻辑 ⇒ 否则线程将吞没异常 IIcn.miozus.gulimall.common.to.mq.SeckillOrderTo cannot be cast to java.lang.String

3.虽然两个切面都返回了 orderSn ,实际最终只有切面A传递到了控制层和http://前端, 切面B的返回值成了摆设。

跳转过程

打断点查看两个切面的跳转过程。

切面A:准备跳转第二个切面

切面B:发送消息完成

打印日志,可见场景需求,已经满足了。

2022-03-29 17:32:56.521 INFO 7904 --- [io-25000-exec-8] c.m.g.s.aspect.SeckillRabbitMqAspect : 快速创建订单:发送消息创建完成: 20220329173244488150873http://8921192005634 2022-03-29 17:33:01.526 INFO 7904 --- [io-25000-exec-8] c.m.g.s.controller.SeckillController : 秒杀创建订单用时:28778 seckill orderSn = 202203291732444881508738921192005634 2022-03-29 17:33:01.527 INFO 7904 --- [nectionFactory5] c.m.g.s.config.RabbitMqSeckillConfig : 消息已发送, params: correlationData:null,ack:true,cause:null

其他方案

最简单的办法,不切了,两个切面耦合在一起。注入和调用方法


版权声明:本文内容由网络用户投稿,版权归原作者所有,本站不拥有其著作权,亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容,请联系我们jiasou666@gmail.com 处理,核实后本网站将在24小时内删除侵权内容。

上一篇:SpringBoot实现多环境配置文件切换教程详解
下一篇:Java8接口之默认方法与静态方法详解
相关文章

 发表评论

暂时没有评论,来抢沙发吧~