Cozi de evenimente tranzacţionale (TxEventQ) şi cozi avansate (AQ)

Oracle Advanced Queuing este o platformă de mesagerie încorporată în Oracle Database care este utilizată pentru fluxuri de lucru ale aplicațiilor, microservicii și acțiuni declanșate de evenimente. Oracle Database 19c prezintă Oracle Transactional Event Queues, unificând tot ce este mai bun în mesagerie și pub/sub pentru evenimentele cu interoperabilitate Kafka.

Turul Oracle Transactional Event Queues (12:26)

Începeți să utilizați Oracle Transactional Event Queues (TxEventQ)

Caracteristici AQ și TxEventQ

Mesagerie şi pub/sub

  • Debit ridicat (~1 M+ mesaje/sec pe RAC) cu fluxuri de evenimente paralele (partiționate) în cadrul unei cozi și în memoria cache pentru mesaje
  • Livrarea exactă a mesajelor tranzacţionale, în care operaţia DML din baza de date şi din mesaj face parte din aceeaşi tranzacţie
  • Sunt acceptate ordinea totală a mesajelor din cadrul fiecărui flux de evenimente şi mai multe fluxuri de evenimente per coadă
  • Pub/sub (subiecte) şi mesagerie de trimitere/primire (cote) acceptate într-o singură infrastructură
  • Consum asincron de mesaje cu expirarea înştiinţării sau a sondajului

Suport pentru limbi

  • Pentru producători şi consumatori sunt acceptate mai multe API-uri lingvistice: Java, Java cu JMS, PL/SQL, C/C++, Python, Node.js, REST şi CLI
  • Suport client Java Kafka pentru înlocuirea brokerului Kafka cu TxEventQ ca broker de mesaje
  • Suport API open source standard JMS pentru JMS 1.1+ (unele funcţionalităţi din JMS 2.0, cum ar fi mai mulţi consumatori, mesaje întârziate etc.)

Caracteristici operaționale

  • Gateway-ul TxEventQ acceptă interoperabilitatea cu Kafka
  • Statistici privind cozile și monitorizare continuă în timp real cu Prometheus/Grafana
  • Securitatea bazei de date pentru criptarea mesajelor din tabelul de cozi
  • Abonaţi bazaţi pe reguli, utilizaţi pentru a filtra mesajele pe fir pe baza execuţiei rapide a regulilor
  • Căutare arbitrară în fluxul de evenimente, consumatorii noi sau existenţi pot consuma mesaje de la un decalaj anterior
  • Întârzierea mesajelor, prioritatea, expirarea și propagarea cozii în coadă permit flexibilitatea în crearea de aplicații și fluxuri de lucru moderne

Rețea de evenimente pentru aplicații moderne bazate pe evenimente

Pub/subevenimente în mediul modern de dezvoltare a aplicațiilor

Dezvoltatorii de microservicii și fluxuri de lucru bazate pe evenimente se bazează pe o platformă de mesagerie fiabilă, cu debit mare. Oracle TxEventQ oferă mesagerie robustă în timp real, evenimente de streaming şi pub-uri cu mai mulţi publisheri şi mai mulţi consumatori. Instalările cu debit ridicat de la TxEventQ pot realiza aproximativ 100 de miliarde de mesaje pe zi într-o bază de date Oracle Real Application Clusters (RAC) pe 8 noduri.

Oracle TxEventQ în diagrama bazei de date convergenteOracle TxEventQ din baza de date convergentă combină pub-ul/sub-ul evenimentelor și produce/consumă mesaje. Producătorii produc sau publică în mai multe limbi către un broker de cozi încorporat în baza de date. Acest lucru este împărțit pentru paralelism. Consumatorii consumă sau se abonează la mesaje. Propagarea cozii pune mesajul la dispoziţia consumatorilor dintr-o bază de date Oracle la distanţă.

Mesagerie JMS fiabilă cu outbox tranzacțional

Oracle AQ este integrat cu Oracle Database, care permite mesageria tranzacțională. Plasările în coadă și ieșirile în coadă sunt confirmate automat în același timp cu alte operațiuni ale bazei de date, fără a fi necesare confirmări în două faze. SQL standard poate interoga mesaje şi metadatele acestora. Suportul outbox tranzacțional pentru microservicii permite simplificarea dezvoltării aplicațiilor bazate pe evenimente.

Oracle AQ în diagrama bazei de date convergenteOracle AQ din baza de date convergentă combină pub-uri/sub evenimente și produce/consumă mesaje. Producătorii produc sau publică în mai multe limbi către un broker de cozi încorporat în baza de date. Consumatorii consumă sau se abonează la mesaje. Propagarea cozii pune mesajul la dispoziţia consumatorilor dintr-o bază de date Oracle la distanţă.

