SpringBoot中怎么利用RabbitMq實現(xiàn)一個定時任務

這篇文章給大家介紹SpringBoot中怎么利用RabbitMq實現(xiàn)一個定時任務，內(nèi)容非常詳細，感興趣的小伙伴們可以參考借鑒，希望對大家能有所幫助。

代碼實現(xiàn):

//首先rabbitAdmin的配置 @Bean public RabbitAdmin rabbitAdmin(CachingConnectionFactory cachingConnectionFactory){ RabbitAdmin rabbitAdmin = new RabbitAdmin(cachingConnectionFactory); rabbitAdmin.setIgnoreDeclarationExceptions(true); return rabbitAdmin; }

然后是隊列交換機以及綁定的聲明(Queue,Exchange,Binding)

@Autowired RabbitAdmin rabbitAdmin; /** * 創(chuàng)建延遲隊列，該隊列內(nèi)容不會唄監(jiān)聽，TLL到期自動轉(zhuǎn)發(fā) * @param queueName * @param delayExchange */ public void createDelayQueue(String queueName,String delayExchange,String delayRoutingKey){ Map<String, Object> map = new HashMap<>(); /**注意這兩個參數(shù)必須綁定**/ map.put("x-dead-letter-exchange", delayExchange); map.put("x-dead-letter-routing-key", delayRoutingKey); rabbitAdmin.declareQueue(new Queue(queueName,true,false,false,map)); } /** * 創(chuàng)建普通隊列 * @param queueName */ public void createQueue(String queueName){ rabbitAdmin.declareQueue(new Queue(queueName,true,false,false,new HashMap<>())); } /** * 創(chuàng)建延遲隊列得交換機，就是一個普通得交換機 * @param name */ public void createExchange(String name){ rabbitAdmin.declareExchange(new DirectExchange(name,true,false)); } /** * 綁定隊列 * @param queueName * @param delayExchange * @param routeKey */ public void bindQueue(String queueName,String delayExchange,String routeKey){ rabbitAdmin.declareBinding(new Binding(queueName,Binding.DestinationType.QUEUE,delayExchange,routeKey,new HashMap<>())); } /** * 發(fā)送消息 * @param message * @param exchange * @param routeKey * @param tll 時間 單位毫秒 */ public void sendMessageWithTll(String message,String exchange,String routeKey,String tll){ rabbitAdmin.getRabbitTemplate().convertAndSend(exchange, routeKey, message, new MessagePostProcessor() {  @Override  public Message postProcessMessage(Message message) throws AmqpException {  message.getMessageProperties().setExpiration(tll);  return message;  } }); } @Override public void sendMessage(String message, String exchange, String routeKey) { rabbitAdmin.getRabbitTemplate().convertAndSend(exchange, routeKey, message, new MessagePostProcessor() {  @Override  public Message postProcessMessage(Message message) throws AmqpException {  return message;  } }); }

進行測試

/** * 監(jiān)聽消息 * @param message * @return */ @RabbitListener(queues = "consumerQueue") public void getMessage(String message){ System.out.println("收到消息getMessage:"+message +",time="+MyUtil.FormatDate(new Date())); }

關(guān)于SpringBoot中怎么利用RabbitMq實現(xiàn)一個定時任務就分享到這里了，希望以上內(nèi)容可以對大家有一定的幫助，可以學到更多知識。如果覺得文章不錯，可以把它分享出去讓更多的人看到。