在Aspire 9中部署带rabbitmq_delayed_message_exchange插件的RabbitMQ遇容器退出问题

问题描述 #

在Aspire 9中部署RabbitMQ 3.13实例，已将rabbitmq_delayed_message_exchange插件下载至本地{curDir}/volumes/rabbitmq/plugins目录并挂载到容器的/myplugins路径，同时配置了RABBITMQ_PLUGINS_DIR环境变量包含该路径。但通过.WithArgs("rabbitmq-plugins", "enable", "rabbitmq_delayed_message_exchange")执行插件启用命令后，容器执行命令后随即重启并停止，无法正常运行RabbitMQ服务。

原配置代码：

var builder = DistributedApplication.CreateBuilder(args);

var curDir = Directory.GetCurrentDirectory();

var rabbitMQ = builder.AddRabbitMQ(nameof(CTE.enmMicroservicios.RabbitMQ))
    .WithEnvironment("RABBITMQ_DEFAULT_USER", "guest")
    .WithEnvironment("RABBITMQ_DEFAULT_PASS", "guest")
    .WithEnvironment("RABBITMQ_PLUGINS_DIR", "/opt/rabbitmq/plugins:/myplugins")
    .WithManagementPlugin()
    .WithEndpoint("management", e => e.Port = 15674)
    .WithImageTag(tag: "3.13")
    .WithBindMount($"{curDir}/volumes/rabbitmq/plugins", "/myplugins")
    .WithArgs("rabbitmq-plugins", "enable", "rabbitmq_delayed_message_exchange");

builder.Build().Run();

问题原因 #

.WithArgs()方法会替换RabbitMQ容器默认的启动命令（原本为rabbitmq-server），而rabbitmq-plugins enable是一次性执行的命令，执行完成后进程随即退出，导致容器失去运行中的主进程，进而停止。

解决方案 #

方法一：通过环境变量自动启用插件 #

利用RabbitMQ的环境变量RABBITMQ_SERVER_ADDITIONAL_ERL_ARGS，在服务启动时指定要启用的插件，保持容器启动命令为默认的rabbitmq-server，确保服务持续运行。

修改后的配置代码：

var builder = DistributedApplication.CreateBuilder(args);

var curDir = Directory.GetCurrentDirectory();

var rabbitMQ = builder.AddRabbitMQ(nameof(CTE.enmMicroservicios.RabbitMQ))
    .WithEnvironment("RABBITMQ_DEFAULT_USER", "guest")
    .WithEnvironment("RABBITMQ_DEFAULT_PASS", "guest")
    .WithEnvironment("RABBITMQ_PLUGINS_DIR", "/opt/rabbitmq/plugins:/myplugins")
    // 指定启动时自动启用的插件，包含管理插件和延迟消息插件
    .WithEnvironment("RABBITMQ_SERVER_ADDITIONAL_ERL_ARGS", "-rabbit plugins_enabled '[rabbitmq_management,rabbitmq_delayed_message_exchange]'")
    .WithEndpoint("management", e => e.Port = 15674)
    .WithImageTag(tag: "3.13")
    .WithBindMount($"{curDir}/volumes/rabbitmq/plugins", "/myplugins");

builder.Build().Run();

方法二：挂载enabled_plugins配置文件 #

1. 在本地创建{curDir}/volumes/rabbitmq/config目录，新建enabled_plugins文件，内容为：

[rabbitmq_management,rabbitmq_delayed_message_exchange].

注意：文件结尾必须包含英文句点。

2. 修改Aspire配置，添加该目录的挂载：

var builder = DistributedApplication.CreateBuilder(args);

var curDir = Directory.GetCurrentDirectory();

var rabbitMQ = builder.AddRabbitMQ(nameof(CTE.enmMicroservicios.RabbitMQ))
    .WithEnvironment("RABBITMQ_DEFAULT_USER", "guest")
    .WithEnvironment("RABBITMQ_DEFAULT_PASS", "guest")
    .WithEnvironment("RABBITMQ_PLUGINS_DIR", "/opt/rabbitmq/plugins:/myplugins")
    .WithEndpoint("management", e => e.Port = 15674)
    .WithImageTag(tag: "3.13")
    .WithBindMount($"{curDir}/volumes/rabbitmq/plugins", "/myplugins")
    // 挂载自定义配置目录，包含enabled_plugins文件
    .WithBindMount($"{curDir}/volumes/rabbitmq/config", "/etc/rabbitmq");

builder.Build().Run();

额外注意事项 #

确保下载的rabbitmq_delayed_message_exchange插件版本与RabbitMQ 3.13完全匹配，版本不兼容会导致插件加载失败，进而影响RabbitMQ启动。

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