Context 協(xié)程上下文

Context用于在協(xié)程中存儲和傳遞上下文信息，例如數(shù)據(jù)庫連接、用戶信息等。每個協(xié)程有自己的上下文，不同協(xié)程之間的上下文是隔離的。

注意
底層自動識別驅(qū)動類型，僅支持Swoole/Swow/Fiber驅(qū)動

提示
此特性需要 workerman>=5.1.0

<?php

use Workerman\Connection\TcpConnection;
use Workerman\Coroutine;
use Workerman\Coroutine\Context;
use Workerman\Events\Swoole;
use Workerman\Protocols\Http\Request;
use Workerman\Worker;
require_once __DIR__ . '/vendor/autoload.php';

$worker = new Worker('http://0.0.0.0:8001');

$worker->eventLoop = Swoole::class; // Or Swow::class or Fiber::class

$worker->onMessage = function (TcpConnection $connection, Request $request) {
    // 在當(dāng)前協(xié)程設(shè)置context數(shù)據(jù)
    Context::set('user_info', ['id' => 1, 'name' => 'name']);
    // 新建協(xié)程
    Coroutine::create(function () use ($connection) {
        // 協(xié)程間context數(shù)據(jù)是隔離的，所以新協(xié)程里獲取的是null
        $userInfo = Context::get('user_info');
        var_dump($userInfo); // 輸出null
    });
    // 獲取當(dāng)前協(xié)程的context數(shù)據(jù)
    $userInfo = Context::get('user_info'); // 得到['id' => 1, 'name' => 'name']
    $connection->send(json_encode($userInfo));
};

Worker::runAll();

接口說明

interface ContextInterface
{
    /**
     * 獲取上下文中的值
     */
    public static function get(string $name, mixed $default = null): mixed;

    /**
     * 設(shè)置上下文中的值
     */
    public static function set(string $name, mixed $value): void;

    /**
     * 檢查上下文中是否存在指定名稱的值
     */
    public static function has(string $name): bool;

    /**
     * 重置當(dāng)前協(xié)程上下文
     */
    public static function reset(?ArrayObject $data = null): void;

    /**
     * 銷毀上下文
     */
    public static function destroy(): void;

}