Corrientes de datos

WebSphere MQ Publicación/Suscripción utiliza principalmente las corrientes de datos como forma de particionar el espacio de nombres de temas. Se pueden agrupar conjuntos de temas relacionados en distintas corrientes de datos, lo que permite aplicar controles de seguridad diferentes a las distintas corrientes de datos y equilibrar mejor la carga de trabajo de publicación del intermediario.

WebSphere Message Broker proporciona controles más flexibles para llevar a cabo estos dos trabajos. Por lo tanto, el concepto de corriente de datos se soporta únicamente para la compatibilidad de aplicaciones MQRFH.

Los controles de seguridad de WebSphere Message Broker permiten aplicar la autorización a un único nivel de tema. Del mismo modo, la carga de trabajo de publicación del intermediario se puede controlar más fácilmente creando instancias adicionales de flujos de mensajes de publicación que puedan prestar servicio a la misma o distintas colas de entrada.

WebSphere Message Broker continúa permitiendo que las aplicaciones cliente MQRFH especifiquen un parámetro de mandato MQPSStreamName en sus suscripciones y publicaciones. Sin embargo, el nombre de la corriente de datos se utiliza únicamente para modificar el tema a fin de conservar la característica de particionamiento de WebSphere MQ Publicación/Suscripción.

Cuando el nombre de una corriente de datos asociado a un mensaje es distinto de SYSTEM.BROKER.DEFAULT.STREAM, el mensaje se procesará como si el o los temas mencionados dentro del mensaje llevasen el prefijo "$SYS/STREAM/<nombreCorrienteDatos>/". Es decir, que una suscripción al tema Topic1 que especifique el nombre de corriente de datos StreamX se procesa como si la suscripción se hubiese hecho para el tema "$SYS/STREAM/StreamX/Topic1".

Las aplicaciones de publicación y suscripción de MQRFH2 siguen pudiendo destinarse a temas relacionados con corrientes de datos, aunque no les esté permitido especificar por sí mismas un nombre de corriente de datos en los mensajes que envíen al intermediario de WebSphere Message Broker. Para ello, deberán prefijar los temas con el prefijo de corriente de datos adecuado.

Por ejemplo, para suscribirse al tema "IBM/Latest" que se publica en la corriente de datos STOCK.STREAM dentro de la red de WebSphere MQ Publicación/Suscripción, un suscriptor MQRFH2 debe especificar el tema "$SYS/STREAM/STOCK.STREAM/IBM/Latest".

WebSphere MQ Publicación/Suscripción permite únicamente el envío de publicaciones relacionadas con la corriente de datos a una cola que tenga el mismo nombre que la corriente de datos. Sin embargo, WebSphere Message Broker permite que los clientes de publicación envíen sus publicaciones a cualquier cola de entrada de un flujo de mensajes.

Las aplicaciones MQRFH que decidan especificar explícitamente un parámetro del nombre de la corriente de datos dentro de una publicación podrán enviarla a cualquier cola de publicación que reciba el servicio del intermediario de WebSphere Message Broker. No es necesario que la cola tenga el mismo nombre que la corriente de datos.

Tenga en cuenta que el orden en que se reciban las publicaciones puede ser distinto del que esperaba.

Cada nodo Publication tiene una propiedad Denominación de corriente de datos implícita que tiene como valor por omisión verdadero. Esta opción por omisión tiene un comportamiento idéntico al de WebSphere MQ Publicación/Suscripción cuando una publicación no contiene un nombre de corriente de datos implícito. Si la propiedad es falso, y la publicación no contiene un nombre de corriente de datos explícito, se da por supuesto SYSTEM.BROKER.DEFAULT.STREAM.

La siguiente tabla resume las opciones que están disponibles para las aplicaciones cliente MQRFH y MQRFH2 que publiquen mensajes para la corriente de datos por omisión o para una corriente de datos de WebSphere MQ Publicación/Suscripción específica. El nombre de la corriente de datos StreamX se usa para ilustrar las opciones.

  Publicador MQRFH   Publicador MQRFH2  
  corriente de datos por omisión StreamX corriente de datos por omisión StreamX
suscriptor MQRFH S1,P1 S2,P2 S1,P3 S2,P4
Suscriptor de MQRFH2 S3,P1 S4,P2 S3,P3 S4,P4
         
         
         
Notas sobre el suscriptor:
  • S1 El suscriptor se suscribe sin ningún nombre de corriente de datos o con el nombre de corriente de datos "SYSTEM.BROKER.DEFAULT.STREAM".
  • S2 El suscriptor se suscribe son el nombre de corriente de datos "StreamX".
  • S3 El suscriptor se suscribe a un tema sin añadir "$SYS/STREAM/<nombreCorrienteDatos>/".
  • S4 El suscriptor se suscribe a un tema que tiene el prefijo "$SYS/STREAM/StreamX/".
Notas del publicador:
  • P1 El publicador publica en cualquier cola especificando el nombre de la corriente de datos "SYSTEM.BROKER.DEFAULT.STREAM". o efectúa la publicación sin especificar un nombre de corriente de datos en ninguna cola que tenga establecida la propiedad Implicit Stream Naming en "false".
  • P2 El publicador efectúa la publicación en cualquier cola especificando el nombre de corriente de datos "StreamX", o efectúa la publicación sin especificar ningún nombre de corriente de datos en la cola "StreamX" con la propiedad Denominación de corriente de datos implícita establecida en "true".
  • P3 El publicador publica en cualquier cola sin añadir el prefijo "$SYS/STREAM/<CorrienteDatos>/" al tema.
  • P4 El publicador publica en cualquier cola y añade el prefijo "$SYS/STREAM/StreamX/" al tema.
Nota: El prefijo "$SYS/STREAM/<nombreCorrienteDatos>/" se elimina de todos los temas en una publicación de MQRFH2 cuando ésta se entrega a un suscriptor de MQRFH.
Avisos | Marcas registradas | Descargas | Biblioteca | Soporte | Su opinión
Copyright IBM Corporation 1999, 2006 Última actualización: 22/08/2006
aq19790_