28365备用网址
当前位置:主页 > 28365备用网址 >

检查Websphere MQ消息支持和未传递消息队列的问题。

时间:2019-07-22 07:22  来源:admin   作者:英国365bet备用网址   点击:
展开全部
Webspheremq:跨平台传输信息的功能
1安装webspheremq并启动2webspheremq以创建queueManager(示例:MQSI_SAMPLE_QM)。3选择队列类型创建本地类型(作为lq)。
Mq; importcom
夏娃。
MQ
*; / ** mq * / publicclassFirstMqTest Java类访问成功。//首先
Test(); publicStaticvoidmain(Stringargs[]){FirstMqTestfirst = newFirstMqTest(); first
Test();}publicvoidtest(){StringqManager = MQSI_SAMPLE_QM // QueueManagernameStringqName = lq // QueueNametry{// configureconnectionparametersMQEnvironment。
主机名= 172
16
17年
123 // MQServername或IP // MQEnvironment。
港口= 1414。// listenrportMQEnvironment。
Channel = BridgeChannel // Server-ConnectionChannelMQEnvironment。
CCSID = 1381。//创建与QueueManager系统的连接。
退房
选择Println(连接工具管理器:+ qManager); MQQueueManager qMgr = newMQQueueManager(qManager); // OpenintopenOptions = MQC。
MQOO_INPUT_AS_Q_DEF | MQC
MQOO_OUTPUT; //不要指定新的Wish Wish to Open系统选项。
退房
Println(访问队列:+ qName); MQQueue queue = qMgr。
accessQueue(qName,openOptions); //定义一个简单的WebSphere MQ消息。
MQMessagemsg = newMQMessage(); //
并以格式8文件格式编写其他扩展名
writeUTF(你好,世界!
; //指定消息的默认配置选项。MQPutMessageOptionspmo = newMQPutMessageOptions(); //将消息放入队列系统。
退房
Println(发送消息)
; / ** where(intj = 0; jj + +){String str = test 11 111 111 111 str = str + j;测试mq的发送子串** /。味精。
writeUTF(str);尾部
(Msg,pmo);}放入队列。
Put(msg,pmo); //再次获取消息。
初始定义WebSphere MQ消息// //接收接收的数据MQMessagercvMessage = newMQMessage(); // defaultgetmessageoptionsMQGetMessageOptionsgmo = newMQGetMessageOptions(); //指定默认值。//获取队列消息
系统
退房
Println(。
恢复图像(背面);尾部
获取(rcvMessage,gmo)。//显示消息文本
StringmsgText = rcvMessage。
readUTF();系统
退房
Println(主题消息:+ msgText); // ClosethequeueSystem。
退房
Println(Closingthequeue);尾巴
Close(); //从QueueManager系统断开连接。
退房
Println(与QueueManager断开连接); qMgr。
断开();系统
退房
Println(?完成。
catch(MQExceptionex){System。
退房
Println(AWebSphere MQ错误代码:CompletionCode + ex。
completedCode + ReasonCode + ex
reasonCode);}catch(java)
木卫一
IOExceptionex){system。
退房
Println(编写邮件信箱时发生异常:+ ex);}}