程序大致如下:
package sendmsg1;
import com.ibm.mq.MQC;
import com.ibm.mq.MQEnvironment;
import com.ibm.mq.MQException;
import com.ibm.mq.MQGetMessageOptions;
import com.ibm.mq.MQPutMessageOptions;
import com.ibm.mq.MQMessage;
import com.ibm.mq.MQQueue;
import com.ibm.mq.MQQueueManager;public class SendMSG1
{
private MQQueueManager qMgr; //定义一个队列管理器变量
public static void main(String args[])
throws Exception
{
new SendMSG1();
}
public SendMSG1() {
// try{
MQEnvironment.hostname="192.1.51.30";
MQEnvironment.channel="SERVER_CHANNEL";//用来通信的通道
MQEnvironment.CCSID =1381;
MQEnvironment.port=1415; try{
qMgr=new MQQueueManager("QM_SVR05120");//队列管理器名称
int openOptions=MQC.MQOO_INPUT_AS_Q_DEF|MQC.MQOO_OUTPUT|MQC.MQOO_INQUIRE;
MQQueue queue=qMgr.accessQueue("SVR05120.TO.EBQM",openOptions,null,null,null);
//建立连接
MQMessage hello=new MQMessage();//要写入队列的消息
try{
hello.format=MQC.MQFMT_STRING ;
hello.characterSet=1381 ;
hello.writeString("这是测试!");
} catch(java.io.IOException ex) {
}finally{};
MQPutMessageOptions pmo=new MQPutMessageOptions();
for (int i=1;i<=5;i++)//将消息依次写入队列
{
hello.expiry=-1; //设置消息用不过期
queue.put(hello);//将消息放入队列
}
queue.close() ;//关闭队列
qMgr.disconnect() ; //断开连接
} catch(Exception ex) {
} finally{};
}
}
在调试时发现在执行到
MQEnvironment.hostname="192.1.51.30";
就退出了,出现下面错误,我用的环境是NETBEANS5。0 ,MQ装在192.1.51.30的WIN2000上Exception in thread "main" java.lang.NoClassDefFoundError: javax/resource/ResourceException
at com.ibm.mq.MQEnvironment.<clinit>(MQEnvironment.java:224)
at mqjava.MQJavaApplication.sender(MQJavaApplication.java:91)
at mqjava.MQJavaApplication.main(MQJavaApplication.java:237)
Java Result: 1请问是什么问题
package sendmsg1;
import com.ibm.mq.MQC;
import com.ibm.mq.MQEnvironment;
import com.ibm.mq.MQException;
import com.ibm.mq.MQGetMessageOptions;
import com.ibm.mq.MQPutMessageOptions;
import com.ibm.mq.MQMessage;
import com.ibm.mq.MQQueue;
import com.ibm.mq.MQQueueManager;public class SendMSG1
{
private MQQueueManager qMgr; //定义一个队列管理器变量
public static void main(String args[])
throws Exception
{
new SendMSG1();
}
public SendMSG1() {
// try{
MQEnvironment.hostname="192.1.51.30";
MQEnvironment.channel="SERVER_CHANNEL";//用来通信的通道
MQEnvironment.CCSID =1381;
MQEnvironment.port=1415; try{
qMgr=new MQQueueManager("QM_SVR05120");//队列管理器名称
int openOptions=MQC.MQOO_INPUT_AS_Q_DEF|MQC.MQOO_OUTPUT|MQC.MQOO_INQUIRE;
MQQueue queue=qMgr.accessQueue("SVR05120.TO.EBQM",openOptions,null,null,null);
//建立连接
MQMessage hello=new MQMessage();//要写入队列的消息
try{
hello.format=MQC.MQFMT_STRING ;
hello.characterSet=1381 ;
hello.writeString("这是测试!");
} catch(java.io.IOException ex) {
}finally{};
MQPutMessageOptions pmo=new MQPutMessageOptions();
for (int i=1;i<=5;i++)//将消息依次写入队列
{
hello.expiry=-1; //设置消息用不过期
queue.put(hello);//将消息放入队列
}
queue.close() ;//关闭队列
qMgr.disconnect() ; //断开连接
} catch(Exception ex) {
} finally{};
}
}
在调试时发现在执行到
MQEnvironment.hostname="192.1.51.30";
就退出了,出现下面错误,我用的环境是NETBEANS5。0 ,MQ装在192.1.51.30的WIN2000上Exception in thread "main" java.lang.NoClassDefFoundError: javax/resource/ResourceException
at com.ibm.mq.MQEnvironment.<clinit>(MQEnvironment.java:224)
at mqjava.MQJavaApplication.sender(MQJavaApplication.java:91)
at mqjava.MQJavaApplication.main(MQJavaApplication.java:237)
Java Result: 1请问是什么问题
解决方案 »
免费领取超大流量手机卡,每月29元包185G流量+100分钟通话, 中国电信官方发货