Jak wysłać wiadomość do konkretnego klienta za pomocą socket.io

Zaczynam od socket.io + node.js, wiem, jak wysłać wiadomość lokalnie i nadać socket.broadcast.emit() funkcję: - wszyscy podłączeni klienci otrzymują tę samą wiadomość.

Teraz chciałbym wiedzieć, jak wysłać prywatną wiadomość do konkretnego klienta, mam na myśli jedno gniazdo do prywatnej rozmowy między 2 osobami (strumień klient-klient). Dzięki.

Kiedy użytkownik łączy się, powinien wysłać do serwera wiadomość z nazwą użytkownika, która musi być unikalna, np. E-mail.

Para nazwa użytkownika i gniazdo powinny być przechowywane w obiekcie takim jak ten:

var users = {
    'userA@example.com': [socket object],
    'userB@example.com': [socket object],
    'userC@example.com': [socket object]
}

Na kliencie wyemituj obiekt do serwera z następującymi danymi:

{
    to:[the other receiver's username as a string],
    from:[the person who sent the message as string],
    message:[the message to be sent as string]
}

Nasłuchuj wiadomości na serwerze. Po odebraniu wiadomości wyemituj dane do odbiorcy.

users[data.to].emit('receivedMessage', data)

Na kliencie nasłuchuj emisji z serwera o nazwie „ReceivedMessage”, a odczytując dane, możesz obsłużyć, od kogo pochodzą i jaka wiadomość została wysłana.

Możesz korzystać z pokoi socket.io. Ze strony klienta wyemituj zdarzenie (w tym przypadku "dołączenie" może być dowolne) z dowolnym unikalnym identyfikatorem (email, id).

Strona klienta:

var socket = io.connect('http://localhost');
socket.emit('join', {email: user1@example.com});

Teraz po stronie serwera użyj tych informacji, aby utworzyć unikalne pomieszczenie dla tego użytkownika

Po stronie serwera:

var io = require('socket.io').listen(80);

io.sockets.on('connection', function (socket) {
  socket.on('join', function (data) {
    socket.join(data.email); // We are using room of socket io
  });
});

Tak więc teraz każdy użytkownik dołączył do pokoju nazwanego na podstawie adresu e-mail użytkownika. Więc jeśli chcesz wysłać konkretnemu użytkownikowi wiadomość, po prostu musisz

Po stronie serwera:

io.sockets.in('user1@example.com').emit('new_msg', {msg: 'hello'});

Ostatnią rzeczą do zrobienia po stronie klienta jest odsłuchanie zdarzenia „new_msg”.

Strona klienta:

socket.on("new_msg", function(data) {
    alert(data.msg);
}

Mam nadzieję, że wpadłeś na pomysł.

PEWNOŚĆ: Po prostu,

Oto, czego potrzebujesz:

io.to(socket.id).emit("event", data);

Za każdym razem, gdy użytkownik dołączył do serwera, zostaną wygenerowane szczegóły gniazda, w tym identyfikator. To identyfikator naprawdę pomaga wysłać wiadomość do określonych osób.

najpierw musimy przechowywać wszystkie socket.ids w tablicy,

var people={};

people[name] =  socket.id;

tutaj nazwa to nazwa odbiorcy. Przykład:

people["ccccc"]=2387423cjhgfwerwer23;

Więc teraz możemy pobrać ten socket.id z nazwą odbiorcy za każdym razem, gdy wysyłamy wiadomość:

w tym celu musimy znać nazwę odbiorcy. Musisz wyemitować nazwę odbiorcy do serwera.

ostatnia rzecz to:

 socket.on('chat message', function(data){
io.to(people[data.receiver]).emit('chat message', data.msg);
});

Mam nadzieję, że to działa dobrze dla Ciebie.

Powodzenia!!

Możesz odnieść się do pokoi socket.io . Kiedy podałeś gniazdo - możesz dołączyć go do nazwanego pokoju, na przykład „user. # {Userid}”.

Następnie możesz wysłać prywatną wiadomość do dowolnego klienta pod dogodną nazwą, na przykład:

io.sockets.in ('user.125'). emit ('new_message', {text: "Hello world"})

W powyższej operacji wysyłamy „new_message” do użytkownika „125”.

dzięki.

W projekcie naszej firmy stosujemy podejście „pokoje”, a jego nazwa jest połączeniem identyfikatorów wszystkich użytkowników w rozmowie jako unikalnego identyfikatora (nasza implementacja bardziej przypomina komunikator facebookowy), przykład:

| id | nazwa | 1 | Scott | 2 | Susan

Nazwa „pokoju” będzie brzmiała „1-2” (identyfikatory są uporządkowane rosnąco) i po odłączeniu socket.io automatycznie czyści pomieszczenie

w ten sposób wysyłasz wiadomości tylko do tego pokoju i tylko do użytkowników online (połączonych) (mniej pakietów wysyłanych przez serwer).

Pozwól, że uproszczę to dzięki pokojom socket.io. zażądaj serwera z unikalnym identyfikatorem, aby dołączyć do serwera. tutaj używamy adresu e-mail jako unikalnego identyfikatora.

Klient Socket.io

socket.on('connect', function () {
  socket.emit('join', {email: user@example.com});
});

Gdy użytkownik dołączył do serwera, utwórz pokój dla tego użytkownika

Serwer Socket.io

io.on('connection', function (socket) {
   socket.on('join', function (data) {    
    socket.join(data.email);
  });
});

Teraz wszyscy jesteśmy gotowi do przyłączenia się. niech wyemituje coś z serwerowni to, aby użytkownik mógł słuchać.

Serwer Socket.io

io.to('user@example.com').emit('message', {msg: 'hello world.'});

Sfinalizujmy temat wysłuchaniem messagezdarzenia po stronie klienta

socket.on("message", function(data) {
  alert(data.msg);
});

Odniesienie z pokoi Socket.io