Как узнать что было добавлена новая запись в бд и вывести её

@tilda_2311 · Регистрация: 17.08.2018

Author24 — интернет-сервис помощи студентам

У меня чат на sse, всё выводится, кроме введённого мною сообщения, почему может быть так?

PHP

<?
include "../php/connect.php";
header("Content-Type: text/event-stream\n\n");
header("Cache-Control: no-cache");
$query = mysqli_query($link, "SELECT msg, id from messages");
$messages = array();
 
while (1) {
echo "event: ping\n";
 
while($result = mysqli_fetch_array($query))
{
    array_push($messages, $result['msg']);
    echo 'data: '.$result['msg']."\n\n";
}
  
  ob_end_flush();
  flush();
}
?>

Javascript

var eventSource = new EventSource('/config/sse_server');
 
eventSource.onopen = function(e) {
  console.log("Connection has opened");
};
 
eventSource.onmessage = function(e) {
  console.log("get new data");
  var messages = document.getElementsByClassName("messages")[0];
  var child_div_messages = document.createElement('div');
  child_div_messages.innerHTML = e.data;
  messages.appendChild(child_div_messages);
};

@Jewbacabra · 03.10.2018, 21:37

Сообщение от tilda_2311

У меня чат на sse, всё выводится, кроме введённого мною сообщения, почему может быть так?

У тебя подход не верный. В твоем случае нужно периодически запрашивать из бд записи с id большим чем был на предыдущей итерации, но это будет так себе решение.
Как сделать чат на php

@tilda_2311 · 03.10.2018, 21:47 **[ТС]**

Jewbacabra, Почему так себе?

@Jewbacabra · 03.10.2018, 21:50

Сообщение от tilda_2311

Почему так себе?

Потому что такой подход требует по 1 процессу на каждого клиента, что способно положить сервер уже при небольшом количестве клиентов.

@tilda_2311 · 03.10.2018, 21:59 **[ТС]**

Jewbacabra, почему вот так не работает, постояно новое соединение открывается

PHP

<?
include "../php/connect.php";
header("Content-Type: text/event-stream\n\n");
header("Cache-Control: no-cache");
$query = mysqli_query($link, "SELECT msg from messages");
 
while (1)
 {
echo "event: ping\n";
 
$last_id = 0;
 
if($last_id != insert_id($link))
{
    
    while($result = mysqli_fetch_array($query))
    {
        echo 'data: '.$result['msg']."\n\n";
        
    }
    $last_id = insert_id($link);
} 
 
ob_end_flush();
 flush();
}
?>

@Jewbacabra 4925 / 3920 / 1620 Регистрация: 24.04.2014 Сообщений: 11,441
	03.10.2018, 21:37	2
	Сообщение от tilda_2311 У меня чат на sse, всё выводится, кроме введённого мною сообщения, почему может быть так? У тебя подход не верный. В твоем случае нужно периодически запрашивать из бд записи с id большим чем был на предыдущей итерации, но это будет так себе решение. Как сделать чат на php 0

@tilda_2311 3 / 2 / 1 Регистрация: 17.08.2018 Сообщений: 81
	03.10.2018, 21:47 [ТС]	3
	Jewbacabra, Почему так себе? 0

@Jewbacabra 4925 / 3920 / 1620 Регистрация: 24.04.2014 Сообщений: 11,441
	03.10.2018, 21:50	4
	Сообщение от tilda_2311 Почему так себе? Потому что такой подход требует по 1 процессу на каждого клиента, что способно положить сервер уже при небольшом количестве клиентов. 0

	03.10.2018, 21:59