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>    /// 創(chuàng)建本地隊列    /// </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">是否包含系統(tǒng)隊列</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>    /// 創(chuàng)建遠程隊列    /// </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>    /// 創(chuàng)建發(fā)送方通道    /// </summary>    /// <param name="qmName">隊列管理器</param>    /// <param name="channelName">通道名稱</param>    /// <param name="transmissionQueueName">傳輸隊列名稱</param>    /// <param name="
以下是前臺調(diào)用：
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