IBM WebSphere MQ 7.5基本用法

时间  2020-09-20
标签 ibm websphere 7.5 基本 用法 繁體版
原文   原文链接

1、下载7.5 Trial版本html

http://www.ibm.com/developerworks/downloads/ws/wmq/java

这是下载网址，下载前先必须注册IBM ID，下载完成后一路Next便可（注：windows上安装时，会询问是否域环境，初次学习时，为简单起见，建议选择No）linux

安装完成后，MQ的Bin目录会自动添加到环境变量Path中，之后就能够直接用Dos命令行窗口操做(固然，也能够用图形化GUI方式经过IBM WebSphere MQ Explorer来管理)web

注：安装时，强烈建议用管理员Administrator身份安装，不然安装完成后，有可能license没法生效、runmqsc命令模式下没法正常执行命令.数据库

 

2、建立队列管理器windows

WIN + R键，输入cmd，进入命令行窗口，键入:安全

crtmqm QM_TEST服务器

建立一个队列管理器QM_TEST(你能够改为本身想要的名字)，若是把整个MQ理解成一个数据库实例，QM_TEST至关于就是db instance中的schema(或user)ide

命令行建立的队列管理器默认是不活动状态的，能够用post

strmqm QM_TEST

来启动队列管理器

 

3、建立队列

若是说“队列管理器”是db中的schema，那么"队列"就至关于db中的Table了，而队列中的每条"消息"，就至关于Table中的每条记录，继续在命令行窗口模式下，输入

runmqsc QM_TEST

将进入MQ的交互命令模式，继续输入

define qlocal(Q1)

将建立一个本地队列Q1(你能够改为本身须要的名字)，若是此时你打开 "开始菜单->程序->IBM WebSphere MQ->WebSphere MQ Explorer (Installation1)"也能同步在图形界面下，看到这个队列

最后键入end，退出MQ的交互命令模式。

 

4、发送消息

继续在Windows命令模式下，输入

amqsput Q1 QM_TEST

这里系统将处于等待用户输入的状态，随便输入一些消息，而后连敲二次回车，完成消息发送

 

5、接收消息

amqsget Q1 QM_TEST

把刚才的put换成了get，将从队列管理器QM_TEST的队列Q1中，把消息取出来

 

6、进阶指南

熟悉以上命令行操做后，还能够用图形化的操做方式再强化一遍（建议仍是多用命令行模式，由于有些操做只能用命令行完成，好比后面要提到的修改队列管理器编码）

WebSphere MQ Explorer中，从"帮助"菜单里调出帮助文档，里面有一个不错的教程，强烈推荐新手看一遍

不过，"教程2：将消息发送至远程队列"这里，帮助文档上有几个细节没讲透，致使初次用命令行照着作，可能会不成功，几个要点以下：

一、通道命名问题

发送方与接收方的通道名称，必须同样，这样二边才能对应起来

二、接收方必需要有侦听器，并且要处于激活状态

三、发送方的发送通道中，链接名称格式为："<接收方HostName或IP地址>(接收方-队列管理器-侦听器的TCP端口) ，不包括"<>“，好比好比：yangjm(1514)或172.12.134.14(1514)

四、发送方的发送通道必须处于激活状态，若是通道启动失败，尝试右键->ping/复位，若是还不行，检查上述要点1-3是否设置有问题

 

7、远程链接问题

图形方式添加“远程队列管理器”时，若是远程队列也是7.x或以上版本，当前登陆用户是管理员时，将提示权利不足，拒绝链接，缘由是7.0以上，MQ提升了安全性，会默认拦截管理员，详情可参考IBM上的解释 http://www-01.ibm.com/support/docview.wss?uid=swg21636532

解决方式：

1. 更换当前用户，建一个mqm用户组(MQ安装后，会默认建立该Windows用户组)的用户，而后以该用户身份登陆操做

2.参考IBM上的解释，若是出于学习目的，最简单的作法，就是在runmqsc交互模式下，键入

ALTER QMGR CHLAUTH(DISABLED)  直接关闭通道认证(生产环境不推荐这么作)

 

另外，要想本机上的队列能被远程管理，前提是该队列管理器容许远程管理，操做方式：队列管理器上右击->选择"远程管理..."，接下来的事情你们都知道

 

8、字符集编码问题

每一个队列管理器，都有一个CCSID的属性，对应的就是字符集编码，在windows系统中，这个编码应该是1381，若是你是用其它OS(好比linux)的配置经过脚本导入MQ的，可能编码就不是1381了，这会致使在windows上没法链接\启动队列管理器，能够经过MQ交互命令行修改，

runmqsc QM_TEST 进入QM_TEST的MQ交互模式

DISPLAY QMGR CCSID 查看当前的CCSID属性

ALTER QMGR CCSID(1381) 修改字符集编码为1381

 

9、如何从“试用版”升级成“正式版”

试用版默认只能用90天，到期后，若是购买了正式版的license，能够经过命令行导入license，命令以下：

setmqprd x:\license\amqpcert.lic

注：amqpcert.lic中的P即表明这是Product生产版本，setmqprd 后面的路径即为license文件的所在路径

 

10、java链接示例代码 

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;

/*
 * 能够在MQ的资源管理器的某一个队列上放入测试消息、浏览消息等
 * 能够放入多条消息，按先进先出的方式取得
 */
public class MQTest {

    private String qManager;// QueueManager名

    private MQQueueManager qMgr;

    private MQQueue qQueue;

    String HOST_NAME;

    int PORT = 0;

    String Q_NAME;

    String CHANNEL;

    int CCSID;

    String Msg;

    public void init() {

        try {
            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() {
        try {
            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() {
        try {
            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 "
                            + e);
        }
    }

    public void SendMsg(byte[] qByte) {
        try {
            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 "
                            + e);
        }

    }

    /**
     * @param args
     */
    public static void main(String[] args) {
        
        MQTest mqst = new MQTest();
        mqst.init();
        try {
            mqst.SendMsg("你好,Webshpere MQ 7.5!".getBytes("GBK"));
            mqst.GetMsg();
        } catch (Exception e) {
            e.printStackTrace();
        }
        mqst.finalizer();
    }

}
View Code

 须要引用的jar包(在MQ的安装目录下都有)

附示例源代码下载地址： http://pan.baidu.com/s/1qWrs9iO

 

 11、机器之间迁移

若是要在多台机器上配置相同的队列管理器，一台台机器去建立、设置十分繁琐，能够用命令

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

 

 

出处：http://www.cnblogs.com/yjmyzz/p/3505325.html

相关文章
相关标签/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公众号
   欢迎关注本站公众号,获取更多信息
联系我们 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程