使用CCDT连接到MQ服务器我正在尝试使用CCDT文件中的信息连接到MQ。我现在可以使用所有详细信息连接到MQ，并从队列中获取和放入消息。经过大量谷歌搜索后，我无法找到任何允许我使用CCDT文件串联的示例代码。我的一位同事向我转发了他的JMS连接代码，但我无法将其移植到C#。JAVA代码如下–publicclassMQTest{publicstaticvoidmain(String[]args){MQQueueManagerqueueManager=null;网址ccdtFileUrl=null;MQMessagemqMessage=null;//MQPutMessageOptionsmyPMO=nulltr??y{StringQM="IB9QMGR";字符串QUEUE1="测试"；System.out.println("启动MQClient放置程序：");ccdtFileUrl=newURL("文件:///D:/AMQCLCHL.TAB");ccdtFileUrl.openConnection();queueManager=newMQQueueManager("SDCQMGR.T1",ccdtFileUrl);System.out.println("连接到QMGR");intopenOptions=MQC.MQOO_OUTPUT;MQQueueInQueue=queueManager.accessQueue(QUEUE1,openOptions,null,null,null);MQMessageinMessage=newMQMessage();inMessage.writeString("###Testing####");InQueue.put(inMessage);System.out.println("消息ID为："+inMessage.messageId);System.out.println(inMessage.toString());InQueue.close();queueManager.disconnect();}catch(MQExceptionex){System.out.println("MQ错误-原因代码："+ex.reasonCode);}猫ch(Exceptione){System.out.println("错误："+e);我使用URI（在C#中）来设置文件位置，而不是URL（这可能是错误的用法。不知道我还能使用什么。）UriccdtFileUrl=newUri("file:///D:/AMQCLCHL.TAB");但是我不能在URI上使用openConnection()。此外，queueManager=newMQQueueManager("SDCQMGR.T1",ccdtFileUrl);给出参数重载异常。由于C#不支持URI。我试过寻找样本，但我发现了一些JMS样本，仅此而已。寻找一些示例代码以在C#中连接。您需要设置MQCHLLIB和MQCHLTAB环境变量才能使用CCDT。您可以从命令提示符、app.config或应用程序本身的代码中设置这两个变量。下面举例演示CCDT的用法：以上为C#学习教程：使用CCDT连接MQ服务器分享全部内容。如果对你有用，需要进一步了解C#学习教程，希望大家多多关注——MQQueueManagerqm=null;System.Environment.SetEnvironmentVariable("MQCHLLIB","C:\ProgramData\IBM\MQ\qmgrs\QM1\@ipcc");System.Environment.SetEnvironmentVariable("MQCHLTAB","AMQCLCHL.TAB");尝试{**Hashtableprops=newHashtable();props.Add(MQC.TRANSPORT_PROPERTY,MQC.TRANSPORT_MQSERIES_CLIENT);qm=newMQQueueManager("QM1",props);**MQQueuequeue1=qm.AccessQueue("SYSTEM.DEFAULT.LOCAL.QUEUE",MQC.MQOO_OUTPUT|MQC.MQOO_FAIL_IF_QUIESCING);MQMessage消息=newMQMessage();msg.WriteUTF("你好，这条消息来自.net客户端");queue1.Put(味精);queue1.Close();平方米。断开（）;}catch(Exceptionex){Console.Write(ex);}本文收集自网络，不代表立场。如涉及侵权，请点击右侧联系管理员删除。如需转载请注明出处：
