Informazioni sull'esempio Bozza

L'esempio Bozza utilizza il tipo di messaggistica pubblicazione/sottoscrizione per trasportare i dati. Per ulteriori informazioni, leggere la sezione relativa alla messaggistica pubblicazione/sottoscrizione nella documentazione di WebSphere Message Broker.

ScribblePublisher e ScribbleSubscriber possono trasportare messaggi di pubblicazione utilizzando il trasporto WebSphere MQ o il trasporto Real-time di WebSphere MQ. I messaggi vengono formattati secondo il tipo di trasporto selezionato all'avvio di ogni applicazione ed il formato del messaggio determina il modo in cui i messaggi entrano ed escono dal flusso di messaggi. Tutti i messaggi di pubblicazione vengono trasmessi al flusso di messaggi indipendentemente dal formato del messaggio.

L'esempio Bozza esegue queste azioni:

  1. Quando si avvia l'applicazione ScribbleSubscriber, questa esegue la sottoscrizione agli argomenti bozza/coord e bozza/cancella.
  2. Quando si inizia a disegnare nella finestra ScribblePublisher, ScribblePublisher pubblica le coordinate del disegno nell'argomento bozza/coord nel flusso di messaggi ScribblePublish.
  3. Il flusso di messaggi controlla che il messaggio sia stato pubblicato nell'argomento bozza/coord e converte le coordinate nel messaggio di pubblicazione.
  4. L'applicazione ScribbleSubscriber riceve i messaggi che contengono le coordinate convertite poiché dispone della sottoscrizione alle pubblicazioni nell'argomento bozza/coord.
  5. Quando si fa clic su Cancella nell'applicazione ScribblePublisher, ScribblePublisher pubblica un messaggio nell'argomento bozza/cancella nel flusso di messaggi ScribblePublish.
  6. Il flusso di messaggi non converte i dati del messaggio poiché il messaggio non è stato pubblicato nell'argomento bozza/coord.
  7. L'applicazione ScribbleSubscriber riceve il messaggio poiché ha effettuato una sottoscrizione alle pubblicazioni nell'argomento bozza/cancella.

Le seguenti sezioni descrivono le risorse dell'esempio in maggiori dettagli:

I messaggi

L'esempio Bozza utilizza due formati di messaggi JMS:

Tutti i messaggi hanno una maschera di messaggio standard che contiene le seguenti parti:

Quando l'applicazione ScribblePublisher pubblica messaggi utilizzando il tipo di trasporto messaggio Real-time, il messaggio di pubblicazione viene formattato in modo differente rispetto a quando ScribblePublisher pubblica messaggi utilizzando il tipo di trasporto messaggio WebSphere MQ. Tuttavia, il nodo Filter nel flusso di messaggi ScribblePublish è in grado di analizzare solo messaggi formattati per il trasporto WebSphere MQ. A causa di questa limitazione, il nodo Real-time Input converte il formato dei messaggi Real-time in messaggi WebSphere MQ in modo che i nodi del flusso di messaggi possano analizzare i messaggi.

Il nodo Publication nel flusso di messaggi pubblica messaggi WebSphere MQ nelle applicazioni ScribbleSubscriber che stanno utilizzando il trasporto messaggi WebSphere MQ. Tuttavia, se ScribbleSubscriber utilizza il trasporto Real-time, il nodo Publication converte il formato del messaggio in Real-time quando pubblica i messaggi.

Per ulteriori informazioni, leggere le sezione relativa ai Domini JMS nella documentazione WebSphere Message Broker.

Il flusso di messaggi

La seguente figura mostra il flusso di messaggi ScribblePublish, che elabora i messaggi di pubblicazione nell'esempio Bozza.

Una screen capture del flusso di messaggi ScribblePublish.

La seguente tabella elenca i tipi di nodi utilizzati nel flusso di messaggi ScribblePublish.

Tipo nodo Nome nodo
MQInput SCRIBBLE_PUBLICATION
Real-timeInput Real-timeInput
Filter Filter On Topic
Compute Invert Coordinates
Publication Publication

