我们很高兴地宣布 TBMQ 的发布 2.1.0！该版本引入了负责管理集成的集成执行器微服务，标志着一个重要的里程碑。它支持向外部系统进行可扩展的多协议消息传递，首先支持 HTTP、Kafka 和 MQTT 出站集成。我们还发布了官方 舵图 对于 TBMQ，简化了 K8s 环境中基础设施的部署和管理。
整合执行者
TBMQ 2.1 的核心是 整合执行者 - 一种新的专用微服务，以可扩展和有弹性的方式启动和管理集成，所有这些都构建在 无数据丢失架构 以获得最大的可靠性。
TBMQ 不是将集成逻辑嵌入到代理中，而是将此责任委托给集成执行器。这种架构确保了清晰的责任分离，使代理能够专注于 MQTT 协议处理，而执行器则负责向外部系统传递消息。结果：更好的性能、隔离性和可扩展性。
集成执行器通过 Kafka 与 TBMQ 通信，Kafka 充当缓冲区和传输层。当 MQTT 消息与集成订阅匹配时，TBMQ 将其转换为集成事件，并通过 Kafka 将其路由到适当的执行程序实例。然后，执行器将其转发到配置的目标，例如 HTTP 端点、Kafka 主题或另一个 MQTT 代理。
亮点：
- MQTT 协议逻辑和集成交付之间清晰分离。
- 内置支持 HTTP协议, 卡夫卡， 和MQTT 出站集成。
- 水平可扩展：并行运行多个执行器。
- 每个集成都使用一个 专门的 Kafka 主题 用于消息处理隔离和高吞吐量。
- 具有重试策略和丰富的监控指标的高级错误处理。
该架构由 Kafka 支持的缓冲和弹性处理提供支持，可确保容错、无损的消息传递。详细了解集成执行器如何在我们的 官方文档.
集成
TBMQ 2.1 引入了强大且可扩展的集成系统，允许您将 MQTT 消息转发到外部系统以进行存储、处理或实时工作流程。
此版本包括三种出站集成类型：
- HTTP 集成 – 通过 HTTP（S） 将 MQTT 消息发送到 REST API 或 Webhook。
- 卡夫卡集成 – 使用基于 TCP（TLS） 的本机 Kafka 协议将消息转发到 Kafka 主题。
- MQTT 集成 – 将 TBMQ 桥接到其他 MQTT 代理，从而实现通过 MQTT（S） 的跨代理通信。
每个集成都可以通过 TBMQ Web UI 或 REST API 轻松配置。您可以定义 主题过滤器、连接参数以及独立启用/禁用集成。当消息与定义的过滤器匹配时，它们会自动路由到正确的外部系统，所有这些都通过集成执行器微服务异步处理。
这些集成使开发人员能够：
- 建造 事件驱动的管道 跨系统。
- 将物联网数据传输至 分析平台或者数据湖.
- 连接 TBMQ 遗留系统, 云服务， 或者第三方平台.
凭借对并行运行的多个集成的支持、可扩展的执行模型以及有保证的消息传递，TBMQ 可以轻松地将 MQTT 数据集成到更广泛的基础设施中。
HTTP 集成
这HTTP 集成 允许您将 MQTT 消息实时转发到 REST API 和 Webhook。这非常适合将 TBMQ 与云平台、无服务器功能或公开 HTTP（S） 端点的任何服务集成。
主要亮点：
- 支持 HTTP 和 HTTPS 协议。
- 可定制的标头、有效负载格式和身份验证选项。
- 非常适合通知外部系统或激活业务逻辑。
由于其简单性和多功能性，HTTP 集成是物联网和消息传递管道中最受欢迎且应用最广泛的选项之一。
MQTT 集成
这MQTT 集成 允许您将消息从 TBMQ 转发到外部 MQTT 代理，从而启用 经纪人与经纪人之间的沟通。这在多层或多区域架构中非常有用。
这种集成使得 TBMQ 与其他 MQTT 生态系统的连接变得容易，无论您是在云和边缘之间中继消息、同步环境还是桥接到旧平台。
主要亮点：
- 使用连接到其他经纪人 MQTT 或 MQTTS.
- 非常适合跨代理通信、数据复制或互连隔离集群。
- 支持主题过滤和可定制的转发规则。
- 可以充当 TBMQ 和 Mosquitto 或 ThingsBoard MQTT 传输等第三方代理之间的桥梁。
使用此集成可以安全、高效地扩展 TBMQ 的跨环境覆盖范围。
卡夫卡集成
这卡夫卡集成 使 TBMQ 能够使用以下方法将消息直接流式传输到 Kafka 主题中 卡夫卡二进制协议 （TCP/TLS）。它专为高吞吐量、事件驱动的数据管道和实时处理而设计。
主要亮点：
- 支持本机 Kafka 连接。
- 自动将 MQTT 主题映射到 Kafka 主题。
- 非常适合大数据、分析和流处理用例。
- 与任何 Kafka 部署兼容，例如 Confluence、MSK 或自我管理集群。
这种集成将 MQTT 世界与现代事件流系统联系起来，并允许可扩展的下游处理。
舵图
Helm 是 Kubernetes 采用最广泛的包管理器。它通过将所有 Kubernetes 清单和配置选项捆绑到可重用图表中，简化了复杂应用程序的部署和管理。与我们的 舵图，TBMQ 用户只需使用几个命令，即可以可重复且标准化的方式部署整个堆栈，包括代理节点、集成执行器和依赖项。
使用 Helm 的好处
- 更快的部署：Helm 可以在开发和生产环境中快速、一致地设置 TBMQ。
-
可配置性：用户可以通过以下方式轻松覆盖设置（例如数据库凭据、资源限制和 MQTT 设置）
values.yaml文件，无需编辑模板。 - 特定于环境的设置：维护开发、登台或生产的定制配置，减少部署错误。
- 升级和回滚：Helm 跟踪发布历史记录，如果出现问题，可以轻松回滚到稳定版本。
- CI/CD 集成：Helm 自然地适合 GitOps 工作流程，并自动执行 CI/CD 管道中的集群部署。
TBMQ Helm 图表中包含哪些内容？
我们的官方图表提供了以云原生方式运行 TBMQ 所需的一切：
- 核 TBMQ经纪商 支持 MQTT 和 MQTT over TLS 的部署。
- 整合执行者具有受支持集成类型（HTTP、MQTT、Kafka）配置的微服务。
- 内置子图部署 PostgreSQL, 雷迪斯， 和卡夫卡.
- 具有 TLS 的可配置入口、具有 TLS 支持的 LoadBalancer 服务、Kubernetes 就绪性/活跃性探测以及有状态组件的持久存储。
角19
我们将 TBMQ UI 从 Angular 15 升级到 Angular 19，在性能、用户体验和长期可维护性方面带来了显着改进。此升级还提高了与现代库和工具的兼容性，确保该平台面向未来。除了版本升级之外，我们还用 Tailwind CSS 替换了 Angular Flex-Layout，以实现更清晰、更快的样式设计，并切换到 Angular 的 esbuild 构建器以提高构建性能。这些变化共同带来了一个响应更快、更美观、更易于维护的界面。
最后的话
我们很高兴为您带来这个强大的更新，我们迫不及待地想看看您用它构建了什么。
查看完整文档 集成 并使用我们的官方部署 TBMQ 2.1 ArtifactHub 上的 Helm 图表.
通过加星来支持我们 TBMQ GitHub 存储库、分享反馈以及开放问题或 PR。
