背景
在多行程模式下行程之間的記憶體是相互隔離的,在一個作業行程中的全域變數和超全域變數,在另一個作業行程中是無法讀取和操作的,
如果只有一個作業行程,則不存在行程隔離問題,可以使用全域變數和超全域變數,
要實作行程間共享資料,我們可以使用第三方的 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();
轉載請註明出處,本文鏈接:https://www.uj5u.com/houduan/5062.html
標籤:PHP
