ibmmq .net

### .NET 中使用 IBM MQ 进行消息队列操作

为了在.NET应用程序中实现与IBM MQ的交互，可以利用AMQP协议或是通过官方提供的IBM MQ .NET客户端库。对于后者来说，它提供了更直接的方式去连接到IBM MQ服务器，并执行诸如发送和接收消息的操作。

#### 安装 IBM MQ .NET Client 库

要开始，在项目中引入IBM MQ .NET client library可以通过NuGet包管理器来完成：

Install-Package IBM.MQ.Client

#### 建立连接并定义队列管理器属性

创建一个`MQQueueManager`对象实例用于表示队列管理者，这一步骤是必要的以便后续能够访问特定的消息队列[^1]。

var qMgrName = "QMGR_NAME"; // 替换成实际的队列管理名称
var hostName = "hostname_or_ip";
var portNumber = 1414;
var channelName = "CHANNEL.NAME";

Hashtable properties = new Hashtable();
properties.Add(MQC.HOST_NAME_PROPERTY, hostName);
properties.Add(MQC.PORT_PROPERTY, portNumber);
properties.Add(MQC.CHANNEL_PROPERTY, channelName);

using (MQQueueManager qmgr = new MQQueueManager(qMgrName, properties))
{
    Console.WriteLine($"Connected to Queue Manager {qMgrName}");
}

#### 发送消息至指定队列

当成功建立起了同队列管理者的会话之后，则可进一步打开目标队列并向其内部写入数据项。

string queueName = "TEST.QUEUE"; // 需替换为真实的队列名
using (MQQueue queue = qmgr.AccessQueue(queueName,
                                        MQC.MQOO_OUTPUT | MQC.MQOO_FAIL_IF_QUIESCING))
{
    string msgToSend = "Hello from .NET!";
    var putMessageOptions = new MQPutMessageOptions();

    using (MQMessage message = new MQMessage())
    {
        message.WriteString(msgToSend);
        queue.Put(message, putMessageOptions);
        Console.WriteLine("Message sent.");
    }
}

#### 接收来自队列的消息

同样地，也可以设置监听程序等待新到达的信息，或者主动轮询获取已存在的条目。

using (MQQueue queue = qmgr.AccessQueue(queueName,
                                       MQC.MQOO_INPUT_SHARED | MQC.MQOO_FAIL_IF_QUIESCING))
{
    int waitInterval = 500; // 单位毫秒
    var getMessageOptions = new MQGetMessageOptions()
    {
        WaitInterval = waitInterval,
        Options = CMQC.MQGMO_WAIT | CMQC.MQGMO_NO_AUTO_ACK
    };

    try
    {
        using (MQMessage receivedMsg = new MQMessage())
        {
            queue.Get(receivedMsg, getMessageOptions);
            string strMsg = receivedMsg.ReadString(receivedMsg.MessageLength);
            Console.WriteLine($"Received Message: '{strMsg}'");
            
            // 手动确认接收到的消息
            queue.Close(); // 关闭队列前需先关闭消息资源
        }
    }
    catch (MQException ex) when ((ex.ReasonCode == MQRCCF_MSG_NOT_AVAILABLE || ex.ReasonCode == MQRCCF_Q_MGR_QUIESCE_IN_PROGRESS))
    {
        Console.WriteLine("No more messages available or quiesce in progress.");
    }
}

以上代码片段展示了基本的发送和接收功能；然而，在生产环境中还需要考虑更多的细节比如错误处理机制、性能优化策略等。此外，针对某些特殊需求如事务支持、持久化存储等问题也应给予适当的关注。