Per ulteriori informazioni, leggere la sezione relativa ai nodi nel flusso di messaggi ScribblePublish nella documentazione di WebSphere Message Broker.

Il flusso di messaggi ScribblePublish converte le coordinate pubblicate dall'applicazione ScribblePublisher e quindi pubblica le nuove coordinate nell'applicazione ScribbleSubscriber. Per ulteriori informazioni, leggere la sezione relativa alla conversione di flussi di messaggi e messaggi nella documentazione di WebSphere Message Broker.

Il flusso di messaggi ScribblePublish effettua le seguenti azioni:

  1. Richiama il messaggio di pubblicazione. Il modo in cui il flusso di messaggi richiama il messaggio di input dipende dalla formattazione del messaggio:
  2. Filtra il messaggio di pubblicazione nel relativo argomento:
  3. Converte le coordinate pubblicate nell'argomento bozza/coord in modo che risultino invertite nell'applicazione ScribbleSubscriber.
  4. Emette il messaggio. Il modo in cui il messaggio lascia il flusso di messaggi dipende dal dominio dei messaggi dell'applicazione sottoscrittore:

I messaggi vengono trasmessi nel flusso di messaggi come descritto indipendentemente dal tipo di trasporto dei messaggi utilizzato dalle applicazioni autore (publisher) e sottoscrittore (subscriber). Tuttavia, poiché i nodi Filter e Compute nel flusso di messaggi possono analizzare solo messaggi formattati per il trasporto WebSphere MQ, il nodo Real-timeInput converte i messaggi Real-time in messaggi WebSphere MQ. In modo simile, il nodo Publication converte i messaggi WebSphere MQ in messaggi Real-time se li sta pubblicando nella porta Real-time.

L'ESQL

Per visualizzare l'ESQL utilizzato nel flusso di messaggi ScribblePublish nel workbench:

  1. Nel workbench, passare alla vista Broker Application Development.
  2. Nella vista Navigator risorse, fare doppio clic su ScribblePublish.esql per aprirlo nell'editor ESQL.

L'ESQL per il nodo Filter On Topic è contenuto nel modulo ScribblePublish_Filter e l'ESQL per il nodo Invert Coordinates è contenuto nel modulo ScribblePublish_Compute. Per ulteriori informazioni, leggere la sezione relativa ad ESQL nella documentazione di WebSphere Message Broker.

I trasporti messaggio

Le applicazioni ScribblePublisher e ScribbleSubscriber pubblicano informazioni nei messaggi JMS. Entrambe le applicazioni possono trasportare i messaggi utilizzando il trasporto dei messaggi WebSphere MQ o Real-time.

Trasporto WebSphere MQ

Quando un'applicazione Scribble utilizza WebSphere MQ per trasportare i propri messaggi di pubblicazione, interagisce con le code locali WebSphere MQ indicate nella seguente tabella.

Coda Modalità di utilizzo della coda da parte del flusso di messaggi
SCRIBBLE_PUBLICATION Il flusso di messaggi richiama le pubblicazioni di eventi pubblicate nella coda dall'applicazione ScribblePublisher.
SYSTEM.JMS.ND.SUBSCRIBER.QUEUE Il flusso di messaggi inserisce le pubblicazioni sulla coda per l'applicazione ScribbleSubscriber in modo che possano essere acquisite e pubblicate nel broker.

Per ulteriori informazioni su WebSphere MQ, consultare la documentazione sul prodotto WebSphere MQ.

Trasporto Real-time WebSphere MQ

Quando un'applicazione Scribble utilizza Real-time per trasportare i propri messaggi di pubblicazione, non interagisce con le code WebSphere MQ. Invece, ScribblePublisher pubblica in una porta Real-time e ScribbleSubscriber richiama le pubblicazioni dalla stessa porta Real-time. In questo esempio, il numero porta Real-time è 1566. Per ulteriori informazioni, leggere le sezione relativa al Trasporto Real-time WebSphere MQ nella documentazione di WebSphere Message Broker.

icona Pagina principale   Torna alla pagina home dell'esempio