IBM WebSphere MQ的C#工具类以及源码（net）

简单的介绍一下MQ常用的对象

Queue的分类：

MQ工具类：

using IBM.WMQ;using IBM.WMQ.PCF;using System;using System.Collections.Generic;using System.Linq;using System.Web;//using IBM.WMQAX;/// <summary>/// MQHelp 类库///   henrylee/// </summary>public class MQHelp{    public MQHelp()    {    }    /// <summary>    /// 创建本地队列    /// </summary>    /// <param name="qmName">队列管理器</param>    /// <param name="queueName">队列名称</param>    /// <param name="isTransmissionQueue">是否为传输队列</param>    public void CreateQueue(string qmName, string queueName, bool isTransmissionQueue = false)    {        PCFMessageAgent agent = new PCFMessageAgent(qmName);        PCFMessage request = new PCFMessage(CMQCFC.MQCMD_CREATE_Q);        request.AddParameter(MQC.MQCA_Q_NAME, queueName);        request.AddParameter(MQC.MQIA_Q_TYPE, MQC.MQQT_LOCAL);        if (isTransmissionQueue) request.AddParameter(MQC.MQIA_USAGE, MQC.MQUS_TRANSMISSION);        PCFMessage[] response = agent.Send(request);    }    /// <summary>    /// 删除队列    /// </summary>    public void DelQueue(string qmName, string queueName)    {        PCFMessageAgent agent = new PCFMessageAgent(qmName);        PCFMessage request = new PCFMessage(CMQCFC.MQCMD_DELETE_Q);        request.AddParameter(MQC.MQCA_Q_NAME, queueName);        PCFMessage[] response = agent.Send(request);    }    /// <summary>    /// 读取消息    /// </summary>    /// <returns></returns>    public string ReadMessage(string qmName, string queueName)    {        MQQueueManager qMgr = new MQQueueManager(qmName);        MQQueue queue = qMgr.accessQueue(queueName, 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);        return message.ReadString(message.MessageLength);    }    /// <summary>    /// 写入消息    /// </summary>    public void WriteMessage(string qmName, string queueName, string body)    {        MQQueueManager qMgr = new MQQueueManager(qmName);        MQQueue queue = qMgr.AccessQueue(queueName, MQC.MQOO_OUTPUT);        MQMessage message = new MQMessage();        message.WriteString(body);        message.Format = MQC.MQFMT_STRING;        queue.Put(message);    }    /// <summary>    /// 获取当前管理器所有队列    /// </summary>    /// <param name="qmName">队列管理器</param>    /// <param name="isFindSystemQueue">是否包含系统队列</param>    /// <returns></returns>    public List<string> GetALLQueue(string qmName, bool isFindSystemQueue = false)    {        PCFMessageAgent agent = new PCFMessageAgent(qmName);        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);        List<string> result = null;        if (!isFindSystemQueue)            result = names.ToList().Where(s => !s.Contains("AMQ.") && !s.Contains("SYSTEM.")).ToList();        else            result = names.ToList();        return result;    }    /// <summary>    /// 创建远程队列    /// </summary>    /// <param name="qmName">队列管理器</param>    /// <param name="queueName">队列名称</param>    /// <param name="ycqmName">远程队列管理器名称</param>    /// <param name="ycqueueName">远程队列名称</param>    /// <param name="csqueueName">传输队列名称</param>    public void CreateRemoteQueue(string qmName, string queueName, string ycqmName, string ycqueueName, string csqueueName)    {        PCFMessageAgent agent = new PCFMessageAgent(qmName);        PCFMessage request = new PCFMessage(CMQCFC.MQCMD_CREATE_Q);        request.AddParameter(MQC.MQCA_Q_NAME, queueName);        request.AddParameter(MQC.MQIA_Q_TYPE, MQC.MQQT_REMOTE);        request.AddParameter(MQC.MQCA_REMOTE_Q_MGR_NAME, ycqmName);        request.AddParameter(MQC.MQCA_REMOTE_Q_NAME, ycqueueName);        request.AddParameter(MQC.MQCA_XMIT_Q_NAME, csqueueName);        PCFMessage[] response = agent.Send(request);        agent.Disconnect();    }    /// <summary>    /// 创建发送方通道    /// </summary>    /// <param name="qmName">队列管理器</param>    /// <param name="channelName">通道名称</param>    /// <param name="transmissionQueueName">传输队列名称</param>    /// <param name="ipPort">IP地址与端口号 例：localhost(1415) </param>    public void CreateChannelBySend(string qmName, string channelName, string transmissionQueueName, string iPPort)    {        PCFMessageAgent agent = new PCFMessageAgent(qmName);        PCFMessage request = new PCFMessage(CMQCFC.MQCMD_CREATE_CHANNEL);        request.AddParameter(CMQCFC.MQCACH_CHANNEL_NAME, channelName);        request.AddParameter(CMQCFC.MQIACH_CHANNEL_TYPE, MQC.MQCHT_SENDER);        request.AddParameter(CMQCFC.MQCACH_CONNECTION_NAME, iPPort);        request.AddParameter(CMQCFC.MQCACH_XMIT_Q_NAME, transmissionQueueName);        PCFMessage[] response = agent.Send(request);        agent.Disconnect();    }    /// <summary>    /// 创建接受方通道    /// </summary>    /// <param name="qmName">队列管理器</param>    /// <param name="channelName">管道名称</param>    public void CreateChannelByReceive(string qmName, string channelName)    {        PCFMessageAgent agent = new PCFMessageAgent(qmName);        PCFMessage request = new PCFMessage(CMQCFC.MQCMD_CREATE_CHANNEL);        request.AddParameter(CMQCFC.MQCACH_CHANNEL_NAME, channelName);        request.AddParameter(CMQCFC.MQIACH_CHANNEL_TYPE, MQC.MQCHT_RECEIVER);        PCFMessage[] response = agent.Send(request);        agent.Disconnect();    }}

以下是前台调用：

using System;using System.Collections.Generic;using System.Linq;using System.Web;using System.Web.UI;using System.Web.UI.WebControls;public partial class _Default : System.Web.UI.Page{    public const string MQNAME1 = "ManageTest1";    public const string MQNAME2 = "ManageTest2";    public readonly MQHelp MQHELP = new MQHelp();    protected void Page_Load(object sender, EventArgs e)    {        if (!I