package mq;
import java.io.IOException;
import com.ibm.mq.MQC;
import com.ibm.mq.MQEnvironment;
import com.ibm.mq.MQException;
import com.ibm.mq.MQGetMessageOptions;
import com.ibm.mq.MQMessage;
import com.ibm.mq.MQPutMessageOptions;
import com.ibm.mq.MQQueue;
import com.ibm.mq.MQQueueManager;
public class MQMain {
public static void main(String[] args) throws Exception {
sendMsg();
getMsg();
}
static void getMsg() throws MQException, IOException {
MQEnvironment.hostname = "172.25.1.69";
MQEnvironment.port = 1414;
MQEnvironment.CCSID = 1381;
MQEnvironment.channel = "ch1";
MQQueueManager qMgr = new MQQueueManager("QM_APPLE");
int openOptions = MQC.MQOO_INPUT_AS_Q_DEF | MQC.MQOO_OUTPUT | MQC.MQOO_INQUIRE;
MQQueue queue = qMgr.accessQueue("Q1_Local", openOptions, null, null, null);
MQMessage msg = new MQMessage();// 要读的队列的消息
MQGetMessageOptions gmo = new MQGetMessageOptions( );
gmo.options = MQC.MQGMO_SYNCPOINT;
int currDepth = queue.getCurrentDepth();
System.out.println(currDepth);
if (currDepth > 0) {
queue.get(msg, gmo);
qMgr.commit();
qMgr.close();
System.out.println(msg.readStringOfCharLength(msg.getDataLength()));
}
}
static void sendMsg() throws MQException, IOException {
MQEnvironment.hostname = "172.25.1.69";
MQEnvironment.port = 1414;
MQEnvironment.CCSID = 1381;
MQEnvironment.channel = "ch1";
MQQueueManager qMgr = new MQQueueManager("QM_APPLE");
int openOptions = MQC.MQOO_OUTPUT | MQC.MQOO_FAIL_IF_QUIESCING;
MQQueue queue = qMgr.accessQueue("Q1_Local", openOptions, null, null, null);
MQMessage msg = new MQMessage();// 要写入队列的消息
msg.writeString("111111111111111111111111"); //将消息写入消息对象中
MQPutMessageOptions pmo = new MQPutMessageOptions();
pmo.options = MQC.MQPMO_SYNCPOINT;
msg.expiry = -1; // 设置消息用不过期
queue.put(msg, pmo);// 将消息放入队列
qMgr.commit();
System.out.println("发送成功");
}
}
分享到:
相关推荐
java操作mq所需的jar包
Java下操作IBM Websphere MQ的项目案例, eclipse工程压缩包, 导入直接可用.
java连接MQ操作Queue数据所需jar包
2.1 MQ基本操作 7 2.1.1 建立侦听端口 7 2.1.2建立队列管理器间的消息通道 7 2.1.3建立远程队列实现消息的传送 8 2.2 MQ基本命令 8 2.3 使用java编写MQ访问程序 9 3、WebSphere MQ Java编程实例 11 3.1 开发前步骤 ...
基于Java编写的,SWT界面的完整的发送接收消息。 演示了分组和设置。 最近学习MQ写的,是学习的捷径。
本项目使用hibernate技术对用MQ传输的数据进行相关的入库,解析操作,如果只是想学习MQ的相关操作,可以吧里面的两个与MQ有关的类给拷贝出现,然后做学习之用。
简单的java操作IBM MQ的代码说明,并有代码例子,希望对大家有帮助
java连接MQ操作Queue数据所需jar: 哥直接把安装目录下的lib文件夹打了包,应该能满足开发需要了
Websphere MQ提供了一个Java API,允许开发者使用Java语言来开发Websphere MQ的应用程序。该API提供了许多有用的方法和类,包括: * MQQueue:用于表示消息队列的类 * MQQueueManager:用于表示队列管理器的类 * ...
12.2.2 WebSphere MQ for Java的运行环境 159 12.3 使用WebSphere MQ for Java 161 12.3.1客户机连接模式 161 12.3.2绑定模式 162 12.3.3 类库 162 12.4用WebSphere MQ Java API开展工作 164 12.4.1 设置连接 164 ...
WebSphere MQ程序设计初探时间:2006-11-04 00:00 来源:bitsCN.com 字体:[大 中 小] IBM的...本文主要介绍:MQ的核心组件介绍、MQ环境的搭建以及利用JAVA对MQ队列管理器的操作的程序设计,希望能起到抛砖引玉的作用。
操作ibm mq用到的jar包,包括com.ibm.mqjms.jar,com.ibm.mqetclient.jar,com.ibm.mq.soap.jar,com.ibm.mq.jms.Nojndi.jar,com.ibm.mq.jar,com.ibm.mq.fta.jar,aspectjrt.jar
包括IBM MQ基本概念、windows、linux下安装和运行IBM MQ,基本操作、IBM MQ学习总结、多个队列管理器互相通信收发消息
java 的 异步通知MQ和 缓存 redis 的基本操作。JVM的使用
WebSphereMQ,也称MQSeries,以一致的、可靠的和易于管理的方式来连接应用程序,并为跨部门、企业范围的集成提供了可靠的基础。通过为重要的消息和事务提供可靠的、一次且仅一次的传递,MQ可以处理复杂的通信协议,...
mq.rar springcloud对接rabbit java工程 RabbitMQ是一种消息中间件,用于处理来自客户端的异步消息。服务端将要发送的消息放入到队列池中。接收端可以根据RabbitMQ配置的转发机制接收服务端发来的消息。 RabbitMQ...
ZeroMQ (也拼写作 ØMQ、 ...ZeroMQ 可以在 Windows、 OS X 和 Linux 等多种操作系统上运行, C、 C++、 C#、 Java、 Python 等语言都可以编写 ZeroMQ 应用程序…这使得不同平台上的不同应用程序之间可以相互 通讯……
WebSphere MQ java Client连接到WebSphere MQ,操作消息队列,获取消息,创建队列管理器等操作。
3分很值得,jar包代码一应俱全,本包下下面包含: Spring_activemq整合代码,java单独操作mq