如何用Nodejs构建分布式聊天系统

如何用Nodejs构建分布式聊天系统

不知道哪位兄弟做过，能否指点下

13 回复

当然可以！构建一个基于Node.js的分布式聊天系统是一个有趣且具有挑战性的项目。以下是一个简单的指南，帮助你从零开始构建一个基本的分布式聊天系统。

1. 技术栈

  • Node.js: 后端服务框架。
  • Socket.IO: 实时双向通信库。
  • Express: 简化HTTP服务器的搭建。
  • MongoDB: 存储用户信息和消息记录（可选）。

2. 架构设计

前端 (客户端)

使用HTML、CSS和JavaScript来创建用户界面。前端主要负责渲染聊天界面，并通过WebSocket与后端进行实时通信。

后端 (服务器端)

使用Node.js配合Express和Socket.IO实现。后端负责处理用户的连接请求，管理用户会话，并将消息广播给所有在线用户。

3. 示例代码

安装依赖

首先，安装所需的Node.js模块：

npm install express socket.io

创建服务器

创建一个名为server.js的文件，并添加以下代码：

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

// 初始化应用和服务
const app = express();
const server = http.createServer(app);
const io = socketIo(server);

// 设置静态资源目录
app.use(express.static('public'));

// 监听连接事件
io.on('connection', (socket) => {
    console.log('A user connected:', socket.id);

    // 广播新连接的消息
    socket.broadcast.emit('message', { text: 'A new user has joined the chat.' });

    // 处理消息事件
    socket.on('chat message', (msg) => {
        console.log('Message received:', msg);
        // 将消息广播给所有连接的客户端
        io.emit('chat message', msg);
    });

    // 处理断开连接事件
    socket.on('disconnect', () => {
        console.log('User disconnected:', socket.id);
        // 广播断开连接的消息
        io.emit('message', { text: 'A user has left the chat.' });
    });
});

// 监听端口
server.listen(3000, () => {
    console.log('Server is running on port 3000');
});

创建前端页面

创建一个名为index.html的文件，位于public目录中，内容如下：

<!DOCTYPE html>
<html lang="en">
<head>
    <meta charset="UTF-8">
    <title>Distributed Chat System</title>
    <style>
        /* 添加一些样式 */
    </style>
</head>
<body>
    <ul id="messages"></ul>
    <form action="">
        <input id="m" autocomplete="off" /><button>Send</button>
    </form>

    <script src="/socket.io/socket.io.js"></script>
    <script>
        const socket = io();

        const form = document.querySelector('form');
        const input = document.getElementById('m');
        const messages = document.getElementById('messages');

        form.addEventListener('submit', (e) => {
            e.preventDefault();
            if (input.value) {
                // 发送消息到服务器
                socket.emit('chat message', input.value);
                input.value = '';
            }
        });

        // 接收并显示消息
        socket.on('chat message', (msg) => {
            const item = document.createElement('li');
            item.textContent = msg;
            messages.appendChild(item);
            window.scrollTo(0, document.body.scrollHeight);
        });

        // 接收系统消息
        socket.on('message', (msg) => {
            const item = document.createElement('li');
            item.textContent = `[System] ${msg.text}`;
            messages.appendChild(item);
            window.scrollTo(0, document.body.scrollHeight);
        });
    </script>
</body>
</html>

4. 运行项目

启动服务器：

node server.js

然后在浏览器中访问http://localhost:3000，即可看到聊天界面。你可以打开多个窗口或标签页测试多人聊天功能。

这样就完成了一个简单的分布式聊天系统的搭建。你可以在此基础上进一步扩展，例如增加用户认证、持久化存储等功能。


  1. session外存储，比如使用redis，这样多节点间可以共享
  2. 负载均衡使用nginx，转发请求到各个node chat节点
  3. redis存储用户基本信息，如状态信息、好友关系
  4. node chat节点间通信使用redis的pub/sub
  5. 前端使用socket.io或者自己封装长连接
  6. 做好客户端断开重练和服务端node chat节点的动态增删

