Inhaltsverzeichnis
Nutzungsszenarien
8. Erstellen Sie einen Verzögerungswarteschlangen-Verbrauchsthread. Öffnen Sie ihn, nachdem das Projekt gestartet wurde Schreiben wir eine Testschnittstelle , simulieren und testen Sie sie mit PostMan , simulieren Sie das Hinzufügen einer Verzögerungswarteschlange , Die Schnittstelle zum Hinzufügen einer Verzögerungswarteschlange.
Über den Redis-Client können Sie sehen, dass die beiden Verzögerungswarteschlangen erfolgreich hinzugefügt wurden wurde erfolgreich konsumiert
Heim Java javaLernprogramm Wie SpringBoot Redisson integriert, um eine Verzögerungswarteschlange zu implementieren

Wie SpringBoot Redisson integriert, um eine Verzögerungswarteschlange zu implementieren

May 30, 2023 pm 02:40 PM
springboot redisson

Nutzungsszenarien

1. Die Bestellung wurde erfolgreich aufgegeben und innerhalb von 30 Minuten erfolgte keine Zahlung. Zahlungszeitüberschreitung,Bestellung wird automatisch storniert

2. Bestelleingang,Es wird keine Bewertung innerhalb von 7 Tagen nach Erhalt durchgeführt. Zeitüberschreitung der Bestellung und Nichtbeurteilung,Das System geht standardmäßig auf positive Bewertungen zurück

3.Bestellung erfolgreich aufgegeben,Händler hat die Bestellung 5 Minuten lang nicht angenommen,Bestellung abgebrochen

4.Push SMS-Erinnerung

… …

Für Szenarien mit langen Verzögerungen und geringer Echtzeitleistung können wir die Aufgabenplanung verwenden, um Abfragen in regelmäßigen Abständen durchzuführen. Zum Beispiel xxl-job

Heute verwenden wir eine relativ einfache und leichte Methode – die Verzögerungswarteschlange von Redis für die Verarbeitung. Natürlich gibt es bessere Lösungen – Sie können die optimale Lösung basierend auf der Technologieauswahl und dem Geschäftssystem des Unternehmens auswählen. Zum Beispiel mit der Nachrichten-Middleware Kafka und der Verzögerungswarteschlange von RabbitMQ. Ich werde vorerst nicht auf das Implementierungsprinzip eingehen. Gehen wir direkt zum eigentlichen Code, um die Redisson-Abhängigkeit einzuführen 2. Nacos-Konfiguration Redis-Verbindung

<dependency>
    <groupId>org.redisson</groupId>
    <artifactId>redisson-spring-boot-starter</artifactId>
    <version>3.10.5</version>
</dependency>

3. Erstellen Sie eine Redis-Delay-Queue-Tool-Klasse Zählen Sie die im Verzögerungswarteschlangen-Executor definierten Beans auf und implementieren Sie sie. OrderPaymentTimeout: Verzögerungswarteschlangen-Verarbeitungsklasse für Auftragszahlungen Zeitüberschreitung und keine Auswertung

spring:
  redis:
    host: 127.0.0.1
    port: 6379
    password: 123456
    database: 12
    timeout: 3000

8. Erstellen Sie einen Verzögerungswarteschlangen-Verbrauchsthread. Öffnen Sie ihn, nachdem das Projekt gestartet wurde Schreiben wir eine Testschnittstelle , simulieren und testen Sie sie mit PostMan , simulieren Sie das Hinzufügen einer Verzögerungswarteschlange , Die Schnittstelle zum Hinzufügen einer Verzögerungswarteschlange.

Über den Redis-Client können Sie sehen, dass die beiden Verzögerungswarteschlangen erfolgreich hinzugefügt wurden wurde erfolgreich konsumiert

Das obige ist der detaillierte Inhalt vonWie SpringBoot Redisson integriert, um eine Verzögerungswarteschlange zu implementieren. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!

Erklärung dieser Website
Der Inhalt dieses Artikels wird freiwillig von Internetnutzern beigesteuert und das Urheberrecht liegt beim ursprünglichen Autor. Diese Website übernimmt keine entsprechende rechtliche Verantwortung. Wenn Sie Inhalte finden, bei denen der Verdacht eines Plagiats oder einer Rechtsverletzung besteht, wenden Sie sich bitte an admin@php.cn

Heiße KI -Werkzeuge

Undress AI Tool

Undress AI Tool

Ausziehbilder kostenlos

Undresser.AI Undress

