ServiceStack.RabbitMQ与.NET Aspire兼容问题及解决方案咨询

我正在构建一个基于.NET Aspire编排器的解决方案，希望同时使用Aspire的RabbitMQ、Redis组件，以及ServiceStack对这些技术的支持。理论上两者都依赖RabbitMQ .NET客户端，我尝试通过注入Aspire配置好的RabbitMQ ConnectionFactory到ServiceStack的RabbitMqConnectionFactory实例来搭建MQ服务器，代码如下：

public class ConfigureMq : IHostingStartup
{
    public void Configure(IWebHostBuilder builder) => builder
        .ConfigureServices((context, services) =>
        {
            services.AddSingleton<IMessageService>(c => 
                new RabbitMqServer(new RabbitMqMessageFactory(c.GetRequiredService<IConnectionFactory>() as ConnectionFactory)));
        })
        .ConfigureAppHost(afterAppHostInit: appHost =>
        {
            var msgService = appHost.Resolve<IMessageService>();
            msgService.RegisterHandler<MqExecutePing>(appHost.ServiceController.ExecuteMessage);
            appHost.Resolve<IMessageService>().Start();
        });
}

但发布消息时抛出如下错误：

System.MissingMethodException: Method not found: 'Void RabbitMQ.Client.IModelExensions.BasicPublish(RabbitMQ.Client.IModel, System.String, System.String, RabbitMQ.Client.IBasicProperties, Byte[])'.
   at ServiceStack.RabbitMq.RabbitMqProducer.PublishMessage(String exchange, String routingKey, IBasicProperties basicProperties, Byte[] body)
   at ServiceStack.RabbitMq.RabbitMqProducer.Publish(String queueName, IMessage message, String exchange) in /home/runner/work/ServiceStack/ServiceStack/ServiceStack/src/ServiceStack.RabbitMq/RabbitMqProducer.cs:line 117
   at ServiceStack.RabbitMq.RabbitMqProducer.Publish(String queueName, IMessage message) in /home/runner/work/ServiceStack/ServiceStack/ServiceStack/src/ServiceStack.RabbitMq/RabbitMqProducer.cs:line 76
   at ServiceStack.RabbitMq.RabbitMqProducer.Publish[T](T messageBody) in /home/runner/work/ServiceStack/ServiceStack/ServiceStack/src/ServiceStack.RabbitMq/RabbitMqProducer.cs:line 61
   at ServiceStack.RabbitMq.RabbitMqProducer.Publish[T](T messageBody) in /home/runner/work/ServiceStack/ServiceStack/ServiceStack/src/ServiceStack.RabbitMq/RabbitMqProducer.cs:line 65
   at Redacted.Api.Accounts.ServiceInterface.HealthServices.Any(MqPing request) in D:\repos\Redacted\src\Redacted.Api.Accounts\ServiceInterface\HealthServices.cs:line 16
   at lambda_method2(Closure, Object, Object)
   at ServiceStack.Host.ServiceRunner`1.ExecuteAsync(IRequest req, Object instance, TRequest requestDto) in /home/runner/work/ServiceStack/ServiceStack/ServiceStack/src/ServiceStack/Host/ServiceRunner.cs:line 131

请问这是否是由于底层RabbitMQ .NET客户端版本差异导致的？有无解决办法？

问题原因 #

确实是RabbitMQ .NET客户端版本不兼容导致的问题。Aspire的RabbitMQ组件（Aspire.Hosting.RabbitMQ）依赖的RabbitMQ.Client版本，和ServiceStack.RabbitMq库依赖的版本不一致：

• ServiceStack.RabbitMq基于旧版本RabbitMQ.Client开发，依赖了IModelExtensions.BasicPublish这个扩展方法
• Aspire引入的新版本RabbitMQ.Client中，该方法的签名被修改、移除，或者扩展类的命名空间/类型发生了变化，导致运行时无法找到对应方法

解决办法 #

1. 统一RabbitMQ.Client版本 #

在解决方案中强制所有项目使用与ServiceStack.RabbitMq兼容的RabbitMQ.Client版本：

• 先查看ServiceStack.RabbitMq NuGet包依赖的RabbitMQ.Client版本（可通过NuGet包管理器或项目.lock文件查看）
• 在解决方案根目录的Directory.Packages.props文件中添加版本锁定：

<Project>
  <PropertyGroup>
    <ManagePackageVersionsCentrally>true</ManagePackageVersionsCentrally>
  </PropertyGroup>
  <ItemGroup>
    <PackageVersion Include="RabbitMQ.Client" Version="x.x.x" /> <!-- 替换为ServiceStack兼容的版本号 -->
  </ItemGroup>
</Project>

• 若没有Directory.Packages.props，也可在每个项目的.csproj文件中直接指定版本：

<PackageReference Include="RabbitMQ.Client" Version="x.x.x" />

2. 升级ServiceStack到最新稳定版 #

ServiceStack可能已更新对高版本RabbitMQ.Client的支持，尝试将ServiceStack相关包（尤其是ServiceStack.RabbitMq）升级到最新稳定版，看是否能适配Aspire使用的RabbitMQ.Client版本。

3. 手动配置RabbitMQ连接（绕过Aspire组件） #

如果版本统一有困难，可暂时不使用Aspire的RabbitMQ组件，手动配置ConnectionFactory：

services.AddSingleton<IConnectionFactory>(_ => new ConnectionFactory
{
    HostName = "localhost", // 从配置文件读取实际地址
    UserName = "guest",
    Password = "guest"
});

这样可避免Aspire引入的版本冲突，同时保持ServiceStack的RabbitMQ服务正常工作。

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