使用c#操作IBM WebSphere MQ
IBM WebSphere MQ 5.3升级到CSD05之后,提供了使用.net操作MQ的类库,安装完成之后,会在MQ的安装目录的bin文件夹下面多出一个amqmdnet.dll文件,把这个DLL作为引用添加到你的.net工程中,你的.net程序中就可以操作IBM WebSphere MQ。
我的MQ是中文版的,操作系统是win2k003 sp1,无论是在队列管理器,还是用代码新建的队列,都与我本机时间相差8小时,不晓得何解,哪位高人可以释疑? 复制内容到剪贴板
代码:
//新建本地队列
PCFMessageAgent agent = new PCFMessageAgent("QM_janus");
PCFMessage request = new PCFMessage(CMQCFC.MQCMD_CREATE_Q);
request.AddParameter(MQC.MQCA_Q_NAME, "test_queue");
request.AddParameter(MQC.MQIA_Q_TYPE, MQC.MQQT_LOCAL);
//request.AddParameter(MQC.MQIA_USAGE, MQC.MQUS_TRANSMISSION);
PCFMessage[] response = agent.Send(request);复制内容到剪贴板
代码:
//删除队列
PCFMessageAgent agent = new PCFMessageAgent("QM_janus");
PCFMessage request = new PCFMessage(CMQCFC.MQCMD_DELETE_Q);
request.AddParameter(MQC.MQCA_Q_NAME, "test_queue");
PCFMessage[] response = agent.Send(request);复制内容到剪贴板
代码:
//从队列中读取消息
MQQueueManager qMgr = new MQQueueManager("QM_janus");
MQQueue queue = qMgr.AccessQueue("postcard", MQC.MQOO_INPUT_AS_Q_DEF | MQC.MQOO_FAIL_IF_QUIESCING);
MQGetMessageOptions gmo = new MQGetMessageOptions();
gmo.Options = MQC.MQGMO_WAIT;
gmo.WaitInterval = 1000;
gmo.MatchOptions = MQC.MQMO_NONE;
MQMessage message = new MQMessage();
queue.Get(message);复制内容到剪贴板
代码:
//向队列写消息
MQQueueManager qMgr = new MQQueueManager("QM_janus");
MQQueue queue = qMgr.AccessQueue("postcard", MQC.MQOO_OUTPUT);
MQMessage message = new MQMessage();
message.WriteString("message body");
queue.Put(message);复制内容到剪贴板
代码:
//枚举所有队列
PCFMessageAgent agent = new PCFMessageAgent("QM_janus");
PCFMessage request = new PCFMessage(CMQCFC.MQCMD_INQUIRE_Q_NAMES);
request.AddParameter(MQC.MQCA_Q_NAME, "*");
PCFMessage[] response = agent.Send(request);
string[] names = response[0].GetStringListParameterValue(CMQCFC.MQCACF_Q_NAMES);
分享到:
相关推荐
在IT行业中,IBM WebSphere MQ...掌握这些知识点后,你将能够使用C#有效地与IBM WebSphere MQ进行通信,实现消息的发送和接收,增强应用程序的可靠性和可扩展性。记得在实践中不断调试和优化,以适应不同场景的需求。
在本文中,我们将深入探讨如何使用C#编程语言与IBM WebSphere MQ进行交互,实现消息的发送和接收。IBM WebSphere MQ(前身为MQSeries)是一种企业级的消息中间件,它提供了一种可靠且可扩展的方式,使得应用程序可以...
本实例将深入探讨如何使用C#语言来实现与IBM WebSphere MQ的交互,进行消息的发送和接收。 首先,我们需要了解IBM WebSphere MQ的基本概念。MQ是一种中间件,通过消息队列作为中介,使得应用程序可以在不直接互相...
C#实现IBM WebSphere MQ 消息收发例子 参考文章: https://www.codeproject.com/Articles/12198/IBM-WebSphere-MQ-with-C-GUI-application-that-is-bo ...
#### 部分内容概述:IBM WebSphereMQ .NET类使用指南 - **版本信息**:文档针对的是IBM WebSphereMQ .NET类的5.3版本及其后续版本。这表明手册中的内容可能包含对5.3版之后的更新和支持,但具体的变更细节会在新...
### IBM WebSphere MQ 介绍、安装及配置服务详解 #### 一、MQ 概述 **MQ**,即**Message Queue**(消息队列),是一种应用程序间的通信方式,通过队列来实现数据通信,无需专用链接。MQ 提供了一种可靠、高效的...
本篇文章将深入探讨如何使用C#连接IBM WebSphere MQ,包括连接MQ队列、获取消息、发送消息到MQ队列以及消息事务的使用。 首先,连接MQ队列是整个过程的基础。C#可以通过IBM提供的MQ .NET客户端库来实现与MQ服务器的...
这些基础操作构成了使用C#与WebSphere MQ交互的基础框架。开发人员可以根据需要扩展 `MQHelp` 类,添加更多功能,如管理队列管理器、处理通道、监控队列状态等。此外,`IBM.WMQ` 和 `IBM.WMQ.PCF` 命名空间提供了...
标题中的“基于soap over jms 的websphere mq与axis2的实现”涉及到的是在企业级应用中使用Web服务和消息中间件技术的具体实践。这里,`SOAP over JMS`指的是通过Java消息服务(JMS)传输SOAP消息,而`Websphere MQ`...
在本文档中,我们使用的是IBM WebSphere MQ V 7.0。请注意,不同版本的MQ可能具有不同的功能和配置方法,因此在实际操作前,请确认您的系统支持此版本。 **2. 软件环境** MQ软件将在Windows Server 2003操作系统上...
在C#中使用IBM MQ,需要引用IBM的.NET客户端库(如IBM.WMQ)。以下是一些基本操作示例: 1. 添加引用:在Visual Studio项目中,添加对IBM.WMQ.dll的引用。 2. 创建MQ环境:实例化MQQueueManager对象,指定队列管理...
作为一款强大的消息队列技术,IBM MQ(原名WebSphere MQ)提供了一种标准的方式来处理异步通信,允许应用程序在不直接交互的情况下交换信息。 在IBM MQ入门教程中,首先会介绍MQ的基本概念,包括消息队列、队列管理...
C#中的`IBM.WMQ`命名空间提供了访问IBM MQ的API,如`MQQueueManager`、`MQQueue`等对象,通过这些对象可以实现对MQ的操作。 3. **Program.cs**:这是程序的主入口点,通常包含程序的启动和主循环。在这里,你可以...
在C#中,我们可以使用IBM提供的WebSphere MQ .NET客户端库,该库提供了一系列接口和类,用于创建、管理和操作消息队列。例如,`MessageQueue`类用于表示MQ队列,`Message`类用于封装发送和接收的数据。开发者可以...
在C#中,我们可以使用各种MQ实现,如RabbitMQ、Apache Kafka、IBM WebSphere MQ或Azure Service Bus等。 对于C#开发者来说,通常需要引用特定的DLL文件来与MQ服务进行交互。DLL(动态链接库)是Windows操作系统中的...
而“mq”标签则直接指出我们的焦点是消息队列技术,这可能涉及到如IBM WebSphere MQ、RabbitMQ、Apache ActiveMQ或Amazon Simple Queue Service (SQS)等MQ产品。 【压缩包子文件的文件名称列表】:mqwork2 根据...
C# IBM websphere MQ 消息队列
在IBM的WebSphere MQ(曾称为MQSeries)中,消息队列可以跨越各种操作系统和网络环境,支持多种编程语言。 ### 2. WebSphere MQ管理 《WebSphere MQ管理指南.chm》详述了如何管理和配置WebSphere MQ环境。这包括...
【标题】"Websphere MQ 5.3的AC#服务组件"涉及到的是IBM的WebSphere MQ中间件与.NET框架的集成,特别是使用C#语言创建的服务组件来操作消息队列。 【描述】中提到的"封装MQ PUT和MQ GET",意味着这个AC#服务组件...