Azure服务总线死信队列消息无法在死信中停留更长时间

如何解决Azure服务总线死信队列消息无法在死信中停留更长时间

我有Azure Main函数应用程序，该应用程序处理来自服务总线的即将到来的消息。

如果由于API错误导致发生异常，则我将消息推送到Dead Letter Queue。

我有另一个天蓝色的Dead功能应用程序，可以连续读取DLQ并将消息推回主队列。

并且主要功能应用检查api是否关闭，然后再次将消息推送到DLQ，这应该一直进行到API开启并且主要功能应用成功处理消息为止。

但是问题是一段时间后消息会自动清除。

我检查“默认邮件生存时间”为2小时30分钟，但邮件无法停留那么长时间。当我将消息推回Main时，我认为是在Dead Function应用程序中。主队列中的邮件可能被标识为重复但不确定。

在给定的默认消息生存时间下，我应如何将消息维持在DLQ中？

死信功能应用程序代码，可将消息推回主队列-

 MessageSender sender = new MessageSender(Environment.GetEnvironmentVariable("ConnectionStringSettingName"),UtilityHelper.GetAndValidateAppSetting("TopicName"),RetryPolicy.Default);

            Message deadLetterMessage = new Message(message.Body);

            foreach (KeyValuePair<string,object> userProperty in message.UserProperties)
            {
                deadLetterMessage.UserProperties.Add(userProperty.Key,userProperty.Value);
            }

            //Send the message to the Active Queue
            await sender.SendAsync(deadLetterMessage);

主要功能应用代码-

[FunctionName("ProcessMessage")]
        public static async System.Threading.Tasks.Task RunAsync([ServiceBusTrigger("mytopic","mysub",Connection = "ConnectionStringSettingName")]Message mySbMsg,string lockToken,MessageReceiver messageReceiver,ILogger log)
        {
            
            try
            { 
                  log.LogInformation("Process message...");
            }
            catch (Exception ex)
            {
                log.LogInformation($"Send message to dead-letter: {ex}");
                await messageReceiver.DeadLetterAsync(lockToken);
            }
        }

我的逻辑是：在API启用之前，我正在将消息发送到DLQ和DLQ功能应用程序，将其推回主队列，以免丢失消息。

更新

找出根本原因：

Microsoft.Azure.ServiceBus.ServiceBusCommunicationException：一个 无法执行套接字上的操作，因为缺少系统 足够的缓冲区空间或因为队列已满ErrorCode： NoBufferSpaceAvailable ---> System.Net.Sockets.SocketException：一个 无法执行套接字上的操作，因为缺少系统 足够的缓冲区空间或队列已满 Microsoft.Azure.ServiceBus.ServiceBusConnection.CreateConnectionAsync（TimeSpan 超时）

如何解决这个问题？

解决方法

默认生存时间设置不不适用于死信。根据{{​​3}}：

没有自动清除DLQ。消息将保留在DLQ中，直到您从DLQ中显式检索它们，并在死信消息上调用Complete（）。

上面用于将死信返回到原始队列的函数的代码将完成每个死信，而这些消息将从死信队列中消失。