События, отправленные сервером - Event-Stream - Запустить PHP-событие на стороне сервера?

Question

У меня есть панель чата с использованием HTML, CSS, jQuery. Настройте прослушиватель событий без проблем. Настройте php-файл text / event-stream, который без проблем может отправлять сообщения клиенту. Как мне связаться от клиента с этим серверным скриптом, чтобы он передавал сообщение всем пользователям, у которых открыт поток событий, после получения нового сообщения от любого из клиентов? Сервер должен отправлять событие только после получения нового сообщения.

Вот message_sender.php:

header('Content-Type: text/event-stream');
header('Cache-Control: no-cache');

while (1) {
 if ($newMessage){ //How does $newMessage get filled in an already running script?
  echo "id: 1234\n";
  echo "event: ping\n";
  echo 'data: {"newMessage": "' . $newMessage . '"}';
  echo "\n\n";
 }

 ob_flush();
 flush();
 sleep(1);
}

Вот JS:

var evtSource = new EventSource("message_sender.php");

evtSource.onmessage = function(e) {
}

evtSource.addEventListener("ping", function(e) {
 var newElement = document.createElement("li");       
 var obj = JSON.parse(e.data);
 newElement.innerHTML = "ping " + obj.newMessage;
 $('#chat_panel').append(newElement);
}, false);

evtSource.onerror = function(e) {
    alert("EventSource failed.");
};

$('#message_form').submit(function(e){
 e.preventDefault();
 var message = $('#txtb_chat').val();

 $.ajax({
  type: 'POST',
  dataType: 'json',
  data: message,
  url: 'message_processor.php',
  beforeSend: function(){

  },
  success: function(){
   $('#txtb_chat').val("");
  }
 });
 return false;
});

Answer 1

Вы можете использовать AJAX для отправки новых сообщений на сервер и хранения сообщений в базе данных.

Вы можете заполнить $newMessage запрашивая общую базу данных.

Ты можешь использовать id: а также Last-Event-Id отслеживать какие сообщения видел клиент и запрашивать SELECT * FROM chat WHERE id > $last_event_id,