springAOP编程整合rabbitmq

Posted 2021-01-07

创建拦截方法的前置通知和后置通知相关类

@Component
public class AopAspect {

@Autowired
private AmqpTemplate template1;
public void beforeAdvice(JoinPoint joinPoint) {
    String s = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date());
    template1.convertAndSend("defaultQueue",s);
    System.out.println("向消息队列发送消息" + s);
}
public void afterAdvice(JoinPoint joinPoint){
    Object o = template1.receiveAndConvert("defaultQueue");
    System.out.println("向队列消费消息" + o.toString());
}

}

springAOP的配置

rabbitmq模板配置 上述配置成功后每次调用userService.checkLogin()方法时, 都会在方法调用前向指定队列发送消息，方法执行完到指定队列消费消息 还有就是spring 和rabbitmq不兼容会导致AOP方法抛出异常