Python使用模块pymqi连接IBM MQ

前言

Python连接使用IBM MQ需要使用模块pymqi，但是安装这个模块又需要装IBM MQ客户端才能安装成功。

安装pymqi模块方法

1.下载部署IBM MQ 客户端服务,此次使用版本：IBM_MQ_9.0.5.0_LINUX_X86-64.tar.gz

2.tar -zxvf MQ tar包

3.开权限./mqlicense.sh -accept

4.安装WEBSphere for Linux服务器(按照如下顺序)

rpm -ivh MQSeriesRuntime-(版本号).rpm
rpm -ivh MQSeriesSDK-(版本号).rpm
rpm -ivh MQSeriesServer-(版本号).rpm
#7.安装WEBSphere MQ for Linux客户端：
rpm -ivh MQSeriesClient-(版本号).rpm
#8.安装WEBSphere MQ样本程序：
#rpm -ivh MQSeriesSamples-(版本号).rpm

5.添加环境变量

vim ~/.bashrc
# 添加以下内容
# 保证永久有效
export LD_LIBRARY_PATH=$LD_LIBRARY_PATH:/opt/mqm/lib64 

# 立即生效
source ~/.bashrc 

6.在线安装pymqi

pip install pymqi

ps:离线安装pymqi

# 下载psycopg2离线包，地址：https://pypi.org/project/pymqi2/
# 下载源码tar包，编译安装
# 步骤如下：
tar -zxvf pymqi-1.12.10.tar.gz
cd pymqi-1.12.10
python setup.py build
python setpy.py install

以下是一个简单测试验证的示例:

import pymqi

# 连接到 MQ 队列管理器
queue_manager = "QM_NAME"
channel = "CHANNEL_NAME"
host = "HOST_NAME"
port = "PORT_NUMBER"
conn_info = "%s(%s)" % (host, port)

qmgr = pymqi.connect(queue_manager, channel, conn_info)

# 打开队列
queue = pymqi.Queue(qmgr, "QUEUE_NAME")

# 发送消息到队列
message = "Hello, MQ!"
put_options = pymqi.MD()
queue.put(message, put_options)

# 关闭队列和连接
queue.close()
qmgr.disconnect()