Комментарии пользователя Сергей Кореневский

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

Сергей Кореневский @Dier_Sergio_Great Автор вопроса

Значит:
имеется 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тему скрипту клиентом.

Войдите на сайт