WebSphere Message Broker, Versão 8.0.0.5 Sistemas operacionais: AIX, HP-Itanium, Linux, Solaris, Windows, z/OS

Consulte as informações sobre a versão mais recente do produto em IBM Integration Bus, Versão 9.0

Serialização de Entrada entre Intermediários Separados no z/OS

Este exemplo demonstra que somente um nó input por vez tira mensagens de uma fila compartilhada quando o token de serialização é utilizado pelos fluxos de mensagens em execução em intermediários separados.

Dois brokers (MQ01BRK e MQ02BRK) estão configurados neste exemplo. Os gerenciadores de filas respectivos são chamados de MQ01 e MQ02. Os gerenciadores de filas participam do mesmo grupo de compartilhamento de fila. Cada gerenciador de filas possui uma fila compartilhada INQueue.QSG que foi definida com uma disposição de QSG e uma fila local chamada INQueue. Os gerenciadores de filas podem estar em execução na mesma Partição lógica (LPAR) ou em LPARs separadas. O Recurso de Acoplamento mostrado nos diagramas a seguir é um componente do zSeries que permite que os gerenciadores de fila do z/OS WebSphere MQ na mesma imagem do sistema, ou em diferentes imagens do sistema, compartilhem filas.

Um fluxo de mensagens idêntico MyFlowA é implementado para um grupo de execução chamado MYGroupA em cada intermediário. Observe que os fluxos de mensagens não precisam ser idênticos; o ponto significativo é que um token de serialização idêntico seja utilizado para ambos fluxos.

O fluxo de mensagem simples neste exemplo consiste em um nó MQInput conectado a um nó MQOutput. O nó MQInput em ambos os fluxos de mensagens obtém mensagens da fila compartilhada INQueue.QSG; o atributo Serialization Token do nó é configurado como MyToken123ABC em ambos os nós MQInput.

A propriedade do fluxo de mensagens instâncias adicionais utiliza o valor padrão zero em ambos fluxos de mensagens, o que assegura que a entrada seja serializada no fluxo.

Ilustração que Mostra Vários Intermediários Participando em um Grupo de Compartilhamento de Fila
Uma seqüência típica de eventos para este exemplo está a seguir:
  1. O primeiro intermediário MQ01BRK inicia e executa o fluxo de mensagens MyFlowA no grupo de execução MyGroupA. O nó input MyInputNode conecta ao gerenciador de filas MQ01 utilizando um token de serialização. MyToken123ABC. O nó input abre com êxito a fila compartilhada INQUeue.QSG e obtém mensagens de entrada.
  2. O segundo intermediário MQ02BRK é iniciado e começa a executar sua cópia do fluxo de mensagens MyFlowA no grupo de execução MyGroupA. O nó Input MyInputNode tenta conectar ao gerenciador de filas MQ02, também utilizando um token de serialização MyToken123ABC.
    A mensagem do console SDSF a seguir é registrada:
     BIP2656I MQ02BRK MyGroupA 17 NÃO FOI POSSÍVEL ABRIR A FILA  
     'INQueue.QSG' NO WEBSPHERE BUSINESS INTEGRATION QUEUE 
     MANAGER 'MQ02': CÓDIGO DE CONCLUSÃO 2; CÓDIGO DE RAZÃO 2271. 
     :ImbCommonInputNode(759) POIS O TOKEN DE SERIALIZAÇÃO  
     MyToken123ABC já está em utilização. NENHUMA AÇÃO DO USUÁRIO É REQUERIDA.   

    Observe que essa mensagem é reproduzida a cada 30 minutos.

    O fluxo de mensagens MyFlowA do grupo de execução MyGroupA em execução no intermediário MQ02BRK não pode processar entrada, pois o token de serialização que transmitiu já está sendo utilizado no grupo de compartilhamento de filas. Isso é indicado pelo código de razão 2271 (MQRC_CONN_TAG_IN_USE) na mensagem bip2623.

  3. O intermediário MQ01BRK pára. O fluxo de mensagens MyFlowA do grupo de execução MyGroupA no intermediário MQ02BRK2 agora é capaz de obter mensagens da fila compartilhada INQueue.QSG.
    Uma seqüência de mensagens do console SDSF é registrada, entre as quais as duas a seguir são relevantes:
      BIP2091I MQ02BRK MyGroupA 17 O INTERMEDIÁRIO 
     RECONECTOU AO WEBSPHERE BUSINESS INTEGRATION 
     COM ÊXITO : ImbCommonInputNode(785)               
      BIP9142I MQ01BRK 0 O COMPONENTE PAROU. : 
     ImbControlService(594)              

A seqüência anterior de eventos também ocorre se o intermediário MQ01BRK falhar, em vez de parar através de um pedido do operador ou se uma nova configuração de intermediário for implementada para MQ01BRK que exclui ou modifica o fluxo de mensagens MyFlowA.

Essa disposição também pode ser utilizada quando o requisito for migrar o processamento de mensagens entre intermediários em execução em diferentes imagens do sistema z/OS que estão conectados ao mesmo Recurso de Acoplamento.

Avisos | Marcas Registradas | Downloads | Biblioteca | Suporte | Feedback

Copyright IBM Corporation 1999, 2014Copyright IBM Corporation 1999, 2014.

        
        Última atualização:
        
        Última atualização: 2015-02-28 18:29:38


Tópico de ConceitoTópico de Conceito | Versão 8.0.0.5 | ae27010_