中使用计划

java中使用websphere

webspheremq:用于传输信息具有跨平台的功能。

1安装webspheremq并启动

2webspheremq建立queueManager(如：MQSI_SAMPLE_QM)

3建立queue类型选择Local类型的（如lq）

3建立channels类型选择ServerConnection（如BridgeChannel）

java代码如下：

;

.*;

/*

*成功的访问mq的java类

*/

publicclassFirstMqTest{

//publicstaticvoidmain(String[]args[]){

//FirstMqTestfirst=newFirstMqTest();

//st();

//}

publicstaticvoidmain(Stringargs[]){

FirstMqTestfirst=newFirstMqTest();

st();

}

publicvoidtest(){

StringqManager=\"MQSI_SAMPLE_QM\";//QueueManagername

StringqName=\"lq\";//QueueName

try{

//configureconnectionparameters

stname=\"172.16.17.123\";//MQServernameorIP

//rt=1414;//listenrport

annel=\"BridgeChannel\";//Server-ConnectionChannel

SID=1381;

//CreateaconnectiontotheQueueManager

intln(\"Connectingtoqueuemanager:\"+qManager);

MueueManagerqMgr=newMueueManager(qManager);

//Setuptheoptionsonthequeuewewishtoopen

intopenOptions=OO_INPUT_AS_Q_DEF|OO_OUTPUT;

//Nowspecifythequeuethatwewishtoopenandtheopenoptions

intln(\"Accessingqueue:\"+qName);

Mueuequeue=cessQueue(qName,openOptions);

//DefineasimpleWebSphereMQMessage...

MQMessagemsg=newMQMessage();

//...andwritesometextinUTF8format

iteUTF(\"Hello,World!\");

//Specifythedefaultputmessageoptions

MQPutMessageOptionspmo=newMQPutMessageOptions();

//Putthemessagetothequeue

intln(\"Sendingamessage...\");

/*

*在此测试一下mq的传输次列

*

*/

for(intj=0;j5;j++){

Stringstr=\"test\";

str=str+j;

iteUTF(str);

t(msg,pmo);

}

t(msg,pmo);

//rstdefineaWebSphereMQmessage

//toreceivethedata

MQMessagercvMessage=newMQMessage();

//Specifydefaultgetmessageoptions

沥青混凝土的路面 MQGetMessageOptionsgmo=newMQGetMessageOptions();

//Getthemessageoffthequeue.

intln(\"...andgettingthemessagebackagain\");

t(rcvMessage,gmo);

//Anddisplaythemessagetext...

StringmsgText=adUTF();

intln(\"Themessageis:\"+msgText);

//Closethequeue

intln(\"Closingthequeue\");

ose();

//DisconnectfromtheQueueManager

intln(\"DisconnectingfromtheQueueManager\");

sconnect();

intln(\"Done!\");

}

catch(MQExceptionex){

intln(\"AWebSphereMQErroroccured:CompletionCode\"

+pletionCode+\"ReasonCode\"+asonCode);

}

catch(Exceptionex){

intln(\"AnIOExceptionoccuredwhilstwritingtothemessagebuffer:\"

+ex);

}

}

}

查看本文来源