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

Oracle Advanced Queuing es una plataforma de transmisión de mensajes integrada en Oracle Database que se utiliza para flujos de trabajo de aplicaciones, microservicios y acciones activadas por eventos. Oracle Database 19c presenta Oracle Transactional Event Queues, que combina lo mejor de la transmisión de mensajes y pub/sub para eventos con interoperabilidad de Kafka.

Recorrido de producto de Oracle Transactional Event Queues (12:26)

Empieza ahora a utilizar Oracle Transactional Event Queues (TxEventQ)

Funciones de AQ y TxEventQ

Mensajería y pub/sub

  • Alto rendimiento (~1 M+ mensajes/s en RAC) con flujos de eventos paralelos (particionados) en una caché de mensajes en cola y en memoria
  • Entrega de mensajes transaccionales una sola vez, donde la operación DML en la base de datos y el mensaje forman parte de la misma transacción
  • Admite orden total de mensajes en cada flujo de eventos y en múltiples flujos de eventos por cola
  • Pub/sub (temas) y envío/recepción de mensajes (colas) admitidos en la misma infraestructura
  • Consumo asíncrono de mensajes con timeouts de notificación o sondeo

Soporte en varios idiomas

  • Admite API en múltiples idiomas para productores y consumidores: Java, Java con JMS, PL/SQL, C/C++, Python, Node.js, REST y CLI
  • Soporte de Kafka Java Client para sustituir el agente de Kafka por TxEventQ, que será el agente de mensajes
  • Soporte de API de código abierto estándar de JMS para JMS 1.1+ (algunas funciones de JMS 2.0, como múltiples consumidores, mensajes retrasados, etc.)

Funciones operativas

  • El gateway TxEventQ admite interoperabilidad con Kafka
  • Estadísticas de colas y supervisión continua en tiempo real con Prometheus/Grafana
  • Seguridad de la base de datos para el cifrado de mensajes en la tabla de colas
  • Suscriptores basados en reglas utilizados para filtrar mensajes en la transferencia con ejecución rápida de reglas
  • Búsqueda arbitraria en el flujo de eventos, los consumidores nuevos o existentes pueden consumir mensajes de un offset anterior
  • Las opciones de retraso, prioridad, caducidad de mensajes y la propagación de cola a cola aumentan la flexibilidad en la creación de aplicaciones y flujos de trabajo modernos

Malla de eventos para aplicaciones modernas basadas en eventos

Pub/sub de eventos en un entorno de desarrollo de aplicaciones modernas

Los desarrolladores de microservicios y flujos de trabajo basados en eventos utilizan una plataforma de transmisión de mensajes fiable de alto rendimiento. Oracle TxEventQ proporciona una sólida función de transmisión de mensajes en tiempo real, eventos de transmisión y pub/sub con múltiples editores y consumidores. Las instalaciones de alto rendimiento de TxEventQ pueden alcanzar aproximadamente 100 mil millones de mensajes al día en una base de datos Oracle Real Application Clusters (RAC) de 8 nodos.

Diagrama de Oracle TxEventQ en la base de datos convergenteOracle TxEventQ en la base de datos convergente combina pub/sub de eventos y produce/consume de mensajes. Los productores generan contenido o publican en varios idiomas en un agente de colas integrado en la base de datos. Esto se particiona para garantizar el paralelismo. Los consumidores consumen o se suscriben a los mensajes. La propagación de colas hace que el mensaje esté disponible para los consumidores en una base de datos remota de Oracle.

Transmisión de mensajes JMS fiable con bandeja de salida transaccional

Oracle AQ está integrado con Oracle Database, lo que permite la transmisión de mensajes transaccional. Las acciones de agregación y eliminación de elementos de una cola ("enqueue" y "dequeue") se confirman de forma automática y a la vez que otras operaciones de base de datos sin necesidad de realizar confirmaciones en dos fases. Un SQL estándar puede consultar mensajes y sus metadatos. El soporte de bandeja de salida transaccional para microservicios permite simplificar el desarrollo de aplicaciones basado en eventos.

Diagrama de Oracle AQ en la base de datos convergenteOracle AQ en la base de datos convergente combina pub/sub de eventos y produce/consume de mensajes. Los productores generan contenido o publican en varios idiomas en un agente de colas integrado en la base de datos. Los consumidores consumen o se suscriben a los mensajes. La propagación de colas hace que el mensaje esté disponible para los consumidores en una base de datos remota de Oracle.

