下面是「nodejs+socket.io实现p2p消息实时发送的项目实践」的攻略。

1.背景

本项目通过搭建一个基于实时通信的 p2p 网络，实现在任意两个节点之间进行实时消息传递的功能。具体实现技术由 Node.js 和 Socket.IO 提供支持，其主要原理是在每个用户连接到服务器（Socket.IO 服务器）时，将其与其他在线用户连接起来，然后进行实时消息传递。

2. 准备工作

首先，需要安装 Node.js 和 Socket.IO。Node.js 是一个基于 Chrome 的 V8 引擎，用于构建高效的网络应用程序的 JavaScript 运行时。Socket.IO 是一个基于 Node.js 的实时网络库，用于在客户端和服务器之间进行实时通信。

可以通过以下命令行安装 Node.js 和 Socket.IO：

# 安装 Node.js
sudo apt-get install nodejs npm

# 安装 Socket.IO
npm install socket.io

3. 项目实践

在此示例中，我们将演示如何设置基于 Node.js 和 Socket.IO 的服务器和客户端以进行实时消息传递。

3.1. 服务器端

在创建一个 Socket.IO 服务器之前，需要先安装 Socket.IO。可以使用以下命令行完成此操作：

npm install socket.io

接下来，将以下代码段保存到名为 server.js 的文件中：

const io = require('socket.io')(3000, {
  cors: {
    origin: "http://localhost:8080",
    methods: ["GET", "POST"]
  }
});

io.on('connection', (socket) => {
  console.log('a user connected');
  socket.on("chat message", (msg) => {
    io.emit("chat message", msg);
  });
  socket.on('disconnect', () => {
    console.log('user disconnected');
  });
});

该文件将创建一个名为 io 的 Socket.IO 服务器实例，并在本地主机上的端口 3000 上启动。

在此示例中，我们使用 Socket.IO 的 io.emit() 方法，将到达的所有消息广播给所有连接的客户端。当客户端连接到服务器时，将触发 on('connection') 事件，并向控制台输出“a user connected”消息。当客户端断开连接时，将触发 on('disconnect') 事件，并向控制台输出“user disconnected”消息。

最后，在命令行中运行以下命令来启动 Socket.IO 服务器：

node server.js

3.2. 客户端

要让客户端连接到 Socket.IO 服务器并进行实时消息传递，需要执行以下步骤：

引用 Socket.IO 库
建立与服务器的连接
发送和接收消息

以下是一个示例客户端实现：

<!DOCTYPE html>
<html>

<head>
  <meta charset="UTF-8">
  <title>P2P Messaging</title>
</head>

<body>
  <h1>P2P Messaging</h1>
  <ul id="messages"></ul>
  <form id="chat-form">
    <input id="chat-input" placeholder="Type a message">
    <button type="submit">Send</button>
  </form>
  <script src="https://cdn.socket.io/4.0.1/socket.io.min.js"></script>
  <script>
    const socket = io("http://localhost:3000");

    const messageList = document.getElementById("messages");
    const chatForm = document.getElementById("chat-form");
    const chatInput = document.getElementById("chat-input");

    chatForm.addEventListener("submit", (e) => {
      e.preventDefault();
      const message = chatInput.value;
      chatInput.value = "";
      socket.emit("chat message", message);
    });

    socket.on("chat message", (msg) => {
      const item = document.createElement("li");
      item.textContent = msg;
      messageList.appendChild(item);
    });
  </script>
</body>

</html>

在此示例中，我们使用 Socket.IO 的 io() 方法创建了名为 socket 的客户端实例，并将其连接到我们的 Node.js 服务器。通过使用 socket.emit()，我们可以发送到服务器的“chat message”消息。在 socket.on('chat message') 事件中，我们接收服务器发送的来自其他客户端的消息，并将其添加到页面上的聊天消息列表中。

4. 示例说明

以下是本示例中的两个示例说明：

4.1. 示例1

在此示例中，我们假设使用 filename1 和 filename2 两个文件名之间的 WebSocket 进行 p2p 通信。

在 filename1 中，将以下代码段保存到名为 server.js 的文件中以启动服务端：

```javascript
const io = require('socket.io')(3000, {
cors: {
origin: "http://localhost:8080",
methods: ["GET", "POST"]
}
});

io.on('connection', (socket) => {
console.log('a user connected');
socket.on("chat message", (msg) => {
io.emit("chat message", msg);
});
socket.on('disconnect', () => {
console.log('user disconnected');
});
});
```

在 filename2 中，添加以下代码以启动客户端并与服务器建立连接：

```html

Open the browser console and watch the messages roll in!

```

启动两个终端，并分别进入到 filename1 和 filename2 所在的目录下。
在第一个终端中，运行以下命令以启动 filename1 服务器：

bash node server.js

在第二个终端中，运行以下命令以启动 filename2 客户端：

bash xdg-open index.html

在 filename2 的网页打开后，在 filename1 的命令行中输入消息，观察消息时候能够实时发送。

4.2. 示例2

在此示例中，我们将展示如何使用面向对象的方法在类中封装 p2p 通信策略。

在 filename3 中，将以下代码段保存到名为 P2PStrategy.js 的文件中：

```javascript
class P2PStrategy {
constructor(host) {
this.socket = io(host);
}

 sendMessage(message) {
   this.socket.emit("chat message", message);
 }

 onNewMessage(callback) {
   this.socket.on("chat message", (msg) => {
     callback(msg);
   });
 }

 disconnect() {
   this.socket.disconnect();
 }

}

module.exports = P2PStrategy;
```

在 filename4 中，创建一个名为 app.js 的文件，并将以下代码保存到其中：

```javascript
const P2PStrategy = require('./P2PStrategy.js');

const server = new P2PStrategy('http://localhost:3000');

server.onNewMessage((msg) => {
console.log(msg);
});

server.sendMessage("Hello, world!");

server.disconnect();
```

此处我们引入了 P2PStrategy 类，通过 new P2PStrategy 生成对象，并通过 .sendMessage() 方法将消息发送出去。并通过 .onNewMessage() 方法监听新消息。最后，通过 .disconnect() 方法断开与服务器的连接。

在 filename3 中启动服务器：

bash node server.js

在 filename4 中启动客户端：

bash node app.js

在 filename3 中输入消息，直接在控制台中观察消息是否正常发送。

总结

在本文中，我们使用了 Node.js 和 Socket.IO 解决了实时消息传递的问题，并且通过面向对象的方法封装了 p2p 通信策略。通过这个案例，读者可以学习到如何使用 Socket.IO 实现实时通信，并应用于实际项目开发中。

本站文章如无特殊说明，均为本站原创，如若转载，请注明出处：nodejs+socket.io实现p2p消息实时发送的项目实践 - Python技术站

nodejs+socket.io实现p2p消息实时发送的项目实践