在访问一个队列首先需要获取队列管理器对象,
需要提供如下属性信息, 如: 队列管理器名称,端口号,服务通道,主机名称,通过这些属性就能获取队列管理器,
然后通过队列管理器 访问队列,
放入消息 即可。 最后,关闭队列。
下面是一个把消息 放入 WebSphere MQ 本地队列中 程序代码:
建立一个QueueManagerEntity实体:
如下:
private String queueManagerName;
private int port;
private String svrconn;
private String hostName;
private String queueName;
// getter和setter方法省略...
然后创建一个QueueManager Class,定义一个获取MQQueueManager的方法,该方法主要是设置初始化环境信息。
public MQQueueManager getMQueueManager(QueueManagerEntity queueManagerEntity){
MQEnvironment.channel = queueManagerEntity.getSvrconn();
MQEnvironment.CCSID = 1383;
MQEnvironment.hostname = queueManagerEntity.getHostName();
MQEnvironment.port = queueManagerEntity.getPort();
MQQueueManager queueManager = null;
try {
queueManager = new MQQueueManager(queueManagerEntity.getQueueManagerName());
} catch (MQException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return queueManager;
}
//往本地队列中放入测试消息。
public boolean sendMessage(MQQueueManager queueManager,QueueManagerEntity queueManagerEntity) throws IOException{
boolean bol = false;
int openOptions = MQC.MQOO_INPUT_AS_Q_DEF | MQC.MQOO_OUTPUT | MQC.MQOO_INQUIRE;
if(queueManager==null || !queueManager.isConnected()){
queueManager = getMQueueManager(queueManagerEntity);
}
MQQueue mqQueue = null;
try {
mqQueue = queueManager.accessQueue(queueManagerEntity.getQueueName(), openOptions,null,null,null);
MQMessage mqMessage = new MQMessage();
mqMessage.writeUTF("Hello World!!!");
MQPutMessageOptions mqPutMessageOptions = new MQPutMessageOptions();
//往队列中放入消息;
mqQueue.put(mqMessage, mqPutMessageOptions);
mqQueue.close();
bol = true;
} catch (MQException e) {
// TODO Auto-generated catch block
e.printStackTrace();
bol = false;
}
return bol;
}
分享到:
相关推荐
一个C#实现IBM WebSphere MQ 消息收发的实例,包含 发送接收等. 使用的时候只需要修改 appconfig 文件的内容即可. 如有问题.请留言
IBM WEBSPHERE MQ实现本地队列消息传送接收。websphere资源管理器中队列,通道等的创建过程,以及java代码实现数据的传输
测试对象:要测试队列管理器和队列,请使用样本程序amqsput(将消息放入队列)和amqsget(从队列获取消息),步骤如下: (1)启动DOS窗口,进入到C:\Program Files\IBM\WebSphere MQ\bin目录下。 (2)将消息...
2.2.1 WebSphere MQ和消息排队 31 2.2.2 队列管理器的进程 32 2.3客户机和服务器 33 客户机-服务器环境中的 WebSphere MQ 应用程序 33 2.4触发机制 33 2.4.1触发的概念 33 2.4.2触发类型 34 2.4.3触发的工作原理 35...
本人自学IBM的WebSphereMQ自学笔记,内有MQ安装文档,建MQ的例子等。 1、 MQ6.0安装 2 1.1 启动MQ v6.0 安装程序 2 1.2 软件需求检查 2 1.3 WebSphere Eclipse Platform V3.0.1软件安装 2 1.4 网络配置检查 3 1.5 ...
一个C#实现IBM WebSphere MQ 消息收发的实例,自己平时写的,如遇困难,请留言
使用WebSphere MQ管理远程队列管理器.doc
IBM Websphere MQ 教程之备份与恢复
websphere mq常用命令 websphere mq常用命令
IBM WebSphere MQ是IBM业界领先面向消息的中间件产品,也是MQ系列产品的基础和核心,它使不同的应用程序能够以企业级的性能,在广泛的平台上安全而可靠地通讯。
通过为重要的消息和事务提供可靠的、一次且仅一次的传递,Websphere MQ 可以处理复杂的通信协议,并动态地将消息传递工作负载分配给可用的资源。 IBM 消息中间件MQ以其独特的安全机制、简便快速的编程风格、卓越不凡...
描述MQ消息持久化,在队列管理器发生异常时,传送到队列中的信息怎样通过日志将信息恢复到队列中。
使用Delphi 7 工具开发,向IBM websphere MQ 消息队列发送消息,使用时,需要安装IBM websphere MQ客户端
2.2.1 WebSphere MQ和消息排队 31 2.2.2 队列管理器的进程 32 2.3客户机和服务器 33 客户机-服务器环境中的 WebSphere MQ 应用程序 33 2.4触发机制 33 2.4.1触发的概念 33 2.4.2触发类型 34 2.4.3触发的工作原理 35...
全书共分为3部分共14章,第一部分 WebSphere MQ原理和体系结构,分为两章;第二部分 WebSphere MQ系统管理,分为六章,分别介绍安装、配置、管理、控制命令和问题确定;第三部分 WebSphere MQ应用开发,由五章组成,...
通过为重要的消息和事务提供可靠的、一次且仅一次的传递,Websphere MQ 可以处理复杂的通信协议,并动态地将消息传递工作负载分配给可用的资源。 IBM 消息中间件MQ以其独特的安全机制、简便快速的编程风格、卓越不凡...
消息中间件及WebSphere MQ入门,介绍WebSphere MQ工作原理,消息队列技术,MQ的基本概念,MQ的通讯模式
IBM Websphere mq安装IBM Websphere mq安装