MIX Fold3包裝盒泄露 新機(jī)本月登場
小米的全新折疊屏旗艦MIX Fold3將于本月發(fā)布，近日該機(jī)的真機(jī)包裝盒在網(wǎng)上泄露。從圖上來看，新的MIX Fold3包裝盒在外觀設(shè)計(jì)方面延續(xù)了之前的方案，變化不大，這也是目前小米旗艦
延遲隊(duì)列是指當(dāng)消息被發(fā)送以后，并不是立即執(zhí)行，而是等待特定的時(shí)間后，消費(fèi)者才會執(zhí)行該消息。延遲隊(duì)列的使用場景有以下幾種：
延遲隊(duì)列有以下兩種實(shí)現(xiàn)方式：
早期，大部分公司都會采用第一種方式，而隨著 RabbitMQ 3.5.7（2015 年底發(fā)布）的延遲插件的發(fā)布，因?yàn)槠涫褂酶唵巍⒏奖悖运F(xiàn)在才是大家普通會采用的，實(shí)現(xiàn)延遲隊(duì)列的方式，所以本文也只講第二種方式。
https://github.com/rabbitmq/rabbitmq-delayed-message-exchange/releases
注意：需要根據(jù)你自己的 RabbitMQ 服務(wù)器端版本選擇相同版本的延遲插件，可以在 RabbitMQ 控制臺查看：
接下來，將上一步下載的插件放到 RabbitMQ 服務(wù)器安裝目錄，如果是 docker，使用一下命令復(fù)制：
docker cp 宿主機(jī)文件 容器名稱或ID:容器目錄
如下圖所示：
之后，進(jìn)入 docker 容器，查看插件中是否包含延遲隊(duì)列：
docker exec -it 容器名稱或ID /bin/bash rabbitmq-plugins list
如下圖所示：
rabbitmq-plugins enable rabbitmq_delayed_message_exchange
如下圖所示：
安裝完 RabbitMQ 插件之后，需要重啟 RabbitMQ 服務(wù)才能生效。如果使用的是 Docker，只需要重啟 Docker 容器即可：
docker restart 容器名稱或ID
如下圖所示：
在 RabbitMQ 控制臺查看，新建交換機(jī)時(shí)是否有延遲消息選項(xiàng)，如果有就說明延遲消息插件已經(jīng)正常運(yùn)行了，如下圖所示：
此步驟可選（非必須），因?yàn)槟承┌姹鞠峦ㄟ^程序創(chuàng)建延遲交換器可能會出錯(cuò)，如果出錯(cuò)了，手動創(chuàng)建延遲隊(duì)列即可，如下圖所示：
import org.springframework.context.annotation.Configuration;import org.springframework.amqp.core.*;import org.springframework.context.annotation.Bean;/** * 延遲交換器和隊(duì)列 */@Configurationpublic class DelayedExchangeConfig { public static final String EXCHANGE_NAME = "myDelayedExchange"; public static final String QUEUE_NAME = "delayed.queue"; public static final String ROUTING_KEY = "delayed.routing.key"; @Bean public CustomExchange delayedExchange() { return new CustomExchange(EXCHANGE_NAME, "x-delayed-message", // 消息類型 true, // 是否持久化 false); // 是否自動刪除 } @Bean public Queue delayedQueue() { return QueueBuilder.durable(QUEUE_NAME) .withArgument("x-delayed-type", "direct") .build(); } @Bean public Binding delayedBinding(Queue delayedQueue,CustomExchange delayedExchange) { return BindingBuilder.bind(delayedQueue()).to(delayedExchange()).with(ROUTING_KEY).noargs(); }}import org.springframework.amqp.rabbit.core.RabbitTemplate;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.scheduling.annotation.Scheduled;import org.springframework.stereotype.Component;@Componentpublic class DelayedMessageProducer { @Autowired private RabbitTemplate rabbitTemplate; @Scheduled(fixedDelay = 5000) public void sendDelayedMessage(String message) { rabbitTemplate.convertAndSend(DelayedExchangeConfig.EXCHANGE_NAME, DelayedExchangeConfig.ROUTING_KEY, message, messagePostProcessor -> { messagePostProcessor.getMessageProperties().setDelay(10000); // 設(shè)置延遲時(shí)間，單位毫秒 return messagePostProcessor; }); }}import org.springframework.beans.factory.annotation.Autowired;import org.springframework.web.bind.annotation.GetMapping;import org.springframework.web.bind.annotation.RequestMapping;import org.springframework.web.bind.annotation.RequestParam;import org.springframework.web.bind.annotation.RestController;@RestController@RequestMapping("/delayed")public class DelayedMessageController { @Autowired private DelayedMessageProducer delayedMessageProducer; @GetMapping("/send") public String sendDirectMessage(@RequestParam String message) { delayedMessageProducer.sendDelayedMessage(message); return "Delayed message sent to Exchange: " + message; }}import org.springframework.amqp.rabbit.annotation.RabbitListener;import org.springframework.stereotype.Component;@Componentpublic class DelayedMessageConsumer { @RabbitListener(queues = DelayedExchangeConfig.QUEUE_NAME) public void receiveDelayedMessage(String message) { System.out.println("Received delayed message: " + message); }}PS：獲取本文延遲隊(duì)列的實(shí)現(xiàn) Demo，請加我：GG_Stone【備注：延遲隊(duì)列】
實(shí)現(xiàn) RabbitMQ 延遲隊(duì)列目前主流的實(shí)現(xiàn)方式，是采用官方提供的延遲插件來實(shí)現(xiàn)。而延遲插件需要先下載插件、然后配置并重啟 RabbitMQ 服務(wù)，之后就可以通過編寫代碼的方式實(shí)現(xiàn)延遲隊(duì)列了。
本文鏈接：http://m.www897cc.com/showinfo-26-86060-0.html阿里面試：RabbitMQ如何實(shí)現(xiàn)延遲隊(duì)列？
聲明：本網(wǎng)頁內(nèi)容旨在傳播知識，若有侵權(quán)等問題請及時(shí)與本網(wǎng)聯(lián)系，我們將在第一時(shí)間刪除處理。郵件：2376512515@qq.com
上一篇： 電視產(chǎn)業(yè)躍升：AI 芯片推動三星電視再度提至新高度
下一篇： 原理剖析| Kafka Exactly Once 語義實(shí)現(xiàn)原理：冪等性與事務(wù)消息
Copyright ? 2016-2023 天津谷騏科技有限公司 版權(quán)所有 sitemap.xml
違法及侵權(quán)請聯(lián)系：2376512515@qq.com 津ICP備18001702號
津公網(wǎng)安備 12010102000574號