Mass Transit - 是否可以使用来自 Azure 服务总线的消息？

Question

请不要问为什么，我正在做我被告知的事情。 我正在从 Azure 服务总线发送消息。我希望使用 Mass Transit 来使用此消息。我可以使用 Azure 服务总线使用来自 Mass Transit 的消息，但反之则不行。 我只能使用 Mass Transit 轻松发送和接收消息，但不能从 Azure Service Bus 到 Mass Transit。 有谁知道我怎样才能做到这一点？

这是我的实现：

Azure 服务总线发送消息：

  queueClient = new QueueClient("Endpoint=sb:", AzureQueueName);

    var murrr = new MainMessage()
                        {
                            ConsignmentReference = DateTime.Now.Ticks.ToString(),
                            CustomerId = "MOOOOOOOOOOOOOOOOOO",
                            OtherProperty = 123,
                            WantMeToFail = false,

                        };

                        var json = JsonConvert.SerializeObject(murrr);
                        var message2 = new Message(Encoding.UTF8.GetBytes(json));


                        // Send the message to the queue
                        await queueClient.SendAsync(message2);

在 Mass Transit 中消费消息：

  var bus = CreateAzureBus(ConfigurationManager.AppSettings["AzureQueueName"], ConfigurationManager.AppSettings["AzureNamespace"], ConfigurationManager.AppSettings["AzureKey"], ConfigurationManager.AppSettings["AzureKeyName"], configurator =>
            {
                configurator.Subscribe(s =>
                {
                    s.Consumer<Consumer>().Permanent();
                    s.Consumer<RetryConsumer>().Permanent();
                    s.Consumer<SBConsumer>().Permanent();  

                });

                configurator.SetCreateMissingQueues(true);
            });


    private static IServiceBus CreateAzureBus(string azureQueueName, string azureNamespace, string azureKey,
            string azureKeyName, Action<ServiceBusConfigurator> config = null)
        {
            var queueUrl = $"azure-sb://{azureNamespace}/{azureQueueName}";
            return ServiceBusFactory.New(x =>
            {
                x.UseAzureServiceBus(r => r.ConfigureNamespace(azureNamespace, h =>
                {
                    h.SetKey(azureKey);
                    h.SetKeyName(azureKeyName);
                }));

                x.ReceiveFrom(queueUrl);
                x.UseJsonSerializer();

                x.UseAzureServiceBusRouting();
                x.SetCreateMissingQueues(true);

                config?.Invoke(x);
            });
        }

这是我希望使用消息的消费者，我已经尝试过我正在使用的对象和 Azure 服务总线对象消息

 public class SBConsumer : Consumes<Message>.All
    {
        public void Consume(Message message)
        {
            AzureProcessor.DoSomethingWithOurMessage(message);
        }
    }

我也试过这个：

 public class Consumer : Consumes<MainMessage>.All
    {
        public void Consume(MainMessage message)
        {
            Processor.DoSomethingWithOurMessage(message, 0);
        }

    }

Answer 1

MassTransit 具有特定的消息格式，这是消息反序列化程序所要求的。

http://masstransit-project.com/MassTransit/advanced/interoperability.html

如果您想使用任意消息，则需要编写自己的反序列化器。