Swoole 中使用 Table 內存表實現進程間共享數據

背景

在多進程模式下進程之間的內存是相互隔離的，在一個工做進程中的全局變量和超全局變量，在另外一個工做進程中是沒法讀取和操做的。

若是隻有一個工做進程，則不存在進程隔離問題，能夠使用全局變量和超全局變量。

要實現進程間共享數據，咱們能夠使用第三方的 Redis 內存數據庫或 Swoole 內置的 Table 共享內存來實現。

Table 的優點

• 性能強悍，單線程每秒可讀寫 200 萬次；
• 應用代碼無需加鎖，Table 內置行鎖自旋鎖，全部操做均是多線程 / 多進程安全。用戶層徹底不須要考慮數據同步問題；
• 支持多進程，Table 能夠用於多進程之間共享數據；
• 使用行鎖，而不是全局鎖，僅當 2 個進程在同一 CPU 時間，併發讀取同一條數據纔會進行發生搶鎖。

使用示例：

<?php
// 實例化一個佔用的共享內存大小爲1024的內存表
$table = new Swoole\Table(1024);
// 內存表增長3列
$table->column('fd', Swoole\Table::TYPE_INT);
$table->column('reactor_id', Swoole\Table::TYPE_INT);
$table->column('data', Swoole\Table::TYPE_STRING, 64);
$table->create();

$serv = new Swoole\Server('127.0.0.1', 9501);
// 設置數據包分發策略：輪循模式
$serv->set(['dispatch_mode' => 1]);
$serv->table = $table;

$serv->on('receive', function ($serv, $fd, $reactor_id, $data) {
    $cmd = explode(" ", trim($data));

    if ($cmd[0] == 'get') {
        //get self
        if (count($cmd) < 2) {
            $cmd[1] = $fd;
        }
        $get_fd = intval($cmd[1]);
        $info = $serv->table->get($get_fd);
        $serv->send($fd, var_export($info, true) . "\n");
    } elseif ($cmd[0] == 'set') {
        // 使用鏈接的文件描述符做爲key寫入內存表
        $ret = $serv->table->set($fd, array('fd' => $fd, 'reactor_id' => $reactor_id, 'data' => $cmd[1]));
        if ($ret === false) {
            $serv->send($fd, "ERROR\n");
        } else {
            $serv->send($fd, "OK\n");
        }
    } else {
        $serv->send($fd, "command error.\n");
    }
});

$serv->start();