使用 CCDT 连接到 MQ 服务器

我正在尝试连接到MQ使用中存在的信息CCDT文件。我目前可以连接到MQ使用所有详细信息，从队列中获取消息以及将消息放入队列中。

经过广泛的谷歌搜索后，我无法找到任何允许我使用以下命令进行连接的示例代码CCDT file.

我的一位同事向我转发了他的JMS连接代码，但我无法将其移植到C#.

The JAVA代码如下-

public class MQTest {
public static void main(String[] args) {

    MQQueueManager queueManager = null;
    URL ccdtFileUrl = null;
    MQMessage mqMessage = null;
    //MQPutMessageOptions myPMO = null
    try {
     String QM =    "IB9QMGR";
     String QUEUE1 = "TEST";

     System.out.println("Starting MQClient Put Program: ");
     ccdtFileUrl = new URL("file:///D:/AMQCLCHL.TAB") ;
     ccdtFileUrl.openConnection();
     queueManager = new MQQueueManager("SDCQMGR.T1", ccdtFileUrl);

     System.out.println("Connected to QMGR ");
     int openOptions = MQC.MQOO_OUTPUT;
     MQQueue InQueue = queueManager.accessQueue(QUEUE1,openOptions,null,null,null);
     MQMessage inMessage = new MQMessage();
     inMessage.writeString("###Testing####");
     InQueue.put(inMessage);
     System.out.println("Message Id is :" + inMessage.messageId);
     System.out.println(inMessage.toString());
     InQueue.close();
     queueManager.disconnect() ;
 }
 catch(MQException ex){
     System.out.println("MQ Error - Reason code :" + ex.reasonCode);
 }
 catch (Exception e){
     System.out.println("Error : " + e);
 }
}
}

代替URL，我用了URI（在 C# 中）设置文件位置。 （这可能被错误地使用。但不知道还能使用什么。）

Uri ccdtFileUrl = new Uri("file:///D:/AMQCLCHL.TAB") ;

但我不能用openConnection()在 URI 上。还，

queueManager = new MQQueueManager("SDCQMGR.T1",ccdtFileUrl);给出参数重载异常。因为 C# 不支持 URI。

我尝试查找示例，但找到了一些 JMS 示例，仅此而已。寻找一些在 C# 中连接的示例代码。

你需要设置MQCHLLIB and MQCHLTAB使用 CCDT 的环境变量。您可以从命令提示符、app.config 或应用程序本身的代码设置这两个变量。

下面的例子演示了使用CCDT:

        MQQueueManager qm = null;
        System.Environment.SetEnvironmentVariable("MQCHLLIB", "C:\\ProgramData\\IBM\\MQ\\qmgrs\\QM1\\@ipcc");
        System.Environment.SetEnvironmentVariable("MQCHLTAB", "AMQCLCHL.TAB");

        try
        {
            **Hashtable props = new Hashtable();
            props.Add(MQC.TRANSPORT_PROPERTY, MQC.TRANSPORT_MQSERIES_CLIENT);
            qm = new MQQueueManager("QM1",props);**
            MQQueue queue1 = qm.AccessQueue("SYSTEM.DEFAULT.LOCAL.QUEUE", MQC.MQOO_OUTPUT | MQC.MQOO_FAIL_IF_QUIESCING);
            MQMessage msg = new MQMessage();
            msg.WriteUTF("Hello this message is from .net client");
            queue1.Put(msg);
            queue1.Close();
            qm.Disconnect();
        }
        catch (Exception ex)
        {
            Console.Write(ex);
        }