1. 程式人生 > >springAOP編程整合rabbitmq

springAOP編程整合rabbitmq

edge exchange method sys delet 後置 rabbit bind nec

創建攔截方法的前置通知和後置通知相關類

@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方法拋出異常

springAOP編程整合rabbitmq