Azure Edge Hub消息过期未触发MESSAGE_EXPIRED回调问题咨询

问题1：回调机制的理解偏差 #

你的理解确实存在偏差：

• OK_EMPTY回调的含义是准确的，代表Edge Hub已经成功接收、落盘并完成路由匹配，这是发送端到Edge Hub链路的投递成功确认，该回调只会触发一次。
• 你预期同一个回调会后续返回MESSAGE_EXPIRED是错误的：该回调仅反馈「消息是否成功送到Edge Hub」，Edge Hub侧因为下游消费者未ack导致的消息过期，不会反向通知原发送端的这个回调。

你观察到设过期时间为0时能触发MESSAGE_EXPIRED，是因为这个过期状态是发送端SDK本地判定的：消息还在SDK的待发送队列里的时候，就已经触发了本地过期校验，还没发往Edge Hub就直接返回了过期状态。而你设100ms~500ms的时候，消息已经在过期前成功发到了Edge Hub，SDK侧就不会再对这条消息做过期判定，自然不会触发对应回调。

问题2：消息级过期时间与Edge Hub路由TTL的关系 #

两者的生效优先级和阶段不同：

1. 优先级：消息对象上设置的expiryTime优先级高于路由配置的TTL，最终生效的是两者的较小值。
2. 生效阶段：
   • 发送端SDK会先校验本地待发送消息的时间是否超过expiryTime，超过则直接返回MESSAGE_EXPIRED，不对外发送。
   • 消息成功到达Edge Hub后，Edge Hub会以消息入站时间为基准，按生效的存活时间（消息expiryTime/路由TTL的较小值）存储，到期后直接丢弃消息，不会生成任何回调通知发送端。

问题3：实现预期业务逻辑的方案 #

你要实现的是「请求下游模块2秒无响应则判定离线」的请求-响应超时检测逻辑，无法通过监听MESSAGE_EXPIRED事件实现，正确方案如下：

• 发送检测请求的同时，在本地启动一个2秒的延迟调度任务（比如用ScheduledExecutorService）
• 单独监听下游模块返回的响应主题，收到对应请求的响应后，取消对应的延迟调度任务
• 如果延迟调度任务触发时还未收到响应，直接执行模块离线的业务逻辑

内容的提问来源于stack exchange，提问作者jokarl