如何解决C# .NET应用无法连接Azure Event Hubs模拟器的问题

从日志可明确核心问题：Azure Event Hubs模拟器启动失败，根源是Blob存储和元数据存储状态不健康，导致.NET客户端无法建立AMQP连接。以下是具体排查和修复步骤：

1. 验证Azure存储连接字符串有效性 #

• 用Azure Storage Explorer或Azure CLI直接测试连接字符串，确认${BlobPassword}对应的账户密钥正确，无特殊字符转义问题
• 检查存储账户防火墙设置：若开启IP限制，需允许模拟器容器的公网IP，或临时设置为「允许所有网络」（测试阶段）

2. 确保存储账户权限足够 #

模拟器需要对Blob存储具备读写权限，需确认存储账户已分配Blob Data Contributor角色权限。

3. 临时切换到Azurite验证模拟器可用性 #

优先排除真实Azure存储的网络/权限问题，临时改用Azurite作为存储后端：

• 修改docker-compose，添加Azurite服务：

  azurite:
    image: mcr.microsoft.com/azure-storage/azurite
    container_name: azurite
    ports:
      - "10000:10000"
      - "10001:10001"
    volumes:
      - azurite_data:/data
    networks:
      - mynetwork
  

• 更新eventhubs服务的AZURE_STORAGE_CONNECTION_STRING为Azurite默认连接字符串：

  AZURE_STORAGE_CONNECTION_STRING=DefaultEndpointsProtocol=http;AccountName=devstoreaccount1;AccountKey=Eby8vdM02xNOcqFlqUwJPLlmEtlCDXJ1OUzFT50uSRZ6IFsuFq2UVErCz4I6tq/K1SZFPTOtr/KBHBeksoGMGw==;BlobEndpoint=http://azurite:10000/devstoreaccount1;QueueEndpoint=http://azurite:10001/devstoreaccount1;
  

• 重启容器，查看docker logs eventhubs是否显示模拟器启动成功

4. 检查容器网络连通性 #

进入eventhubs容器，测试到Azure存储端点的网络连通性：

# 测试DNS解析
docker exec -it eventhubs nslookup mystoragename.blob.core.windows.net
# 测试HTTP访问
docker exec -it eventhubs curl https://mystoragename.blob.core.windows.net/

若无法访问，检查mynetwork网络配置，确保容器能正常访问外部网络。

5. 修正.NET客户端连接配置 #

当模拟器启动成功后，调整客户端配置：

• 连接字符串的SharedAccessKey需使用模拟器默认密钥：SbSecrets123!，替换当前的here_some_random_key
• 若.NET应用为容器化部署，需加入同一个mynetwork网络，连接字符串的Endpoint改为sb://eventhubs:5672/（而非localhost）
• 临时关闭证书验证（模拟器使用自签名证书）：

  var clientOptions = new EventProcessorClientOptions
  {
      ConnectionOptions = new EventHubConnectionOptions
      {
          TransportType = EventHubsTransportType.AmqpTcp,
          CertificateValidationCallback = (sender, cert, chain, errors) => true
      }
  };
  

6. 排查端口占用 #

检查本地5672端口是否被其他服务占用：

• Windows：netstat -ano | findstr :5672
• Linux/macOS：lsof -i :5672
  若被占用，停止对应服务或修改模拟器端口映射。

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