Heim >Java >javaLernprogramm >Wie SpringBoot RabbitMQ integriert, um eine Verzögerungswarteschlange zu implementieren
rabbitmq-Nachrichtenübermittlungspfad
Produzent->Switch->Warteschlange->Verbraucher
Im Allgemeinen ist es in drei Phasen unterteilt.
1. Der Produzent stellt die Zuverlässigkeit der Nachrichtenübermittlung sicher.
2.mq interne Nachrichten gehen nicht verloren.
3. Der Verbraucherkonsum ist erfolgreich.
Einfach ausgedrückt: Die Nachricht wird zu 100 % an die Nachrichtenwarteschlange gesendet.
Wir können den Bestätigungsrückruf aktivieren
Nachdem der Produzent die Nachricht übermittelt hat, gibt mq dem Produzenten eine Bestätigung. Basierend auf der Bestätigung kann der Produzent bestätigen, ob die Nachricht an mq gesendet wurde.
Aktivieren Sie den Bestätigungsrückruf.
Ändern Sie die Konfigurationsdatei
#NONE:禁用发布确认模式,是默认值,CORRELATED:发布消息成功到交换器后会触发回调方法 spring: rabbitmq: publisher-confirm-type: correlated
Der Testcode
@Test public void testConfirmCallback() throws InterruptedException { rabbitTemplate.setConfirmCallback(new RabbitTemplate.ConfirmCallback() { /** * * @param correlationData 配置 * @param ack 交换机是否收到消息,true是成功,false是失败 * @param cause 失败的原因 */ @Override public void confirm(CorrelationData correlationData, boolean ack, String cause) { System.out.println("confirm=====>"); System.out.println("confirm==== ack="+ack); System.out.println("confirm==== cause="+cause); //根据ACK状态做对应的消息更新操作 TODO } }); rabbitTemplate.convertAndSend(RabbitMQConfig.EXCHANGE_NAME,"ikun.mei", "鸡你太美"); Thread.sleep(10000); }
stellt sicher, dass die Nachricht über returnCallback erfolgreich von der Vermittlungsstelle an die Warteschlange gesendet wird. Ändern Sie die Konfigurationsdatei
spring: rabbitmq: #开启returnCallback publisher-returns: true #交换机处理消息到路由失败,则会返回给生产者 template: mandatory: true
Testcode
@Test void testReturnCallback() { //为true,则交换机处理消息到路由失败,则会返回给生产者 配置文件指定,则这里不需指定 rabbitTemplate.setMandatory(true); //开启强制消息投递(mandatory为设置为true),但消息未被路由至任何一个queue,则回退一条消息 rabbitTemplate.setReturnsCallback(returned -> { int code = returned.getReplyCode(); System.out.println("code="+code); System.out.println("returned="+ returned); }); rabbitTemplate.convertAndSend(RabbitMQConfig.EXCHANGE_NAME,"123456","测试returnCallback"); }
Wenn Verbraucher Nachrichten konsumieren, müssen sie manuell durch Bestätigung bestätigen, dass die Nachrichten konsumiert wurden.
Ändern Sie die Konfigurationsdatei.
spring: rabbitmq: listener: simple: acknowledge-mode: manual.
Schreiben Sie den Testcode
Was ist eine Warteschlange für unzustellbare Nachrichten? nack)und wird nicht erneut in die Warteschlange gestellt
requeue=falseDie Nachricht wurde nicht in der Warteschlange verbraucht und hat die Ablaufzeit der Warteschlange oder der Nachricht selbst überschritten
TTL (Time-to-Live)Die Nachrichtenlänge der Warteschlange hat das Limit erreichtDas Ergebnis: Die Nachricht wird zu einem unzustellbaren Brief. Wenn die Warteschlange schließlich an einen Schalter für unzustellbare Nachrichten gebunden ist, wird die Nachricht in die Warteschlange für unzustellbare Nachrichten umgeleitet durch den Dead-Letter-Schalter
Die Dead-Letter-Warteschlange wird häufig für den verzögerten Warteschlangenverbrauch verwendet. Verzögerte Warteschlange
Springboot integriert Rabbitmq, um das automatische Schließen von Bestellungen bei Zeitüberschreitung zu realisieren. 04 - 16 15:14:44
msgTag=1Das obige ist der detaillierte Inhalt vonWie SpringBoot RabbitMQ integriert, um eine Verzögerungswarteschlange zu implementieren. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!