IBM WebSphere MQ介绍安装以及配置服务详解

时间  2020-09-20
标签 ibm websphere 介绍 安装 以及 配置 服务 详解 繁體版
原文   原文链接

首先介绍一下MQhtml

    MQ消息队列的简称是一种应用程序对应用程序的通讯方法。说白了也就是经过队列的方式来对应用程序进行数据通讯。而无需专用连接来连接它们。java

MQ的通信方式linux

    1.数据报的方式 Datagram (Send and forget) apache

            应用程序在建立完消息后。利用MQ的API将消息发送到队列中。它充分利用了MQ（once and once only ）服务器

    2.请求和应答方式 Request/Reply 网络

            发送消息以后需等待对方处理结果。  需考虑以下问题：session

                        a.等待应答的时间是多少？函数

                         b.若是没有应答怎么办。工具

                         c.本次session是否须要保留？post

MQ的开发流程

    1.让应用程序与队列管理器连接，经过MQconnect调用来进行此连接。

    2.使用MQOpen调用为输出打开一个队列

    3.应用程序使用MQPut调用将其数据放到队列上。

    4.调用MQOpen调用打开输入队列

    5.使用MQGet从队列上接收数据

 

安装步骤。（此处为转载文章，做者已经证明全部步骤。）

 

Windows下 WebSphere MQ
服务端的安装：
（ 1）把WebSphere MQ
Windows版服务器CD-ROM插入CD-ROM驱动器。
（ 2）若是安装了自动运行，那么会启动安装进程。若是不启动，则双击CD-ROM上的根目录中的Setup图标以启动安装程序。
（3）请等待，直到出现"WebSphere MQ
安装启动板"窗口为止。
（4）若是须要更改安装的本地语言，单击"选择语言"图标，而后从列表中选择所需的语言。
（5）选择必备软件选项。
选择典型安装后，安装界面上的每一个安装项右边有一个对钩号（表示已安装），反之则为一个叉号（表示尚未安装，若是要装 MQ，则必须先把这些软件装好）。
若是出现了叉号：
1）单击项目左边的 "+"号以显示安装链接；
2）选择要使用的安装源的选项，从如下各项选择：
  • WebSphere MQ CD
  • 因特网
  • 网络


 

（ 6）安装完成时，单击项目左边的"-"符号。
注意：对于定制安装，可能不须要全部的必备软件。
（ 7）安装完全部的必备软件，而后选择"网络先决条件"选项。
（ 8）选择"WebSphere
MQ"安装选项 

（9）选择启动WebSphere
MQ安装程序，而后等待，直到显示了带有欢迎信息的"WebSphere MQ安装"窗口为止。

（10）单击"下一步"按钮继续。

（11）阅读面板上的信息和许可证条款，选择接受，而后单击"下一步"。

（12）若是机器上未安装过此产品的前一个版本，则显示"安装类型"面板。选择但愿的安装类型（通常选择"典型"安装便可），而后单击"下一步"按钮。

（13）"WebSphere
MQ安装"窗口显示"安装WebSphere MQ就绪"信息。该窗口还显示用户选中的安装摘要，单击"安装"开始正式安装。

（ 14）成功安装WebSphere
MQ后，"WebSphere MQ安装"窗口显示如下信息：安装向导成功完成。
（ 15）单击"完成"按钮启动"准备WebSphere
MQ"向导。
安装图示


 


 


 


 


 

 

 


 


 


 


 


 


 


 


 

 

 


 


 


 

应用分析


 

该章节主要内容包括MQ服务端的基本配置，如队列管理器，队列以及通道的创建,
且包含JAVA实现的客户端程序。由此构成一个完整的客户端-服务器的流程。


 

 
服务端配置


 

1）点 "开始"->"全部程序"->"IBM
WebSphere MQ"->"WebSphere MQ 资源管理器"，进入WebSphere MQ
资源管理器界面。以下图所示：


 


图9
服务端配置


 

2）建立名为 "QM_JACK"的队列管理器


 

<1>选中 "队列管理器"->"新建"->"队列管理器"，以下图所示：


 


图10 建立名为"QM_JACK"的队列管理器


 

<2>在队列管理中输入 "QM_JACK"，其余选项默认不变，点"下一步"：


 


