Serverless C#函数向Azure Event Hub发消息的最佳实践及性能优化

你当前实现的性能瓶颈非常明确：每次接口请求都新建一个EventHubProducerClient实例。
这个客户端初始化时需要完成TLS握手、AMQP连接建立、密钥鉴权、Event Hub分区元数据拉取等一系列网络操作，这部分就是你测到的1秒以上耗时的来源，后续创建批次、序列化JSON的操作耗时通常只有几毫秒，完全不是性能瓶颈。
EventHubProducerClient本身是线程安全的，官方设计规范明确要求将其作为单例长期复用，每次调用新建实例是完全错误的用法，除了性能差之外还会导致连接泄漏、触发Event Hub的连接数限流。

• 绝对不要在每次函数执行时新建EventHubProducerClient，将其注册为单例通过依赖注入获取，复用底层的AMQP连接池。
• 单消息发送场景不需要手动调用CreateBatchAsync，直接调用SendAsync传入单条消息数组即可，SDK内部会自动完成消息大小校验，减少冗余操作。
• 补充参数容错逻辑，避免非法格式的agendaId直接抛出未处理异常。
• 修正原代码里的笔误：类名、构造函数名、ILogger泛型参数需要保持一致，否则依赖注入会失败。

首先在Azure Functions启动配置中注册单例的EventHubProducerClient：

// Program.cs
var host = new HostBuilder()
    .ConfigureFunctionsWorkerDefaults() // 进程内模型请替换为ConfigureWebJobs
    .ConfigureServices(services =>
    {
        services.AddAzureClients(builder =>
        {
            // 从配置中读取Event Hub连接字符串与Hub名称，客户端默认注册为单例
            builder.AddEventHubProducerClient(
                connectionString: Environment.GetEnvironmentVariable("EventHubConnectionString"),
                eventHubName: "myHub"
            );
        });
    })
    .Build();

host.Run();

函数实现代码：

using System.Text;
using System.Text.Json;
using Azure.Messaging.EventHubs;
using Azure.Messaging.EventHubs.Producer;
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Azure.Functions.Worker;
using Microsoft.Extensions.Logging;

namespace MyNamespace
{
    public class Ping
    {
        private readonly ILogger<Ping> _logger;
        private readonly EventHubProducerClient _producerClient;

        // 构造函数直接注入复用的单例客户端与日志实例
        public Ping(ILogger<Ping> log, EventHubProducerClient producerClient)
        {
            _logger = log;
            _producerClient = producerClient;
        }

        [FunctionName("Ping")]
        public async Task<IActionResult> Run(
            [HttpTrigger(AuthorizationLevel.Anonymous, "get", Route = "v1/Ping")] HttpRequest req)
        {
            _logger.LogInformation("Processing: Ping");

            // 参数合法性校验
            if (!req.Query.TryGetValue("agendaId", out var agendaIdRaw)
                || !Guid.TryParse(agendaIdRaw.FirstOrDefault(), out var agendaId))
            {
                return new BadRequestResult();
            }

            // 构造消息体
            var message = new MensagemPing
            {
                ID = Guid.NewGuid(),
                agendaId = agendaId,
                dataTag = "ZZZZ",
                timestamp = DateTime.Now
            };
            var eventData = new EventData(Encoding.UTF8.GetBytes(JsonSerializer.Serialize(message)));

            // 直接发送单条消息，无需手动创建批次
            await _producerClient.SendAsync(new[] { eventData });

            return new OkResult();
        }
    }

    public class MensagemPing
    {
        public Guid ID { get; set; }
        public Guid agendaId { get; set; }
        public string dataTag { get; set; }
        public DateTime timestamp { get; set; }
    }
}

• 首次函数冷启动时会完成一次客户端初始化，后续所有请求都会复用已建立的长连接，Event Hub发送操作的耗时会降到50ms以内，整体接口耗时通常可以控制在200ms级别。
• 如果你使用进程内（In-Process）Azure Functions模型，还可以直接使用Event Hub输出绑定，无需手动注册和管理客户端，SDK会自动完成单例复用，代码会更简洁，性能表现一致。

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