c# - 服务总线主题插入了相同 MessageId 的重复消息记录

Question

[FunctionName("MyProcess")]
public static void Run(BrokeredMessage currentMessage,[ServiceBus("mytopic",
    Connection = "ConnServiceBus")]ICollector<BrokeredMessage> mytopicDemo, TraceWriter log)
{
    string messageBody = currentMessage.GetBody<string>();
    BrokeredMessage brokeredMessage = new BrokeredMessage(result);
    //extracted Id and Name from body using some code for simplicity making it as messageBody.Id and messageBody.Name
    brokeredMessage.Properties.Add("Id", messageBody.Id);    
    brokeredMessage.Properties.Add("Name", messageBody.Name);
    brokeredMessage.MessageId = "ZZ"; // I also tried GUID here messageBody.Id
    mytopicDemo.Add(brokeredMessage);

    ...                     

服务总线无法识别重复的 messageId 消息。

为什么为同一个messageId插入多条记录？

如果已经存在，应避免插入重复记录。

Answer 1

可能的原因可能是

• 如果应用程序在发送后立即遇到 fatal error 一条消息，并且错误地重新启动了应用程序实例认为之前的消息传递没有发生，后续的消息传递send 导致同一条消息在系统中出现两次。

• 客户端或网络级别的错误也可能导致
  发生在更早的时刻，并且将发送的消息提交到
  队列，确认未成功返回
  客户。这种情况使客户对结果产生怀疑发送操作。

启用重复检测可以通过丢弃重复消息来解决此问题。

队列和主题的重复检测时间历史默认为 30 秒，最大值为 7 天。

重复检测时间历史必须很大才能检测到尽可能多的重复消息。另请注意，窗口的大小直接影响队列(和主题)吞吐量。

点击here了解更多信息。