Oracle AQ/TxEventQ combina las mejores características de la transmisión de mensajes y pub/sub

Principales ventajas de Oracle TxEventQ para los desarrolladores

  • Combina las mejores características de los mensajes y los flujos
  • Admite tanto JMS como Kafka Java Client para la programación en Java
  • Utiliza una implementación en memoria persistente y de alto rendimiento
  • Ofrece mejoras de rendimiento entre 3 y 10 veces mayores que Oracle AQ
  • Se escala con Oracle RAC y varias vCPU en una instancia de Oracle Autonomous Database
  • Interoperable con Apache Kafka, mediante conectores de Kafka JMS

Diagrama del breve historial de Oracle AQ y Transactional Event Queues (TxEventQ)

Oracle AQ se introdujo en Oracle Database 8.0

Oracle Advanced Queuing (AQ) se introdujo en Oracle Database 8.0. En la versión 12.2, se introdujeron AQ Sharded Queues para colas JMS, al mismo tiempo que Kafka se convirtió en un proyecto Apache. AQ Sharded Queues cambió su nombre por Transactional Event Queues en Oracle Database 21c. Tanto lAQ Classic Queues como Transactional Event Queues pueden utilizarse con Oracle Database en cualquier despliegue.

Diagrama del breve historial de Oracle AQ y Transactional Event Queues (TxEventQ) Oracle AQ se introdujo en Oracle Database 8.0 y ha aumentado sus capacidades en todas las ediciones posteriores de la base de datos Oracle. En Oracle Database 12c, se introdujeron colas con particiones horizontales de AQ, con partición y continuación en Oracle Database 19c. AQ Sharded Queues cambió su nombre por Transactional Event Queues en Oracle Database 21c. Oracle AQ sigue estando disponible para flujos de trabajo simples que no requieren un rendimiento muy elevado.
Descubre todos los casos de éxito de nuestros clientes

Casos de éxito de clientes de Oracle AQ y TxEventQ



Logotipo de Auto Zone
Logotipo de Bissell
Logotipo de Data Intensity
Logotipo de jetBlue
Logotipo de Mazda
Logotipo de Pella
Logotipo de Specialized
Logotipo de Tramontina
Logotipo de FedEX

FedEx ha trasladado E-Business Suite a Oracle Cloud Infrastructure. El flujo de trabajo y el sistema de eventos de negocio de E-Business Suite se basan en Oracle Advanced Queuing (AQ).

Casos de uso de AQ y TxEventQ

  • Flujos de trabajo de aplicaciones

    Flujo de trabajo de garantía de distribución para el sector retail

    Las empresas de envíos y paquetería usan contraseñas de un solo uso (OTP) para verificar la dirección y la identidad de la persona destinataria. Para ello, recurren a Oracle AQ, que actúa como eje central para el intercambio de mensajes entre la aplicación del proveedor, la empresa a cargo de la entrega y el cliente. Consulta el código en Oracle AQ LiveLab.

  • Aplicaciones controladas por eventos

    Autenticación de segundo factor para operaciones de banca mediante cajero automático

    En muchos países, los bancos requieren una contraseña de un solo uso (u OTP) para validar las cuentas de cara a la retirada de efectivo. Descubre cómo utilizar Oracle AQ para crear una infraestructura de transmisión de mensajes con el fin de transferir la OTP entre el código de servidor del cajero automático y la aplicación móvil del cliente.

    Oracle AQ se utiliza para coordinar la OTP desde el cajero automático con el teléfono móvil registrado del cliente.

  • Microservicios

    Aplicación de distribución de comida en Oracle Autonomous Database

    GrabDish es una aplicación de distribución de comida que utiliza Oracle AQ para comunicarse entre los microservicios de pedidos, inventario y distribución. Consulta el código en Simplificar microservicios con Oracle AQ LiveLab.

    Moderna AppDev de microservicios con Oracle TxEventQ en la base de datos convergente de Oracle

Empieza ahora a utilizar AQ y TxEventQ


Prueba Oracle Cloud Free Tier

Crea, prueba y despliega aplicaciones en Oracle Cloud de forma gratuita.


LiveLab

Utiliza Oracle AQ y TxEventQ en tu entorno de desarrollo de aplicaciones modernas con Oracle Database.


Ponte en contacto con ventas

¿Deseas saber más? Ponte en contacto con uno de nuestros expertos líderes del sector.