基于JbossMQ的数据交互平台技术解决方案.docVIP

基于JBossMQ的数据交互平台 技术解决方案 No part of this document may be reproduced, stored in any electronic retrieval system, or transmitted in any form or by any means, mechanical, photocopying, recording, otherwise, without the written permission of the copyright owner. 文档修订记录 序号 版本号 修订日期 修订概述 修订人 审批人 备注 1 创建 目 录 1 文档摘要 4 1.1 文档分类 4 1.2 关键字/Tag 4 1.3 摘要 4 1.4 作者、协作者及评审人员 4 1.5 定义、首字母缩写词及缩略语 4 2 概述 4 2.1 问题或场景 4 2.2 目的 5 2.3 参考资料 5 2.4 工具和技术 5 2.5 系统运行环境 5 3 总体解决方案 5 3.1 新增目的地 6 3.2 新增消息发送 7 3.3 新增消息接收 10 4 注意事项 18 4.1 配置监听时注意消息提供者URL 18 4.2 配置JMS持久性管理 18 5 不足及改进建议 18 5.1 目前只支持JBossMQ,期待下一版本实现对WebSphereMQ等的支持。 18 5.2 JMS消息类型只支持TextMessage,对BytesMessage、MapMessage、StreamMessage、ObjectMessage的支持期待大家提供好的建议。 18 5.3 对大消息体、BLOB的处理目前已经实现了，正在具体的项目中测试，期待下一版本能补充进来。 18 文档摘要 文档分类 技术解决方案(基于JBossMQ的数据交互平台 关键字/Tag JbossMQ、JMS、JAVA、XML 摘要 本文档主要介绍通过JBoss MQ来完成不同业务系统间的数据交互，交互过程中支持直接调用EOS平台上的业务逻辑，消息类型支持队列、主题。 作者、协作者及评审人员 胡福来 定义、首字母缩写词及缩略语 JMS：Java Messageing Service Java消息服务 JBossMQ：JBoss的消息服务 概述 问题或场景 越来越多的企业、单位面临着各种各样的数据集成和系统整合，传统的处理技术在性能、健壮性、可扩展性上都存在着诸多缺点。基于消息的异步处理模型采用非阻塞的调用特性，发送者将消息发送给消息服务器，消息服务器在合适的时候再将消息转发给接收者；发送和接收是异步的，发送者无需等待，二者的生命周期也可以不必相同，而且发送者可以将消息间接传给多个接收者，大大提高了程序的性能、可扩展性及健壮性，这使得异步处理模型在分布式应用上得到广泛的应用。 目的 帮助开发人员或系统设计人员提供一套在不同的业务系统进行数据交互的可行性方案，供大家参考。 参考资料 参考JBossMQ、JMS的相关资料。 工具和技术 Java 、JMS、XML 系统运行环境 EOS5.X for Jboss 总体解决方案 在JMS中有两种域：topics 和queues 一个消息发送到一个topics ，可以有多个客户端。用topic发布允许一对多，或多对多通讯通道。消息的产生者被叫做publisher, 消息接受者叫做subscriber。 queue 是另外一种方式，仅仅允许一个消息传送给一个客户。一个发送者将消息放在消息队列中，接受者从队列中抽取并得到消息，消息就会在队列中消失。第一个接受者抽取并得到消息后，其他人就不能在得到它。 为了能发送和接收消息，必须得到一个JMS连接。该连接是使用JMS Provider得到连接的，在得到连接之后，建立一个会话(Session)。然后再建立publisher/sender 来发送消息或subscriber/receiver来接收消息。运行时，如果使用topic 那么publisher 或subscriber 通过一个topic来关联，如果使用queue ，则sender 或receiver通过queue来关联起来。 配置目的地 在JBoss3.X中找到目的地的配置文件jbossmq-destinations-service.xml（\primeton\jboss-3.2.5\server\default\deploy\jms），目前提供了几个缺省的目的地，可以根据业务需求新增目的地。 Topic主题目的地： mbean code=org.jboss.mq.server.jmx.Top