Strapi自定义RabbitMQ配置加载环境变量失败，求解决方案

错误原因 #

你把RabbitMQ客户端代码放在了config/目录下，Strapi会自动将该目录下的文件识别为系统配置文件并提前加载，此时strapi实例尚未初始化，导致代码中strapi.config.get()调用时出现strapi为undefined的报错。

优化方案 #

方案1：将客户端代码移至非config目录（推荐） #

Strapi的src/services/或src/utils/目录用于存放业务工具/服务代码，不会被当作配置文件提前加载：

1. 创建src/services/rabbitmq.ts，将原config/rabbitmq.ts的代码迁移过去：

import amqp, { Channel, Connection, Options } from 'amqplib';
import { Topic, Message } from '../topics';

let connection: Connection | null = null;
let channel: Channel | null = null;

const RabbitMQClient = (strapi) => {
  const { url, queue, reconnectInterval } = strapi.config.get('plugin.rabbitmq');

  // 省略connect、sendMessageToQueue等核心逻辑

  return {
    connect,
    sendMessageToQueue,
  };
};

export default RabbitMQClient;

2. 修改bootstrap.ts中的引入路径：

import RabbitMQClient from "../services/rabbitmq";

export default {
  register() {},
  async bootstrap({ strapi }) {
    const rabbitMQClient = RabbitMQClient(strapi);
    rabbitMQClient.connect();
  }
};

方案2：直接在客户端中读取环境变量 #

如果不想依赖strapi实例的config，可以直接通过Strapi的工具函数读取环境变量：

修改原客户端代码（建议移至services/utils目录，避免被Strapi当作配置文件加载）：

import amqp, { Channel, Connection, Options } from 'amqplib';
import { Topic, Message } from './topics';
import { env } from '@strapi/utils';

let connection: Connection | null = null;
let channel: Channel | null = null;

const RabbitMQClient = () => {
  // 直接读取环境变量，支持默认值
  const url = env('RABBITMQ_URL');
  const queue = env('RABBITMQ_INGEST_QUEUE');
  const reconnectInterval = env('RECONNECT_INTERVAL', 3000);

  // 省略核心逻辑

  return {
    connect,
    sendMessageToQueue,
  };
};

export default RabbitMQClient;

然后在bootstrap中无需传入strapi：

import RabbitMQClient from "../config/rabbitmq";

export default {
  register() {},
  async bootstrap() {
    const rabbitMQClient = RabbitMQClient();
    rabbitMQClient.connect();
  }
};

方案3：通过Strapi插件规范配置（进阶） #

如果你的RabbitMQ功能需要在多个项目或模块中复用，可封装为Strapi插件，插件的配置会自动集成到strapi.config中，加载时机更可控，同时支持插件级别的配置扩展，但实现成本稍高。

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