Um fluxo é um método de particionamento de tópico utilizado por aplicativos do MQSeries Publicação/Assinatura. Conjuntos de tópicos relacionados são agrupados em fluxos separados.
Através da utilização de fluxos, diferentes controles de segurança podem ser aplicados a diferentes grupos de tópicos, e a carga de trabalho de publicação do intermediário pode ser melhor equilibrada.
Embora o WebSphere Business Integration Event Broker forneça outras maneiras para que um aplicativo para atingir ambos comportamentos, o conceito de fluxos é suportado para compatibilidade com aplicativos MQRFH.
WebSphere Business Integration Event Broker permite que aplicativos cliente do MQRFH especifiquem um parâmetro de comando MQPSStreamName em suas assinaturas e publicações.No entanto, o nome do fluxo é utilizado apenas para modificar o tópico para preservar a característica de particionamento doMQSeries Publicação/Assinatura.
Se o nome de um fluxo associado a uma mensagem não for SYSTEM.BROKER.DEFAULT.STREAM, a mensagem será processada como se o tópico ou tópicos mencionados na mensagem tivessem sido prefixados com a cadeia "SYS/STREAM/<streamname>/". Por exemplo, uma assinatura de Topic1 que especifica um nome de fluxo de StreamX é processada como se a assinatura tivesse sido feita para o tópico "$SYS/STREAM/StreamX/Topic1".
Aplicativos de publicação e assinatura MQRFH2 também podem ter como destino tópicos relacionados a fluxo, embora eles próprios não possam especificar um nome de fluxo nas mensagens enviadas para o intermediário WebSphere Business Integration Event Broker. Para fazer isto, eles devem colocar os prefixos apropriados nos tópicos.
Por exemplo, um assinante MQRFH2 deve especificar o tópico "$SYS/STREAM/STOCK.STREAM/IBM/Latest" para assinar o tópico "IBM/Latest" publicado no fluxo STOCK.STREAM dentro da rede do MQSeries Publicação/Assinatura.
MQSeries Publicação/Assinatura permite que uma publicação relacionada a fluxo seja enviada apenas para uma fila que possui o mesmo nome do fluxo. No entanto, WebSphere Business Integration Event Broker permite que clientes de publicação enviem suas publicações para qualquer fila de entrada em um fluxo de mensagens. Aplicativos MQRFH que especificam um parâmetro de nome de fluxo explicitamente dentro de uma publicação podem enviá-la para qualquer publicação atendida pelo intermediário WebSphere Business Integration Event Broker. O nome da fila não precisa ser igual ao nome do fluxo. Entretanto, esse comportamento pode afetar a ordem em que as publicações são recebidas. Veja se isso é importante para seus aplicativos.
Cada nó de publicação possui uma propriedade Implicit Stream Naming que utiliza true como padrão. Esta opção padrão resulta em um comportamento idêntico ao demonstrado peloMQSeries Publicação/Assinatura quando uma publicação MQRFH não conter um nome de fluxo explícito. Se esta propriedade for false, e a publicação não conter nenhum nome de fluxo explícito, SYSTEM.BROKER.DEFAULT.STREAM será assumido.
As opções disponíveis para os aplicativos cliente MQRFH e MQRFH2 que publicam mensagens são mostrados na tabela a seguir; a tabela mostra as opções para o fluxo padrão é um nome de fluxo de exemplo de StreamX.
Publicador do MQRFH | Publicador do MQRFH2 | |||
---|---|---|---|---|
Fluxo Padrão | FluxoX | Fluxo Padrão | FluxoX | |
Assinante do MQRFH | S1,P1 | S2,P2 | S1,P3 | S2,P4 |
Assinante do MQRFH2 | S3,P1 | S4,P2 | S3,P3 | S4,P4 |
Em uma rede do MQSeries Publicação/Assinatura um intermediário não precisa suportar o mesmo conjunto de fluxos de seus vizinhos. Se um intermediário não suportar um fluxo que seja suportado por um dos intermediários vizinhos, as publicações associadas a esse fluxo não estarão disponíveis aos clientes nesse intermediário.
Quando um intermediário WebSphere Business Integration Event Broker unir a rede, ela suporta todos os fluxos de seus intermediários vizinhos do MQSeries Publicação/Assinatura. Isto significa que clientes do intermediário WebSphere Business Integration Event Broker podem atingir publicações para qualquer fluxo que seja suportado por seus vizinhos do MQSeries Publicação/Assinatura.
No entanto, para tornar essas publicações disponíveis, você deve definir as filas de fluxo, e definir e implementar os fluxos de mensagens que as suportam, no intermediário WebSphere Business Integration Event Broker.
Uma Rede Heterogênea
O fila de fluxo padrão SYSTEM.BROKER.DEFAULT.STREAM sempre é suportado por todos os intermediários em uma rede do MQSeries Publicação/Assinatura, e deve ser definida em todos os intermediários do WebSphere Business Integration Event Broker em uma rede heterogênea. Em cada intermediário, é preciso definir e implementar um fluxo de mensagens para servir a essa fila.
Quando um intermediário do WebSphere Business Integration Event Broker for integrado em uma rede do MQSeries Publicação/Assinatura, e ligar dois ou mais intermediários do MQSeries Publicação/Assinatura que compartilham fluxos comuns, será necessário definir as filas de fluxo comuns, além de definir e implementar os fluxos de mensagem que os atendem, para o intermediário do WebSphere Business Integration Event Broker.
Por exemplo, o intermediário NEWBROKER do WebSphere Business Integration Event Broker deve possuir uma fila de fluxo definida para BULLETIN.STREAM. Ele também deve ter um fluxo de mensagens definido e implementado para fornecer um serviço de publicação para essa fila.
Quando um intermediário do MQSeries Publicação/Assinatura for migrado para um intermediário do WebSphere Business Integration Event Broker (utilizando o comandomigmqbrk), os fluxos suportados no momento da migração serão replicados exatamente como no intermediário WebSphere Business Integration Event Broker. Nenhuma alteração pode ser feita posteriormente; ou seja, nenhum fluxo pode ser adicionado a esse conjunto replicado ou removido dele. A migração não está concluída até que você tenha criado e implementado os fluxos de mensagens que processam todos esses fluxos.
Conceitos relacionados
Segurança para Recursos de Tempo de Execução
Tarefas relacionadas
Assinando
Referências relacionadas
Cabeçalho do MQRFH2
Avisos |
Marcas |
Downloads |
Biblioteca |
Suporte |
Feedback
![]() ![]() |
aq01180_ |