PHP 7向Microsoft Message Queuing (MSMQ)发送消息方案求助

方法一：利用PHP COM扩展（Windows环境专属） #

Windows平台下的PHP可以通过COM对象直接调用MSMQ的系统API，前提是PHP已启用com_dotnet扩展（在php.ini中开启extension=com_dotnet）。

代码示例 #

<?php
$queueName = ".\\Private$\\MyTestQueue"; // 目标私有队列路径
try {
    // 初始化队列信息对象
    $queueInfo = new COM("MSMQ.MSMQQueueInfo");
    $queueInfo->PathName = $queueName;

    // 以发送权限打开队列
    $openedQueue = $queueInfo->Open(2, 0); // MQ_SEND_ACCESS = 2, MQ_DENY_NONE = 0

    // 构造消息对象
    $message = new COM("MSMQ.MSMQMessage");
    $message->Body = "来自PHP 7的测试消息内容";
    $message->Label = "PHP测试消息标签";

    // 发送消息到队列
    $message->Send($openedQueue);

    // 关闭队列连接
    $openedQueue->Close();

    echo "消息发送成功";
} catch (Exception $e) {
    echo "发送失败: " . $e->getMessage();
}
?>

注意事项 #

• 目标队列需提前创建（可通过「计算机管理」→「服务和应用程序」→「消息队列」手动创建）
• 运行PHP的进程用户（如IIS应用池账户、CLI执行用户）需拥有队列的「发送消息」权限
• 仅支持Windows平台的PHP环境

方法二：调用命令行工具（受限环境备选） #

若无法启用COM扩展，可通过调用Windows系统的mqsend.exe命令行工具发送消息，该工具属于Windows资源工具包组件，需提前安装。

代码示例 #

<?php
$queueName = ".\\Private$\\MyTestQueue";
$messageBody = "命令行方式发送的测试消息";
$messageLabel = "命令行测试标签";

// 构造执行命令
$command = "mqsend -q \"{$queueName}\" -l \"{$messageLabel}\" -b \"{$messageBody}\"";

// 执行命令并获取结果
exec($command, $output, $returnCode);

if ($returnCode === 0) {
    echo "消息发送成功";
} else {
    echo "发送失败，错误信息: " . implode("\n", $output);
}
?>

通用注意事项 #

• 生产环境中需补充完善的错误捕获与日志记录逻辑
• 若使用IIS部署PHP，需确保应用池身份对目标队列有足够权限
• PHP 7.0+版本对COM扩展的兼容性良好，无需额外版本适配

内容的提问来源于stack exchange，提问作者Bhowmik Sanad