Как отправить сообщение к конкретным пользователям?

Question

[Space]

Привет. Как через socket.io отправить сообщение к конкретным пользователям? Можно кусочек кода? Важна суть, как отправить опр. пользователям. Может, можно сделать, чтобы отправка происходила туда, откуда пришла?

Answer 1

[Aliansys]

Из документации socket.io (отправка сообщений)

// отправить текущему сокету сформировавшему запрос (туда откуда пришла)
socket.emit('message', "this is a test");

// отправить всем пользователям, включая отправителя
io.sockets.emit('message', "this is a test");

// отправить всем, кроме отправителя
socket.broadcast.emit('message', "this is a test");

// отправить всем клиентам в комнате (канале) 'game', кроме отправителя
socket.broadcast.to('game').emit('message', 'nice game');

// отправить всем клиентам в комнате (канале) 'game', включая отправителя
io.sockets.in('game').emit('message', 'cool game');

// отправить конкретному сокету, по socketid
io.sockets.socket(socketid).emit('message', 'for your eyes only');

Comments

[Space]

А вот как определить эту комнату?

[Space]

@Aliansys ?

[Aliansys]

Ты говоришь о примерах с комнатой 'game'? Комнаты создаются тобой. Если ты не создавал комнат, то по умолчанию, все сокеты подключены к глобальной комнате '/'. Если же ты хочешь создать свою комнату, то ты можешь написать что-то вроде socket.join(имя_комнаты) и потом слать туда сообщения.
Документация по комнатам(https://github.com/LearnBoost/socket.io/wiki/Rooms)

Присоединение к комнатам:
socket.join(имя)
Отключение от комнат:
socket.leave(имя)

Тогда слать в комнату можно будет по примерам из моего ответа:
// отправить всем клиентам в комнате (канале) 'game', кроме отправителя
socket.broadcast.to('game').emit('message', 'nice game');

[Space]

@Aliansys прочитал, но что-то непонятно, комнату создавать на клиенте?

[Aliansys]

@ruslite нет, на сервере. Грязный пример:

На клиенте что-то вроде:

socket.emit('join_room', {room: 'game'});

Сервер:

socket.on('join_room', function(data){
//Вот здесь ты можешь подключить сокет к нужной тебе комнате
socket.join(data.room);
socket.broadcast.to(data.room).emit('new_user', {данные})// отправит всем в этой комнате (кроме себя), что подключился новый пользователь
})

Что-то вроде этого

[Space]

@Aliansys

socket.emit( 'message', { avatar: avatarVal, name: nameVal, message: msg, canal: canalVal } )

Сначала я отправляю данные на сервер.
Значит надо так?

socket.emit( 'join_room', {
room: 'game';
 avatar: avatarVal, name: nameVal, message: msg, canal: canalVal } )

А на сервере принимал и отправлял:

client.on( 'message', function( data ) {
io.sockets.emit( 'message', { avatar: data.avatar, name: data.name, message: data.message})
}

Потом на клиенте обрабатывал в:

socket.on( 'message', function( data ) {
	var messageMsg = не буду расписывать.
})
Теперь как на сервере принять? Что-то не пойму.

[Space]

socket.on('join_room', function(data){
//откуда ниже уже переменная и зачем она?
socket.join(data.room);
io.sockets.emit( 'message', { avatar: data.avatar, name: data.name, message: data.message})
})

Будет так?

[Aliansys]

@ruslite
socket.emit(event, callback), event - может быть любым, только совпадающим и на клиенте и на сервере. Например у тебя есть чат. В чате есть комнаты. Для того, чтобы подписаться на кукую-то комнату у тебя на клиенте должна быть отправка по некому событию, например 'join_room' (имя не важно):
socket.emit('join_room', {room: имя_комнаты...});
тогда на сервере должен быть слушатель на это событие:
socket.on('join_room', callback);
Примеры по подключению к комнатам я уже приводил.

Тогда если ты захочешь переслать сообщение в эту комнату, код может выглядеть так:
клиент:

socket.emit('send_message', {message: 'Сообщение', room: 'Имя-комнаты'});

и обработчик получения сообщений
socket.on('send_message', callback);

сервер:

socket.on('send_message', function(data){
socket.broadcast.to(data.room).emit('send_message', {message: data.message})
})

Что-то вроде этого.

[Aliansys]

@ruslite
в твоем примере:

socket.emit( 'join_room', {
room: 'game';
 avatar: avatarVal, name: nameVal, message: msg, canal: canalVal } )

а слушателя на 'join_room' на сервере нет. На сервере надо описать функционал на это событие, то есть:
socket.on('join_room', callback);

[Space]

@Aliansys на колбэк жалуется.
клиент:

var socket = io.connect( 'http://localhost:8080' );
$( "#messageForm" ).submit( function(e) { e.preventDefault();
	var nameVal = $( "#nameInput" ).val();
	var avatarVal = $( "#avatarInput" ).val();
	var msg = $( "#messageInput" ).val();
	var canalVal = $( "#canalInput" ).val();

	if(msg) {
           //вот отправляю на сервер
		socket.emit( 'message', {
			room: 'game', avatar: avatarVal, name: nameVal, message: msg, canal: canalVal } )
	   
		$( "#messageInput" ).val('');
   }
   });
 //ниже принимаю сообщение с сервера
socket.on( 'message', function( data ) {
	var messageMsg =  '<div  class="list-group-item2" >' + '<img src="user/' + data.name+'/' + data.avatar + '" height="60px" width="60px">' + '<h4 class="list-group-item-header"><a href="user.php?u='+data.name + '">' + data.name + '</a></h4>' + '<div class="list-group-item-text-chat" >' + data.message
																					
																		.replace(new RegExp("&#D83DDC8A",'gi'),"<img src='../packs/basic/D83DDC8A.png' height='21' width='21'>") + '</div></div>';
	
	document.getElementById('messages').innerHTML += messageMsg;
	$(window).scrollTop($(document).height());
});

сервер: 
<code>
var socket = require( 'socket.io' ),
   express = require( 'express' ),
    http = require( 'http' ),
    app = express(),
    server = http.createServer( app ),
    io = socket.listen( server ),
    socketEmitLastCallTime = 0,
	clientId = 1
io.sockets.on( 'connection', function( client ) {
	client.broadcast.emit('clientNew', {clientNew : '<div id="123new">Пришел новый Вася!</div>'});
	client.on( 'message', function( data ) {
	//socket.on('join_room', callback); - добавил жалуется
		var t=new Date(),
			h=t.getHours(),
			m=t.getMinutes(),
			s=t.getSeconds()
				if(h < 10){
				h = '0' + t.getHours();
				}
				if(m < 10){
				m = '0' + t.getMinutes();
				}
				if(s < 10){
				s = '0' + t.getSeconds();
				}	
			result=h+":"+m+":"+s,
			aqwsde = Date.now() - socketEmitLastCallTime,
				srtMessage = false;
				str = data.message
				str.split(' ');
				for (var key in str) {
				 if(str.length > 26) { 
					srtMessage = true;
				 } 
				}
		if (aqwsde > 1100 && !srtMessage){
		
		socketEmitLastCallTime = Date.now(); //опять эта переменная не записывается, что не так?
		console.log( 'Message received ' + result + data.name + "1" + data.message + data.canal );
            
		
		//client.broadcast.emit( 'message', { name: data.name, message: data.message } );
		io.sockets.emit( 'message', { avatar: data.avatar, result : result, name: data.name, message: data.message
																			.replace(/&/g,"&")
																			.replace(/</g,"<")
																			.replace(/>/g,">")
																			.replace(/"/g,'"')
																			.replace(/'/g,"'")
																			.replace(/\//g,"⁄")
		, canal: data.canal } );
		}else{
		console.log('TIMEEEEE!');
		}
	});
	 client.on('disconnect', function (client) {
	 io.sockets.emit('clientNew', {clientNew : '<div id="123out">Вася уплыл!</div>'});
	 });
});


server.listen( 8080 );</code>

Что не так? Как правильно?

[Space]

socketEmitLastCallTime = Date.now(); //опять эта переменная не записывается, что не так? Это В коде не тебе.

[Space]

@Aliansys можно вместо "room:" использовать "canal:" она передает название канала каждого чата

[Aliansys]

@ruslite
socket.on('join_room', callback);
в твоем случае socket = client;
а callback - это функция, которую тебе надо реализовать.
то есть должно быть так:

client.on('join_room', function(data){
...
})

Особо я в твой код не всматривался, но тебе надо понять следующее:
socket.io работает пересылая между клиентом и сервером данные подписываясь на определенные тобой события.
если у тебя на клиенте есть объект socket и он подключился к серверу, то отправлять данные на сервер ты будешь через:
socket.emit('событие', данные)
чтобы получать данные на клиенте ты должен быть подписан на соответствующие события, например:

socket.on('message', function(data){...});
socket.on('join_room', function(data){...});
socket.on('что угодно', function(data){...});

на сервере у тебя должны быть подписки на такие же события. И отправка этих событий, то есть, например:

socket.on('message', function(data){...
    socket.emit('message') или socket.broadcast...
});
socket.on('join_room', function(data){...
    socket.emit('message') или socket.broadcast...
});
...

В общем случае у тебя должны быть подписки на методы и отправка сообщений по этим методам.

socket.on(subscribe, fn());
socket.emit(subscribed_event, data);

Код и на сервере и на клиенте одинаковый.

В твоем случае вместо слова socket, тебе надо использовать client на сервере, потому что ты так его назвал:

io.sockets.on( 'connection', function( client ) {...})

Видишь? Ты написал в callback функции 'client'. Значит внутри callback'а все будет через cliet.emit и client.on;

То есть в твоем случае ты можешь создать подключение к комнате, например, так:

client.on('join_room', function(data){
client.join(data.room)
client.broadcast.to(data.room).emit('new_user', data);
})

Из меня очень плохой объясняющий судя по всему.

[Space]

@Aliansys добрый человек, так подробно и понятно я не где не видел объяснений, даже в азбуке. Спасибо, все отлично работает, а главное я наконец понял, что же такое колбэк!!!! Спасибо огромное

[Space]

и получается открыто три раза одна комната, я написал, отправилось мне и еще двум комнатам. то есть поступает три ответа? Все верно?

[Aliansys]

@ruslite не понял, что ты имеешь ввиду. Ты сделал client.broadcast.to(room_name).emit(...)?
Тогда должен уйти ответ всем сокетам(кроме тебя самого) в комнате room_name;
если ты просто написал client.emit(...), то ответ должен уйти всем сокетам на сервере.

[Space]

@Aliansys да все нормально) и еще вопрос:
у вас есть что-нибудь насчет распарсить куки на js?

[Aliansys]

@ruslite этот вопрос выходит за пределы темы. Но по поводу cookie с express.js много подробной информации в интернете, включая документацию самого express.js:
expressjs.com/api.html#cookieParser

[Space]

@Aliansys благодарю за помощь)

Answer 2

[Burgul]

Чтобы отправить конкретному клиенту используй:
io.sockets.sockets[id].emit('message', 'Hello!');
Где id - sid клиента socket.io.
Чтобы оправить данные с сервера отправителю используй аргумент функции callback:
Сервер:

socket.on('message', function (data,callback) {
        socket.broadcast.emit('message', data);
        callback("Send");
    });

Клиент:

socket.emit('message',msg,function(data) {
        console.log(data);
});

Comments

[Space]

@Burgul а что такое колбэк сенд?

[Burgul]

@ruslite Именно то, что вернется клиенту в переменную data.