Redis异步点对点聊天完美实现极致体验（redis 点对点聊天）

Redis异步点对点聊天：完美实现极致体验

Redis是一款高性能的开源Redis数据存储系统。它可以用来存储各种类型的数据，包括字符串、列表、哈希、集合和有序集合。Redis还提供了一些高级特性，例如发布/订阅、事务处理、Lua脚本和管道等。

在本文中，我们将探讨如何使用Redis构建一个异步点对点聊天应用程序。我们将使用Redis的发布/订阅模式和Websocket协议实现此功能。我们将使用Node.js和Express来构建我们的应用程序，并使用Socket.io作为我们的Websocket库。

在这个点对点聊天应用程序中，用户可以登录并与其他在线用户进行实时聊天。用户的聊天消息将通过Redis频道广播到其他在线用户。我们还将使用Redis列表数据类型来存储聊天消息的历史记录。

在我们开始之前，让我们确保我们已安装了Redis和Node.js。我们还需要安装一些Node.js依赖项，包括Express、Socket.io和Redis客户端。

在我们的应用程序中，我们将使用两个Redis频道：一个用于广播聊天消息，另一个用于广播用户状态更改。我们还将使用两个Redis列表：一个用于存储聊天消息的历史记录，另一个用于存储在线用户的ID。

让我们从创建我们的Express应用程序开始。在终端中，输入以下命令：

mkdir redis-chat-app
cd redis-chat-app
npm init -y
npm install express socket.io redis --save

创建一个名为index.js的文件，并将以下代码复制到文件中：

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

const app = express();
const server = http.createServer(app);
const io = socketIo(server);

const PORT = process.env.PORT || 3000;
const REDIS_PORT = process.env.REDIS_PORT || 6379;
const redisClient = redis.createClient(REDIS_PORT);
const redisSubscriber = redis.createClient(REDIS_PORT);
const redisPublisher = redis.createClient(REDIS_PORT);

redisClient.on('error', console.error);
redisSubscriber.on('error', console.error);
redisPublisher.on('error', console.error);

app.use(express.static('public'));

app.get('/', (req, res) => {
  res.sendFile(__dirname + '/public/index.html');
});

io.on('connection', socket => {
  socket.on('join', user => {
    socket.userId = user.id;
    redisClient.lpush('onlineUsers', socket.userId);
    redisPublisher.publish('userJoined', JSON.stringify(user));
  });
  socket.on('sendMessage', message => {
    const chatMessage = {
      userId: socket.userId,
      message,
      timestamp: new Date().getTime()
    };
    redisClient.lpush('chatHistory', JSON.stringify(chatMessage));
    redisPublisher.publish('chatMessage', JSON.stringify(chatMessage));
  });

  socket.on('disconnect', () => {
    redisClient.lrem('onlineUsers', 1, socket.userId);
    redisPublisher.publish('userLeft', socket.userId);
  });
});

redisSubscriber.subscribe('chatMessage');
redisSubscriber.subscribe('userJoined');
redisSubscriber.subscribe('userLeft');

redisSubscriber.on('message', (channel, messageString) => {
  const message = JSON.parse(messageString);
  io.emit(channel, message);
});
server.listen(PORT, () => {
  console.log(`Server listening on port ${PORT}`);
});

在上面的代码中，我们创建了一个Express应用程序和一个HTTP服务器。我们使用Socket.io将Websocket功能添加到我们的应用程序中，并使用Redis客户端来连接到Redis数据库。然后，我们创建一个具有三个事件监听器的Socket.io套接字：

– join：用户加入聊天室事件。我们将用户ID添加到Redis在线用户列表，并发布一个“用户加入”事件。

– sendMessage：用户发送消息事件。我们将用户ID、消息和时间戳组成的聊天消息对象添加到Redis聊天消息历史记录列表，并发布一个“聊天消息”事件。

– disconnect：用户离开聊天室事件。我们将用户ID从Redis在线用户列表中删除，并发布一个“用户离开”事件。

我们还创建了一个Redis订阅器来监听来自Redis频道的事件。每当有消息发布到一个频道中时，我们都会将其发送到所有连接的客户端。

现在，让我们创建我们的前端代码。在public文件夹中，创建一个名为index.html的文件，将以下代码复制到文件中：




  Redis Chat App


    #messages {
      border: 1px solid black;
      height: 400px;
      overflow-y: scroll;
      padding: 10px;
    }



  
 
  Online Users: 
  



    
  Send
  



    const socket = io();

    const onlineUsersElement = document.getElementById('onlineUsers');
    const messagesElement = document.getElementById('messages');
    const messageInputElement = document.getElementById('messageInput');
    const messageButtonElement = document.getElementById('messageButton');

    let currentUser;

    const addMessage = message => {
      const messageElement = document.createElement('div');
      messageElement.innerText = `${message.userId}: ${message.message}`;
      messagesElement.appendChild(messageElement);
    };

    const updateOnlineUsers = users => {
      onlineUsersElement.innerText = users.join(', ');
    };

    socket.emit('join', {
      id: Date.now().toString(36)
    });

    messageButtonElement.addEventListener('click', () => {
      const message = messageInputElement.value.trim();

      if (message) {
        socket.emit('sendMessage', message);
        messageInputElement.value = '';
      }
    });

    socket.on('chatMessage', addMessage);

    socket.on('userJoined', user => {
      currentUser = user;
    });

    socket.on('userLeft', () => {
      currentUser = null;
    });

    socket.on('onlineUsers', updateOnlineUsers);

    socket.on('connect', () => {
      console.log('connected');
    });

    socket.on('disconnect', () => {
      console.log('disconnected');
    });

    socket.on('reconnect', () => {
      console.log('reconnected');
    });

    socket.on('reconnecting', () => {
      console.log('reconnecting');
    });

    socket.on('reconnect_fled', () => {
      console.log('reconnect_fled');
    });