使用MassTransit发布消息时报anonymous types are not valid message types错误

问题诱因 #

• MassTransit的核心设计要求所有消息必须是明确的公开命名类型，依赖消息的全限定类型名完成路由、序列化契约匹配、消费者订阅匹配逻辑，匿名类型没有固定的公开类型标识，默认禁止作为消息类型使用。
• 你提供的代码中，Ids.Select(id=>new SomeEvent())返回的是LINQ生成的运行时迭代器对象，该迭代器属于.NET runtime生成的匿名内部类型。直接将迭代器传入Publish方法时，没有显式指定消息泛型参数，编译器会自动将消息类型推断为该匿名迭代器类型，触发MassTransit的匿名类型校验规则，抛出对应异常。

解决方案 #

根据你的业务需求选择对应处理方案：

方案1：批量发布多条独立的SomeEvent消息 #

如果需要每条SomeEvent作为独立消息被消费者消费，可选择以下两种写法：

1. 遍历逐条发布

foreach (var id in Ids)
{
    await _bus.Publish(new SomeEvent 
    {
        // 给SomeEvent属性赋值的逻辑
    });
}

2. 调用MassTransit提供的批量发布方法

await _bus.PublishBatch(Ids.Select(id => new SomeEvent()));

方案2：发布单条包含事件集合的消息 #

如果需要把整个事件集合作为单条消息发布，需先定义公开的顶级消息类承载集合，禁止直接使用系统内置集合类型作为消息类型：

// 先定义公开的消息类型
public class SomeEventBatchMessage
{
    public List<SomeEvent> Events { get; set; }
}

// 发布逻辑
await _bus.Publish(new SomeEventBatchMessage
{
    Events = Ids.Select(id => new SomeEvent()).ToList()
});

注意事项 #

• 所有MassTransit消息类型都需要定义为公开的顶级类，不能嵌套在其他类内部，禁止使用匿名类型、动态类型、系统内置集合/迭代器类型直接作为消息类型，避免出现序列化、路由匹配异常。

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