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. Los conjuntos de temas relacionados se pueden agrupar en corrientes de datos aparte. Pueden aplicarse distintos controles de seguridad a distintas corrientes de datos y, de este modo, la carga de trabajo de publicación del intermediario puede equilibrarse mejor.

Aunque WebSphere Message Broker proporciona controles más flexibles para que una aplicación lleve a cabo estas dos acciones, el, concepto de corrientes de datos se soporta para que exista compatibilidad con 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 permite a las aplicaciones cliente MQRFH especificar un parámetro del mandato MQPSStreamName en sus suscripciones y publicaciones. No obstante, 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 asociada a un mensaje se establece en un valor distinto a SYSTEM.BROKER.DEFAULT.STREAM, el mensaje se procesa como si el tema o temas mencionados dentro del mensaje llevasen el prefijo "$SYS/STREAM/<streamname>/". 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 sea para el tema "$SYS/STREAM/StreamX/Topic1".

Las aplicaciones de publicación y suscripción de MQRFH2 también pueden destinarse a temas relacionados con corrientes de datos, aunque no puedan 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 el nombre de la cola sea igual que el nombre de la corriente de datos. No obstante, esto podrían afectar al orden en que se reciben las publicaciones. Vea si esto es importante para sus aplicaciones.

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 predeterminado verdadero. Esta opción predeterminada 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.

Las opciones que están disponibles tanto para aplicaciones cliente MQRFH como MQRFH2 que publiquen mensajes se indican en la siguiente tabla; la tabla muestra las opciones para la corriente de datos predeterminada y para un ejemplo del nombre de corriente de datos CorrienteDatosX.
  Publicador MQRFH Publicador MQRFH2
  corriente de datos predeterminada CorrienteDatosX corriente de datos predeterminada CorrienteDatosX
Suscriptor de 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 efectúa la suscripción sin un nombre de corriente de datos o con el nombre de corriente de datos "SYSTEM.BROKER.DEFAULT.STREAM".
S2
El suscriptor efectúa la suscripción con el nombre de corriente de datos "CorrienteDatosX".
S3
El suscriptor efectúa la suscripción a un tema sin añadir "$SYS/STREAM/<nombreCorrienteDatos>/".
S4
El suscriptor efectúa la suscripción prefijando el tema con "$SYS/STREAM/CorrienteDatosX/".

Notas sobre el publicador

P1
El publicador efectúa la publicación en cualquier cola especificando el nombre de 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 haya dado a la propiedad Denominación de corriente de datos implícita el valor "falso".
P2
El publicador efectúa la publicación en cualquier cola especificando el nombre de corriente de datos "CorrienteDatosX", o efectúa la publicación sin especificar ningún nombre de corriente de datos en la cola "CorrienteDatosX" habiendo dado a la propiedad Denominación de corriente de datos implícita el valor "verdadero".
P3
El publicador efectúa la publicación 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/CorrienteDatosX/" 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.
Conceptos relacionados
Seguridad de recursos de ejecución: listas de control de acceso
Tareas relacionadas
Configuración de la seguridad para los componentes del dominio
Publicación
Suscripciones
Referencia relacionada
Cabecera MQRFH2
Avisos | Marcas registradas | Descargas | Biblioteca | Soporte | Su opinión

Copyright IBM Corporation 1999, 2009Copyright IBM Corporation 1999, 2009.
Última actualización : 2009-02-16 13:56:01

aq19790_