Oracle AQ/TxEventQ combină cele mai bune soluţii pentru mesagerie şi pub/sub

Principalele avantaje ale Oracle TxEventQ pentru dezvoltatori

  • Combină tot ce este mai bun în mesagerie și streaming
  • Acceptă atât clientul Java JMS, cât şi clientul Kafka pentru programarea Java
  • Utilizează o implementare persistentă în memorie, cu performanţe ridicate
  • Oferă 3X 10X îmbunătăţiri ale performanţei faţă de Oracle AQ
  • Se scalează cu Oracle RAC și vCPUs în cadrul unei instanțe Oracle Autonomous Database
  • Interoperabil cu Apache Kafka, utilizând conectorii Kafka JMS

Diagrama unui scurt istoric al Oracle AQ și al cozilor de evenimente tranzacționale (TxEventQ)

Oracle AQ a fost introdus în Oracle Database 8.0

Oracle Advanced Queuing (AQ) a fost introdus în Oracle Database 8.0. În versiunea 12.2, au fost introduse cozi partiţionate AQ pt. cozile JMS, aproximativ în acelaşi timp în care Kafka a devenit un proiect Apache. Cozile de evenimente tranzacţionale AQ sunt redenumite cozi de evenimente tranzacţionale în Oracle Database 21c. Atât cozile AQ Classic, cât şi cozile de evenimente tranzacţionale sunt gratuite, utilizate cu Oracle Database în orice implementare.

Diagrama unui scurt istoric al Oracle AQ și al cozilor de evenimente tranzacționale (TxEventQ) Oracle AQ a fost introdus în Oracle Database 8.0 şi prezintă funcţionalităţile sale în fiecare ediţie ulterioară a bazei de date Oracle. În Oracle Database 12c, au fost introduse cozi partiţionate AQ, cu partiţionare şi continuare în Oracle Database 19c. Cozile partiţionate AQ sunt redenumite în cozi de evenimente tranzacţionale din Oracle Database 21c. Oracle AQ continuă să fie disponibil pentru fluxuri de lucru simple, care nu necesită un debit foarte mare.
Vedeți toate succesele clienților

Realizările clienților Oracle AQ și TxEventQ



Siglă zonă automată
Sigla Bissell
Siglă Data Intensity
jetBlue Siglă
Sigla Mazda
Sigla Pella
Siglă specializată
Sigla Tramontina
FedEX Siglă

FedEx a mutat E-Business Suite în Oracle Cloud Infrastructure. Fluxul de lucru și sistemul de evenimente business din E-Business Suite sunt create pe Oracle Advanced Queuing (AQ).

Vizualizați relatarea

Cazuri de utilizare AQ și TxEventQ

  • Fluxuri de lucru pentru aplicaţii

    Flux de lucru pentru garanția livrării în retail

    Companiile de livrare utilizează parole unice (OTP) pentru a verifica adresa şi persoana de livrare, utilizând Oracle AQ ca backbone pentru schimbul de mesaje dintre aplicaţia furnizorului, emitent şi client. Consultaţi codul de aici: Oracle AQ LiveLab.

  • Aplicații bazate pe evenimente

    Autentificarea prin al doilea factor în ATM banking

    Băncile au nevoie de un OTP pentru a-și valida conturile pentru retragere în multe țări. Aflaţi cum să utilizaţi Oracle AQ pentru a crea o infrastructură de mesagerie pentru transferul OTP între codul serverului ATM şi aplicaţia de mobil a clientului.

    Oracle AQ este utilizat pentru coordonarea OTP de la bancomat cu telefonul mobil înregistrat al clientului.

  • Microservicii

    Aplicația de livrare a alimentelor pe Oracle Autonomous Database

    GrabDish este o aplicație pentru livrarea de alimente care utilizează Oracle AQ pentru comunicarea între microserviciile de comandă, inventar și livrare. Consultaţi codul din Simplificaţi microserviciile cu Oracle AQ LiveLab.

    AppDev modern de microservicii cu Oracle TxEventQ în baza de date convergentă Oracle

Resurse AQ și TxEventQ

Începeți să utilizați AQ și TxEventQ


Încercați Oracle Cloud Free Tier

Creați, testați și implementați gratuit aplicații în Oracle Cloud.

Încercați gratuit

LiveLab

Utilizaţi Oracle AQ şi TxEventQ în mediul dvs. modern de dezvoltare a aplicaţiilor cu Oracle Database.

Detalii

Contactați departamentul de vânzări

Doriți să aflați mai multe? Contactați unul dintre experții noștri de top din domeniu.

Contactați