配置和使用WebSphere MQ
A.设置环境变量
在shell中执行MQ的控制命令:
ctrmqm
strmqm
若识别这些命令,则说明PATH环境变量已配置好了;
若提示找不到命令,则说明需配置Linux环境变量,指定MQ的bin路径到PATH:
可选择修改系统的环境变量(/etc/profile文件,对全部用户可见),
或只修改用户mqadmin的环境变量(/var/mqm/.bash_profile,只对当前用户可见。
下面列出前者的修改方式:
vi /etc/profile
切换到插入模式,在文件尾部加入以下内容:
export PATH=${PATH}:/opt/mqm/bin:/opt/mqm/samp/bin
export
CLASSPATH=${CLASSPATH}:/opt/mqm/java/lib/com.ibm.mq.jar:/opt/mqm/samp/wmqjava/samples
其中/opt/mqm为MQ的安装路径,若安装路径不是这个,替换之。
保存退出 :wq
重启系统后,shell中就可执行MQ控制命令了。
B.MQ服务器单机测试
任务:MQ服务器本地发送和收取消息
1.创建名为 QM_APPLE 的缺省队列管理器
shell命令:
crtmqm -q QM_APPLE
2.启动此队列管理器
shell命令:
strmqm QM_APPLE
3.使用 MQSC(MQ服务器控制台)创建本地队列
shell命令:
runmqsc QM_APPLE //启动MQSC
define qlocal (Q1) //定义本地队列
end //退出控制台
4.将测试消息放入本地队列
shell命令:
amqsput Q1 QM_APPLE //调用MQ内置样本程序向Q1队列放入消息
此时屏幕显示:
Sample AMQSPUT0 start
target queue is Q1
输入消息文本(一行或多行),然后按 Enter 键两次。此时屏幕显示:
Sample AMQSPUT0 end
现已创建了测试消息并将其放入本地队列。
5.从本地队列获取消息
shell命令:
amqsget Q1 QM_APPLE //调用MQ内置样本程序向Q1队列放入消息
此时会屏幕显示:
Sample AMQSGET0 start
message <***> //×××为消息内容
现已成功获取消息。
C.两台MQ服务器消息通信测试
前提:假如有两台MQ服务器:A和B,服务器B的IP为192.168.222.132
A已建立队列管理器QM_APPLE和本地队列LQA;
B已建立并启动队列管理器QM_ORANGE和本地队列LQB;
任务:实现服务器A向服务器B发送一条消息,服务器B接收并读取该条消息。
1.服务器A定义传输队列和远程队列
shell命令:
runmqsc QM_APPLE //启动MQSC
define qlocal (TQA) usage (xmitq)
define qremote (RQA) rname (LQB) rqmname(QM_ORANGE) xmitq (TQA)
//定义远程队列:RQA-远程队列名称,QM_ORANGE-远程队列管理器,LQB-远程队列管理器的本地队列,TQA-本地传输队列
end
2.服务器B定义接收方消息通道和侦听器
shell命令:
runmqsc QM_ORANGE //启动MQSC
define channel (QM_ORANGE.QM_APPLE) chltype (RCVR) trptype (TCP) //定义接收方消息通道
define listener (LSR.QM_ORANGE)TRPTYPE(TCP) PORT(1414) //定义侦听器,需保证TCP端口1414没被其他程序使用,否则使用其他端口
start listener (LSR.QM_ORANGE) //启动侦听器
end
3.服务器A创建发送方消息通道,并启动
shell命令:
runmqsc QM_APPLE
//启动MQSC
define channel(QM_APPLE.QM_ORANGE) chltype(sdr) conname('192.168.222.132(1414)') xmitq(TQA) trptype(tcp)
//定义发送方消息通道
start channel (QM_APPLE.QM_ORANGE)
//启动发送方消息通道
end
4.服务器A放入测试消息
shell命令:
amqsput RQA QM_APPLE //调用MQ内置样本程序向远程队列RQA放入消息
此时屏幕显示:
Sample AMQSPUT0 start
target queue is RQA
输入消息文本(一行或多行),然后按 Enter 键两次。
此时屏幕显示:
Sample AMQSPUT0 end
已将测试消息放入远程队列。
5.服务器B接收并获取测试消息
shell命令:
amqsget LQB QM_ORANGE //调用MQ内置样本程序向Q1队列放入消息
此时会屏幕显示:
Sample AMQSGET0 start
message <***> //×××为消息内容
已成功获取测试消息。
D.客户机-服务器通信测试
任务:客户机向服务器发送和收取消息。
1.服务器设置
(假设服务器已建立队列管理器QM_APPLE)
shell命令:
runmqsc QM_APPLE //启动MQSC
define qlocal (LQA) //定义本地队列
define channel(CLIENT.QM_APPLE) chltype(SVRCONN) trptype(TCP) mcauser('mqadmin')
//定义服务器连接通道,mqadmin为客户机映射到的服务器本地MQ用户
define listener (LSR.QM_APPLE)TRPTYPE(TCP) PORT(1414)
//定义侦听器,需保证TCP端口1414没被其他程序使用,否则使用其他端口
start listener (LSR.QM_APPLE) //启动侦听器
end
服务端设置完毕。
2.客户机设置
(假设客户机为Linux系统,已安装MQ客户端)
shell命令:
vi $HOME/.bash_profile
设置环境变量PATH和MQSERVER,将下列文本添加至文件末尾:
export PATH=${PATH}:/opt/mqm/bin:/opt/mqm/samp/bin
export MQSERVER=CLIENT.QM_ORANGE/TCP/'hostname'; export MQSERVER
注销并重新登录以使更改生效。
3.客户机放入消息到服务器队列
shell命令:
amqsputc LQA QM_APPLE
//调用MQ内置样本程序,连接远程MQ服务器,并向服务器队列放入消息
具体过程省略。
4.客户机从服务器队列获取消息
shell命令:
amqsgetc LQA QM_APPLE
//调用MQ内置样本程序,连接远程MQ服务器,并从服务器队列获取消息
具体过程省略。
至此,完成WebSphere MQ的配置和基本功能使用。
相关推荐
作为MQ系列产品的基石,WebSphere MQ为不同系统间的通信提供了强大的支持,确保了企业应用之间的稳定、高性能和可靠的通讯。 1. **消息中间件概念**:消息中间件是连接分布式系统的一种软件,它通过消息队列进行...
下面是对 IBM WebSphere MQ 的入门教程的总结,涵盖了 WebSphere MQ 的原理、体系结构、重要特点和应用场景等方面的知识点。 中间件的概念和优点 中间件是一种软件系统,用于连接不同的应用程序,实现它们之间的...
IBM WebSphere MQ 技术白皮书是 IBM 公司发布的一份技术白皮书,旨在介绍 IBM WebSphere MQ 产品的技术特性、架构和价值。下面是根据白皮书的内容生成的相关知识点。 概述 在概述部分,白皮书介绍了 IBM WebSphere...
本教程旨在指导用户在Windows系统上安装和使用IBM WebSphere MQ v6.0。 **安装先决条件** 在安装MQ之前,需要满足以下硬件和软件要求: 1. **硬件环境**:至少需要一台基于32位Intel处理器的IBM PC兼容机,支持...
【配置IBM WEBSPHERE MQ触发器】是IBM企业级消息中间件产品中的一项重要功能,它允许用户在消息进入或离开队列时自动执行特定的操作,例如启动应用程序、执行脚本或者更新数据库。这一特性使得MQ系统能更好地与业务...
在IT行业中,IBM WebSphere MQ(也称为IBM MQ)是一种广泛使用的中间件,它允许应用程序在不同的网络协议、操作系统和硬件之间可靠地交换消息。在这个“Java下操作IBM Websphere MQ的项目案例”中,我们将探讨如何...
【标题】:“Websphere MQ入门教程-使用IBM Websphere MQ” 【正文】: IBM WebSphere MQ(原名MQSeries)是IBM提供的一款企业级的消息中间件产品,它允许不同应用程序、系统和网络在不同时区和平台之间交换消息。...
IBM Websphere MQ是IBM公司开发的一款消息队列中间件,旨在提供一个可靠的异步通信机制,实现不同应用程序之间的数据交换和集成。下面是该教程的知识点总结: 中间件的概念和优点 中间件是一种特殊的软件系统,它...
IBM WebSphere MQ 8.0 linux 安装包 part1
在IBM WebSphere MQ中,消息持久性的属性通常由消息头MQMD(MQ Message Descriptor)中的DefPersistence域来定义,它主要有三种取值,但实际上只有两种有效值,即持久(MQPER_PERSISTENT)和非持久(MQPER_NOT_...
IBM websphereMQ 8.0.0.5 lib包; IBM\WebSphere MQ\java\lib下的文件 文件列表: com.ibm.mq.jms.Nojndi.jar com.ibm.mq.pcf.jar com.ibm.mq.allclient.jar com.ibm.mq.postcard.jar com.ibm.mq.axis2.jar ...
在本文中,我们将深入探讨如何使用C#编程语言与IBM WebSphere MQ进行交互,实现消息的发送和接收。IBM WebSphere MQ(前身为MQSeries)是一种企业级的消息中间件,它提供了一种可靠且可扩展的方式,使得应用程序可以...
IBM提供了一系列的管理工具,如WebSphere MQ Explorer、WebSphere MQ Administrator和WebSphere MQ Command Line Processor(mqsc),帮助管理员监控、配置和管理WebSphere MQ环境。 ## 9. API和编程接口 WebSphere...
### 在IBM WebSphere 6.1中配置IBM MQ并通过JMS验证的方法 #### 一、配置概述 在本文档中,我们将详细介绍如何在IBM WebSphere 6.1中配置IBM MQ,并通过Java消息服务(JMS)进行验证的过程。IBM MQ是一种高级的...
IBM WebSphere MQ(旧称MQSeries)是一款由IBM公司开发的企业级消息中间件,它允许应用程序之间通过网络发送和接收消息,确保数据的可靠传输。在Java开发环境中,与IBM WebSphere MQ进行交互通常需要使用特定的Java ...
在文件系统中定位并删除对应文件,例如在路径`WebSphereMQ\Qmgrs\QM!02\queues\QL!B\Q`下。 - 显示队列QL.B的属性以确认其仍然存在但已损坏: `display queue(QL.B)` - 浏览队列QL.B,验证队列已损坏: `...
IBM WebSphere MQ 8.0 linux 安装包 part3,IBM WebSphere MQ 8.0 linux 安装包 part3
在v6.0版本中,IBM WebSphere MQ进一步提升了性能、可扩展性和安全性,以满足日益复杂的企业需求。 1. **消息传递模型**: - IBM WebSphere MQ基于发布/订阅和队列模型,支持点对点和广播通信模式。在v6.0中,这两...
6. **案例研究与实践** (第6章): 通过具体的案例来展示WebSphere MQ在实际应用场景中的配置和使用方法。 ### 三、关键技术点解析 #### 1. WebSphere MQ简介 - **产品定位**: WebSphere MQ是一款企业级的消息...