Я хотел бы знать, сколько клиентов на самом деле подписываются на чат / беседу.
Чтобы быть более точным, я просто хочу знать, есть ли больше одного клиента. (Чат на самом деле представляет собой частный разговор между двумя пользователями).
Единовременно может быть только одна чат-комната / приватная беседа (для каждого пользователя).
class Chat implements WampServerInterface
{
protected $conversationId;
public function __construct(){
$this->conversationId = null;
}
public function onSubscribe(ConnectionInterface $conn, $conversation_id){
$this->conversationId = $conversation_id;
echo "Client $conn->resourceId assigned to the conversation : $conversation_id\n";
}
public function onPublish(ConnectionInterface $conn, $conversation_id, $event, array $exclude, array $eligible){
// How to get $nb_clients ?
echo "$nb_clients User(s) in conversation";
echo "Message sent to $conversation_id : $event";
// ...
$message = $event;
// Send data to conversation
$this->conversationId->broadcast($message);
}
}
Итак, в данном коде, как получить $ nb_clients?
Обновление:
Думаю, я начинаю видеть решение.
Вот моя вторая попытка:
class Chat implements WampServerInterface
{
protected $conversation = array();
public function onSubscribe(ConnectionInterface $conn, $conversation_id){
$conversation_id = (string) $conversation_id;
if(!array_key_exists($conversation_id, $this->conversation)){
$this->conversation[$conversation_id] = 1;
}
else{
$this->conversation[$conversation_id]++;
}
echo "{$this->conversation[$conversation_id]}\n";
echo "Client $conn->resourceId assigned to the conversation : {$conversation_id}\n";
}
public function onUnSubscribe(ConnectionInterface $conn, $conversation_id){
// Foreach conversations or given conversation remove one client
$this->conversation[$conversation_id]--;
echo "$this->conversation[$conversation_id]\n";
echo "Client $conn->resourceId left the conversation : $conversation_id\n";
}
public function onOpen(ConnectionInterface $conn){
echo "New connection! ({$conn->resourceId})\n";
}
public function onClose(ConnectionInterface $conn){
$this->onUnsubscribe($conn, $this->conversation);
echo "Connection closed!\n";
}
public function onCall(ConnectionInterface $conn, $id, $fn, array $params){
}
public function onPublish(ConnectionInterface $conn, $conversation_id, $event, array $exclude, array $eligible){
$conversation_id = (string) $conversation_id;
$nb_clients = $this->conversation[$conversation_id]
echo "$nb_clients User(s) in conversation";
echo "Message sent to $conversation_id : $event";
// ...
$message = $event;
// Send data to conversation
$this->conversation[$conversation_id]->broadcast($message);
}
public function onError(ConnectionInterface $conn, \Exception $e){
echo "An error has occurred: {$e->getMessage()}\n";
$conn->close();
}
}
Есть идеи, правильно ли это сработает? Кажется, это действительно работает, но я все еще не уверен, что это лучшее решение. На самом деле я вдохновился Рэтчетом github.
$conversation_id->count()
(перед преобразованием в строку) - как описано в источнике github.com/ratchetphp/Ratchet/blob/master/src/Ratchet/Wamp/ - person VolenD   schedule 26.06.2015