与MQ通讯的完整JAVA程序).doc

下载文档 降价啦

1
0
约6.48千字
约 6页
2018-03-08 发布于河南
举报
版权申诉
保障服务

与MQ通讯的完整JAVA程序).doc

1、本文档共6页，可阅读全部内容。
2、有哪些信誉好的足球投注网站（book118）网站文档一经付费（服务费），不意味着购买了该文档的版权，仅供个人/单位学习、研究之用，不得用于商业用途，未经授权，严禁复制、发行、汇编、翻译或者网络传播等，侵权必究。
3、本站所有内容均由合作方或网友上传，本站不对文档的完整性、权威性及其观点立场正确性做任何保证或承诺！文档内容仅供研究参考，付费前请自行鉴别。如您付费，意味着您自己接受本站规则且自行承担风险，本站不退款、不进行额外附加服务；查看《如何避免下载的几个坑》。如果您已付费下载过本站文档，您可以点击这里二次下载。
4、如文档侵犯商业秘密、侵犯著作权、侵犯人身权等，请点击“版权申诉”（推荐），也可以打举报电话：400-050-0827(电话支持时间：9:00-18:30)。

与MQ通讯的完整JAVA程序)

/** ? ?*?@author?Fenglb?E-mail163.com ? ?*?@version?创建时间：2009-4-30?下午04:13:38 ? ?*? ? ?*/?? import?java.io.IOException; ?? import?com.ibm.mq.MQC; ?? import?com.ibm.mq.MQEnvironment; ?? import?com.ibm.mq.MQException; ?? import?com.ibm.mq.MQGetMessageOptions; ?? import?com.ibm.mq.MQMessage; ?? import?com.ibm.mq.MQPutMessageOptions; ?? import?com.ibm.mq.MQQueue; ?? import?com.ibm.mq.MQQueueManager; ?? ?? public?class?MessageByMQ{ ?? ?????//定义队列管理器和队列的名称 ?? ?????private?static?String?qmName;? ?? ?????private?static?String?qName; ?? ?????private?static?MQQueueManager?qMgr; ?? ?????static{ ?? ?????????//设置环境: ?? ?????????//MQEnvironment中包含控制MQQueueManagerMQEnvironment的MQQueueManager的构造函数加 ?? ?????????//因此必MQQueueManager对象之前设定MQEnvironment中的. ?? ?????????MQEnvironment.hostname=80;??????????//MQ服IP地址?????? ?? ?????????MQEnvironment.channel=S_FENGLB;??????????????//服 ?? ?????????MQEnvironment.CCSID=1381;??????????????????????//服MQ服1381代表GBK、1208代表UTF(Coded?Character?Set?Identifier:CCSID) ?? ?????????MQEnvironment.port=1414;???????????????????????//MQ端口 ?? ?????????qmName?=?QM_FENGLB;??????????????????????????//MQ的 ?? ?????????qName?=?testQ;???????????????????????????????//MQ远程队列的名称 ?? ?????????try?{ ?? ?????????????//定义并初始化队列管理器对象并连接? ?? ?????????????//MQQueueManager可以被多线程共享，但是从MQ获取信息的时候是同步的，任何时候只有一个线程可以和MQ通信。 ?? ????????????qMgr?=?new?MQQueueManager(qmName); ?? ????????}?catch?(MQException?e)?{ ?? ????????????//?TODO?Auto-generated?catch?block ?? ????????????System.out.println(初使化MQ出); ?? ????????????e.printStackTrace(); ?? ????????}? ?? ?????} ?? ?????/** ? ??????*?往MQ ? ??????*?@param?message ? ??????*?@return ? ??????*/?? ?????public?static?int?sendMessage(String?message){ ?? ?????????int?result=0; ?? ?????????try{??? ?? ?????????????//设置将要连接的队列属性 ?? ?????????????//?Note.?The?MQC?interface?defines?all?the?constants?used?by?the?WebSphere?MQ?Java?programming?interface? ?? ?????????????//(except?for?completion?code?constants?and?error?code?constants). ?? ?????????