Azure Event Hub(Azure事件中心) 是大数据流式处理平台和事件引入服务。 它可以每秒接收和处理数百万个事件。在我们的使用中,需要代码编写的是两个部分:事件生产者和事件接收者
事件生成者:向事件中心发送数据的所有实体。 事件发布者可以使用 HTTPS、AMQP 1.0 或 Apache Kafka(1.0 和更高版本)发布事件。
事件接收者:从事件中心读取事件数据的所有实体。 所有事件中心使用者通过 AMQP 1.0 会话进行连接。 事件中心服务在事件变得可用时通过会话来提供事件。 所有 Kafka 使用者都通过 Kafka 协议 1.0 及更高版本进行连接。
下图显示了事件中心流处理体系结构:
(其他组件说明:https://docs.azure.cn/zh-cn/event-hubs/event-hubs-about#key-architecture-components)
问题描述
在使用事件生产者或接收者时,都需要与Event Hub服务建立连接。那么只要建立了连接,都需要考虑连接空闲超时参数。当发生Timout后,EventHubClient的表现是什么呢?有什么日志输出呢?同时,当新的消息需要发送时,EventHubClient时如何重建的连接呢? 重建连接耗时多长呢?
问题分析
以上问题,都可以通过调试EventHubClient的代码日志来分析。
实验步骤:
准备条件:参考文档,构建EventHub的发送消息代码:
【旧版】使用 Java 向/从 Azure 事件中心 (azure-eventhubs) 发送/接收事件:https://docs.azure.cn/zh-cn/event-hubs/event-hubs-java-get-started-send-legacy
【新版】使用 Java 向/从 Azure 事件中心 (azure-messaging-eventhubs) 发送/接收事件:https://docs.azure.cn/zh-cn/event-hubs/event-hubs-java-get-started-send
1) 在初始化EventHubClient对象时,使用默认的OperationTimout时间(60秒)
2) 在发送第一条消息前,使线程睡眠65秒。验证EventHubClient对象超时后SDK的输出
3) 记录触发发送第一条消息前的时间,获取EventHubClient建立连接的日志。计算耗时时间
4) 根据测试中输出的日志,得出5点结论
1:在2021-03-23 15:17:37.505时候,Connection连接建立成功,由于线程睡眠,所以在2021-03-23 15:18:37.463 (60秒后)Connection关闭,理由是( errorDescription[The connection was inactive for more than the allowed 60000 milliseconds and is closed by container 'LinkTracker')
2:当线程睡眠结束,在2021-03-23T15:18:42.559930300开始发送消息
3:EventHubClient马上开始重新创建 Connection, Session,Link。耗时近2秒(从2021-03-23 15:18:42.578到2021-03-23 15:18:44.592)
4:重建连接后第一条消息发送成功在2021-03-23T15:18:44.829493900
5:第二条,第N条发送的时间就非常的短暂,在300毫秒左右。
总结:EventHub Client在创建过程中的三个关键因素和日志中所打印出的事件顺序
EventHub Client使用AMQP协议的连接创建与关闭的过程: 它涉及到三个主要的部分:connection,session和link
三者关系图
创建连接全过程事件顺序
关闭连接全过程事件顺序
代码文件(pom.xml & SendehmsgApplication.java)和日志可以参考博客园文章:https://www.cnblogs.com/lulight/p/14571236.html
参考资料
Azure 服务总线和事件中心内的 AMQP 1.0 协议指南:https://docs.azure.cn/zh-cn/service-bus-messaging/service-bus-amqp-protocol-guide?toc=https%3A%2F%2Fdocs.azure.cn%2Fzh-cn%2Fevent-hubs%2Ftoc.json&bc=https%3A%2F%2Fdocs.azure.cn%2Fzh-cn%2Fbread%2Ftoc.json#what-is-amqp