server.js

const WebSocket = require('ws');
const fs = require('fs');
const path = require('path');
const http = require('http');
const redis = require('redis');

const redisList = redis.createClient();
const redisSub = redis.createClient();
const redisPub = redis.createClient();

// раздача статики, код можно игнорировать
const server = http.createServer(function (req, res) {
    const url = req.url === '/' ?
        path.join(__dirname, 'www', 'index.html') :
        path.join(__dirname, 'www', req.url);

    fs.readFile(url, (err, data) => {
        if (err) {
            res.writeHead(404);
            res.end(JSON.stringify(err));
            return;
        }

        res.writeHead(200);
        res.end(data);
    });
}).listen(process.argv[2] || 4444);

const wss = new WebSocket.Server({server});

wss.on('connection', (ws) => {
    console.log('Client connected');

    // при первом соединении отдаем клиенту сообщения из истории
    redisList.lrange('messages-archive', 0, -1, (error, messages) => {
        ws.send(JSON.stringify({
            type: 'chat-history',
            payload: messages
        }));
    });

    redisList.llen('messages-archive', console.log)

    ws.on('message', (message) => {
        console.log(`Message: ${message}`);
        // записываем сообщение в историю
        redisList.rpush('messages-archive', message);
        // отправляем сообщение в брокер
        redisPub.publish('chat-messages', message);
    });
});

redisSub.subscribe('chat-messages');

// отправляем сообщение из брокера всем клиентам
redisSub.on('message', (channel, message) => {
    wss.clients.forEach((client) => {
        client.send(JSON.stringify({
            type: 'new-message',
            payload: message
        }));
    });
});