图11 在队列管理中输入"QM_JACK"


 

<3>设置队列日志（本步骤采用系统默认设置），点 "下一步"：


 


图12
设置队列日志


 

<4>启动队列管理器，建立服务器链接通道，容许在 TCP/IP上进行队列管理器的远程管理，点击"下一步"：


 


图13 建立服务器链接通道


 

<5>设置队列管理器 QM_JACK的侦听端口：8927（用户能够根据须要自行更改端口号），点击"完成"。


 


图 14
设置队列管理器QM_JACK的侦听端口


 

<6>系统进入等待界面：


 


图 15
系统等待界面


 

<7>队列管理器 QM_JACK建立成功


 


图 16
系统队列管理器QM_JACK建立成功


 

3）在 QM_JACK下建立名为"QUEUE_RECV"和"QUEUE_REPLY"的本地队列（客户能够根据本身的需求随意更改本地队列的名字和数量，这里建立这两个本地队列只是为以后的MQ_Tuxedo项目做准备）：


 


图17 定义本地队列



图18 定义本地队列
设置队列名后其余属性全为系统默认值，点击 "肯定"。
4）在 QM_JACK下建立名为"CNN_JACK"的服务器通道。
图 19
建立服务器链接通道


图20 建立服务器链接通道
通道名称设为 CNN_JACK，其余选项保留为系统默认设置，点击"肯定"。
5）在 MQ服务器端的计算机用户中添加MQ客户端所在计算机的系统用户。好比个人MQ客户端被Suse
Linux下的root用户使用，那么，咱们就须要在MQ的服务端（也就是Windows
xp系统中添加名为"root"的用户）所在的计算机系统中添加名为"root"的用户。具体步骤以下：
<1>点击 "开始"->"控制面板"->"计算机管理"->"系统工具"->"本地用户和组"->"用户"，点右键，选"新用户"，以下图所示：

图21
建立系统用户


 

<2>建立新用户： root（注意：这里的用户名"root"是MQ客户端所在系统的用户名，用户要根据具体状况进行修改）


图22 建立系统用户

随意设置一个有效密码，选中密码永不过时，点击 "建立"。
<3>将新用户加入 mqm组（注意：这里的mqm组是咱们安装完MQ
Server后系统自动建立的）。具体操做以下：

图23
设置系统用户所在组
 
点击 "属性"：
图24 设置系统用户所在组
点击 "添加"：


图25
设置系统用户所在组

输入对象名称： mqm，点击"肯定"：

图26 设置系统用户所在组
root用户被添入 mqm组中：


图27 设置系统用户所在组

 

点击 "应用"，点击"肯定"。
重启机器。至此， MQ服务端的配置完成。
 
客户端实现 　　 JAVA客户端源码
 
复制代码 
import java.io.File;
import java.io.FileInputStream;
import java.io.InputStream;
import java.util.Properties;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
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.MQQueue;
import com.ibm.mq.MQQueueManager;

/**
 * 函数功能： MQjava客户端实现
 */

public class MQClient {

    /**
     * Logger for this class
     */
    private static final Log logger = LogFactory.getLog(MQClient.class);
    private String strExtraSendXmlFileName = "D:\\jndi.properties";
    private static Properties props;

    static {
    props = new Properties();
    props.put("mqHostName", "139.31.89.67");
    props.put("mqPort", "4032");
    props.put("mqCCSID", "1381");
    props.put("mqUserName", "liujx");
    props.put("mqPassword", "linux");
    props.put("mqQManager", "Monitor_Queue_Manager");
    props.put("mqChannel", "Monitor_Conn_Chanel");
    props.put("mqLocalOutQueue", "Q_RECEIVE");
    props.put("mqLocalInQueue", "Q_RECEIVE");

    }

    /**
     * 
     * 函数功能：TODO 主测试方法 <br>
     * 相关参数： <br>
     * 
     * @param args
     *            修改记录： <br>
     */

    public static void main(String[] args) {

    MQClient test = new MQClient();
    // 发送消息
    test.putMsg();
    // 接收消息
    test.getMsg();
    }

