使用JMS接口接入WebSphere MQ消息
创建JMS管理对象 JMS定义了一个通用的接口来发送和接收消息,只要与之通信的程序兼容JMS即可,点到点的JMS接口是: 1. javax.jms.QueueConnection - 这个接口提供一个到JMS提供程序的连接,用于创建会话对象。 2.javax.jms.QueueSession - 这个接口为产生和消耗消息提供上下文呢,包括创建QueueSender和QueueReceiver的方法。 3. javax.jms.QueueSender - 这个接口用于向队列发送消息,javax.jms.QueueReceiver用于从队列接收消息。 为了让你的代码可以在不同的消息提供程序间有良好的移植性,你必须在你的应用程序中使用javax.jms中的标准JMS接口,所有特定厂家的信息都封装在javax.jms.QueueConnectionFactory 和 javax.jms.Queue中,这些管理对象可以使用厂家提供管理工具进行构建,存储在JNDI命名空间中,JMS应用程序可以从命名空间中检索这些对象,这时就不需要知道是哪个厂家提供的了。 按照下面的步骤使用Websphere MQ管理器创建管理对象,存储在基于文件的目录下: 1.在JMS-管理对象上点击右键?添加初始上下文。 2.在屏幕1上: 为“JNDI存储在哪里”选择“文件系统” 在关联目录处,输入C:JNDI-Directory(前提是这个目录已经存在) 注意工厂类和提供程序URL,因为你将会在Java代码中使用到(如图5所示) 图5 添加初始上下文向导:你将在样例类中使用工厂类和提供程序URL 3.你的管理器现在应该如图6所示 图6 添加初始上下文后的MQ管理器:你可以在MQ管理器中轻易地创建JMS管理对象 在新的初始上下文中,创建一个连接工厂。 1.在连接工厂上点击右键?新建?连接工厂,在第一个屏幕上,在名称区域输入“TestQM_QCF”,点击“下一步”,在JNDI查找中你就使用TestQM_QCF了。 2.将类型设置为“队列连接工厂”,点击“下一步”。如图7所示。 图7 新建连接工厂向导:用于点对点消息的队列连接工厂 3.保持传送类型为汇集,点击下一步,当WMQ和应用程序在同一机器上时使用汇集传输。 4.在下一页面点击下一步(无需修改设置)。 (编辑:威海站长网) 【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容! |