.net - MassTransit Azure ServiceBus 强制连接使用 HTTPS 而不是 AMQP

Question

我们如何强制 MassTransit 使用 HTTPS 而不是 AMQP 连接到 Azure 服务总线？

我们的应用程序位于企业防火墙后面。它需要从Azure主题发送/接收消息。我们更愿意使用 HTTPS 而不是 AMQP，这样更容易实现安全管理目的。

该应用程序具有以下设置

• .NET Framework 4.6.2
• MassTransit.Azure.ServiceBus.Core 6..1.0
• Microsoft.Azure.ServiceBus 4.1.1

根据 Azure 服务总线文档，我们应该能够将传输类型设置为 AmqpWebSockets，它应该使用 HTTPS 进行通信。连接字符串如下所示:

Endpoint=sb://test.servicebus.windows.net/;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=secret;TransportType=AmqpWebSockets

(引用:https://github.com/MicrosoftDocs/azure-docs/issues/14133)

如果我们使用 Microsoft.Azure.ServiceBus 4.1.1 中的 TopicClient，我们可以看到流量通过端口 443。示例代码为

class Program
{
    public static async Task Main(string[] args)
    {
        var serviceBus = new ServiceBus();
        await serviceBus.SendMessageAsync();

        Console.ReadKey();
    }
}

public class ServiceBus
{
    public async Task SendMessageAsync()
    {
        const int numberOfMessages = 10;
        topicClient = new TopicClient(ServiceBusConnectionString, TopicName);
        // Send messages.
        await SendMessagesAsync(numberOfMessages);

        Console.ReadKey();

        await topicClient.CloseAsync();
    }

    public async Task SendMessagesAsync(int numberOfMessagesToSend)
    {
        try
        {
            for (var i = 0; i < numberOfMessagesToSend; i++)
            {
                // Create a new message to send to the topic.
                string messageBody = $"Message {i}";
                var message = new Message(Encoding.UTF8.GetBytes(messageBody));

                // Write the body of the message to the console.
                Console.WriteLine($"Sending message: {messageBody}");

                // Send the message to the topic.
                await topicClient.SendAsync(message);
            }
        }
        catch (Exception exception)
        {
            Console.WriteLine($"{DateTime.Now} :: Exception: {exception.Message}");
        }
    }
}

但是，当我们使用具有 TransportType=AmqpWebSockets 的相同连接字符串时，MassTransit 仍使用 AMQP 端口 5671:

public class Order : IModel
{
    public int Id { get; set; }
    public double Amount { get; set; }
    public string Description { get; set; }
}


public static async Task Main(string[] args)
{
    var bus = Bus.Factory.CreateUsingAzureServiceBus(cfg =>
    {
        cfg.Host(ConnectionString);
    });
    await bus.StartAsync();
    for (int i = 0; i < 100; i++)
    {
        var order = new Order() { Id = i, Amount = 20, Description = "Test order" };
        await bus.Publish(order);
    }
}

以下是 Wireshark 捕获的流量:

有趣的是，它使用端口 443 处理前几个数据包，然后更改为端口 5671

Answer 1

找到了解决方案，可以在设置总线时设置传输类型:

var bus = Bus.Factory.CreateUsingAzureServiceBus(cfg =>
{
    cfg.Host(ConnectionString, hc => hc.TransportType = TransportType.AmqpWebSockets);
    cfg.PrefetchCount = 1;
    AddSubscriptionEndpoints(context, cfg);
});

宾果，它现在使用端口 443