Дублируются сообщения при отправке конкретному пользователю через socket.io

@badwolf770 · Регистрация: 22.06.2017

Студворк — интернет-сервис помощи студентам

Всем добрый день!
Такая проблема. Делаю простой чат, в котором можно отправлять сообщения конкретным пользователям. Есть клиенты и есть операторы.Но есть проблема, если подключены несколько клиентских сокетов и мы отправляем сообщение на один из них, то сообщение дублируется у клиента, которому отправляем его. Допустим, если подключены два клиентских сокета,то у получателя сообщение дублируется 2 раза. Если 3 сокета, то 3 раза. А если подключен только один клиент, то у него сообщение не дублируется. Сообщения конкретному клиенту пробовал отправлять через socket.to(socketID)... и через socket.broadcast.to(socketID)...... Подскажите, пожалуйста.

Код сервера:

JavaScript
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
var app = require('express')();
var server = require('http').Server(app);
var io = require('socket.io')(server);
var redis = require('redis');
 
server.listen(8890);
 
io.on('connection', function (socket) {
 
console.log("new client connected");
 
var redisClient = redis.createClient();
 
redisClient.subscribe('notification');
 
 
redisClient.on("message", function (channel, message) {
    console.log("New message: " + message + ". In channel: " + channel);
    var json = JSON.parse(message);
    if (json.clientId != '' && json.operatorId == '') {
        socket.emit('newClient', message);
        socket.to(json.clientId).emit('notification', message);
        console.log(1);
    } else if (json.clientId != '' && json.operatorId != '') {
        socket.broadcast.to(json.clientId).emit('notification', message);
        socket.broadcast.to(json.operatorId).emit('notification', message);
        console.log(2);
    } else {
        console.log('не вышло');
    }
});
 
socket.on('disconnect', function () {
    redisClient.quit();
});
 
});

Код клиента:

JavaScript
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
jQuery(function ($) {
    $(document).ready(function () {
 
        var
                socket = io.connect('http://localhost:8890'),
                socketId;
 
        socket.on('connect', function () {
            socketId = socket.id;
            $('#chat-form input[name=client-id]').val(socketId);
        });
 
        socket.on('notification', function (data) {
 
            var message = JSON.parse(data);
 
            if (message.operatorId) {
                $('#chat-form input[name=operator-id]').val(message.operatorId);
            }
            $("#notifications").prepend("<p><strong>" + message.name + "</strong>: " + message.message + "</p>");
 
        });
 
    });
});

Код оператора:

JavaScript
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
jQuery(function ($) {
    $(document).ready(function () {
 
        var socket = io.connect('http://localhost:8890');
 
        socket.on('connect', function () {
            socketId = socket.id;
            $('#chat-form input[name=operator-id]').val(socketId);
 
        });
 
        socket.on('notification', function (data) {
 
            var message = JSON.parse(data);
 
            $("#notifications").prepend("<p><strong>" + message.name + "</strong>: " + message.message + "</p>");
 
        });
 
        socket.on('newClient', function (data) {
            var message = JSON.parse(data);
            alert(message.clientId + ' присоединился!');
            if (message.clientId) {
                $('#chat-form input[name=client-id]').val(message.clientId);
            }
 
        });
 
    });
});

@muxahuk1214 · 22.06.2017, 23:02

JavaScript
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
var redisClient = redis.createClient();
 
redisClient.subscribe('notification');
 
 
redisClient.on("message", function (channel, message) {
    console.log("New message: " + message + ". In channel: " + channel);
    var json = JSON.parse(message);
    if (json.clientId != '' && json.operatorId == '') {
        socket.emit('newClient', message);
        socket.to(json.clientId).emit('notification', message);
        console.log(1);
    } else if (json.clientId != '' && json.operatorId != '') {
        socket.broadcast.to(json.clientId).emit('notification', message);
        socket.broadcast.to(json.operatorId).emit('notification', message);
        console.log(2);
    } else {
        console.log('не вышло');
    }
});

