java websphere mq_如何在java中使用WebSphere MQ
展开全部
websphere mq : 用于传输信息 具有跨平台的功能。
1 安装32313133353236313431303231363533e58685e5aeb931333337376261websphere mq 并启动
2 websphere mq 建立 queue Manager (如:MQSI_SAMPLE_QM)
3 建立queue 类型选择 Local类型 的 (如lq )
3 建立channels 类型选择Server Connection (如BridgeChannel)
java 代码如下:
package test.mq;
import com.ibm.mq.*;
/*
* 成功的访问mq 的java 类
*/
public class FirstMqTest {
// public static void main(String[] args[]){
// FirstMqTest first = new FirstMqTest();
// first.test();
// }
public static void main(String args[]){
FirstMqTest first = new FirstMqTest();
first.test();
}
public void test(){
String qManager = "MQSI_SAMPLE_QM"; //QueueManager name
String qName = "lq";//Queue Name
try {
//configure connection parameters
MQEnvironment.hostname="172.16.17.123";//MQ Server name or IP
//MQEnvironment.port=1414;//listenr port
MQEnvironment.channel="BridgeChannel";//Server-Connection Channel
MQEnvironment.CCSID =1381;
// Create a connection to the QueueManager
System.out.println("Connecting to queue manager: "+qManager);
MQQueueManager qMgr = new MQQueueManager(qManager);
// Set up the options on the queue we wish to open
int openOptions = MQC.MQOO_INPUT_AS_Q_DEF | MQC.MQOO_OUTPUT;
// Now specify the queue that we wish to open and the open options
System.out.println("Accessing queue: "+qName);
MQQueue queue = qMgr.accessQueue(qName, openOptions);
// Define a simple WebSphere MQ Message ...
MQMessage msg = new MQMessage();
// ... and write some text in UTF8 format
msg.writeUTF("Hello, World!");
// Specify the default put message options
MQPutMessageOptions pmo = new MQPutMessageOptions();
// Put the message to the queue
System.out.println("Sending a message...");
/*
* 在此测试一下 mq 的传输次列
*
*/
for(int j=0;j< 5;j++){
String str ="test11111111111";
str = str+j;
msg.writeUTF(str);
queue.put(msg, pmo);
}
queue.put(msg, pmo);
// Now get the message back again. First define a WebSphere MQ message
// to receive the data
MQMessage rcvMessage = new MQMessage();
// Specify default get message options
MQGetMessageOptions gmo = new MQGetMessageOptions();
// Get the message off the queue.
System.out.println("...and getting the message back again");
queue.get(rcvMessage, gmo);
// And display the message text...
String msgText = rcvMessage.readUTF();
System.out.println("The message is: " + msgText);
// Close the queue
System.out.println("Closing the queue");
queue.close();
// Disconnect from the QueueManager
System.out.println("Disconnecting from the Queue Manager");
qMgr.disconnect();
System.out.println("Done!");
}
catch (MQException ex) {
System.out.println("A WebSphere MQ Error occured : Completion Code "
+ ex.completionCode + " Reason Code " + ex.reasonCode);
}
catch (java.io.IOException ex) {
System.out.println("An IOException occured whilst writing to the message buffer: "
+ ex);
}
}
}
已赞过
已踩过<
你对这个回答的评价是?
评论
收起
java websphere mq_如何在java中使用WebSphere MQ相关推荐
- java websphere mq_如何在java中使用WebSphere MQ?
Java中使用websphere websphere mq:用于传输信息 具有跨平台的功能. 1 安装websphere mq并启动 2 websphere mq建立queue Manager(如:M ...
- java发送gmail_如何在Gmail中轻松通过电子邮件发送人群
java发送gmail Mailing lists are an old tool in the email arsenal, but their implementation in Gmail is ...
- cmd中加载java源文件_如何在cmd中编译和运行java源文件
如何在cmd中编译和运行java源文件 首先写一个名为HelloWorld.java的java源文件,存储在如C:/java/src的地址,我们再假设待会要存储的位置是C:/java/bin,则我们做 ...
- java 联合_如何在java中进行联合,相交,区分和反向数据
我想在Java中有联合,相交,差异和反向操作. 首先我有2个ArrayList< Integer> a = [0,2,4,5,6,8,10] b = [5,6,7,8,9,10] 一个工会 ...
- java 运费_如何在Java中创建运费成本计算器
我正在创建计算器来计算运费.代码是这样的:如何在Java中创建运费成本计算器 class ShippingCalc { public static void main(String[] args) { ...
- java 合并pdf,如何在Java中合并PDF
如何在Java中合并PDF 为小型企业和大型企业,保持 您的 重要 文件, 组织将提高您的工作流程,并成倍增长你的组织的工作效率. PDF文档由于其接受的输入格式的类型的安全性和灵活性,通常是共享大量 ...
- java 关闭jpanel_如何在Java中关闭Jpanel程序
我正在制作一个Java游戏,我需要一些关于如何操作的建议.如何在Java中关闭Jpanel程序 目前我使用2个不同的.java文件来制作游戏.我有一个扩展JFrame的主程序,我调用扩展JPanel的 ...
- java 二叉查找树_如何在Java中实现二叉搜索树( binary search tree)?
二叉搜索树或BST是一种流行的数据结构,用于保持元素的顺序.二叉搜索树是二叉树,其中左子节点的值小于或等于父节点,右子节点的值大于或等于父节点.由于它是二叉树,它只能有0,1或2个子节点.二叉搜索树之 ...
- java spring scope_如何在Spring中自定义scope的方法示例
大家对于 Spring 的 scope 应该都不会默认.所谓 scope,字面理解就是"作用域"."范围",如果一个 bean 的 scope 配置为 sing ...
最新文章
- MATLAB 2014a (8.3) Compiler Runtime (MCR)
- Zookeeper集群部署和使用
- CBNet:物体检测的一种新的组合主干网络结构
- NSCoding 的作用
- 网络故障解决方案之非标准子网划分【网管员必懂】
- WebPart的Web部件页部署时发生错误--小窍门
- hdu java_HDU Java8 集锦
- MySQL求类型为GX的平均积分_mysql基本操作
- 微型计算机内存主要,微型计算机的内存容量主要指 ( ) 的容量 (7.0分)
- P2574 XOR的艺术
- mac android手机调试,mac os开发android应用通过usb真机调试
- mybatis3文档
- 针对IE 7的hack写法
- 游戏封包模拟器_问道模拟器人物移动封包分析教程
- 《嵌入式 – GD32开发实战指南》第1章 开发环境搭建
- 视频编解码硬件加速器分类
- LINUX下DNS的查看和配置,Linux系统中查看和修改DNS配置的方法
- 【统计学】用Stata做时间序列分析
- Verilog 基本电路1-与或非,异或门
- Everything指定用XYplorer打开目录路径
热门文章
- 【HDLBits 刷题 10】Circuits(6)Finite State Manchines 10-17
- 加推超级IP名片正式上线!联合京东打造个人轻商城
- 电子商城数据库建表心得
- 电商行业市场行情解析,shopee虾皮平台讲解
- php获取12306余票,获取12306余票信息
- 【教程】Spire.Doc系列教程(3):C# Word查找和替换功能
- 张秋民老师6月9号给海油集团讲授《金字塔思维与公文写作》圆满结束
- 简单、好用才是真道理,适用于初学人群的Linkboy5.0
- 围棋棋盘and半个巴基斯坦国旗
- java方法返回值_如何高效率的学习Java函数返回值