Чат между двумя пользователями?

Question

[lUser L]

Нужно сделать чат для сайта между клиентом и админом. Для этого используюRatchet

Есть такой код server.php

require dirname(__DIR__) . '/vendor/autoload.php';

use Ratchet\Server\IoServer;
use Ratchet\WebSocket\WsServer;
use App\Chat;

$server = IoServer::factory(
    new WsServer(
        new Chat()
    )
  , 8080
);

$server->run();

Так жеChat.php

namespace App;
use Ratchet\MessageComponentInterface;
use Ratchet\ConnectionInterface;

class Chat implements MessageComponentInterface {
    protected $clients;
    protected $clientids;

    public function __construct() {
        $this->clients = new \SplObjectStorage; 
        $this->clientids = array();
    }

    public function multicast($msg) {
        foreach ($this->clients as $client) $client->send($msg);
    }

    public function send_to($to,$msg) {
        if (array_key_exists($to, $this->clientids)) $this->clientids[$to]->send($msg);
    }

    public function onOpen(ConnectionInterface $conn) {
        $socket_name = "{$conn->resourceId}@{$conn->WebSocket->request->getHeader('X-Forwarded-For')}";
        $this->clients->attach($conn,$socket_name);
        $this->clientids[$socket_name] = $conn;
    }

    public function onMessage(ConnectionInterface $from, $msg) {
        $this->multicast($msg);
    }

    public function onClose(ConnectionInterface $conn) {
        unset($this->clientids[$this->clients[$conn]]);
        $this->clients->detach($conn);
    }

    public function onError(ConnectionInterface $conn, \Exception $e) {
        $conn->close();
    }
}

Задача состоит в том, что бы сделать чат между двумя конкретными пользователями а на данный момент чат отправляет сообщения всем. Чат доступен только зарегистрированным пользователям которые хранятся в базе данных mysql.

upd - проблема в том, что я не могу отправить сообщения конкретному пользователю. Как мне сделать так, что бы сообщение отправлялось одному пользователю а не всем. На данный момент отправляется всем.

Comments

[Александр Аксентьев]

В чем конкретно проблема? Пока выглядит как "сделайте всё за меня".

Вы пробовали хотя бы? Что-то получилось? Что не получилось?

[lUser L]

Александр Аксентьев, проблема в том, что я не могу отправить сообщения конкретному пользователю. Как мне сделать так, что бы сообщение отправлялось одному пользователю а не всем. На данный момент отправляется всем.

[Павел Лебедев]

Эмиль Гасанов, попробуйте использовать send_to($to,$msg)

Answer 1

[xmoonlight]

Заменить multicast на send_to

Comments

[lUser L]

Видимо я делаю что то не так, но теперь сообщения приходят только отправителю.

вот js

<script>
	
	var conn = new WebSocket('ws://localhost:8080');
	
	conn.onopen = function(e){
	
	    console.log("Connection established!");
	    
	};
	
	conn.onmessage = function(e){
			
		addMessage(e.data);
	    
	};
	
	$(function(){
		
		$('body').on('click', '.send_message_btn', function(e){
		
			e.preventDefault();
			
			var el = $('.text_area_message_css');
			var message = el.val();
			
			var messageData = {
				'to': '9',
				'userId': '1',
				'content': message
			}
			
			var messageDataJson = JSON.stringify(messageData);
			var msg = JSON.stringify(message);

			conn.send(messageData);
			
			addMessage(message);
			
			el.val('');
			
		});
		
	});
	
	function addMessage(message)
	{
		
		$('.message_content_list').append('<div class="chat-message">' + message + '</div>');
		
	}
	
	</script>

[xmoonlight]

Эмиль Гасанов, причём тут js?
В chat.php это нужно менять, в функции события onMessage().

[lUser L]

xmoonlight, я в chat.php поменял $this->multicast($msg); на это $this->send_to($msg); . Но все равно отправляет самому себе.
js приложил думал может там ошибка.

[xmoonlight]

Эмиль Гасанов, мда...
найдите параметры send_to - это крайне просто....