Principiile de construire a WebSphere Message Broker
Brokerul de mesaje conectează instrumentele de dezvoltare. mediul de execuție scalabil și instrumentele de modelare.
Componentele principale ale WebSphere Message Broker sunt sistemul de broker executiv, Managerul de configurare, mediul grafic de dezvoltare universal și administrarea Message Broker Toolkit.
Interacțiunea dintre componentele WebSphere Message Broker se bazează pe coșurile WebSphere MQ. Toate comenzile și solicitările care provin de la Message Broker Toolkit la serverul de configurare sunt implementate ca mesaje. Serverul de configurare în sine și brokerii sunt conectați utilizând cozile de mesaje WebSphere MQ. prin care mesajele de control intern și de raportare WebSphere Message Broker în format XML. Pentru stocarea permanentă a informațiilor de configurare, datele despre formate, fluxurile de procesare, serverul de configurare și brokerii utilizează baze de date relaționale. Standard în WebSphere Message Broker este DBMS DB2. cu toate acestea, alte DBMS-uri pot fi folosite pentru a rula brokerul. Oracle. MS SQL Server. Sybase. Serverul de configurare este componenta centrală. gestionarea întreținerii depozitului de formate și reguli de afaceri, activitatea brokerilor.
Brokerii sunt responsabili pentru executarea fluxurilor de procesare, adică sunt mediul de execuție. Fiecare broker are o bază de date proprie, care stochează o parte din datele depozitului principal. Arhitectura multi-proces și multi-threaded a brokerului asigură scalabilitatea sistemului cu fluxuri intense de mesaje.
Fluxul de procesare a mesajelor și designul vizual al acestora. Prelucrarea unui mesaj prins într-un broker este determinată de o așa-numită schemă de flux sau de flux de mesaje. Procesul de procesare constă dintr-o secvență de operații pe mesaj și este construit folosind un set de manipulatoare existente (figura 12.4). Stivuitoarele WebSphere Message Broker sunt în esență rutine personalizabile. Ele implementează o etapă separată sau o funcție specializată a procesului de procesare. Proprietățile manipulatoarelor de procedură definesc parametrii necesari pentru executarea acestui fir. De exemplu, dacă handlerul citește mesaje din coada WebSphere MQ. atunci numele coadajului este specificat ca parametru. Dacă un alt manipulator este proiectat să acceseze o bază de date externă, parametrii săi vor fi numele bazei de date, tabelelor și câmpurilor. Fluxul de procesare este obținut vizual de la manipulatorii necesari. care au puncte de intrare și ieșire - bornele, terminalele de intrare și ieșire ale manipulatoarelor sunt conectate prin conexiuni, formând un grafic direcționat. realizând o secvență pas cu pas a prelucrării mesajelor.
Fig. 12.4. Componentele fluxului de mesaje
Există un grup de manipulatori. care este proiectat să implementeze controale și structuri de control în cadrul fluxului de procesare, de exemplu, dispozitivul de tratare a filtrelor împarte fluxul de procesare în ramuri în funcție de starea de filtrare. Tranzițiile condiționate cu alocări dinamice și statice în interiorul filetului sunt furnizate de robotii RouteToLabel și Label. Pentru a răspunde erorilor și a trata situații excepționale, există instrucțiuni TryCatch și Throw. Urmărirea și verificarea corectitudinii fluxului și a structurii mesajelor trecute sunt efectuate de către operatorii Trace și Check. FlowOrder determină ordinea fiecărei ramuri a fluxului de procesare.
Pentru a interacționa cu bazele de date, există specializați de gestionare a bazei de date. DatabaseInsert. DatabaseUpdate. DatabaseDelete pentru a atribui vizual link-uri și conversii între câmpurile bazei de date și câmpurile mesajelor (Figura 12.5). Capabilitățile cel mai frecvent utilizate și universale sunt computerele de computere. care vă permite să scrieți o varietate de scripturi în limba ESQL.
Fig. 12.5. Exemplu de flux de mesaje
Domenii de mesaje. Când procesați orice mesaj care a căzut în WebSphere Message Broker. Mai întâi, procedura de atribuire a unui mesaj domeniului corect și divizarea mesajului în câmpuri separate este efectuată. Mesaje pe care WebSphere Message Broker le poate gestiona. se poate referi la unul din mai multe domenii primare. și anume XML. JMS. MRM. NEON. BLOB. Unele tipuri de mesaje pe care WebSphere Message Broker le poate recunoaște și procesa dinamic, adică fără a adăuga anterior metadate la depozit. de exemplu, prelucrarea documentelor XML bine definite. Pentru alte tipuri de documente XML, trebuie să intrați în depozit. Mesajele referitoare la domeniul MRM (Message Repository) sunt mesaje din depozitul intern WebSphere Message Broker. Mesajele create de aplicațiile care utilizează interfața JMS pot aparține mai multor domenii. text, fluxuri, hărți și obiecte Java. WebSphere Message Broker acceptă parsarea și interpretarea. În plus, WebSphere Message Broker include tehnologii avansate de parsing și procesare de mesaje licențiate de IBM de la NEON și procesează mesaje din domeniul corespunzător. În cele din urmă, mesajele care sunt nestructurate sau au o structură necunoscută aparțin domeniului BLOB. Pentru fiecare dintre domeniile sunt utilizate parserii proprii.
O întrebare importantă este modul în care WebSphere Mesaj Broker determină ce domeniu se referă mesajul. posturi Domain Informații și parametrii referitori (identificator set, tipul de format, etc.) pot fi definite în două moduri - fie în mesajul în sine, sau care urmează să fie definită în mesajul Broker. un flux de intrare setare handler INPUT specific de prelucrare (ris.12.6). În primul caz, pentru a determina propriul conținut mesajul folosește un domeniu special format standard WebSphere MQ mesaj antet. În plus, aplicația poate insera o MQRFH2 subtitrare specială. având un set de câmpuri pentru a defini tipul și formatul mesajului. În cazul setării debitului, la handler fluxul de procesare de intrare de intrare are parametrii adecvați pentru definirea valorilor de domeniu. dimensiuni și tipuri de mesaje care vor primi coada de intrare.
Fig. 12.6. Reprezentarea internă a mesajelor WebSphere Message Broker
Articole similare
Trimiteți-le prietenilor: