Linux PHP System V 消息队列实战：创建、发送与接收

Aria

发布时间：2026-10-13| 2人浏览过

原创

在 Linux 服务器环境中，利用 PHP 的 System V IPC（进程间通信）扩展可以实现高效的进程间消息传递。本文将通过具体的代码示例，解析如何使用 msg_get_queue、msg_send 和 msg_receive 等函数构建一个完整的消息队列处理流程。

准备工作与核心概念

System V 消息队列是 Linux 内核提供的一种进程间通信机制，允许不同进程通过唯一的队列 ID 交换数据。在 PHP 中，使用前需确保环境支持且扩展已开启。最关键的初始步骤是获取或创建一个队列标识符。

第1步：获取队列标识符并确认存在性

首先需要为队列指定一个唯一的键值（Key）。通常使用 ftok() 函数根据文件路径和类字符生成整数键值。

#根据路径和后缀创建一个id
$key = ftok(__DIR__, 'R');
#获取队列中的消息
$q = msg_get_queue($key);

此步骤用于建立程序与内核队列的连接。若队列不存在，可能需要先创建（取决于具体配置和调用方式，msg_get_queue 通常会返回资源ID）。在测试阶段，为了重新初始化环境，可以先删除旧队列：

#删除队列（需谨慎执行，以免误删其他进程使用的队列）
if ($q) {
    msg_remove_queue($q);
}

消息发送逻辑

向队列写入数据时，必须遵循队列容量限制，并处理可能的阻塞情况。

第2步：循环发送消息数据

使用 msg_send() 将数据推入队列。该函数包含多个参数，需注意序列化设置与非阻塞模式的选择：

$errorcode = 0;
for($i=0; $i<100;$i++)
{
  /**
   * 向队列里添加消息 
   * resource $queue , int $msgtype , mixed $message [, bool $serialize = true [, bool $blocking = true [, int &$errorcode ]]]
   */
  // 参数说明：
  // 1. $q: 队列资源
  // 2. 111: 消息类型（Type），接收方可根据此类型过滤
  // 3. array('a'=>1): 实际发送的数据（会自动序列化）
  // 4. true: 是否序列化（默认true，发送数组/对象必须开启）
  // 5. false: 是否阻塞。设为false，当队列满时直接报错而非等待
  // 6. $errorcode: 返回错误代码
  $flag = msg_send($q, 111, array('a'=>1), true, false , $errorcode);
  var_dump($errorcode);
}

关键注意点：

消息类型（$msgtype）：发送方指定，接收方可根据此类型选择性接收。
非阻塞模式（$blocking=false）：设置为非阻塞可避免程序挂起。若队列为满且未设为非阻塞，程序会进入等待状态；设为非阻塞时，若失败则会在 $errorcode 中返回 MSG_EAGAIN。

消息接收与状态监控

接收端负责从队列中提取数据，并可随时监控队列的健康状态。

第3步：监听并接收单条消息

/**
resource $queue , int $desiredmsgtype , int &$msgtype , int $maxsize , mixed &$message [, bool $unserialize = true [, int $flags = 0 [, int &$errorcode ]]] 
*/
$data = msg_receive($q, 0, $type, 200, $msg);
var_dump($data); // 返回值通常是 boolean，表示操作是否成功
echo "\n";
var_dump($type); // 实际接收到的消息类型
echo "\n";
var_dump($msg);  // 反序列化后的实际内容
echo "\n";

接收参数详解：

$desiredmsgtype (0)：设为 0 表示接收队列头部的任何类型消息；设为正整数则仅接收特定类型的消息。
$maxsize (200)：定义接收缓冲区的最大字节数。如果消息长度超过此值，操作将失败。
$flags：常用的有 MSG_IPC_NOWAIT（队列空则立即返回不阻塞）。

第4步：检查队列状态

调试时，了解队列当前的填充量、字节数和权限非常重要：

#获取队列的状态信息
$status = msg_stat_queue($q);
print_r($status);

常见的输出结构如下，关注 [msg_qnum]（当前消息数）和 [msg_qbytes]（最大字节限制）：

Array
(
    [msg_perm.uid] => 1015
    [msg_perm.gid] => 100
    [msg_perm.mode] => 438
    [msg_stime] => 0
    [msg_rtime] => 0
    [msg_ctime] => 1411830331
    [msg_qnum] => 0       # 当前待处理消息数量
    [msg_qbytes] => 65536 # 队列最大容量
    [msg_lspid] => 0
    [msg_lrpid] => 0
)