Undresser.AI Undress

KI-gestützte App zum Erstellen realistischer Aktfotos

AI Clothes Remover

AI Clothes Remover

Online-KI-Tool zum Entfernen von Kleidung aus Fotos.

Stock Market GPT

Stock Market GPT

KI-gestützte Anlageforschung für intelligentere Entscheidungen

Heiße Werkzeuge

Notepad++7.3.1

Notepad++7.3.1

Einfach zu bedienender und kostenloser Code-Editor

SublimeText3 chinesische Version

SublimeText3 chinesische Version

Chinesische Version, sehr einfach zu bedienen

Senden Sie Studio 13.0.1

Senden Sie Studio 13.0.1

Leistungsstarke integrierte PHP-Entwicklungsumgebung

Dreamweaver CS6

Dreamweaver CS6

Visuelle Webentwicklungstools

SublimeText3 Mac-Version

SublimeText3 Mac-Version

Codebearbeitungssoftware auf Gottesniveau (SublimeText3)

Wie Springboot Jasypt integriert, um die Verschlüsselung von Konfigurationsdateien zu implementieren Wie Springboot Jasypt integriert, um die Verschlüsselung von Konfigurationsdateien zu implementieren Jun 01, 2023 am 08:55 AM

Einführung in Jasypt Jasypt ist eine Java-Bibliothek, die es einem Entwickler ermöglicht, seinem Projekt mit minimalem Aufwand grundlegende Verschlüsselungsfunktionen hinzuzufügen und kein tiefes Verständnis der Funktionsweise der Verschlüsselung erfordert. standardbasierte Verschlüsselungstechnologie. Passwörter, Text, Zahlen, Binärdateien verschlüsseln ... Geeignet für die Integration in Spring-basierte Anwendungen, offene API, zur Verwendung mit jedem JCE-Anbieter ... Fügen Sie die folgende Abhängigkeit hinzu: com.github.ulisesbocchiojasypt-spring-boot-starter2 Die Vorteile von Jasypt schützen unsere Systemsicherheit. Selbst wenn der Code durchgesickert ist, kann die Datenquelle garantiert werden.

So implementieren Sie verteilte Sperren mit Redis in SpringBoot So implementieren Sie verteilte Sperren mit Redis in SpringBoot Jun 03, 2023 am 08:16 AM

1. Redis implementiert das Prinzip der verteilten Sperren und warum verteilte Sperren erforderlich sind. Bevor über verteilte Sperren gesprochen wird, muss erläutert werden, warum verteilte Sperren erforderlich sind. Das Gegenteil von verteilten Sperren sind eigenständige Sperren. Wenn wir Multithread-Programme schreiben, vermeiden wir Datenprobleme, die durch den gleichzeitigen Betrieb einer gemeinsam genutzten Variablen verursacht werden. Normalerweise verwenden wir eine Sperre, um die Richtigkeit der gemeinsam genutzten Variablen sicherzustellen Die gemeinsam genutzten Variablen liegen im gleichen Prozess. Wenn es mehrere Prozesse gibt, die gleichzeitig eine gemeinsam genutzte Ressource betreiben müssen, wie können sie sich dann gegenseitig ausschließen? Heutige Geschäftsanwendungen sind in der Regel Microservice-Architekturen, was auch bedeutet, dass eine Anwendung mehrere Prozesse bereitstellen muss. Wenn mehrere Prozesse dieselbe Datensatzzeile in MySQL ändern müssen, ist eine Verteilung erforderlich, um fehlerhafte Daten zu vermeiden wird zu diesem Zeitpunkt eingeführt. Der Stil ist gesperrt. Punkte erreichen wollen

Wie SpringBoot Redis anpasst, um die Cache-Serialisierung zu implementieren Wie SpringBoot Redis anpasst, um die Cache-Serialisierung zu implementieren Jun 03, 2023 am 11:32 AM

1. Passen Sie den RedisTemplate1.1-Standard-Serialisierungsmechanismus an. Die API-basierte Redis-Cache-Implementierung verwendet die RedisTemplate-Vorlage für Daten-Caching-Vorgänge. Öffnen Sie hier die RedisTemplate-Klasse und zeigen Sie die Quellcodeinformationen der Klasse publicclassRedisTemplateextendsRedisAccessorimplementsRedisOperations an. Schlüssel deklarieren, verschiedene Serialisierungsmethoden des Werts, der Anfangswert ist leer @NullableprivateRedisSe

