Transactional Event Queues (TxEventQ) und Advanced Queuing (AQ)

Oracle Advanced Queuing ist eine in Oracle Database integrierte Messaging-Plattform, die für Anwendungsworkflows, Microservices und ereignisgesteuerte Aktionen verwendet wird. Oracle Database 19c führt Oracle Transactional Event Queues ein und vereint das Beste aus Messaging und Pub/Sub für Ereignisse mit Kafka-Interoperabilität.

Einführung in Oracle Transactional Event Queues (12:26)

Erste Schritte mit Oracle Transactional Event Queues (TxEventQ)

Features von AQ und TxEventQ

Messaging und Pub/Sub

  • Hoher Durchsatz (~1 M+ Nachrichten/Sek. auf RAC) mit parallelen (partitionierten) Ereignisstreams innerhalb einer Queue und einem speicherinternen Nachrichtencache.
  • Exakte Zustellung von Transaktionsnachrichten, bei denen DML-Vorgänge in Datenbank und Nachricht Teil derselben Transaktion sind.
  • Die Gesamtreihenfolge der Nachrichten innerhalb jedes Ereignisstreams sowie mehrere Ereignisstreams pro Queue werden unterstützt.
  • Pub/Sub (Themen) und Sende-/Empfangsnachrichten (Queues) werden in einer Infrastruktur unterstützt.
  • Asynchroner Nachrichtenverbrauch mit Timeouts für Benachrichtigungen oder Abfragen.

Sprachunterstützung

  • Unterstützt mehrere Sprach-APIs für Producer und Consumer: Java, Java mit JMS, PL/SQL, C/C++, Python, Node.js, REST und CLI
  • Kafka Java Client-Unterstützung zum Ersetzen des Kafka-Brokers durch TxEventQ als Nachrichtenbroker
  • JMS-Standard-Open-Source-API-Unterstützung für JMS 1.1+ (einige Features von JMS 2.0, wie z. B. mehrere Consumer, verzögerte Nachrichten und mehr)

Betriebsmerkmale

  • Das TxEventQ-Gateway unterstützt die Interoperabilität mit Kafka
  • Queue-Statistiken und kontinuierliche Echtzeitüberwachung mit Prometheus/Grafana
  • Datenbanksicherheit zur Verschlüsselung von Nachrichten in der Queue-Tabelle
  • Regelbasierte Abonnenten, die Nachrichten basierend auf der schnellen Ausführung von Regeln filtern
  • Willkürliche Suche im Ereignisstream, neue oder vorhandene Consumer können Nachrichten von einem früheren Offset konsumieren
  • Nachrichtenverzögerung, Priorität, Ablauf und Weitergabe von Queue zu Queue ermöglichen Flexibilität beim Aufbau moderner Anwendungen und Workflows

Event Mesh für moderne ereignisgesteuerte Anwendungen

Pub/Sub von Ereignissen in einer modernen Umgebung zur Anwendungsentwicklung

Entwickler ereignisgesteuerter Microservices und Workflows verlassen sich auf eine zuverlässige Messaging-Plattform mit hohem Durchsatz. Oracle TxEventQ bietet robustes Echtzeit-Messaging, Streaming-Ereignisse und Pub/Sub mit mehreren Producern und Consumern. Installationen für einen hohen Durchsatz von TxEventQ können etwa 100 Milliarden Nachrichten pro Tag in einer Oracle Real Application Clusters-(RAC-)Datenbank mit 8 Knoten erreichen.

Diagramm zu Oracle TxEventQ in der konvergierten DatenbankOracle TxEventQ in der konvergenten Datenbank kombiniert Pub/Sub von Ereignissen und Produce/Consume von Nachrichten. Producer produzieren oder veröffentlichen in mehreren Sprachen über einen in die Datenbank integrierten Queue-Broker. Dies ist aus Gründen der Parallelität partitioniert. Consumer konsumieren oder abonnieren Nachrichten. Durch die Queue-Weitergabe wird die Nachricht für Consumer in einer Remote-Oracle Database verfügbar.

Zuverlässiges JMS-Messaging mit transaktionalem Postausgang

Oracle AQ ist in die Oracle Database integriert und ermöglicht das Transaktions-Messaging. Enqueues und Dequeues werden automatisch gleichzeitig mit anderen Datenbankvorgängen festgeschrieben, ohne dass zweiphasige Commits erforderlich sind. Mit standardmäßigen SQL-Anweisungen können Nachrichten und deren Metadaten abgefragt werden. Die transaktionale Outbox-Unterstützung für Microservices ermöglicht eine Vereinfachung der ereignisgesteuerten Anwendungsentwicklung.

