使用redis和webpack实现Socket.io不直播间示例

npm install redis socket.io express

const express = require('express');
const app = express();
const http = require('http').Server(app);
const io = require('socket.io')(http);
const redis = require('redis');

// 创建redis客户端
const redisClient = redis.createClient();

// 监听客户端连接事件
io.on('connection', (socket) => {
  console.log('A client connected.');

  // 从redis中获取消息
  redisClient.lrange('messages', 0, -1, (err, messages) => {
    if (err) throw err;

    // 发送历史消息给客户端
    socket.emit('history', messages);

    // 监听客户端发送的消息
    socket.on('message', (message) => {
      console.log('Received message:', message);

      // 将消息存储到redis中
      redisClient.rpush('messages', message, (err) => {
        if (err) throw err;

        // 发送消息给所有客户端
        io.emit('message', message);
      });
    });
  });

  // 监听客户端断开连接事件
  socket.on('disconnect', () => {
    console.log('A client disconnected.');
  });
});

// 启动服务器
http.listen(3000, () => {
  console.log('Server is running on http://localhost:3000');
});

const socket = io();

// 监听服务器发送的历史消息
socket.on('history', (messages) => {
  console.log('Received history:', messages);
  // 处理历史消息...
});

// 监听服务器发送的消息
socket.on('message', (message) => {
  console.log('Received message:', message);
  // 处理新消息...
});

// 发送消息给服务器
const messageInput = document.getElementById('message-input');
const sendButton = document.getElementById('send-button');

sendButton.addEventListener('click', () => {
  const message = messageInput.value;
  console.log('Sending message:', message);
  socket.emit('message', message);
});

// 连接到服务器
socket.connect();

const path = require('path');

module.exports = {
  entry: './client.js',
  output: {
    filename: 'bundle.js',
    path: path.resolve(__dirname, 'dist'),
  },
};