Как в workerman реализовать приватность?

Question

[yapaofficial]

const div = document.querySelector("echo");
const ws = new WebSocket("ws://localhost:2346");

document.addEventListener('keydown', function(){
    ws.send(JSON.stringify("123"));
});
ws.onmessage = response => {
	let data = JSON.parse(response.data);
	console.log(data);
}

<?php
use Workerman\Worker;

require_once __DIR__ . "/vendor/autoload.php";

$wsWorker = new Worker("websocket://0.0.0.0:2346");
$wsWorker->count = 4;

$wsWorker->onConnect = function($con){
	echo "подключен";
};

$wsWorker->onMessage = function($con, $data) use ($wsWorker){
	foreach ($wsWorker->connections as $clientConnection) {
		$clientConnection->send($data);
	}
};

$wsWorker->onClose = function($con){
	echo "отключен";
};




Worker::runAll();

?>

как доработать этот код что бы сервер отвечал только тому пользователю который сделал запрос?

в общем есть авторизованый пользователь и как вывести его данные тоьлко ему, а не всем

Comments

[Vitsliputsli]

очевидно, не перебирать все соединения и не отправлять каждому:

foreach ($wsWorker->connections as $clientConnection) {
    $clientConnection->send($data);
  }

а взять только нужный, и отправить только ему. Раз пишите, что он "авторизованый пользователь", значит уже знаете его соединение.

[yapaofficial]

Vitsliputsli, а можете по подробней сказать что мне нужно сделать, а то ничего не понял. но очен интересно

[yapaofficial]

Vitsliputsli,
$wsWorker->onMessage = function($con, $data) use ($wsWorker){
$con->send($data);
};
мне нужно сделать типо такого?

[Vitsliputsli]

yapaofficial, типа такого, он отправит только конкретному клиенту, от которого пришло сообщение.
Кстати, попробовать и убедиться у вас заняло бы 5 минут.

Answer 1

[O . J]

const div = document.querySelector("echo");
const ws = new WebSocket("ws://localhost:2346");

document.addEventListener('keydown', function(){
    ws.send(JSON.stringify("123"));
});
ws.onmessage = response => {
  let data = JSON.parse(response.data);
  console.log(data);
}

<?php
use Workerman\Worker;

require_once __DIR__ . "/vendor/autoload.php";

$wsWorker = new Worker("websocket://0.0.0.0:2346");
$wsWorker->count = 4;

$wsWorker->onConnect = function($con){
  echo "подключен";
};

$wsWorker->onMessage = function($con, $data) {
  // Вместо отправки ответа всем подключенным пользователям отправляем его только тому, кто сделал запрос
  $con->send($data);
};

$wsWorker->onClose = function($con){
  echo "отключен";
};

Worker::runAll();
?>