Как в PHP из одного потока(сессии) вызвать скрипт другого потока(сессии) скрипт другого клиента?

Question

[Сергей Кореневский]

Требуется передавать данные клиенту используя SSE в PHP полученные в API в другом потоке другой сессии.
Как передавать данные между сессиями(потоками)?

Comments

[Сергей Соколов]

никак.
Но можно продумать асинхронную архитектуру, события. Посмотрите, что умеет Swoole.

Answer 1

[rPman]

Используй семафоры, там есть инструменты по отсылке сообщений между процессами машины, на linux всегда включена, на windows сборках к к сожалению нет

Иначе реализуй на основе сокетов, тогда будет пофиг на какой машине в кластере работает процесс

Comments

[Сергей Кореневский]

Спасибо большое за помощь. Это то что нужно.
Но есть проблемка. Семафор возвращает ошибку, а коды ошибок ни где нету.
Вы прежде имели дело с ошибками семафоров?

[rPman]

кусок кода и ошибку в студию, зачем дополнительно спрашивать то?

[Сергей Кореневский]

Значит:
имеется 3 скрипта на сервере,
1й. API- который сохраняет в базу значения и передает в семафор события.
2й. Обычный сайт с графиками. Графики грузятся при обновлении страницы.
-После загрузки страницы сайта, JS запрашивает на сервере SSE поток.
3й. Скрипт который передает через SSE поток на страницу клиента сообщения полученные из симаффора.
PS что SSE, что семафор я начал использовать первый раз. Вот в песочнице грязный код, чтобы хоть чтото заработало.
КОД:
1й:

$id =6; // - это id  графика 
$stream_id = msg_get_queue($id);
 			$result['remove'] = msg_remove_queue($stream_id);
 			$stream_id = msg_get_queue($id);
$message = "{\"DevID\":$id,\"DevEUI\":\"$DevEUI\",\"payload_hex\":\"$payload_hex\"}"; // какой то JSON
$result['send'] = msg_send($stream_id, $id, $message, false, true, $err); 
$result['stat'] = msg_stat_queue($stream_id);

3й:

date_default_timezone_set('Europe/Moscow'); //  "America/New_York"	'Europe/Moscow'
	header('Cache-Control: no-cache');
	header("Content-Type: text/event-stream");
	header("Connection: keep-alive");
$queue_id = msg_get_queue($id);// Такой же ID как из 1го скрипта, тот же ID для того же графика.
while (1) {
	if (msg_receive ($queue_id, 1, $id, 16384, $message, false, 0, $msg_error)) {
		if (in_array(strtolower($message), 'quit','exit'))
			break;	 
		echo "id: $id\n";
		echo "data: $message\n";
		echo "\n"; 
	} else { 
		echo "data: $msg_error\n";
		echo "\n"; 
		break; 
	}
	ob_end_flush();
	flush(); 
	if(connection_aborted()) 
		break; 
}
msg_remove_queue ($queue_id);

2й JavaScript:

let url = `/modules/mod_axitech/event.php?DevID=${devid}`; 
        const evtSource = new EventSource(url);
        
        evtSource.onmessage = function(event){
            console.log('MessageON!!!! \n',event.data,event); 
        };
        evtSource.onerror = function(err){console.log('error',err);}
        evtSource.onopen = function(open){console.log('open',open);}

В общем при вызове 1го скрипта
в клиенте в консоли JS сыпится сразу 3лога.
OPEN, Message, Error.
Причем Message скрипт получает 43. т.е. это сообщение ошибки при неудачном выполнении msg_send.
В 1ом скрипте есть ошибка как Вы заметили, я там 2 раза указал оператор msg_get_queue(). а между ними указал оператор msg_remove_queue();
.
Так вот если я не буду указывать msg_get_queue() и msg_remove_queue() дополнительно.
То клиент вообще не получает сообщений.
А если укажу эти 2 функции то клиент получает сообщение 43 , ошибку и открытие каждый раз при вызове msg_send семафора ,
1. Не понятно что за ошибка семафора 43.
2.Не понятно каким образом msg_remove_queue() очистка семафора влияет на новое открытие потока.
3.Не понятно какой инструмент использовать в браузере чтобы видеть состояние подключения к 3тему скрипту клиентом.

[rPman]

ошибка 43 это EIDRM Identifier removed
тут ее описали (не про php но на си у семафоров идентичное поведение)

Слушать очередь должен процесс, не закрывающийся постоянно, т.е. работающий как служба

p.s. семафоры считается хардкором, но идеологически верным подходом
я ожидал что ты выберешь более простой и привычный подход с сокетами

[Сергей Кореневский]

rPman, не умею их использовать. Но при мыслях с чего же начать, мне попался SSE.
Но даже без семафоров, SSE отлично работает у меня.
.
Но подскажите пожалуйста, когда я НЕ удаляю //msg_remove_queue() метку симафора, то тогда симафор вообще перестает получать сообщения.
Может я в коде чтото не так обозначил и определил?

[rPman]

Советую поиграть с очередями сообщений, на простейших тестовых скриптах (прямо копируй из документации)... основная идея
- есть очередь (с указанным идентификатором), в нее все процессы могут отправлять и могут читать сообщения, после чтения сообщения, оно удаляется из очереди, очередь FIFO.
- можно читать сообщения определенного типа (второй параметр msg_receive) пропуская остальные (поведение по умолчанию)
- очередь живет даже если все процессы, использующие ее, закрылись (т.е. можно положить сообщение, закрыть процесс, потом открыть и прочитать его, есть лимиты), чтобы убить очередь, ее нужно msg_remove_queue но любой процесс, попытавшись ее прочитать, создаст ее пустую в момент вызова msg_get_queue (т.е. сообщения в очереди будут лежать до выключения компьютера, учитывай это)
- можно не ждать сообщения в очередь (флаг MSG_IPC_NOWAIT у msg_receive) т.е. определить, есть ли сообщения указанного (или любого, не равного указанному, MSG_EXCEPT флаг) в очереди.

Семафоры хороши, если тебе надо сообщать что то, не ожидая ответа, и хотя ответы можно симулировать через тип сообщений, используя его как идентификатор процесса, но лучше так не делать, размер очереди маленький, для двунаправленных сообщений лучше сокеты использовать, подняв свой сервер (почему я и говорю, если в проекте есть websocket сервер, его можно использовать и внутри бакэнда).

[Сергей Кореневский]

rPman, Последовал Вашему совету отделить мух от котлет.
выяснил что имеется ошибка в SSE.
может поможете?
Почему сообщения сервера приходят только когда возникает ошибка соединения?