Azure EventHub：发送异步性能

Question

    public async Task Produce(string topic, object message, MessageHeader messageHeaders)
    {
        try
        {
            var producerClient = _EventHubProducerClientFactory.Get(topic);
            var eventData = CreateEventData(message, messageHeaders);

            messageHeaders.Times?.Add(DateTime.Now);
            await producerClient.SendAsync(new EventData[] { eventData });
            messageHeaders.Times?.Add(DateTime.Now);
            //.....
            Log.Info($"Milliseconds spent: {(messageHeaders.Times[1]- messageHeaders.Times[0]).TotalMilliseconds});
        }
    }

    private EventData CreateEventData(object message, MessageHeader messageHeaders)
    {
        var eventData = new EventData(Encoding.UTF8.GetBytes(JsonConvert.SerializeObject(message)));
        eventData.Properties.Add("CorrelationId", messageHeaders.CorrelationId);

        if (messageHeaders.DateTime != null)
            eventData.Properties.Add("DateTime", messageHeaders.DateTime?.ToString("s"));
        if (messageHeaders.Version != null)
            eventData.Properties.Add("Version", messageHeaders.Version);

        return eventData;
    }

在日志中，我有将近1秒(~800毫秒）的值，为什么会有这么长的执行时间？

Answer 1

EventHubProducerClient缓慢地打开到事件集线器服务的连接，直到操作第一次需要它。在您的代码片段中，调用SendAsync将触发创建AMQP连接、创建AMQP链接和执行身份验证。

除非客户机关闭，否则大多数将来的调用不会产生这种开销，因为连接和链接是持久的。大多数是该语句中的一个重要区别，因为客户机可能需要在面对网络错误时重新连接，当活动较低且连接空闲时，或者如果事件集线器服务终止连接/链接时。

正如Serkant所提到的，如果您想了解时间安排，最好使用像benchmark.net这样的库，它可以通过大量的迭代获得统计上有意义的结果。