【Azure 服务总线】查看Service Bus中消息多次发送的日志信息,消息是否被重复消费

消息,信息,日志,总线 · 浏览次数 : 38

小编点评

**问题描述:** 使用 Azure Service Bus,发现消息被重复消费。 **查看特定消息的具体消费情况需要哪些属性?** * Partition Key * Message ID * Enqueued Time * Sequence Number **其他信息:** * 消息ID:用于标识消息的唯一标识。 * Enqueued Time:消息被放入 Service Bus 的时间。 * Sequence Number:消息在 Service Bus 中处理的消息顺序。 * Partition Key:消息分区的唯一标识。 * Complete:消息消费成功标记。 * Abandoned:消息消费失败或放弃标记。

正文

问题描述

使用Service Bus,发现消息被重复消费。如果要查看某一条消息的具体消费情况,需要那些消息的属性呢?

 

问题解答

使用Azure Service Bus,当消费发送到服务端后,就会生产相关属性,如Partition Key,Message ID,Enqueued Time, Sequence Number等。这些信息可以直接在Server Bus的服务端海量日志中定位到一条消息的具体日志。

例如,发现一条消息ID为 f10daa8d-193a-4dc1-b6a8-768a3f66fdaa的消息,存在多次消费的情况。

查看日志就发现:

 

根据上图,确实存在消息从Service Bus服务端传输到消费端总次数为5次。只是前四次都在30秒的锁定时间中都没有收到消费端的Complete信号,所以都记录为放弃,未完成的状态,直到第五次消费后,状态为Completed。

这是因为客户端使用 PeekLock 模式消费时,会对当前消息启用排他锁(默认锁定时间30秒),当30秒内没有收到消费端的Compete状态时,则标记为Abandoned。 

 

参考资料

处置接收操作 PeekLock :https://docs.azure.cn/zh-cn/service-bus-messaging/message-transfers-locks-settlement#peeklock

 

与【Azure 服务总线】查看Service Bus中消息多次发送的日志信息,消息是否被重复消费相似的内容:

【Azure 服务总线】查看Service Bus中消息多次发送的日志信息,消息是否被重复消费

问题描述 使用Service Bus,发现消息被重复消费。如果要查看某一条消息的具体消费情况,需要那些消息的属性呢? 问题解答 使用Azure Service Bus,当消费发送到服务端后,就会生产相关属性,如Partition Key,Message ID,Enqueued Time, Seque

【Azure 服务总线】Azure.Messaging.ServiceBus 多次发送消息报超时错误,是否可以配置重新发送?是否有内置重试机制?

问题描述 使用 Azure Service Bus,提供应用程序之间松耦合的消息交换,但是有时候发送消息多次出现超时错误。 A connection attempt failed because the connected party did not properly respond after a

【Azure 服务总线】使用Azure Service Bus 时,出现证书错误: 所使用的证书具有无法验证的信任链

问题描述 在Azure中连接 Service Bus 服务发送消息时发生证书错误,抛出证书异常消息: 或 The X.509 certificate CN=servicebus.chinacloudapi.cn, OU=Azure, O=Shanghai Blue Cloud Technology

【Azure 服务总线】Azure门户获取ARM模板,修改Service Bus的TLS版本

问题描述 在Azure中创建Sverice Bus服务后,如果想修改服务的TLS版本,是否有办法呢? 问题解答 通过Service Bus的ARM模板,修改属性值中的 minimumTlsVersion,可以设置Service Bus服务最低支持的TLS版本,如1.0, 1.1, 1.2 操作步骤为

【Azure 服务总线】如何批量删除Azure Service Bus中的Topics(数量较多,需要过滤后批量删除)

问题描述 Azure Service Bus 的门户操作页面上,是否可以批量删除其中的Topics呢? 问题解答 Azure Service Bus门户或Service Bus Explorer工具没有提供批量删除Topic的方法。但是可以自己写脚本删除,并且可以在删除的时候自定义过滤条件。 以Py

【Azure 云服务】为Azure云服务配置上自签名的SSL证书步骤

问题描述 在使用Azure Cloud Service(云服务),默认的情况下都是使用的 HTTP 服务,通过 Visual Studio 2022 创建的默认 Cloud Service项目中,在ServiceDefinition.csdef 服务定义文件中,值默认开启了HTTP 80的Endpo

【Azure Key Vault】Key Vault能不能生成DigiCert证书?能不能自动 Rotate 证书呢?

问题描述 因为Azure Key Vault服务上保管的证书可以轻松的与其他Azure服务集成使用,所以需要知道 Key Vault 能不能生成 DigiCert 证书?能不能自动 Rotate 证书呢? 问题解答 Azure Key Vault本身只是一个保管库,它不会颁发证书。但是可以在页面上直

Azure Service Principals ----- Azure 上最好保守的秘密的服务

一,引言 Azure Service Principals 是 Azure Active Directory (AAD) 中的一种标识,代表应用程序,服务,自动化流程。Service Principals 支持各种 Azure 服务和资源之家的安全通信,为应用程序提供了一种进行身份验证并于 Azur

【Azure 媒体服务】Media Service的编码示例 -- 创建缩略图子画面的.NET代码调试问题

Azure.Identity.AuthenticationFailedException: 'ClientSecretCredential authentication failed: AADSTS90002: Tenant '********-****-****-****-************' not found. Check to make sure you have the corre

【Azure 云服务】Cloud Service Worker Role Workerrole突然停机,查看Events发现 Defrag Error (0x8900002D)

问题描述 Cloud Service Worker Role Workerrole突然停机,查看Events,发现是错误源为 Defrag。 错误消息: The volume Windows was not optimized because an error was encountered: Ne