Как сделать глобальный массив с доступом из нескольких потоков в PHP?

Question

[RigelGL]

Доброго времени суток.
Я в данный момент разрабатываю веб сервер на PHP 7.4.11, использующий сокеты и HTTP протокол для получения сообщений от Android-клиента.
Для обработки сокетов и запросов от Android-клиента использую библиотеку Workerman, сайт работает на Apache 2.4.

При получении сообщения от Android'а нужно отправить сообщения через websocket'ы клиентам на сайте.
Имеется файл global_vars.php со следующим содержанием:

<?php

namespace global_vars;

class Globals {
    private static $connections = array();

    public static function add($connection) { Globals::$connections[$connection->id] = $connection; }
    public static function remove($connection) { unset(Globals::$connections[$connection->id]); }
    public static function get($id) { return Globals::$connections[$id]; }

    public static function keys() { return array_keys(Globals::$connections); }
}

При подключении нового сокета я добавляю его в массив соединений:

include_once "global_vars.php";
global_vars\Globals::add($connection);

Я ожидаю, что при получении запроса от Android-клиента, который обработается в файле apiServer.php, я смогу получить текущие websocket'ы:

include_once "global_vars.php";
global_vars\Globals::get($target)->send("Message from android");

Однако массив global_vars\Globals::$connections из файла global_vars.php оказывается пуст.

Как решить проблему с массивом? Или для решения моей задачи нужно использовать иную архитектуру сервера?

Дополнительно проверял с инкрементацией счётчика в Globals, и он оказывался уникальным для обоих потоков (wsServer.php и apiServer.php), что весьма странно, так как он был статическим (static public $i = 0).

Answer 1

[Владимир Коротенко]

Попробуйте redis. Возможно он вам подойдёт

Comments

[RigelGL]

В настоящий момент я использую Redis, чтобы получить $target, то есть id websocket'а, в который нужно отправить сообщение.
Redis не хранит PHP объекты, которым является $connection. Мне нужно получить именно объект $connection (чтобы отправить в него сообщение), который помещается в global_vars/Globals::connections при подключении websocket'а.

[Владимир Коротенко]

RigelGL, насколько тяжелые объекты? Возможно ли их быстро сериализовать? Используются ли там нативные дескрипторы. Что то типа сокетов или файлов?

[RigelGL]

Владимир Коротенко, при попытке сериализовать получаю ошибку: Exception: Serialization of 'Closure' is not allowed. Сериализация - точно не то, что мне нужно.

[Владимир Коротенко]

RigelGL, Опять же глупый вопрос у вас PHP стоит как модуль апача или как cgi fcgi ?

[RigelGL]

Владимир Коротенко, как модуль апача.

PHPIniDir "D:/Server/bin/php"
AddHandler application/x-httpd-php .php
LoadModule php7_module "D:/Server/bin/php/php7apache2_4.dll"

[Владимир Коротенко]

RigelGL,
Попробуйте поиграться вот с этим
и желательно выложите конфиг апача
httpd.apache.org/docs/current/mod/mpm_winnt.html

[FanatPHP]

Владимир Коротенко, тут не только вопросы глупые, но и ответ.
слушай, ну ты же не знаешь ни РНР, ни веб-серверы от слова совсем. Недавно просил на пальцах объяснить как работает веб-сервер. Ну зачем пытаться отвечать на вопросы, в которых ты не разбираешься?

Главное человек тебе объясняет, у него объекты которые держат сетевое соединение, а ты все равно продолжаешь тупить. В КАКОЙ РЕДИС ТЫ СОБРАЛСЯ ИХ КЛАСТЬ? КАК ТЫ ВООБЩЕ СОБРАЛСЯ СЕТЕВОЕ СОЕДИНЕНИЕ СЕРИАЛИЗОВАТЬ?
Тебе объясняют что тут отдельная пепяка держит соединение с клиентом, а ты ему все про конфиг апача талдычишь

Answer 2

[MaLuTkA_UA]

Раз вы начали работать с workerman нужно было почитать документацию как и что там делать, и зайти на гит и почитать ответы разработчика на вопросы, там много полезного. Увы ваша реализация на сколько я понял не правильна, так как если запустить воркерман в несколько потоков у вас будут проблемы с поиском соединения, также для того чтобы отправить данные в сокет вам нужно в каждом процессе открыть TCP соединение через которое и будет происходить отправка сообщений, это тоже есть в их документации.