借力Node.js搭建TCP聊天室，畅快交流 без границ

2023-12-17 09:35:15

前言

随着互联网的飞速发展，人们对实时通信的需求日益增长。TCP协议作为一种可靠的传输层协议，在各种实时通信场景中发挥着至关重要的作用。在本文中，我们将深入探讨如何利用Node.js的强大功能，构建一个功能齐全的TCP聊天室应用程序。

TCP协议简介

TCP（Transmission Control Protocol）是一种面向连接的、可靠的传输层协议。它在OSI网络模型中位于传输层，负责在两个主机之间建立和维护一个虚拟连接，并确保数据的可靠传输。TCP协议采用滑动窗口机制和拥塞控制算法，可以有效地避免数据丢失和拥塞。

Node.js中的TCP编程

Node.js的net模块提供了对TCP协议的封装，使得我们可以轻松地构建TCP服务器和客户端。net模块提供了丰富的API，包括创建服务器、连接服务器、发送数据、接收数据等。

TCP服务器的构建

const net = require('net');

const server = net.createServer();

server.on('connection', (socket) => {
  console.log('客户端已连接');

  socket.on('data', (data) => {
    console.log(`收到客户端数据：${data}`);

    socket.write(`服务器回应：${data}`);
  });

  socket.on('close', () => {
    console.log('客户端已断开连接');
  });
});

server.listen(3000, () => {
  console.log('服务器已启动，正在监听3000端口');
});

TCP客户端的构建

const net = require('net');

const client = net.createConnection({
  host: '127.0.0.1',
  port: 3000
});

client.on('connect', () => {
  console.log('已连接到服务器');

  client.write('你好，服务器');
});

client.on('data', (data) => {
  console.log(`收到服务器数据：${data}`);
});

client.on('close', () => {
  console.log('与服务器断开连接');
});

TCP聊天室的构建

在前述TCP服务器和客户端的基础上，我们可以构建一个简单的TCP聊天室。我们可以在服务器端保存所有连接的客户端，当一个客户端发送消息时，服务器将消息转发给所有其他客户端。

服务器端代码

const net = require('net');

const clients = [];

const server = net.createServer();

server.on('connection', (socket) => {
  console.log('客户端已连接');

  clients.push(socket);

  socket.on('data', (data) => {
    console.log(`收到客户端数据：${data}`);

    for (const client of clients) {
      if (client !== socket) {
        client.write(`客户端 ${socket.remoteAddress}:${socket.remotePort} 说：${data}`);
      }
    }
  });

  socket.on('close', () => {
    console.log('客户端已断开连接');

    const index = clients.indexOf(socket);
    clients.splice(index, 1);
  });
});

server.listen(3000, () => {
  console.log('服务器已启动，正在监听3000端口');
});

客户端代码

const net = require('net');

const client = net.createConnection({
  host: '127.0.0.1',
  port: 3000
});

client.on('connect', () => {
  console.log('已连接到服务器');

  client.write('你好，世界');
});

client.on('data', (data) => {
  console.log(`收到服务器数据：${data}`);
});

client.on('close', () => {
  console.log('与服务器断开连接');
});