[z/OS]

Flujo de mensajes para beans controlados por mensajes JCA con WebSphere MQ como proveedor de mensajería

Application Server Facilities (ASF) se utiliza con los proveedores de mensajería que incluyen las extensiones ASF opcionales en la especificación JMS. En z/OS estas extensiones son implementadas por el proveedor de mensajería WebSphere MQ. A partir de WebSphere Application Server versión 7.0 hacia adelante, se prefiere JCA respecto a la tecnología ASF más antigua.

El soporte de ASF para los beans controlado por mensaje en WebSphere Application Server también se conoce como el servicio de escucha de mensajes. Cuando se instala una aplicación de bean controlado por mensaje ASF se puede proporcionar información de configuración como un puerto de escucha de mensajes.

Figura 1. Conexiones de WebSphere MQ - Message Listener Service (ASF)
Una instalación de servidor WebSphere Application Server escalable contiene una región de control (CR) y varias regiones de sirviente (SR). La CR contiene un servicio de escucha de mensajes y la SR contiene una aplicación. Los mensajes fluyen de WebSphere MQ al servicio de escucha de mensajes en la CR, a través de una cola zWLM en la instalación de WebSphere Application Server y, a continuación, a la aplicación en la SR. Los mensajes también fluyen directamente de WebSphere MQ a la aplicación en la SR y vuelven desde allí a WebSphere MQ. Las comunicaciones de salida fluyen desde la SR.
En z/OS, ASF se utiliza con dos patrones distintos de flujo de mensajes.
  • Para todas las fuentes de mensajes, excepto las suscripciones no duraderas, el escucha de mensajes se ejecuta en la región de control (CR), es decir, es Escucha en el controlador para estos mensajes.
  • Para las suscripciones no duraderas, el escucha de mensajes se ejecuta en las regiones de sirviente (SR), es decir, es Escucha en el sirviente para estos mensajes.

Escucha en el controlador

En la siguiente figura se muestra el flujo de mensajes de WebSphere MQ ASF cuando el escucha de mensajes está escuchando en el controlador

En z/OS WebSphere Application Server, ASF soporta el proceso controlado por mensajes donde el escucha del bean controlado por mensaje está en la CR y el trabajo se distribuye en el asignador de bean controlado por mensaje en las SR. Tenga en cuenta que para la publicación/suscripción hay un escucha que registra una suscripción para todo el servidor, no suscripciones separadas para cada SR.

Figura 2. WebSphere MQ ASF - escucha en el controlador
Una instalación de servidor WebSphere Application Server escalable engloba una región de control (CR) y varias regiones de sirviente (SR). La CR contiene un cliente WebSphere MQ Java, que gestiona los mensajes de WebSphere MQ, y una escucha de WebSphere MQ ASF para la clasificación de carga de trabajo. Cada SR contiene un cliente WebSphere MQ Java, un asignador de WebSphere MQ ASF y un contenedor EJB que contiene un bean controlado por mensaje. La instalación también tiene un número de colas WLM. Así como la instalación de WebSphere Application Server, hay una instancia de WebSphere MQ que contiene una cola de WebSphere MQ donde se originan los mensajes. El texto que sigue a la figura describe la vía de acceso que toma un mensaje a través de estos elementos.
El proceso es el siguiente:
  1. Cuando llega un mensaje en un destino JMS (se muestra en la figura como una cola de WebSphere MQ), el escucha recibe una copia del mensaje. El escucha no suprime el mensaje del destino.
  2. El escucha determina la clase de transacción para el mensaje y utiliza una gestión de carga de trabajo (WLM) de z/OS para pasar un símbolo de mensaje (no el mensaje real) a una SR. La gestión de carga de trabajo selecciona una SR apropiada basada en la clase de transacción.
  3. El asignador utiliza el símbolo del mensaje para recibir el mensaje y lo pasa en el método onMessage del bean controlado por mensaje. El asignador suprime los mensajes del destino.

Escucha en el sirviente

En la figura siguiente se muestra el flujo de mensajes de WebSphere MQ ASF cuando el escucha de mensajes está escuchando en una región de sirviente.

En la figura se muestra un formato especial de proceso de bean controlado por mensaje ASF donde tanto el escucha del bean controlado por mensaje, como el asignador del bean controlado por mensaje se ejecutan en la misma SR. WebSphere Application Server utiliza esta configuración para la mensajería de publicación/suscripción no duradera. Cada SR registra su propia suscripción de forma que dicho servidor, potencialmente, recibe y procesa varias copias de la misma publicación (es decir, una copia de la misma publicación para cada SR).

Figura 3. WebSphere MQ ASF - escucha en el sirviente
Una instalación de servidor WebSphere Application Server escalable engloba una región de control (CR) y varias regiones de sirviente (SR). El direccionamiento de WLM se lleva a cabo en la CR. Cada SR contiene un cliente WebSphere MQ Java, un escucha de WebSphere MQ MDB, un asignador de MDB de WebSphere MQ y un contenedor EJB que contiene un bean controlado por mensaje. La instalación también tiene una cola WLM. Así como la instalación de WebSphere Application Server, hay una instancia de WebSphere MQ que contiene una cola de WebSphere MQ donde se originan los mensajes. El texto que sigue a la figura describe la vía de acceso que toma un mensaje a través de estos elementos.
El proceso es el siguiente:
  1. Cuando un mensaje llega al destino (que se muestra en la figura como una cola de WebSphere MQ), el escucha recibe una copia del mensaje. El escucha no suprime el mensaje del destino.
  2. El escucha llama al código de la CR que utiliza z/OS WLM para volver a pasar un símbolo de mensaje a la misma SR.
  3. El asignador utiliza el símbolo del mensaje para recibir el mensaje y lo pasa en el método onMessage del bean controlado por mensaje. El asignador suprime los mensajes del destino.

Icon that indicates the type of topic Concept topic



Timestamp icon Last updated: last_date
http://www14.software.ibm.com/webapp/wsbroker/redirect?version=cord&product=was-nd-mp&topic=cprf_tunezmdb_MQ_ASF
File name: cprf_tunezmdb_MQ_ASF.html