`

MB--MQ数据流

MB--MQ数据流
阅读更多
1.启动mq资源管理器
   新建队列管理器csp_test,新建2个本地队列q1,q2

2.启动mb toolkit管理器
   2.1新建MQ单向消息流工程,命名为csp_project
   2.2新建消息流csp_demo,在图的右边部分新增MQInput和MQOutput节点
   2.3配置MQInput节点,先设置绑定队列q1
   2.4再添加监视项目,包括事务开始,事务结束,输出终端,捕获终端
   2.5在添加监视项目时,需要添加事件有效内容,其中事务开始,事务结束,输出终端:$Root捕获终端:$ExceptionList

3.新建代理,执行组,部署信息流
  3.1新建代理csp_broker
  3.2新建执行组csp_group
  3.3部署信息流mqsi.csp_demo

4.启动mb控制台,启动监视程序
     命令: mqsichangeflowmonitoring csp_broker -e csp_group -f      mqsi.csp_demo -c active

5.启动MM+ Web控制台
  5.1点击代理管理代理列表注册代理
  5.2点击代理管理代理列表启动监视chengxu如果图右边显示已启动,表示配置成功!

6.发送队列信息
   往队列q1发送信息A,队列q2会收到信息A.这时会生成2个信息流信息.
  6.1一个mqinput的xml字符流
<wmb:event
xmlns:wmb="http://www.ibm.com/xmlns/prod/websphere/messagebroker/6.1.0/monitoring/event">
<wmb:eventPointData>
<wmb:eventData wmb:productVersion="7000"
wmb:eventSchemaVersion="6.1.0.3" wmb:eventSourceAddress="MQInput.terminal.out">
<wmb:eventIdentity wmb:eventName="MQInput.输出Terminal" />
<wmb:eventSequence wmb:creationTime="2011-11-29T06:13:17.760Z"
wmb:counter="2" />
<wmb:eventCorrelation wmb:localTransactionId="b0d3597e-83dc-4c25-a86d-1f707ad97650-6"
wmb:parentTransactionId="" wmb:globalTransactionId="" />
</wmb:eventData>
<wmb:messageFlowData>
<wmb:broker wmb:name="csp_broker"
wmb:UUID="870d79d0-8e61-4ddd-ae47-c0a0e405a8fb" />
<wmb:executionGroup wmb:name="csp_group"
wmb:UUID="049c14ed-3301-0000-0080-fd9b8f33a858" />
<wmb:messageFlow wmb:uniqueFlowName="csp_broker.csp_group.mqsi.csp_demo"
wmb:name="mqsi.csp_demo" wmb:UUID="f9fb68ed-3301-0000-0080-dfd4a52f545b"
wmb:threadId="9512" />
<wmb:node wmb:nodeLabel="MQInput" wmb:nodeType="ComIbmMQInputNode"
wmb:terminal="out" />
</wmb:messageFlowData>
</wmb:eventPointData>
<wmb:applicationData xmlns="">
<wmb:complexContent wmb:elementName="Root">
<Root>
<Properties>
<MessageSet></MessageSet>
<MessageType></MessageType>
<MessageFormat></MessageFormat>
<Encoding>273</Encoding>
<CodedCharSetId>819</CodedCharSetId>
<Transactional>true</Transactional>
<Persistence>false</Persistence>
<CreationTime>2011-11-29T06:13:17.740</CreationTime>
<ExpirationTime>-1</ExpirationTime>
<Priority>0</Priority>
<ReplyIdentifier>000000000000000000000000000000000000000000000000
</ReplyIdentifier>
<ReplyProtocol>MQ</ReplyProtocol>
<Topic></Topic>
<ContentType></ContentType>
<IdentitySourceType></IdentitySourceType>
<IdentitySourceToken></IdentitySourceToken>
<IdentitySourcePassword></IdentitySourcePassword>
<IdentitySourceIssuedBy></IdentitySourceIssuedBy>
<IdentityMappedType></IdentityMappedType>
<IdentityMappedToken></IdentityMappedToken>
<IdentityMappedPassword></IdentityMappedPassword>
<IdentityMappedIssuedBy></IdentityMappedIssuedBy>
</Properties>
<MQMD>
<SourceQueue>q1</SourceQueue>
<Transactional>true</Transactional>
<Encoding>273</Encoding>
<CodedCharSetId>819</CodedCharSetId>
<Format>MQSTR   </Format>
<Version>2</Version>
<Report>0</Report>
<MsgType>8</MsgType>
<Expiry>-1</Expiry>
<Feedback>0</Feedback>
<Priority>0</Priority>
<Persistence>0</Persistence>
<MsgId>414d51206373705f74657374202020208f3ed44e2002d502</MsgId>
<CorrelId>000000000000000000000000000000000000000000000000
</CorrelId>
<BackoutCount>0</BackoutCount>
<ReplyToQ>
</ReplyToQ>
<ReplyToQMgr>csp_test                                        </ReplyToQMgr>
<UserIdentifier>MUSR_MQADMIN</UserIdentifier>
<AccountingToken>160105150000000a6e2fbd359b96123a3cd9e5ec03000000000000000000000b
</AccountingToken>
<ApplIdentityData>
</ApplIdentityData>
<PutApplType>28</PutApplType>
<PutApplName>WebSphere MQ Client for Java</PutApplName>
<PutDate>2011-11-29</PutDate>
<PutTime>06:13:17.740</PutTime>
<ApplOriginData>
</ApplOriginData>
<GroupId>000000000000000000000000000000000000000000000000</GroupId>
<MsgSeqNumber>1</MsgSeqNumber>
<Offset>0</Offset>
<MsgFlags>0</MsgFlags>
<OriginalLength>-1</OriginalLength>
</MQMD>
<XMLNSC />
</Root>
</wmb:complexContent>
<wmb:complexContent wmb:elementName="Root">
<Root>
<Properties>
<MessageSet></MessageSet>
<MessageType></MessageType>
<MessageFormat></MessageFormat>
<Encoding>273</Encoding>
<CodedCharSetId>819</CodedCharSetId>
<Transactional>true</Transactional>
<Persistence>false</Persistence>
<CreationTime>2011-11-29T06:13:17.740</CreationTime>
<ExpirationTime>-1</ExpirationTime>
<Priority>0</Priority>
<ReplyIdentifier>000000000000000000000000000000000000000000000000
</ReplyIdentifier>
<ReplyProtocol>MQ</ReplyProtocol>
<Topic></Topic>
<ContentType></ContentType>
<IdentitySourceType></IdentitySourceType>
<IdentitySourceToken></IdentitySourceToken>
<IdentitySourcePassword></IdentitySourcePassword>
<IdentitySourceIssuedBy></IdentitySourceIssuedBy>
<IdentityMappedType></IdentityMappedType>
<IdentityMappedToken></IdentityMappedToken>
<IdentityMappedPassword></IdentityMappedPassword>
<IdentityMappedIssuedBy></IdentityMappedIssuedBy>
</Properties>
<MQMD>
<SourceQueue>q1</SourceQueue>
<Transactional>true</Transactional>
<Encoding>273</Encoding>
<CodedCharSetId>819</CodedCharSetId>
<Format>MQSTR   </Format>
<Version>2</Version>
<Report>0</Report>
<MsgType>8</MsgType>
<Expiry>-1</Expiry>
<Feedback>0</Feedback>
<Priority>0</Priority>
<Persistence>0</Persistence>
<MsgId>414d51206373705f74657374202020208f3ed44e2002d502</MsgId>
<CorrelId>000000000000000000000000000000000000000000000000
</CorrelId>
<BackoutCount>0</BackoutCount>
<ReplyToQ>
</ReplyToQ>
<ReplyToQMgr>csp_test                                        </ReplyToQMgr>
<UserIdentifier>MUSR_MQADMIN</UserIdentifier>
<AccountingToken>160105150000000a6e2fbd359b96123a3cd9e5ec03000000000000000000000b
</AccountingToken>
<ApplIdentityData>
</ApplIdentityData>
<PutApplType>28</PutApplType>
<PutApplName>WebSphere MQ Client for Java</PutApplName>
<PutDate>2011-11-29</PutDate>
<PutTime>06:13:17.740</PutTime>
<ApplOriginData>
</ApplOriginData>
<GroupId>000000000000000000000000000000000000000000000000</GroupId>
<MsgSeqNumber>1</MsgSeqNumber>
<Offset>0</Offset>
<MsgFlags>0</MsgFlags>
<OriginalLength>-1</OriginalLength>
</MQMD>
<XMLNSC />
</Root>
</wmb:complexContent>
</wmb:applicationData>
</wmb:event>


   6.2一个mqoutput字符流
<wmb:event
xmlns:wmb="http://www.ibm.com/xmlns/prod/websphere/messagebroker/6.1.0/monitoring/event">
<wmb:eventPointData>
<wmb:eventData wmb:productVersion="7000"
wmb:eventSchemaVersion="6.1.0.3" wmb:eventSourceAddress="MQOutput.terminal.in">
<wmb:eventIdentity wmb:eventName="MQOutput.输入Terminal" />
<wmb:eventSequence wmb:creationTime="2011-11-29T06:13:17.760Z"
wmb:counter="3" />
<wmb:eventCorrelation wmb:localTransactionId="b0d3597e-83dc-4c25-a86d-1f707ad97650-6"
wmb:parentTransactionId="" wmb:globalTransactionId="" />
</wmb:eventData>
<wmb:messageFlowData>
<wmb:broker wmb:name="csp_broker"
wmb:UUID="870d79d0-8e61-4ddd-ae47-c0a0e405a8fb" />
<wmb:executionGroup wmb:name="csp_group"
wmb:UUID="049c14ed-3301-0000-0080-fd9b8f33a858" />
<wmb:messageFlow wmb:uniqueFlowName="csp_broker.csp_group.mqsi.csp_demo"
wmb:name="mqsi.csp_demo" wmb:UUID="f9fb68ed-3301-0000-0080-dfd4a52f545b"
wmb:threadId="9512" />
<wmb:node wmb:nodeLabel="MQOutput" wmb:nodeType="ComIbmMQOutputNode"
wmb:terminal="in" />
</wmb:messageFlowData>
</wmb:eventPointData>
<wmb:applicationData xmlns="">
<wmb:complexContent wmb:elementName="Root">
<Root>
<Properties>
<MessageSet></MessageSet>
<MessageType></MessageType>
<MessageFormat></MessageFormat>
<Encoding>273</Encoding>
<CodedCharSetId>819</CodedCharSetId>
<Transactional>true</Transactional>
<Persistence>false</Persistence>
<CreationTime>2011-11-29T06:13:17.740</CreationTime>
<ExpirationTime>-1</ExpirationTime>
<Priority>0</Priority>
<ReplyIdentifier>000000000000000000000000000000000000000000000000
</ReplyIdentifier>
<ReplyProtocol>MQ</ReplyProtocol>
<Topic></Topic>
<ContentType></ContentType>
<IdentitySourceType></IdentitySourceType>
<IdentitySourceToken></IdentitySourceToken>
<IdentitySourcePassword></IdentitySourcePassword>
<IdentitySourceIssuedBy></IdentitySourceIssuedBy>
<IdentityMappedType></IdentityMappedType>
<IdentityMappedToken></IdentityMappedToken>
<IdentityMappedPassword></IdentityMappedPassword>
<IdentityMappedIssuedBy></IdentityMappedIssuedBy>
</Properties>
<MQMD>
<SourceQueue>q1</SourceQueue>
<Transactional>true</Transactional>
<Encoding>273</Encoding>
<CodedCharSetId>819</CodedCharSetId>
<Format>MQSTR   </Format>
<Version>2</Version>
<Report>0</Report>
<MsgType>8</MsgType>
<Expiry>-1</Expiry>
<Feedback>0</Feedback>
<Priority>0</Priority>
<Persistence>0</Persistence>
<MsgId>414d51206373705f74657374202020208f3ed44e2002d502</MsgId>
<CorrelId>000000000000000000000000000000000000000000000000
</CorrelId>
<BackoutCount>0</BackoutCount>
<ReplyToQ>
</ReplyToQ>
<ReplyToQMgr>csp_test                                        </ReplyToQMgr>
<UserIdentifier>MUSR_MQADMIN</UserIdentifier>
<AccountingToken>160105150000000a6e2fbd359b96123a3cd9e5ec03000000000000000000000b
</AccountingToken>
<ApplIdentityData>
</ApplIdentityData>
<PutApplType>28</PutApplType>
<PutApplName>WebSphere MQ Client for Java</PutApplName>
<PutDate>2011-11-29</PutDate>
<PutTime>06:13:17.740</PutTime>
<ApplOriginData>
</ApplOriginData>
<GroupId>000000000000000000000000000000000000000000000000</GroupId>
<MsgSeqNumber>1</MsgSeqNumber>
<Offset>0</Offset>
<MsgFlags>0</MsgFlags>
<OriginalLength>-1</OriginalLength>
</MQMD>
<XMLNSC />
</Root>
</wmb:complexContent>
</wmb:applicationData>
</wmb:event>

7.查看记录
   7.1流信息写入数据库表MONITOR_MAIN，MONITOR_MESSAGE_FLOW
   7.2点击代理监控实时监控
   7.3点击链接,查看详细信息

8.修改的bug
   8.1MONITOR_MESSAGE_FLOW表的字段MMFID原来是interger字段,要改成varchar2(50)字段.
   8.2用myMonitorMB项目(10楼那位称改了至少10个bug了的),其中PaserMonitorMsg.java的164行,256行需要修改.164行:transaction.startterminal.out,256行:transaction.endterminal.in

9.存在问题
    9.1上面8.2bug修改有风险.用Mb做成的csp_project工程还比较简单，只有mqinput和mqoutput，如果环境复杂化，需要进一步测试修改。另外上次我们去10楼，那位也只试成功错误监视节点，即terminal.failure还是terminal.error
   9.2Web控制台中点击代理管理部署管理部署信息流,不成功。
    9.3Web控制台中点击代理监控实时监控链接,缺少事务开始记录。
分享到：
| Hibernate总结
评论
发表评论

您还没有登录,请您登录后再发表评论

相关推荐

    MBMQ从入门到精通.zip

    《MBMQ从入门到精通》是一份全面介绍IBM企业服务总线（Enterprise Service Bus，ESB）中的Message Broker（MB）和Message Queuing（MQ）技术的深度学习资源。这份资料旨在帮助初学者快速掌握这两种关键技术，并提升...

    北京中科信软was mb培训01

    - 管理变量和数据流 - 实现网关和路由以控制流程流 - 设计用户输入表单（Lombardi教练） - 访问和操作外部数据 - 测试业务流程模型 - 模型和实现消息事件 - 使用工具包、快照和标记组织流程资产 - 主要课题包括课程...

    sg247137-MB Basic.pdf

    - 该平台提供了一个消息流编辑器，允许用户通过图形化界面设计和部署消息处理流。 - WebSphere Message Broker可以与WebSphere MQ、DB2 UDB和IBM Rational Agent Controller等IBM产品集成使用。 2. **产品版本和...

    MB中消息流事务[归类].pdf

    资源管理器负责协调这些事务，确保与消息流中使用的各种资源（如数据库、MQ消息、JMS消息、队列等）之间的交互一致。 对于支持事务的资源，如数据库和WMQ队列，可以通过配置决定是在消息流结束或特定节点结束时提交...

    MB开发的相关节点配置

    节点是MB工作流中的基本构建块，它们可以是输入、输出、转换或者控制节点，每个节点都有特定的功能。例如： 1. **Input Node（输入节点）**：这是工作流的起点，接收来自外部源的消息。常见的输入节点有MQ Input ...

    docker-compose,nacos的yaml,日志文件

    Nacos，另一方面，是阿里巴巴开源的一款分布式服务治理和服务数据平台，它提供了服务发现、配置管理和命名服务等功能。 首先，我们来谈谈Docker Compose。Docker Compose是一个用于定义和运行多容器Docker应用的...

    【精品】如何打造一个高效的AIoT数据平台-19.9.pdf

    3. 透明的流式计算，支持对数据流进行实时聚合计算。 4. 数据订阅功能，可实时将最新数据推送至应用。 5. 全面的集群管理、资源调度和系统监控。 TDengine的技术优势体现在： - 创新的时序数据存储结构，采用无锁...

    计算机组成原理课后答案

    7. 在指令字长、存储字长和机器字长相等的条件下，假设主存容量为256MB（256M * 32位），那么每个寄存器的位数至少为32位，以适应32位的数据传输。例如，PC、IR、MAR、MDR等寄存器都需要至少32位来存储32位的地址或...

    Linux 开发基础 <1>

    - **标准输入输出与重定向及管道**：理解如何使用 `、`&gt;`、`&gt;&gt;` 和 `|` 进行输入输出的重定向和管道连接，能够更高效地处理数据流。 - **Linux 帮助系统**：学会利用 `man` 和 `info` 等命令获取在线帮助，这对于...

    Websphere Message Broker 入门经典必备实例

    它允许开发人员创建、管理和优化应用程序之间的数据流，实现企业集成。在本入门经典实例中，我们将深入理解WMB的核心概念和技术，通过三个具体实例来掌握其基本操作。 **核心概念** 1. **Message Broker**: 作为...

    struts2文件上传（转）

    例如，除了Struts2的核心库，还需要Apache Commons IO和Commons FileUpload库，以及可能的JMS提供者的jar，如ActiveMQ或IBM MQ。 总结，Struts2的文件上传功能结合了Java Web开发的多个方面，包括表单提交、文件流...

    IBM中间件手册

    例如，IBM WebSphere Portal、WebSphere Application Server (WAS)、WebSphere Process Server (WPS)、WebSphere Service Registry and Repository (WSRR)、WebSphere Message Broker (MB) 和 WebSphere MQ 的不同...

    计算机组成原理第二版 课后习题答案

    - **ACC**、**X**、**MQ**、**MDR**：这些寄存器涉及到数据处理，因此位宽为32位。 以上分析基于给定信息，详细阐述了计算机组成原理中的重要概念、组件及其工作原理，希望对理解和掌握计算机组成原理有所帮助。

    计算机等级考试四级嵌入式系统真题库.pdf

    - **知识点扩展**：批处理操作系统主要用于大规模数据处理任务，例如银行账务处理、工资发放等，特点是高效率地处理大量数据，但由于不支持用户直接交互，因此对于需要即时反馈的应用场景并不适用。 **3. 只能在...

    IBM WebSphere message broker 命令详解

    3. **mqsi_setupdatabase** 和 **mqsisetdbparms**: 设置数据库的类型和安装目录，以及配置消息流使用的数据源认证信息。 #### 安全控制 1. **mqsicreateaclentry**、**mqsideleteaclentry** 和 **...

Magicbox
Global site tag (gtag.js) - Google Analytics