如何在Express路由中访问IPFS节点实例并实现文件上传？

你现在的核心问题是：IPFS节点实例在启动后没有被传递到路由模块中，导致/routes/uploads.js里无法调用ipfs.add()。下面给你两种简单可行的解决方案：

方案1：将IPFS实例挂载到Express的App对象上 #

这种方法利用Express内置的app.locals来共享实例，路由可以通过req.app.locals直接访问，非常贴合Express的生态。

步骤1：修改IPFS服务文件 #

先把/services/IPFS.js改成一个返回IPFS实例的异步函数，避免导出时的语法问题：

const IPFS = require("ipfs-core");

async function startNode() {
  console.log("Starting IPFS node...");
  return await IPFS.create();
}

module.exports = startNode;

步骤2：在入口文件初始化并挂载实例 #

修改index.js，等待IPFS节点启动完成后，把实例挂载到app.locals，再启动服务器：

const express = require("express");
const bodyParser = require("body-parser");
const apiRouter = require("./routes/api");
const cors = require("cors");
const startNode = require("./services/IPFS");

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

app.use(cors());
app.use(bodyParser.urlencoded({ extended: true })); // 加上extended避免解析警告
app.use(bodyParser.json());
app.use("/api/v1", apiRouter);

// 异步启动服务器和IPFS节点
async function startServer() {
  try {
    // 启动IPFS节点
    const ipfs = await startNode();
    // 挂载到app.locals，路由中可通过req.app.locals.ipfs访问
    app.locals.ipfs = ipfs;
    console.log("IPFS node started successfully");

    // 启动Express服务器
    app.listen(port, () => {
      console.log(`Example app listening at http://localhost:${port}`);
    });
  } catch (err) {
    console.error("Failed to start IPFS node:", err);
    process.exit(1); // 启动失败时退出进程
  }
}

startServer();

步骤3：在路由中使用IPFS实例 #

修改/routes/uploads.js，从req.app.locals获取IPFS实例并调用ipfs.add()：

const express = require("express");
const router = express.Router();
// 如果处理文件上传，需要引入multer等中间件，这里假设你已经配置好
const multer = require("multer");
const upload = multer();

router.post("/upload", upload.single("file"), async (req, res) => {
  try {
    // 获取IPFS实例
    const ipfs = req.app.locals.ipfs;
    // 上传文件到IPFS（req.file是multer解析后的文件对象）
    const result = await ipfs.add(req.file.buffer);
    
    res.json({
      success: true,
      cid: result.cid.toString(),
      message: "File uploaded to IPFS successfully"
    });
  } catch (err) {
    console.error("Error uploading to IPFS:", err);
    res.status(500).json({
      success: false,
      error: err.message
    });
  }
});

module.exports = router;

方案2：使用单例模式共享IPFS实例 #

这种方法更通用，不管是不是Express环境都能使用，通过一个模块维护唯一的IPFS实例，路由直接导入这个模块获取实例。

步骤1：修改IPFS服务为单例模式 #

修改/services/IPFS.js，创建一个单例函数，确保只初始化一次IPFS节点：

const IPFS = require("ipfs-core");

let ipfsInstance = null;

async function getIPFSInstance() {
  if (!ipfsInstance) {
    console.log("Starting IPFS node...");
    ipfsInstance = await IPFS.create();
  }
  return ipfsInstance;
}

module.exports = getIPFSInstance;

步骤2：在入口文件提前初始化（可选） #

你可以在index.js里提前启动IPFS节点，避免路由第一次调用时等待初始化：

const express = require("express");
const bodyParser = require("body-parser");
const apiRouter = require("./routes/api");
const cors = require("cors");
const getIPFSInstance = require("./services/IPFS");

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

app.use(cors());
app.use(bodyParser.urlencoded({ extended: true }));
app.use(bodyParser.json());
app.use("/api/v1", apiRouter);

async function startServer() {
  try {
    // 提前初始化IPFS节点
    await getIPFSInstance();
    console.log("IPFS node ready");

    app.listen(port, () => {
      console.log(`Example app listening at http://localhost:${port}`);
    });
  } catch (err) {
    console.error("Failed to start IPFS node:", err);
    process.exit(1);
  }
}

startServer();

步骤3：在路由中使用单例实例 #

修改/routes/uploads.js，直接导入单例函数获取IPFS实例：

const express = require("express");
const router = express.Router();
const multer = require("multer");
const upload = multer();
const getIPFSInstance = require("../services/IPFS");

router.post("/upload", upload.single("file"), async (req, res) => {
  try {
    // 获取IPFS单例实例
    const ipfs = await getIPFSInstance();
    const result = await ipfs.add(req.file.buffer);
    
    res.json({
      success: true,
      cid: result.cid.toString()
    });
  } catch (err) {
    console.error("IPFS upload error:", err);
    res.status(500).json({
      success: false,
      error: err.message
    });
  }
});

module.exports = router;

注意事项 #

• 一定要处理IPFS启动失败的情况，避免服务器静默崩溃；
• 如果需要处理大文件上传，建议配置multer的存储方式（比如存到磁盘），避免内存溢出；
• 两种方案都能解决你的问题，方案1更贴合Express的使用习惯，方案2更灵活通用，根据你的项目需求选择即可。

内容的提问来源于stack exchange，提问作者coeu5a