在现代网页应用中，经常需要使用点对点（Peer-to-Peer，P2P）通信。libp2p-swarm 是一个基于 Node.js 的 P2P 网络库，它提供了对各种传输协议（如 WebSockets、TCP、UDP 等）的支持，并具有高度的可扩展性。本文将详细介绍如何使用 npm 包 libp2p-swarm 进行 P2P 通信。
安装
在开始使用 libp2p-swarm 之前，需要先安装 Node.js 和 npm，然后在命令行中运行以下命令安装 libp2p-swarm：
npm install libp2p-swarm
基本用法
创建 Swarm
Swarm 是 libp2p-swarm 的核心概念，它负责处理与其他节点的连接和消息传输。要创建 Swarm，可以使用以下代码：
-- -------------------- ---- -------
----- ------ - ------------------
----- --- - ----------------------
----- ---------- - -----------------------------
----- - ----- - - ------------------------
----- - --- - - --------------------------
----- ----- - ------------------------
----- ----- - --- --------
-------- -
---------- ----- ------------
--------------- --------
------------ --------
-------------- --- --- ----
---- ----
-
---在上面的示例代码中，我们使用了 TCP 和 Websockets 两种传输协议、NOISE 加密、MPLEX 流复用器和 Kad-DHT 分布式哈希表模块。其中，可以通过定义自定义的 peerDiscovery 模块来决定节点的发现方式。
监听和连接
要监听入站连接和连接到其他节点，可以使用 swarm.listen() 和 swarm.dial() 方法：
// 监听端口号 8080
await swarm.listen('/ip4/0.0.0.0/tcp/8080');
// 连接到指定节点
const addr = '/ip4/127.0.0.1/tcp/9090/p2p/xxxxxx';
await swarm.dial(addr);在上面的示例代码中，我们监听端口号 8080，并尝试连接到另一个节点的地址 addr。
发送和接收消息
要发送和接收消息，可以使用 swarm.pubsub.publish() 和 swarm.pubsub.subscribe() 方法：
swarm.pubsub.subscribe('chat-room', (msg) => {
console.log(msg.data.toString());
});
swarm.pubsub.publish('chat-room', Buffer.from('Hello World!'));在上面的示例代码中，我们订阅了名为 "chat-room" 的频道，并在收到消息时打印出来。然后，我们发布了一条消息到 "chat-room" 频道中。
高级用法
libp2p-swarm 的高级用法包括节点发现、路由和协议协商。下面将分别介绍这些用法。
节点发现
节点发现指的是 Swarm 如何发现其他节点并建立连接。libp2p-swarm 支持多种节点发现方式，包括：
- rendezvous（类似于 Node.js 的 EventEmitter）
- mDNS（多播 DNS）
- peer-routing（使用 Kad-DHT 或其他协议）
节点发现在 Swarm 中通过 peerDiscovery 模块来实现。你可以使用现有的 peerDiscovery 模块，也可以自定义自己的模块。以下是一个自定义 peerDiscovery 模块的示例代码：
-- -------------------- ---- -------
----- --------------- -
------------- ----- -- -
---------- - ------
---------- - --- ------
-
------- -
-- ----
-
------ -
-- ----
-
----- ---------- -
-- -----
----- ----------- - -- ------- ---
----- - --- ---------- - - ------------
---------------------------------------- ---------------
----- -------------------------------
-
-
----- - --- --------
-------- -
-- ---
-------------- ------------------
-- ---
--
---在上面的示例代码中，我们创建了一个名为 MyPeerDiscovery 的自定义节点发现模块，它在启动时从网络中的其他节点获取新的 peerInfo，然后连接到它。我们将这个模块添加到了 Swarm 中。
路由
路由指的是 Swarm 如何找到提供特定服务的节点。libp2p-swarm 支持通过多种协议实现路由，包括 DHT、IPNS 和 DNS。下面的示例代码展示了如何使用 DHT 路由：
-- -------------------- ---- -------
----- - --- - - --------------------------
----- - --- --------
-------- -
-- ---
---- ---- -- -- --- --
-- ---
--
---
----- --------------
----- --- - ---------
----- ----------------------------------
----- -------- - ----- ----------------------------------------在上面的示例代码中，我们启用了 DHT 算法，在 Swarm 上提供了一个名为 "my-key" 的服务，然后查找提供这个服务的节点。
协议协商
协议协商指的是 Swarm 如何协商使用哪种协议进行通信。在 libp2p-swarm 中，协议有版本和名称两个属性，并由每个 peerInfo 对象描述。当 Swarm 与另一个节点建立连接时，它会尝试协商使用哪个版本和哪个协议。
以下是一个使用协议协商的示例代码：
-- -------------------- ---- -------
----- ------ - -------------------
----- - ----- - - ------------------------
----- - ----- - - ------------------------
----- ---- - ----- ---------------------------------------
----- -------- - ----- ---------------------------------------------
----- ------------
----- ---------
------- -
-- ----
---- -------------
-- ----
-------- -
------------ --------
--------------- --------
--
--
---在上面的示例代码中，我们定义了一个名为 "my-protocol" 的协议，并使用 NOISE 和 MPLEX 模块进行加密和流复用。当 Swarm 连接到目标节点时，会尝试协商是否使用这个协议。
结论
本文介绍了如何使用 npm 包 libp2p-swarm 进行 P2P 通信。我们学习了如何创建 Swarm、监听和连接、发送和接收消息，以及如何进行高级用法，包括节点发现、路由和协议协商。libp2p-swarm 具有高度的可扩展性，并且可以使用多种传输协议、加密方式和流复用器。这使得它成为一个非常有用的工具来构建现代网页应用程序。
来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/92814