So lösen Sie das Problem, dass Springboot nach dem Einlesen in ein JAR-Paket nicht auf die Datei zugreifen kann So lösen Sie das Problem, dass Springboot nach dem Einlesen in ein JAR-Paket nicht auf die Datei zugreifen kann Jun 03, 2023 pm 04:38 PM

Springboot liest die Datei, kann aber nach dem Packen in ein JAR-Paket nicht auf die neueste Entwicklung zugreifen. Es gibt eine Situation, in der Springboot die Datei nach dem Packen in ein JAR-Paket nicht lesen kann ist ungültig und kann nur über den Stream gelesen werden. Die Datei befindet sich unter resources publicvoidtest(){Listnames=newArrayList();InputStreamReaderread=null;try{ClassPathResourceresource=newClassPathResource("name.txt");Input

So verwenden Sie die @Import-Annotation in SpringBoot So verwenden Sie die @Import-Annotation in SpringBoot May 31, 2023 pm 06:25 PM

1. @Import führt gewöhnliche Klassen ein @Import führt gewöhnliche Klassen ein, um uns dabei zu helfen, gewöhnliche Klassen als Beans zu definieren. @Import kann zu den Klassen hinzugefügt werden, die @SpringBootApplication (Startklasse), @Configuration (Konfigurationsklasse) und @Component (Komponentenklasse) entsprechen. Hinweis: @RestController, @Service und @Repository gehören alle über die Annotation @Import zu @Component@SpringBootApplication@Import(ImportBean.class)//ImportBean

So implementieren Sie Springboot+Mybatis-plus, ohne SQL-Anweisungen zum Hinzufügen mehrerer Tabellen zu verwenden So implementieren Sie Springboot+Mybatis-plus, ohne SQL-Anweisungen zum Hinzufügen mehrerer Tabellen zu verwenden Jun 02, 2023 am 11:07 AM

Wenn Springboot + Mybatis-plus keine SQL-Anweisungen zum Hinzufügen mehrerer Tabellen verwendet, werden die Probleme, auf die ich gestoßen bin, durch die Simulation des Denkens in der Testumgebung zerlegt: Erstellen Sie ein BrandDTO-Objekt mit Parametern, um die Übergabe von Parametern an den Hintergrund zu simulieren dass es äußerst schwierig ist, Multi-Table-Operationen in Mybatis-plus durchzuführen. Wenn Sie keine Tools wie Mybatis-plus-join verwenden, können Sie nur die entsprechende Mapper.xml-Datei konfigurieren und die stinkende und lange ResultMap konfigurieren Schreiben Sie die entsprechende SQL-Anweisung. Obwohl diese Methode umständlich erscheint, ist sie äußerst flexibel und ermöglicht es uns

Die Königslösung unter den verteilten Schlössern – Redisson Die Königslösung unter den verteilten Schlössern – Redisson Aug 24, 2023 pm 03:31 PM

Wenn Sie Redis bereits verwendet haben, erzielen Sie mit Redisson das doppelte Ergebnis mit halbem Aufwand. Redisson bietet die einfachste und bequemste Möglichkeit, Redis zu verwenden. Der Zweck von Redisson besteht darin, die Trennung der Benutzer von Redis zu fördern, damit sich Benutzer mehr auf die Verarbeitung der Geschäftslogik konzentrieren können.

Wie SpringBoot Redisson integriert, um eine Verzögerungswarteschlange zu implementieren Wie SpringBoot Redisson integriert, um eine Verzögerungswarteschlange zu implementieren May 30, 2023 pm 02:40 PM

Nutzungsszenario 1. Die Bestellung wurde erfolgreich aufgegeben, die Zahlung erfolgte jedoch nicht innerhalb von 30 Minuten. Die Zahlung ist abgelaufen und die Bestellung wurde automatisch storniert. 2. Die Bestellung wurde unterzeichnet und es wurde 7 Tage lang keine Bewertung durchgeführt. Wenn die Bestellung abläuft und nicht ausgewertet wird, wird die Bestellung standardmäßig positiv bewertet. Wenn der Händler die Bestellung innerhalb von 5 Minuten nicht erhält, wird die Bestellung abgebrochen Es wird eine SMS-Erinnerung gesendet ... Für Szenarien mit langen Verzögerungen und geringer Echtzeitleistung können wir die Aufgabenplanung verwenden, um eine regelmäßige Abfrageverarbeitung durchzuführen. Zum Beispiel: xxl-job Heute werden wir auswählen

See all articles