如何检查Azure Service Bus中IMessageSender的连接存活状态？

你使用的3.5.1版本Service Bus Java SDK没有提供直接返回布尔值的内置连接状态检测接口。
该版本SDK采用延迟连接策略，仅在首次调用发送方法时才会建立实际连接，且运行时会主动回收空闲超过阈值的连接，因此未公开实时连接状态查询的公开API。

可行替代方案 #

方案1：轻量探测消息检测 #

适合需要主动预检测连接的场景，通过发送无业务意义的探测消息判断连接状态：

• 构造零负载的探测消息，设置极短的过期时间，避免被业务消费者获取
• 发送时添加超时控制，根据发送结果返回布尔状态

import com.microsoft.azure.servicebus.IMessageSender;
import com.microsoft.azure.servicebus.Message;
import java.time.Duration;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.TimeoutException;

public boolean checkSenderConnection(IMessageSender sender) {
    try {
        Message probeMsg = new Message(new byte[0]);
        probeMsg.setLabel("connection_probe");
        // 设置消息1秒过期，避免进入业务队列
        probeMsg.setTimeToLive(Duration.ofSeconds(1));
        // 1.5秒超时控制，避免阻塞业务逻辑
        CompletableFuture<Void> sendFuture = sender.sendAsync(probeMsg);
        sendFuture.get(1500, java.util.concurrent.TimeUnit.MILLISECONDS);
        return true;
    } catch (TimeoutException e) {
        return false;
    } catch (Exception e) {
        return false;
    }
}

该方案会产生极少量的服务端请求开销，适合定时健康检测类场景使用。

方案2：业务发送时异常捕获（生产环境更推荐） #

主动检测的结果仅能代表检测瞬间的连接状态，实际发送业务消息时仍可能出现网络波动、服务端连接重置等问题，更推荐在业务发送逻辑中增加异常处理：

• 捕获发送时抛出的ServiceBusException，通过isTransient()方法判断是否为可重试的连接类错误
• 结合SDK内置的重试策略，或自定义降级逻辑处理连接异常

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