博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
Websphere Application Server(版本:8.0.0.3)JMS配置(m...
阅读量:6564 次
发布时间:2019-06-24

本文共 2605 字,大约阅读时间需要 8 分钟。

hot3.png

1.         总线配置

服务集成>总线 

创建总线,创建时去除“总线安全性”选项,避免客户端请求时的安全拦截;

总线 > mybus(总线名称) > 总线成员

建完后,添加总线成员,选择“服务器”下拉项中的当前server,完成添加

总线 > mybus > 目标

添加队列,队列名称自定义,如MyBusQueue

 

注:

总线 > mybus > 消息传递引擎 > Node01.server1-mybus > 队列点

可查看当前消息队列中的消息数量

总线 > mybus > 消息传递引擎 > Node01.server1-mybus > 队列点 > MyBusQueue@Node01.server1-mybus > 消息

可查看消息队列中的详情

 

2.         队列连接工厂配置

资源>JMS>队列连接工厂

新建“缺省消息传递提供程序”类型连接工厂:

名称:ConnectionFactory

JNDI: jms/MyConnectionFactory

类别:javax.jms.ConnectionFactory

总线名称:mybus(第一步新建的bus

其他默认,创建完成

 

3.         队列配置

资源>JMS>队列

新建“缺省消息传递提供程序”类型队列:

名称:MyMDBQueue

JNDIjms/MyMDBQueue

总线名称:mybus(第一步新建的bus

队列名称:选择MyBusQueue(第一步新建的队列名称)

其他默认,创建完成

 

4.         激活规范配置

资源>JMS>激活规范

新建“缺省消息传递提供程序”激活规范:

名称:MyActivationSpec

JNDI 名称:eis/MyMDBQueue_Act_Spec

目标类型:队列

目标JNDI 名称:jms/MyMDBQueue(第三步新建的队列JNDI

总线名称:mybus(第一步新建的bus

其他默认,创建完成

 

5.         JMS应用部署配置

应用程序>应用程序类型>WebSphere企业应用程序

安装MDBTest.ear,默认安装完成

企业应用程序 > MDBTest > 消息驱动的 bean 侦听器绑定

目标资源 JNDI 名称:eis/MyMDBQueue_Act_Spec

目标 JNDI 名称:jms/MyMDBQueue

 

配置完成,重新启动Websphere Application Server,保证配置生效

应用代码下载:  

实际只适用了上面包中的一个MDB 

客户端:

Client代码:

            Properties env1 = new Properties();

           

            env1.put(Context.INITIAL_CONTEXT_FACTORY, "com.ibm.websphere.naming.WsnInitialContextFactory");

           

            env1.put(Context.PROVIDER_URL, "corbaloc:iiop:192.168.160.13:2809"); // server port is 2809

           

            String qcfName = "jms/MyConnectionFactory";

           

            Context context = new InitialContext(env1);

           

            QueueConnectionFactory qConnectionFactory = (QueueConnectionFactory)context.lookup(qcfName);

            Queue queue = (Queue)context.lookup("jms/MyMDBQueue");

            QueueConnection qConnection = qConnectionFactory.createQueueConnection();

            QueueSession qSession = qConnection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);

           

            qSession.createSender(queue);

           

            QueueSender sender = qSession.createSender(queue);

            TextMessage message = qSession.createTextMessage();

            for (int i = 0; i < 10; i++) {

                String messageToSend = "MESSAGE: " + i;

                message.setText(messageToSend);

                // message.setJMSReplyTo(resQueue); // 应答队列

                sender.send(message);

                System.out.println("[dzmonkey] INSIDE JMS SERVLET: MESSAGE -> \"" + message.getText() + "\"");

                String messageID = message.getJMSMessageID();

                boolean bDelivered = message.getJMSRedelivered();

                System.out.println("[dzmonkey] INSIDE JMS SERVLET: MESSAGE ID -> \"" + message.getText() + ":"

                    + messageID + ":" + bDelivered + "\"");

            }

            sender.close();

            qSession.close();

        qConnection.close();

 

 

依赖:

WAS自带JDK

com.ibm.ws.ejb.thinclient_8.0.0.jar

com.ibm.ws.orb_8.0.0.jar

com.ibm.ws.sib.client.thin.jms_8.0.0.jar

 

参考:

http://www.ibm.com/developerworks/websphere/library/techarticles/0504_barcia/0504_barcia.html

转载于:https://my.oschina.net/u/1047983/blog/131420

你可能感兴趣的文章
python3 在不同操作系统安装第三方库方法
查看>>
redhat5.8+mfs(提供软件包文档)
查看>>
python编写登录接口
查看>>
MySQL高可用方案之多级复制
查看>>
OVS 中的各种网络设备 - 每天5分钟玩转 OpenStack(128)
查看>>
Python火车票代码
查看>>
Android开发者指南(7) —— App Install Location
查看>>
Trafficserver Cluster模式
查看>>
亚马逊推出 Blox,用于 EC2 容器服务的开源工具集合
查看>>
SSDB 数据库的图形界面管理工具发布了!
查看>>
Linux:在中国没有真正的新闻
查看>>
iOS推送功能极光推送的介绍与实现
查看>>
单用户模式与grub加密
查看>>
Chromium Graphics: 3D上下文及其虚拟化 - Part I
查看>>
jquery javascript获得网页的高度和宽度
查看>>
2019 -2-15 复习
查看>>
vim锁定屏幕
查看>>
FL2440 ubifs文件系统烧录遇到的问题——内核分区的重要性
查看>>
实用的 JavaScript 调试小技巧
查看>>
027移除元素
查看>>