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

背景

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

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

要實現進程間共享數據,咱們能夠使用第三方的 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();
相關文章
相關標籤/搜索