Azure服务总线监听器打开太多TCP连接（耗尽）

Question

我们有几个服务总线侦听器在应用服务中作为连续的Azure Web作业运行。总而言之，有12个侦听器-网络作业在同一个S1应用服务计划上运行。环境很小，每天总共大约有1000-10000条消息。最近我们部署了一个新的监听器（一个监听器，它会定期将DLQ消息重新发送到原始主题长达24小时

我分析了代码，但没有发现高传输控制协议需求的原因。

所有侦听器都像这样工作（. NET控制台应用程序，在应用服务中作为连续的Azure Web作业托管）：

public static async Task Main(string[] args)
{
    var configuration = GetConfiguration();

    // Setup dependencies (e.g. Singleton HttpClient)
    IServiceCollection serviceCollection = new ServiceCollection();
    ConfigureServices(serviceCollection, configuration);

    IServiceProvider serviceProvider = serviceCollection.BuildServiceProvider();
    var factory = serviceProvider.GetService<TopicReceiverFactory<Model>>();
    var receiver = await factory.CreateAsync();
    receiver.ReceiveMessages();

    Console.ReadLine();
}

// ctor of the receiver used above
public QueueReceiver(QueueConfiguration configuration, IHandler<T> handler, ILogger<IReceiver> logger)
        : base(logger, handler)
{
    this.configuration = configuration;

    this.Client = new QueueClient(
    this.configuration.ConnectionString,
    this.configuration.QueueName,
    this.configuration.ReceiveMode);
}

// The ReceiveMessages Method used in Main
public void ReceiveMessages()
{
    var messageHandlerOptions = new MessageHandlerOptions(this.HandleExceptionReceivedAsync)
    {
        MaxConcurrentCalls = this.configuration.MaxConcurrentCalls,
        AutoComplete = false
    };

    this.Register(messageHandlerOptions);
}

protected void Register(MessageHandlerOptions messageHandlerOptions)
{
    if (messageHandlerOptions == null)
    {
        throw new ArgumentNullException(nameof(messageHandlerOptions));
    }

    this.Client.RegisterMessageHandler(this.ProcessMessageAsync, messageHandlerOptions);
}

ProcessMessage大致有这样的逻辑：调用特定实体的处理程序（将消息发布到api），如果成功：完成消息；如果关键异常不成功（例如JsonSerializerException，因为消息的格式错误）直接死信。轻微的异常会导致内置重试（最多10次）。

预计TCP连接永远不会耗尽。环境中发生的事情并不多。

Answer 1

我们找到了问题的根源。考虑以下体系结构：具有多个主题和一个队列的servicebus命名空间。消息被发送到服务总线侦听器接收和处理消息的主题。如果无法处理消息，则将其转发到中央错误处理队列。在此队列上，一个侦听器正在接收消息并读取消息的DeadLetterSource属性。此属性中包含有关原始主题的信息。

现在问题来了：目前我们正在为每条消息创建一个TopicClient。这是因为监听器不需要提前知道有哪些主题，从而降低了可重用性。然而，正如我们现在发现的那样，这是不可持续的，因为您耗尽了TCP连接。

解决方案：我们通过配置引入主题名称，以便该侦听器可以为整个应用程序生活方式的每个主题创建一个TopicClient。本质上有n-Singleton TopicClient实例同时运行。