springAOP編程整合rabbitmq
阿新 • • 發佈:2018-09-22
edge exchange method sys delet 後置 rabbit bind nec 創建攔截方法的前置通知和後置通知相關類
上述配置成功後每次調用userService.checkLogin()方法時,
都會在方法調用前向指定隊列發送消息,方法執行完到指定隊列消費消息
還有就是spring 和rabbitmq不兼容會導致AOP方法拋出異常
@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模板配置springAOP編程整合rabbitmq