Express服务器通过MQTT转发请求实现P2P处理请求

众所周知，对于个人用户而言，云服务器的性能往往伴随着高昂的成本。那么，如何才能以更经济的方式获得高性能并确保拥有固定的公网访问呢？答案就是利用 P2P（点对点）技术 来转发数据。

通过 P2P 网络架构，数据可以在各个节点之间直接传输，而无需依赖昂贵的中央服务器。这种方式不仅能够显著降低运营成本，还能充分利用网络中各个节点的闲置资源，从而实现高性能的数据传输。此外，P2P网络中的每个节点都可以拥有固定的公网地址，确保了稳定的网络连接和高效的通信。

通过这种方式，个人用户可以在不牺牲性能的前提下，大幅降低对云服务器的依赖，实现更经济、高效的网络解决方案。这里采用的HTTP+MQTT的方式，静态资源可以留存服务器，而需要计算量的API则可以通过基于MQTT的P2P转发。

要实现一个使用 Express 作为公网服务器接收 HTTP 请求，并通过 MQTT 将请求转发到局域网内的高性能服务器，等待结果并返回给客户端的架构，您可以按照以下步骤进行操作。这个过程需要处理异步请求，确保每个 HTTP 请求都能等待 MQTT 消息的响应。

架构概述

步骤详解

1. 设置 MQTT Broker

首先，您需要一个 MQTT Broker 来中转消息。可以使用 Mosquitto、EMQX 或其他 MQTT Broker。这里以 Mosquitto 为例：

# 安装 Mosquitto（以 Ubuntu 为例）
sudo apt-get update
sudo apt-get install mosquitto mosquitto-clients

# 启动 Mosquitto
sudo systemctl start mosquitto

2. 安装必要的依赖

在您的项目中安装 Express、MQTT.js 和 async（用于处理异步流程）：

npm install express mqtt async

3. 实现公网 Express 服务器

以下是一个示例代码，展示如何接收 HTTP 请求，通过 MQTT 转发请求，并等待响应：

const express = require(\’express\’);
const mqtt = require(\’mqtt\’);
const async = require(\’async\’);
const uuid = require(\’uuid\’);

const app = express();
const port = 3000;

// MQTT Broker 连接配置
const mqttHost = \’mqtt://localhost\’; // 根据实际情况修改
const clientId = `express_${
uuid.v4()}`;
const connectUrl = `${
mqttHost}`;

const client = mqtt.connect(connectUrl, {

clientId,
clean: true,
connectTimeout: 4000,
reconnectPeriod: 1000,
});

// 存储等待的响应
const responseMap = {
};

client.on(\’connect\’, () => {

console.log(\’Connected to MQTT Broker\’);
// 订阅用于接收响应的主题
client.subscribe(\’response_topic\’, (err) => {

if (!err) {

console.log(\’Subscribed to response_topic\’);
}
});
});

// 处理来自 MQTT Broker 的响应
client.on(\’message\’, (topic, message) => {

if (topic === \’response_topic\’) {

const payload = JSON.