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

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

創(chuàng)新互聯(lián)公司從2013年開始，先為鐵門關(guān)等服務(wù)建站，鐵門關(guān)等地企業(yè)，進(jìn)行企業(yè)商務(wù)咨詢服務(wù)。為鐵門關(guān)企業(yè)網(wǎng)站制作PC+手機(jī)+微官網(wǎng)三網(wǎng)同步一站式服務(wù)解決您的所有建站問題。

代碼實(shí)現(xiàn):

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

然后是隊列交換機(jī)以及綁定的聲明(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)建延遲隊列得交換機(jī)，就是一個普通得交換機(jī) * @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;  } }); }

進(jìn)行測試

/** * 監(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實(shí)現(xiàn)一個定時任務(wù)就分享到這里了，希望以上內(nèi)容可以對大家有一定的幫助，可以學(xué)到更多知識。如果覺得文章不錯，可以把它分享出去讓更多的人看到。

新聞名稱：SpringBoot中怎么利用RabbitMq實(shí)現(xiàn)一個定時任務(wù)
網(wǎng)站網(wǎng)址：http://muchs.cn/article14/ipicge.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供標(biāo)簽優(yōu)化、搜索引擎優(yōu)化、微信小程序、網(wǎng)站收錄、Google、動態(tài)網(wǎng)站

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源： 創(chuàng)新互聯(lián)