Вам вот эту часть кода нужно вынести из .on('connection', ... ) функции..

Получается, что каждый раз когда кто-то заходит на сокет вы создаёте новое редис подключение и вешаете событие на отлов сообщений редиса.

это как в хендлере клика вешать слушатель на передвежение мыши..
каждый раз как вы будете кликать будет ещё 1-н слушатель передвежения мыши..

@badwolf770 · 26.07.2017, 11:36 **[ТС]**

Сообщение от muxahuk1214

Вам вот эту часть кода нужно вынести из .on('connection', ... ) функции..
Получается, что каждый раз когда кто-то заходит на сокет вы создаёте новое редис подключение и вешаете событие на отлов сообщений редиса.
это как в хендлере клика вешать слушатель на передвежение мыши..
каждый раз как вы будете кликать будет ещё 1-н слушатель передвежения мыши..

А подскажите тогда, пожалуйста, как быть, чтобы nodejs сервер создавал только одну подписку на редис при старте и всегда ее слушал, или это невозможно? Я наверно не понимаю как устроена работа nodejs. Сервер вешает обработчики событий, только когда на него подключаются клиенты или просто при старте сервера он устанавливает обработчики событий сам? Спасибо

Новые блоги и статьи Все статьи Все блоги /
SDL3 для Web (WebAssembly): Обработчик клика мыши в браузере ПК и касания экрана в браузере на мобильном устройстве 8Observer8 02.02.2026 Содержание блога Для начала пошагово создадим рабочий пример для подготовки к экспериментам в браузере ПК и в браузере мобильного устройства. Потом напишем обработчик клика мыши и обработчик. . .	Философия технологии iceja 01.02.2026 На мой взгляд у человека в технических проектах остается роль генерального директора. Все остальное нейронки делают уже лучше человека. Они не могут нести предпринимательские риски, не могут. . .	SDL3 для Web (WebAssembly): Вывод текста со шрифтом TTF с помощью SDL3_ttf 8Observer8 01.02.2026 Содержание блога В этой пошаговой инструкции создадим с нуля веб-приложение, которое выводит текст в окне браузера. Запустим на Android на локальном сервере. Загрузим Release на бесплатный. . .	SDL3 для Web (WebAssembly): Сборка C/C++ проекта из консоли 8Observer8 30.01.2026 Содержание блога Если вы откроете примеры для начинающих на официальном репозитории SDL3 в папке: examples, то вы увидите, что все примеры используют следующие четыре обязательные функции, а. . .
SDL3 для Web (WebAssembly): Установка Emscripten SDK (emsdk) и CMake для сборки C и C++ приложений в Wasm 8Observer8 30.01.2026 Содержание блога Для того чтобы скачать Emscripten SDK (emsdk) необходимо сначало скачать и уставить Git: Install for Windows. Следуйте стандартной процедуре установки Git через установщик. . . .	SDL3 для Android: Подключение Box2D v3, физика и отрисовка коллайдеров 8Observer8 29.01.2026 Содержание блога Box2D - это библиотека для 2D физики для анимаций и игр. С её помощью можно определять были ли коллизии между конкретными объектами. Версия v3 была полностью переписана на Си, в. . .	Инструменты COM: Сохранение данный из VARIANT в файл и загрузка из файла в VARIANT bedvit 28.01.2026 Сохранение базовых типов COM и массивов (одномерных или двухмерных) любой вложенности (деревья) в файл, с возможностью выбора алгоритмов сжатия и шифрования. Часть библиотеки BedvitCOM Использованы. . .	SDL3 для Android: Загрузка PNG с альфа-каналом с помощью SDL_LoadPNG (без SDL3_image) 8Observer8 28.01.2026 Содержание блога SDL3 имеет собственные средства для загрузки и отображения PNG-файлов с альфа-каналом и базовой работы с ними. В этой инструкции используется функция SDL_LoadPNG(), которая. . .