Diagramm zu Oracle AQ in der konvergierten DatenbankOracle AQ in der konvergierten Datenbank kombiniert Pub/Sub von Ereignissen und Produce/Consume von Nachrichten. Producer produzieren oder veröffentlichen in mehreren Sprachen über einen in die Datenbank integrierten Queue-Broker. Consumer konsumieren oder abonnieren Nachrichten. Durch die Queue-Weitergabe wird die Nachricht für Consumer in einer Remote-Oracle Database verfügbar.

Oracle AQ/TxEventQ kombiniert das Beste aus Messaging und Pub/Sub

Wichtige Vorteile von Oracle TxEventQ für Entwickler

  • Kombiniert das Beste aus Messaging und Streaming
  • Unterstützt sowohl den JMS- als auch den Kafka-Java-Client für die Java-Programmierung
  • Verwendet eine leistungsstarke, persistente In-Memory-Implementierung
  • Bietet 3- bis 10-fache Leistungsverbesserungen gegenüber Oracle AQ
  • Skaliert mit Oracle RAC und vCPUs innerhalb einer Oracle Autonomous Database-Instanz
  • Interoperabel mit Apache Kafka unter Verwendung von Kafka-JMS-Connectors

Diagramm zur Geschichte von Oracle AQ und Transactional Event Queues (TxEventQ)

Oracle AQ wurde in Oracle Database 8.0 eingeführt

Oracle Advanced Queuing (AQ) wurde in Oracle Database 8.0 eingeführt. In Version 12.2 wurden AQ Sharded Queues für JMS-Queues eingeführt, etwa zur gleichen Zeit, als Kafka zu einem Apache-Projekt wurde. AQ Sharded Queues werden in Oracle Database 21c in Transactional Event Queues umbenannt. Sowohl AQ Classic Queues als auch Transactional Event Queues können kostenlos bei jedem Deployment mit Oracle Database verwendet werden.

Diagramm zur Geschichte von Oracle AQ und Transactional Event Queues (TxEventQ) Oracle AQ wurde in Oracle Database 8.0 eingeführt und hat seine Funktionen in jeder nachfolgenden Edition der Oracle Database erweitert. In Oracle Database 12c wurden AQ-Sharded-Queues mit Partitionierung eingeführt und in Oracle Database 19c fortgesetzt. AQ Sharded Queues werden in Oracle Database 21c in Transactional Event Queues umbenannt. Oracle AQ ist weiterhin für einfache Workflows verfügbar, die keinen sehr hohen Durchsatz erfordern.
Alle Kundenerfolge anzeigen

Kundenerfolge mit Oracle AQ und TxEventQ



Auto Zone-Logo
Bissell-Logo
Data Intensity-Logo
jetBlue-Logo
Mazda-Logo
Pella-Logo
Specialized-Logo
Tramontina-Logo
FedEX-Logo

FedEx hat die E-Business Suite auf Oracle Cloud Infrastructure verlagert. Der E-Business Suite-Workflow und das Geschäftsereignissystem basieren auf Oracle Advanced Queuing (AQ).

AQ und TxEventQ – Anwendungsfälle

  • Anwendungsworkflows

    Workflow für die Liefergarantie im Einzelhandel

    Zustellungsunternehmen verwenden Einmalkennwörter (OTP), um die Lieferadresse und -person zu überprüfen, und nutzen Oracle AQ als Rückgrat für den Nachrichtenaustausch zwischen der Anbieter-App, dem Zusteller und dem Kunden. Siehe Code im Oracle AQ LiveLab.

  • Ereignisbasierte Anwendungen

    Zweitfaktor-Authentifizierung am Geldautomaten

    In vielen Ländern verlangen Banken ein OTP, um ihre Konten für die Auszahlung zu validieren. Erfahren Sie, wie Sie mit Oracle AQ eine Messaging-Infrastruktur erstellen, um das OTP zwischen dem Servercode des Geldautomaten und der mobilen Client-App des Kunden zu übertragen.

    Oracle AQ wird für die Koordination des OTP vom Geldautomaten mit dem registrierten Mobiltelefon des Kunden verwendet.

  • Microservices

    Food Delivery-App auf Oracle Autonomous Database

    GrabDish ist eine App für die Lieferung von Lebensmitteln, die Oracle AQ für die Kommunikation zwischen den Microservices für Bestellung, Inventar und Lieferung verwendet. Sehen Sie sich den Code im LiveLab zum Thema „Einfachere Microservices mit Oracle AQ“ an.

    Moderne AppDev von Microservices mit Oracle TxEventQ in der konvergierten Datenbank von Oracle

Erste Schritte mit AQ und TxEventQ


Oracle Cloud Free Tier testen

Erstellen, testen und stellen Sie Anwendungen in der Oracle Cloud kostenlos bereit.


LiveLab

Nutzen Sie Oracle AQ und TxEventQ in Ihrer modernen Umgebung zur Anwendungsentwicklung mit der Oracle Database.


Vertrieb kontaktieren

Möchten Sie mehr erfahren? Kontaktieren Sie einen unserer branchenführenden Experten.