如何为OpenSwoole UDP服务器的on()回调传递额外参数？

在OpenSwoole场景下，完全可以通过以下几种方式替代global，给UDP服务器的Packet回调传递类实例、变量等额外参数：

1. 闭包use语法捕获变量（推荐） #

直接在闭包回调中通过use关键字捕获需要的实例，这是最简洁且常用的方式：

// 初始化swbeanstalk客户端
$beanstalk = new \xpader\swbeanstalk\Client([
    'host' => '127.0.0.1',
    'port' => 11300,
    // 其他配置项
]);

// 创建UDP服务器
$server = new Swoole\Server('0.0.0.0', 9502, SWOOLE_PROCESS, SWOOLE_SOCK_UDP);

// 定义Packet回调，通过use捕获beanstalk实例
$server->on('Packet', function ($server, $data, $clientInfo) use ($beanstalk) {
    // 处理UDP接收的数据
    $jobContent = json_encode([
        'raw_data' => $data,
        'client_info' => $clientInfo
    ]);
    
    // 直接使用捕获的beanstalk实例推送任务
    $beanstalk->put($jobContent);
});

$server->start();

2. 绑定到Server对象的自定义属性 #

将需要传递的实例赋值给$server的自定义属性，在回调中通过服务器对象直接访问：

$beanstalk = new \xpader\swbeanstalk\Client([/* 配置 */]);

$server = new Swoole\Server('0.0.0.0', 9502, SWOOLE_PROCESS, SWOOLE_SOCK_UDP);
// 给server对象添加自定义属性存储beanstalk实例
$server->beanstalkClient = $beanstalk;

$server->on('Packet', function ($server, $data, $clientInfo) {
    // 通过server对象访问beanstalk实例
    $server->beanstalkClient->put(json_encode(['data' => $data]));
});

$server->start();

3. 类封装（适合复杂业务场景） #

把UDP服务、依赖实例都封装到类中，回调作为类的成员方法，直接访问类的属性：

class UdpToBeanstalkService
{
    private $beanstalk;
    private $server;

    public function __construct()
    {
        // 初始化beanstalk客户端
        $this->beanstalk = new \xpader\swbeanstalk\Client([
            'host' => '127.0.0.1',
            'port' => 11300
        ]);

        // 创建UDP服务器
        $this->server = new Swoole\Server('0.0.0.0', 9502, SWOOLE_PROCESS, SWOOLE_SOCK_UDP);
        // 绑定回调为类的成员方法
        $this->server->on('Packet', [$this, 'handleUdpPacket']);
    }

    public function handleUdpPacket($server, $data, $clientInfo)
    {
        // 直接使用类的beanstalk属性推送任务
        $this->beanstalk->put(json_encode([
            'data' => $data,
            'client' => $clientInfo
        ]));
    }

    public function start()
    {
        $this->server->start();
    }
}

// 启动服务
$service = new UdpToBeanstalkService();
$service->start();

多进程场景补充说明 #

如果UDP服务器启用多Worker进程，建议在WorkerStart事件中初始化beanstalk客户端，避免进程间资源竞争：

$server->on('WorkerStart', function ($server, $workerId) {
    // 每个Worker进程初始化独立的beanstalk客户端
    $server->beanstalk = new \xpader\swbeanstalk\Client([/* 配置 */]);
});

$server->on('Packet', function ($server, $data, $clientInfo) {
    $server->beanstalk->put(json_encode(['data' => $data]));
});

内容的提问来源于stack exchange，提问作者Philip Lee