pomelo …

https://github.com/NetEase/pomelo/wiki/tutorial1–分布式聊天

pomelo 顶起来

pomelo搞这种高实时，分布式的应用太完美了，亲身体验啊！

NB，说的太全面了！ 1.session用redis做外存，怎么保证session的同步啊？因为reids的读写都是异步的，而且要经过socket传输，所以不可避免的会出现session不同步的情况。 2.redis当做rpc通信使用，这个想法很有创意，不知道有没有测试过其性能啊？

这也是我之前考虑的问题，不过还没有很好的解决方式……

pomelo有用过的吗，性能怎么样？

多谢，讲的比较详细，不过对redis的pub/sub不太熟，仔细研究下！

性能挺好的，看你用什么协议了！如果服务器配置还行的话，一般可以撑到协议的上线……

https://github.com/NetEase/pomelo/wiki/pomelo性能参考

这里有个参考文档…

多谢各位的分享，我们做的是手游项目，前台用的flash starling框架，后台用php，实时部分打算用nodejs，不知各位有什么好的建议？

thrift通信

要使用Node.js构建分布式聊天系统，我们需要考虑几个关键点：消息传递、用户管理、负载均衡以及系统的可扩展性。这里我们将介绍一个基本的框架，并提供一些关键组件的示例代码。

技术栈

  • Node.js：后端逻辑处理。
  • Socket.IO：实现实时双向通信。
  • Redis：用于数据缓存和分布式会话管理。
  • Nginx：作为反向代理服务器进行负载均衡。

示例架构

  1. 服务端（Node.js + Socket.IO）

    • 每个服务节点都运行相同的服务代码。
    • 使用Socket.IO处理客户端与服务端之间的实时通信。

  2. 共享状态存储（Redis）

    • 用于存储在线用户列表和消息历史记录。
    • 在线用户的订阅/取消订阅事件需要同步到所有服务节点。

  3. 负载均衡器（Nginx）

    • 将请求分配给不同的服务节点，确保高可用性和负载均衡。

关键代码示例

服务端代码

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

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

io.on('connection', (socket) => {
    console.log(`New client connected: ${socket.id}`);

    // 订阅在线用户列表
    redisClient.sadd('onlineUsers', socket.id);

    // 当用户离开时更新在线列表
    socket.on('disconnect', () => {
        redisClient.srem('onlineUsers', socket.id);
        console.log(`Client disconnected: ${socket.id}`);
    });

    // 处理消息广播
    socket.on('message', (msg) => {
        io.emit('message', msg);  // 广播给所有连接的客户端
    });
});

server.listen(3000, () => {
    console.log('Server listening on port 3000');
});

客户端代码

<!DOCTYPE html>
<html lang="en">
<head>
    <meta charset="UTF-8">
    <title>Chat App</title>
</head>
<body>
    <input id="username" type="text" placeholder="Username">
    <button onclick="join()">Join Chat</button>
    <ul id="messages"></ul>
    <input id="message" type="text" placeholder="Message">
    <button onclick="sendMessage()">Send</button>

    <script src="/socket.io/socket.io.js"></script>
    <script>
        let socket;

        function join() {
            const username = document.getElementById('username').value;
            socket = io({ query: `username=${username}` });
            socket.on('connect', () => {
                console.log('Connected to the server!');
            });
        }

        function sendMessage() {
            const message = document.getElementById('message').value;
            socket.emit('message', message);
            document.getElementById('message').value = '';
        }

        socket.on('message', (msg) => {
            const li = document.createElement('li');
            li.textContent = msg;
            document.getElementById('messages').appendChild(li);
        });
    </script>
</body>
</html>

总结

通过上述架构和示例代码，我们可以实现一个简单的分布式聊天系统。你可以根据实际需求调整代码，并加入更多的功能如用户认证、消息持久化等。

回到顶部