如何正确配置Azure Event Hub中Producer.close()的调用规则？

你参考的入门文档中每次发送后调用producer.close()属于示例场景专属写法，这类入门示例默认适配单次执行、发送完成后直接退出进程的场景，完全不适用于需要持续发送事件的后端服务场景。

核心问题解答 #

• 是否可以长期保持生产者开启？
  可以，且这是生产级部署的官方推荐用法。EventHubProducerClient本身被设计为线程安全的长生命周期对象，应用运行期间复用单实例，比每次发送都新建、销毁实例的性能高出数倍，也能避免频繁建连给Event Hub服务端带来不必要的压力。
• 长期开启会不会引发内存泄漏？
  规范使用的前提下不会出现内存泄漏。客户端底层的连接、缓冲区资源都会被内部自动管理，只要你没有额外持有发送后未释放的事件对象、也没有无限制创建生产者实例，单例复用的场景不存在内存泄漏风险。

生产环境处理策略 #

• 去掉单次发送逻辑后的producer.close()调用，你当前通过Bean在应用启动时创建单实例的做法是完全正确的，日常发送直接复用该实例即可。
• 仅在应用进程优雅下线阶段调用一次close方法释放资源，避免进程强制退出导致缓冲区未发完的事件丢失。Spring生态下可直接通过Bean的销毁方法绑定close操作，示例配置如下：

@Configuration
public class EventHubConfig {
    @Value("${eventhub.connection-string}")
    private String connectionString;
    @Value("${eventhub.name}")
    private String eventHubName;

    // 配置destroyMethod后，Spring容器销毁时会自动调用客户端的close方法
    @Bean(destroyMethod = "close")
    public EventHubProducerClient eventHubProducerClient() {
        return new EventHubClientBuilder()
            .connectionString(connectionString, eventHubName)
            .buildProducerClient();
    }
}

• 运行过程中如果出现不可恢复的连接异常（比如权限变更、网络长期不通触发重试耗尽），客户端会抛出明确的异常提示，此时销毁旧实例、重新构建一个新的EventHubProducerClient实例替换即可，不需要每次发送都重建实例。
• 若发送量较大，可基于同一个生产者开启批量发送模式，进一步提升吞吐量。

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