如何将LoadRunner与IBM MQ连接？求详细分步操作指引

一、环境准备 #

• 安装IBM MQ客户端：确保版本与LoadRunner兼容（例如LoadRunner 12.55适配MQ 9.x系列），安装时选择完整客户端组件。
• 配置环境变量：
  • 设置MQ_INSTALL_PATH指向MQ客户端安装目录（如C:\Program Files\IBM\MQ）
  • 将%MQ_INSTALL_PATH%\bin添加到系统PATH变量中
• 获取MQ核心连接参数：队列管理器名称、服务器主机/IP、监听端口、通道名称、目标队列名，以及认证信息（若启用用户认证）

二、LoadRunner 基础配置 #

1. 打开Virtual User Generator（VuGen），新建脚本时选择Custom协议，在协议列表中勾选IBM MQ（若未找到该选项，需重新安装LoadRunner并勾选IBM MQ插件）
2. 进入脚本的Run-time Settings：
   • 导航到Protocols > IBM MQ
   • 确认MQ Client Installation Path已自动识别（或手动指向MQ_INSTALL_PATH）

三、脚本开发分步实现 #

1. 初始化MQ环境 #

调用mq_init()完成MQ客户端环境初始化，需校验返回码：

int rc;
rc = mq_init();
if (rc != 0) {
    lr_error_message("MQ初始化失败，错误码: %d", rc);
    return -1;
}

2. 定义连接参数 #

构造队列管理器连接所需的通道、主机端口等信息：

// 替换为实际MQ参数
char qmgr_name[] = "PROD_QMGR";
char channel_name[] = "SVRCONN_CHAN";
char host_port[] = "10.0.0.5:1414";
char mq_user[] = "mq_test";
char mq_pwd[] = "Test@123";

// 初始化通道定义
MQCD client_channel_def = {MQCD_CLIENT_CONN_DEFAULT};
strcpy(client_channel_def.ChannelName, channel_name);
strcpy(client_channel_def.ConnectionName, host_port);

// 初始化连接参数
MQCONN_PARAMS conn_params = {MQCONN_PARAMS_DEFAULT};
conn_params.pClientChannelDef = &client_channel_def;
// 若启用用户认证，添加以下两行
strcpy(conn_params.UserId, mq_user);
strcpy(conn_params.Password, mq_pwd);

3. 连接队列管理器 #

使用mq_connx()建立与队列管理器的连接：

MQHCONN hConn; // 连接句柄

rc = mq_connx(qmgr_name, &conn_params, &hConn);
if (rc != MQRC_NONE) {
    lr_error_message("连接队列管理器失败，错误码: %d，描述: %s", rc, mq_strerror(rc));
    mq_terminate();
    return -1;
}
lr_output_message("成功连接队列管理器: %s", qmgr_name);

4. 打开目标队列 #

调用mq_open()打开指定队列，设置合适的打开选项（输入/输出权限）：

MQHOBJ hObj; // 队列句柄
char queue_name[] = "TEST_QUEUE";
MQOD od = {MQOD_DEFAULT};
strcpy(od.ObjectName, queue_name);

// 打开队列：允许输入（接收）和输出（发送）
rc = mq_open(hConn, &od, MQOO_INPUT_AS_Q_DEF | MQOO_OUTPUT, &hObj);
if (rc != MQRC_NONE) {
    lr_error_message("打开队列失败，错误码: %d，描述: %s", rc, mq_strerror(rc));
    mq_disc(hConn);
    mq_terminate();
    return -1;
}
lr_output_message("成功打开队列: %s", queue_name);

5. 发送消息到MQ #

构造消息结构，通过mq_put()发送消息：

MQMD md = {MQMD_DEFAULT};
MQPMO pmo = {MQPMO_DEFAULT};
char send_msg[] = "LoadRunner MQ测试消息";

md.Format = MQFMT_STRING; // 消息格式为字符串
pmo.Options = MQPMO_NO_SYNCPOINT; // 不使用事务

rc = mq_put(hConn, hObj, &md, &pmo, strlen(send_msg)+1, send_msg);
if (rc != MQRC_NONE) {
    lr_error_message("发送消息失败，错误码: %d，描述: %s", rc, mq_strerror(rc));
    mq_close(hConn, hObj, MQCO_NONE);
    mq_disc(hConn);
    mq_terminate();
    return -1;
}
lr_output_message("成功发送消息: %s", send_msg);

6. 接收MQ消息 #

使用mq_get()从队列接收消息，可设置等待时长：

MQGMO gmo = {MQGMO_DEFAULT};
char recv_buf[1024] = {0};
MQBYTE recv_len = sizeof(recv_buf);

gmo.Options = MQGMO_NO_SYNCPOINT | MQGMO_WAIT;
gmo.WaitInterval = 30000; // 等待30秒，超时返回

rc = mq_get(hConn, hObj, &md, &gmo, recv_len, recv_buf, &recv_len, NULL);
if (rc != MQRC_NONE) {
    lr_error_message("接收消息失败，错误码: %d，描述: %s", rc, mq_strerror(rc));
} else {
    lr_output_message("成功接收消息，长度: %d，内容: %s", recv_len, recv_buf);
}

7. 资源清理 #

依次关闭队列、断开连接、终止MQ环境：

// 关闭队列
rc = mq_close(hConn, hObj, MQCO_NONE);
if (rc != MQRC_NONE) {
    lr_error_message("关闭队列失败，错误码: %d", rc);
}

// 断开与队列管理器的连接
rc = mq_disc(hConn);
if (rc != MQRC_NONE) {
    lr_error_message("断开连接失败，错误码: %d", rc);
}

// 终止MQ客户端环境
mq_terminate();

四、调试与常见问题排查 #

• 错误码解析：使用mq_strerror(rc)获取错误的文本描述，辅助定位问题
• MQ通道状态：在MQ服务器端执行DISPLAY CHSTATUS(通道名)命令，确认通道处于RUNNING状态
• 网络连通性：在LoadRunner机器上执行telnet MQ服务器IP 端口，检查端口是否可达
• 认证问题：若启用MQ用户认证，确保脚本中配置的用户名密码拥有队列的访问权限
• 日志排查：查看MQ客户端日志（默认路径%MQ_INSTALL_PATH%\errors），获取更详细的错误信息

内容的提问来源于stack exchange，提问作者GAURAV KAPOOR