    public void putMsg() {
    // MQ发送数据
    try {
        // 创建MQ客户端应用上下文环境
        MQEnvironment.hostname = props.getProperty("mqHostName");
        MQEnvironment.port = Integer.parseInt(props.getProperty("mqPort"));
        MQEnvironment.CCSID = Integer
            .parseInt(props.getProperty("mqCCSID"));
        MQEnvironment.channel = props.getProperty("mqChannel");
        MQEnvironment.userID = props.getProperty("mqUserName");
        MQEnvironment.password = props.getProperty("mqPassword");
        // 链接队列管理器
        MQQueueManager qMgr = new MQQueueManager(
            props.getProperty("mqQManager"));
        int openOptions = MQC.MQOO_OUTPUT | MQC.MQOO_FAIL_IF_QUIESCING;
        // 打开队列
        MQQueue q = null;
        try {
        q = qMgr.accessQueue(props.getProperty("mqLocalOutQueue"),
            openOptions);
        } catch (MQException me) {
        System.out.println("打开队列出现通信异常" + me.getMessage() + "\n");
        return;
        }
        InputStream fins = new FileInputStream(new File(
            strExtraSendXmlFileName));
        byte[] data = new byte[fins.available()];
        fins.read(data);
        fins.close();
        MQMessage msg = new MQMessage();
        msg.write(data);
        // 放入消息
        q.put(msg);
        System.out.println("客户端发送数据包成功..");
        // 关闭队列
        q.close();
        // 断开队列管理器链接
        qMgr.disconnect();
    } catch (MQException e) {
        if (logger.isDebugEnabled())
        logger.debug(e.getMessage());
        e.printStackTrace();
    } catch (Exception e) {
        if (logger.isDebugEnabled())
        logger.debug(e.getMessage());
        e.printStackTrace();
    }
    }

    /**
     * 
     * 函数功能：TODO 获取数据 <br>
     * 修改记录： <br>
     */
    public void getMsg() {
    // MQ接收数据
    try {
        // 创建用上下文环境
        MQEnvironment.hostname = props.getProperty("mqHostName");
        MQEnvironment.port = Integer.parseInt(props.getProperty("mqPort"));
        MQEnvironment.CCSID = Integer
            .parseInt(props.getProperty("mqCCSID"));
        MQEnvironment.channel = props.getProperty("mqChannel");
        MQEnvironment.userID = props.getProperty("mqUserName");
        MQEnvironment.password = props.getProperty("mqPassword");
        // 创建队列管理器
        MQQueueManager qMgr = new MQQueueManager(
            props.getProperty("mqQManager"));
        int openOptions = MQC.MQOO_INPUT_AS_Q_DEF
            | MQC.MQOO_FAIL_IF_QUIESCING;
        // 打开队列
        MQQueue q = qMgr.accessQueue(props.getProperty("mqLocalInQueue"),
            openOptions);
        MQGetMessageOptions mgo = new MQGetMessageOptions();
        mgo.options |= MQC.MQGMO_NO_WAIT;
        // 构造返回消息
        MQMessage msg = new MQMessage();
        if ((msg = fetchOneMsg(q)) != null) {
        byte[] xmlData = new byte[msg.getDataLength()];
        msg.readFully(xmlData);
        logger.info(new String(xmlData));
        System.out.println("接收服务器端返回数据包成功..\n接收数据为:\n"
            + new String(xmlData));
        }
        // 关闭队列
        q.close();
        // 断开队列管理器
        qMgr.disconnect();
    } catch (MQException e) {
        logger.error(e);
        e.printStackTrace();
    } catch (Exception e) {
        logger.error(e);
        e.printStackTrace();
    }
    }

    /**
     * 
     * 函数功能：TODO 从队列中取出消息 <br>
     * 相关参数： <br>
     * 
     * @param q
     * @return
     * @throws Exception
     *             修改记录： <br>
     */
    private static MQMessage fetchOneMsg(MQQueue q) throws Exception {
    MQGetMessageOptions mgo = new MQGetMessageOptions();
    mgo.options |= MQC.MQGMO_NO_WAIT;
    MQMessage msg = new MQMessage();
    try {
        // 获取消息
        q.get(msg, mgo);
    } catch (MQException e) {
        return null;
    }
    return msg;
    }
}
复制代码

 

 

 

出处：https://www.cnblogs.com/swugogo/p/5917677.html

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