.NET 6调用Azure Service Bus SendMessageAsync后程序意外终止问题

1. 修复异步操作的等待逻辑 #

.NET Core 6控制台项目默认采用顶级语句，若直接调用await但未阻塞主线程，主线程会在异步发送操作完成前提前退出，导致消息未发送程序就终止。

错误示例：

var client = new ServiceBusClient(connectionString);
var sender = client.CreateSender(topicName);
var message = new ServiceBusMessage("test");
await sender.SendMessageAsync(message);
// 主线程执行到这里直接结束，异步发送未完成

解决方式二选一：

• 用同步阻塞方法等待异步操作完成：

var client = new ServiceBusClient(connectionString);
using var sender = client.CreateSender(topicName);
var message = new ServiceBusMessage("test");
sender.SendMessageAsync(message).GetAwaiter().GetResult();

• 封装为异步方法并同步调用：

await MainAsync();

async Task MainAsync()
{
    var client = new ServiceBusClient(connectionString);
    using var sender = client.CreateSender(topicName);
    var message = new ServiceBusMessage("test");
    await sender.SendMessageAsync(message);
}

2. 确保客户端与发送者正确释放 #

ServiceBusClient和ServiceBusSender实现了IAsyncDisposable，必须用await using包裹，否则资源可能在消息发送完成前被回收，导致消息丢失：

await using var client = new ServiceBusClient(connectionString);
await using var sender = client.CreateSender(topicName);
var message = new ServiceBusMessage("test");
await sender.SendMessageAsync(message);

3. 验证SharedAccessPolicy与连接字符串 #

• 确认连接字符串中的SharedAccessKeyName是你手动创建的策略名称，SharedAccessKey是对应密钥，无复制错误；
• 检查策略权限确实包含Send，且主题名称拼写、大小写完全匹配（Azure Service Bus实体名称区分大小写）；
• 可临时切换为RootManageSharedAccessKey的连接字符串测试，排除权限配置问题。

4. 捕获并排查异常 #

主线程提前退出可能导致异常未被抛出，添加try-catch块捕获错误信息：

try
{
    await using var client = new ServiceBusClient(connectionString);
    await using var sender = client.CreateSender(topicName);
    var message = new ServiceBusMessage("test");
    await sender.SendMessageAsync(message);
    Console.WriteLine("消息发送成功");
}
catch (Exception ex)
{
    Console.WriteLine($"发送失败：{ex.Message}");
    Console.WriteLine(ex.StackTrace);
}

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