没有更多推荐了，
不良信息举报
举报内容：
windows 7 cmd 下执行 crtmqm -q TestMqm报AMQ8101: 发生 WebSphere MQ 错误（893）。
举报原因：
原文地址：
原因补充：
最多只允许输入30个字
加入CSDN，享受更精准的内容推荐，与500万程序员共同成长！如何解决websphere mq 副本试用期到期_百度知道
如何解决websphere mq 副本试用期到期
我有更好的答案
websphere mq
: 用于传输信息 具有跨平台的功能。1 安装websphere mq 并启动2 websphere mq 建立 queue Manager (如：MQSI_SAMPLE_QM)3 建立queue 类型选择 Local类型 的 （如lq
）3 建立channels 类型选择Server Connection （如BridgeChannel）java 代码如下：package test.import com.ibm.mq.*;/* * 成功的访问mq 的java 类 */public class FirstMqTest {//
public static void main(String[] args[]){//
FirstMqTest first = new FirstMqTest();//
first.test();//
public static void main(String args[]){
FirstMqTest first = new FirstMqTest();
first.test();
public void test(){
String qManager = &MQSI_SAMPLE_QM&; //QueueManager name
String qName = &lq&;//Queue Name
//configure connection parameters
MQEnvironment.hostname=&172.16.17.123&;//MQ Server name or IP
//MQEnvironment.port=1414;//listenr port
MQEnvironment.channel=&BridgeChannel&;//Server-Connection Channel
MQEnvironment.CCSID =1381;
// Create a connection to the QueueManager
System.out.println(&Connecting to queue manager: &+qManager);
MQQueueManager qMgr = new MQQueueManager(qManager);
// Set up the options on the queue we wish to open
int openOptions = MQC.MQOO_INPUT_AS_Q_DEF | MQC.MQOO_OUTPUT;
// Now specify the queue that we wish to open and the open options
System.out.println(&Accessing queue: &+qName);
MQQueue queue = qMgr.accessQueue(qName, openOptions);
// Define a simple WebSphere MQ Message ...
MQMessage msg = new MQMessage();
// ... and write some text in UTF8 format
msg.writeUTF(&Hello, World!&);
// Specify the default put message options
MQPutMessageOptions pmo = new MQPutMessageOptions();
// Put the message to the queue
System.out.println(&Sending a message...&);
* 在此测试一下 mq 的传输次列
for(int j=0;j& 5;j++){
String str =&test&;
str = str+j;
msg.writeUTF(str);
queue.put(msg, pmo);
queue.put(msg, pmo);
// Now get the message back again. First define a WebSphere MQ message
// to receive the data
MQMessage rcvMessage = new MQMessage();
// Specify default get message options
MQGetMessageOptions gmo = new MQGetMessageOptions();
// Get the message off the queue.
System.out.println(&...and getting the message back again&);
queue.get(rcvMessage, gmo);
// And display the message text...
String msgText = rcvMessage.readUTF();
System.out.println(&The message is: & + msgText);
// Close the queue
System.out.println(&Closing the queue&);
queue.close();
// Disconnect from the QueueManager
System.out.println(&Disconnecting from the Queue Manager&);
qMgr.disconnect();
System.out.println(&Done!&);
catch (MQException ex) {
System.out.println(&A WebSphere MQ Error occured : Completion Code &
+ ex.completionCode + & Reason Code & + ex.reasonCode);
catch (java.io.IOException ex) {
System.out.println(&An IOException occured whilst writing to the message buffer: &
采纳率：92%
来自团队：
为您推荐：
其他类似问题
websphere的相关知识
换一换
回答问题，赢新手礼包
个人、企业类
违法有害信息,请在下方选择后提交
色情、暴力
我们会通过消息、邮箱等方式尽快将举报结果通知您。Error 404 (Not Found)!!1
404. That’s an error.
The requested URL /482036/ was not found on this server.
That’s all we know.吃饭的时候吃饭，睡觉的时候睡觉，工作的时候工作，学习的时候学习......
? WebSphere MQ Reason code list ?
转载声明：本站文章若无特别说明，皆为原创，转载请注明来源，谢谢 ！
原文：http://publib.boulder.ibm.com/infocenter/wmqv7/v7r0/index.jsp?topic=%2Fcom.ibm.mq.amqzao.doc%2Ffm12040_.htm
本文链接：
转载声明：本站文章若无特别说明，皆为原创，转载请注明来源，谢谢 ！
上一篇：下一篇：
?&最近修改
?&最新发布一、下载7.5 Trial版本
这是下载网址，下载前先必须注册IBM ID，下载完成后一路Next即可（注：windows上安装时，会询问是否域环境，初次学习时，为简单起见，建议选择No）
安装完成后，MQ的Bin目录会自动添加到环境变量Path中，以后就可以直接用Dos命令行窗口操作(当然，也可以用图形化GUI方式通过IBM WebSphere MQ Explorer来管理)
注：安装时，强烈建议用管理员Administrator身份安装，否则安装完成后，有可能license无法生效、runmqsc命令模式下无法正常执行命令.
二、创建队列管理器
WIN&+ R键，输入cmd，进入命令行窗口，键入:
crtmqm QM_TEST
创建一个队列管理器QM_TEST(你可以改成自己想要的名字)，如果把整个MQ理解成一个数据库实例，QM_TEST相当于就是db instance中的schema(或user)
命令行创建的队列管理器默认是不活动状态的，可以用
strmqm QM_TEST
来启动队列管理器
三、创建队列
如果说&队列管理器&是db中的schema，那么"队列"就相当于db中的Table了，而队列中的每条"消息"，就相当于Table中的每条记录，继续在命令行窗口模式下，输入
runmqsc QM_TEST
将进入MQ的交互命令模式，继续输入
define qlocal(Q1)
将创建一个本地队列Q1(你可以改成自己需要的名字)，如果此时你打开 "开始菜单-&程序-&IBM WebSphere MQ-&WebSphere MQ Explorer (Installation1)"也能同步在图形界面下，看到这个队列
最后键入end，退出MQ的交互命令模式。
四、发送消息
继续在Windows命令模式下，输入
amqsput Q1 QM_TEST
这里系统将处于等待用户输入的状态，随便输入一些消息，然后连敲二次回车，完成消息发送
五、接收消息
amqsget Q1 QM_TEST
把刚才的put换成了get，将从队列管理器QM_TEST的队列Q1中，把消息取出来
六、进阶指南
熟悉以上命令行操作后，还可以用图形化的操作方式再强化一遍（建议还是多用命令行模式，因为有些操作只能用命令行完成，比如后面要提到的修改队列管理器编码）
WebSphere MQ Explorer中，从"帮助"菜单里调出帮助文档，里面有一个不错的教程，强烈推荐新手看一遍
不过，"教程2：将消息发送至远程队列"这里，帮助文档上有几个细节没讲透，导致初次用命令行照着做，可能会不成功，几个要点如下：
1、通道命名问题
发送方与接收方的通道名称，必须一样，这样二边才能对应起来
2、接收方必须要有侦听器，而且要处于激活状态
3、发送方的发送通道中，连接名称格式为："&接收方HostName或IP地址&(接收方-队列管理器-侦听器的TCP端口) ，不包括"&&&，比如比如：yangjm(1514)或172.12.134.14(1514)
4、发送方的发送通道必须处于激活状态，如果通道启动失败，尝试右键-&ping/复位，如果还不行，检查上述要点1-3是否设置有问题
七、远程连接问题
图形方式添加&远程队列管理器&时，如果远程队列也是7.x或以上版本，当前登录用户是管理员时，将提示权利不足，拒绝连接，原因是7.0以上，MQ提高了安全性，会默认拦截管理员，详情可参考IBM上的解释
解决方式：
1. 更换当前用户，建一个mqm用户组(MQ安装后，会默认创建该Windows用户组)的用户，然后以该用户身份登录操作
2.参考IBM上的解释，如果出于学习目的，最简单的做法，就是在runmqsc交互模式下，键入
ALTER QMGR CHLAUTH(DISABLED)& 直接关闭通道认证(生产环境不推荐这么做)
另外，要想本机上的队列能被远程管理，前提是该队列管理器允许远程管理，操作方式：队列管理器上右击-&选择"远程管理..."，接下来的事情大家都知道
八、字符集编码问题
每个队列管理器，都有一个CCSID的属性，对应的就是字符集编码，在windows系统中，这个编码应该是1381，如果你是用其它OS(比如linux)的配置通过脚本导入MQ的，可能编码就不是1381了，这会导致在windows上无法连接\启动队列管理器，可以通过MQ交互命令行修改，
runmqsc QM_TEST 进入QM_TEST的MQ交互模式
DISPLAY QMGR CCSID 查看当前的CCSID属性
ALTER QMGR CCSID(1381) 修改字符集编码为1381
九、如何从&试用版&升级成&正式版&
试用版默认只能用90天，到期后，如果购买了正式版的license，可以通过命令行导入license，命令如下：
setmqprd x:\license\amqpcert.lic
注：amqpcert.lic中的P即代表这是Product生产版本，setmqprd 后面的路径即为license文件的所在路径
十、java连接示例代码&
import com.ibm.mq.MQC;
import com.ibm.mq.MQE
import com.ibm.mq.MQE
import com.ibm.mq.MQGetMessageO
import com.ibm.mq.MQM
import com.ibm.mq.MQPutMessageO
import com.ibm.mq.MQQ
import com.ibm.mq.MQQueueM
* 可以在MQ的资源管理器的某一个队列上放入测试消息、浏览消息等
* 可以放入多条消息，按先进先出的方式取得
public class MQTest {
private String qM// QueueManager名
private MQQueueManager qM
private MQQueue qQ
String HOST_NAME;
int PORT = 0;
String Q_NAME;
String CHANNEL;
int CCSID;
public void init() {
HOST_NAME = "yangjm";//Hostname或IP
PORT = 1414;//要有一个侦听器，处于活动状态，且监听1414端口
qManager = "QM_APPLE";
Q_NAME = "Q1";//Q1是一个本地队列
CHANNEL = "DC.SVRCONN";//QM_APPLE上要建一个名为DC.SVRCONN的服务器连接通道
CCSID = 1381; // 表示是简体中文，
// CCSID的值在AIX上一般设为1383，如果要支持GBK则设为1386，在WIN上设为1381。
MQEnvironment.hostname = HOST_NAME; // 安裝MQ所在的ip address
MQEnvironment.port = PORT; // TCP/IP port
MQEnvironment.channel = CHANNEL;
MQEnvironment.CCSID = CCSID;
qMgr = new MQQueueManager(qManager);
int qOptioin = MQC.MQOO_INPUT_AS_Q_DEF | MQC.MQOO_INQUIRE
| MQC.MQOO_OUTPUT;
qQueue = qMgr.accessQueue(Q_NAME, qOptioin);
} catch (MQException e) {
System.out
.println("A WebSphere MQ error occurred : Completion code "
+ e.completionCode + " Reason Code is "
+ e.reasonCode);
void finalizer() {
qQueue.close();
qMgr.disconnect();
} catch (MQException e) {
System.out
.println("A WebSphere MQ error occurred : Completion code "
+ e.completionCode + " Reason Code is "
+ e.reasonCode);
* 取过一次，下次就没有了
public void GetMsg() {
MQMessage retrievedMessage = new MQMessage();
MQGetMessageOptions gmo = new MQGetMessageOptions();
gmo.options += MQC.MQPMO_SYNCPOINT;
qQueue.get(retrievedMessage, gmo);
int length = retrievedMessage.getDataLength();
byte[] msg = new byte[length];
retrievedMessage.readFully(msg);
String sMsg = new String(msg);
System.out.println(sMsg);
} catch (RuntimeException e) {
e.printStackTrace();
} catch (MQException e) {
if (e.reasonCode != 2033) // 没有消息
e.printStackTrace();
System.out
.println("A WebSphere MQ error occurred : Completion code "
+ e.completionCode
+ " Reason Code is "
+ e.reasonCode);
} catch (java.io.IOException e) {
System.out
.println("An error occurred whilst to the message buffer "
public void SendMsg(byte[] qByte) {
MQMessage qMsg = new MQMessage();
qMsg.write(qByte);
MQPutMessageOptions pmo = new MQPutMessageOptions();
qQueue.put(qMsg, pmo);
System.out.println("The message is sent!");
System.out.println("\tThe message is " + new String(qByte, "GBK"));
} catch (MQException e) {
System.out
.println("A WebSphere MQ error occurred : Completion code "
+ e.completionCode + " Reason Code is "
+ e.reasonCode);
} catch (java.io.IOException e) {
System.out
.println("An error occurred whilst to the message buffer "
* @param args
public static void main(String[] args) {
MQTest mqst = new MQTest();
mqst.init();
mqst.SendMsg("你好,Webshpere MQ 7.5!".getBytes("GBK"));
mqst.GetMsg();
} catch (Exception e) {
e.printStackTrace();
mqst.finalizer();
&需要引用的jar包(在MQ的安装目录下都有)
附示例源代码下载地址：
&十一、机器之间迁移
如果要在多台机器上配置相同的队列管理器，一台台机器去创建、设置十分繁琐，可以用命令
dmpmqcfg -m&QM_TEST -A & C:\SCRIPT\QM_TEST_SCRIPT.DUMP
注：其中QM_TEST即为要导出的队列管理器名称，而 "QM_TEST_SCRIPT.DUMP"是导出脚本的文件名，可以随便修改，执行完后会在"C:\SCRIPT\"下生成一个&.dump&的脚本文件，这里我们借用了管道操作符号"&"
在另一台机器上，先把dump文件复制过去(比如就放在c盘根目录下)，然后按下列步骤执行
crtmqm QM_TEST
strmqm QM_TEST
runmqsc QM_TEST & C:\QM_TEST_SCRIPT.DUMP & C:\QM_TEST_SCRIPT.OUT
这表示runmqsc命令将对 QM_TEST操作，操作的命令来源于脚本文件 C:\QM_TEST_SCRIPT.DUMP，而执行结果会输出到 C:\QM_TEST_SCRIPT.OUT
阅读(...) 评论()