PHPで多次元配列を比較して、差分を取得したい

Question

javascript・phpとServer-Sent Eventsでチャットを作成しています。
phpでjsonファイルを確認し、最新のメッセージがあればjavascript側に送信し、表示される仕組みなのですが、下のプログラムではファイルの末尾だけを取得しています。
これだと同時に複数人の書き込みがあった場合、最後に書きこんだ人のメッセージしか表示されません。
過去ログと最新データを比較して、差分を取得するにはどうすればよいでしょうか。
文章が伝わりにくかったら申し訳ございません。ご提示よろしくお願いいたします。

var lastLog = [];
var es = new EventSource('server.php');

//過去ログを取得
function logDataRead(){
	es.addEventListener('log', function (event) {
		var result = JSON.parse(event.data);
		if(lastLog == false){
			for(var ct=0;ct < result.length;ct++){
				$("div").prepend(result[ct]);
			}
			if(result == false){
				lastLog = [];
			}else{
				lastLog = result.slice(-1)[0];
			}
			newDataRead();
		}
	});
}

//新着メッセージを取得
function newDataRead(){
	es.addEventListener('newmessage', function (event) {
		var result = JSON.parse(event.data);
		lastLog = result;
		$("div").prepend(result[ct]);
	});
}

<?php
ignore_user_abort(true);
header('Content-Type: text/event-stream');
header('Cache-Control: no-store');
session_start();

while(connection_aborted() !== CONNECTION_ABORTED) {
	//ログデータ読み込み
	$url = '../data/log.json';
	$json = file_get_contents($url);
	$data = json_decode($json);
	$cnt = count($data);
	if($cnt > 20){
		$log_data = array_slice($data , $cnt-20, 20);
	}else{
		$log_data = $data;
	}
	$log_data = json_encode($log_data);
	$last_data = end($data);
	$last_data = json_encode($last_data);

	echo "id: $n\n";

	//過去ログ送信
	if(empty($_SESSION['last_log'])){
		echo "event: log\n";
		
		printf("data: %s\n\n", $log_data);
		echo "\n\n";
		
		$_SESSION['last_log'] = $last_data;
	}
	//新着メッセージ送信
	if($last_data){
		echo "event: newmessage\n";
		
		printf("data: %s\n\n", $last_data);

		echo "\n\n";
		
		$_SESSION['last_log'] = $last_data;
	}

	echo "retry: 1000\n";
		
	ob_end_flush();
	flush();
	session_write_close();
	sleep(1);
}
?>

Answer 1

ユーザごとに「何行目まで取得済み」であるかを判別できる情報を利用する必要がありそうですね。

もし、セッション単位での保持でよければ、セッション情報として「取得済み行番号」を保持しておき、以下の新着メッセージの取得の際に利用すると良いと思います。

    $last_data = end($data); // ここをセッションから取得した行番号以降データの読み込みに変更
    $last_data = json_encode($last_data);

システムの規模が大きくなるようであれば、ユーザごとの情報をDB等に保持しておくと、ログインを跨いで「取得済み行番号」の保持が行えるようになるかと思います。

Comments

[nosonosolife]

ご回答ありがとうございます。
$_SESSION['last_log_num'] = $cnt;
$last_num = $_SESSION['last_log_num'];
$new_data = array_slice($data , $last_num, true);
$new_data = json_encode($new_data);
このように変更したところ、正常に動きましたが、若干メッセージが送信されてから表示されるまでの速度が遅くなりました。

[nosonosolife]

↑上の不具合は自己解決しました。