轨道交通。使用不同命名空间中定义的相同对象

Question

首先，请原谅我的英语，非常糟糕。我将 MassTransit 与 Azure 服务总线一起用于微服务之间的异步通信。根据它们自己的定义，为了避免它们之间产生依赖关系，不同微服务之间发送的消息被定义在每个微服务中，即它们是不同命名空间的一部分。MassTransit 的自动管理导致队列和主题按对象类型进行管理，从而阻止消费消息的微服务接收微服务发布者发送的消息。同样的事情发生在同一个命名空间中具有相同属性但具有不同类名的两个类。

有没有办法解决这个问题？我想到的选项是：

• 从目标地址的端点删除命名空间，仅使用类的名称命名。
• MassTransit 可以根据对象的序列化来管理队列和主题的创建，而不是根据对象类型来管理它（也许通过某种类型的包装对象？）

我留下一个例子，希望可以帮助您理解问题。

//FIRST PROGRAM - MESSAGE CONSUMER 

namespace Consumer
{
    public class Example
    {
        public string PropOne { get; set; }

        public string PropTwo { get; set; }
    }

    public class ExampleConsumer : 
        IConsumer<Example>
    {
        public List<Example> ConsumedTestObjectList { get; } = new List<Example>();

        //THIS METHOD NEVER CALL !!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!
        public Task Consume(ConsumeContext<ExampleConsumer> context)
        {
            ConsumedTestObjectList.Add(context.Message);
            return Task.CompletedTask;
        }
    }

    public class ConsumerProgram
    {
        public static void Main()
        {
            var bus = Bus.Factory.CreateUsingAzureServiceBus(sbc =>
            {
                var host = sbc.Host("connectionString", h => {});

            });

            sbc.ReceiveEndpoint(host, e =>
            {
                e.Consumer<ConsumerProgram.Example>(context =>
                {
                    return Console.Out.WriteLineAsync($"Message Received: {JsonConvert.SerializeObject(context.Message)}");
                });
            });

            bus.Start(); // This is important!

            Console.WriteLine("Press any key to exit");
            Console.ReadKey();

            bus.Stop();
        }
    }
}


//SECOND PROGRAM - MESSAGE PUBLISHER 

namespace Publisher
{
    public class Example
    {
        public string PropOne { get; set; }

        public string PropTwo { get; set; }
    }

    public class PublisherProgram
    {
        public static void Main()
        {
            var bus = Bus.Factory.CreateUsingAzureServiceBus(sbc =>
            {
                var host = sbc.Host("connectionString", h => {});

            });

            bus.Start(); // This is important!

            //send new instance of Publisher.Example 
            var example = new Example() { PropOne = "1", PropTwo = "2" };
            bus.Publish(example);

            Console.WriteLine("Press any key to exit");
            Console.ReadKey();

            bus.Stop();
        }
    }
}

非常感谢。

问候

博尔哈

Answer 1

消息类型和结果名称是 MassTransit 中的一个关键概念。如果您想避免在项目之间共享程序集，那很好，但是您需要匹配整个接口（或类，在您的情况下）名称，包括命名空间，否则将无法正确路由。

是的，您可以覆盖实体名称格式化程序以更改主题的命名方式，但它不会更改消息反序列化的消息类型要求（按类型发生）。

所以这里的建议是为合约使用相同的命名空间，即使它们在不同的项目中。