//msg_remove_queue() метку симафора, то тогда симафор вообще перестает получать сообщения.
$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);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);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);}
. А что такое PHP -S? это запуск из консоли чтоли?