JMS手册.doc

引言 JMS：Java Message Service Java消息服务 JMS是设计分布式应用程序的常用技术，基于JMS实现的程序可以运行在不同的JVM JMS是SUN在统一各种MOM系统接口的规范，它包含点对点（Point to Point，PTP）和发 布/订阅（Publish/Subscribe，pub/sub）两种消息模型，提供可靠消息传输、事务和消 息过滤等机制。 JMS提供者 JMS的实现需要JMS Server 支撑。支持SUN JMS的中间件(JMS Server)有： opnerJMS、activeMQ、WebLogic、JBoss等 activemq下载地址：/activemq-410-release.html JMS优点 使用JMS API不仅使通信耦合降低，而且它还使通信变得： ●异步：JMS提供者将到来的消息发送给客户，客户不用发送请求接收消息。 ●可靠：JMS API确保消息传送一次而且只传送一次。可靠性差的应用程序可能会丢失消息 或者重复接收消息 JMS实现 1、java程序通过JMS的api接口来访问JMS消息服务器，如WebLogic。而访问JMS消息服务器，则需要通过JNDI查询获得消息服务器的引用。 2、如果需要提供消息事务支持，则要求通过JTA接口实现。 3、消息的持久性存储可以是文件或是数据库 JMS消息构成 消息头：包括消息的识别信息和路由信息。有以下预定字段 JMSSDestination－指出消息发送的目的地名字 JMSDeliveryMode－指定消息是一个持久性消息还是非持久性消息 JMSExpiration－定义一个消息何时过期，默认值为0表示永不过期 JMSPriority－指定消息的优先级 JMSMessageId－默认情况下由消息服务器产生，也可程序生成，唯一标识消息 的字符串 JMSReplyTo－指定消息响应的目的地 JMSType－指出消息的类型 JMSRedelivered－消费者无法得到消息时，是否需要重新传递 JMSTimestamp－消息服务器接收消息的时间 消息属性 消息体 JMS程序实现组成 生产者：创建和发送消息的程序 消费者：接收消息的程序 消息服务器：管理消息并在生产者和消费者之间传递 JMS消息机制 JMS消息传递提供了两种模式：点对点和发布/订阅 点到点式 PTP(Point-to-Porint)消息机制如图 JMS Provider 消息队列 消息生产者1 发送消息 发送消息 消息生产者1 消息消费者1 消息??费者2 生产者与消费者之间的消息数据由‘消息队列’管理，一旦消费者接收了生产者的消息，此消息数据即被JMS从消息队列中删除 发布／订阅式 JMS Provider 消息主题 Pub/Sub(Publish-and-Subscribe)消息机制图 消息订阅者2 确 接 认 收 发送消息 确认 消息订阅者1 消息生产者 接收 多个消息生产者可以向同一主题发送消息，多个消息消费者可以从同一主题订阅消息。消息主题由消息服务器管理。JMS将消息发送到所有订阅了此主题的订阅者，并且只有当所有订阅者都收到消息时，JMS才删除这条消息 JMS连接工厂 连接工厂为指定的消息服务器和系统配置产生一个JMS连接，本身为Java类。 在开发JMS应用时，发送与接收消息需要利用连接工厂来建立连接。连接工厂可以在 消息服务器如WebLogic中配置，也可以在程序代码中创建。 消息连接工厂具有开始、停止和关闭处理。连接开始调用Connection.start()、 连接停止调用Connection.stop()、连接关闭调用Connection.close()。 其中连接停止只是暂停连接并不释放连接占用的系统资源，连接关闭才是直接释放连接占用的系统资源 JMS连接会话 生产者与消费者与消息服务器的交互是通过会话来完成。对于点到点消息机制采用的是QueueSession会话，对于发布/订阅消息机制采用的是TopicSession会话 WebLogic实现JMS WebLogic应用服务器本身内置了JMS功能，因此JMS可以直接在WebLogic中配置使用。 其中WebLogic充当了消息服务器和WEB运行容器。 JMS配置 WebLogic实现JMS步骤： 创建连接工厂 进入WebLogic控制台，左边的树形菜单中