TiOMQ platform系统-产品介绍

TiOMQ Platform（简称“TMQP”）是基于企业版t-io研发的消息中间件平台，专为大规模物联网应用场景设计， 提供了高性能、低延迟、高可靠的消息传递机制，支持亿级别的设备连接和百万级别的并发消息处理能力。

• 产品优势
    高性能，海量连接
  单节点支持百万设备连接，集群场景下可扩展至支持 1 亿+的设备连接，每秒处理1000+万条消息
  跨平台，安全稳定
  基于企业版t-io的网络框架，保证了平台的连接安全与稳定性
  多协议，灵活扩展
  支持 MQTT、HTTP、WebSocket、LwM2M、CoAP，提供以插件形式集成任何私有协议
  可视化监控
  图形化配置、操作与管理，实时监测运行状态，一目了然
  功能概览
  TMQP 由多个组件组成，这些组件共同构建了一个功能强大、可扩展的 MQTT 消息服务器和 物联网平台 。以下是TMQP 核心功能部分：
• 设备连接​
  TMQP V1.0 版本100% 适配 MQTT 3.x 规范，出色的扩展性使其能够轻松处理海量的 MQTT 设备客户端连接。与此同时它还提供了包括 HTTP、 LwM2M/CoAP 在内的其他开放标准协议接入，从而实现更多物联网设备与场景接入。TMQP 还扩展实现了文件传输、延迟发布等功能，丰富使用场景。
• 多协议网关​
  多协议网关使 TMQP 能够支持除使用 MQTT 协议以外的不同通信协议的设备连接到TMQP 服务器。多协议网关会监听设备的连接请求并识别设备使用的通信协议，随后根据相应的协议规范解析设备发送的消息、命令和数据，并将其转换为 MQTT 消息格式进行消息处理。
• 消息路由​
  TMQP 通过支持发布/订阅模式提供了高度可靠的消息传输机制，确保消息能够可靠地传递到目标设备或应用程序。借助 QoS 机制和保留会话能力，即便在不稳定的网络环境下，也能确保数据快速和可靠地传递，从而保障业务的连续性和稳定性。
• 分布式集群​
  TMQP 提供t-io原生的集群能力，能够实现无缝 弹性伸缩 ，避免单点故障。通过极致的优化，单节点每秒能够低时延地实时接收、处理与分发数百万条 MQTT 消息，并通过集群水平扩展支持 1 亿+ 的 MQTT 连接，这对于大规模 IoT 部署至关重要，如车联网、工业 自动化 和智能家居等领域。
• 系统运维​
  通过 TLS/SSL 加密、认证和授权机制，TMQP 能够保障设备数据传输的机密性和完整性。TMQP 内置了多重客户端认证机制，包括用户名密码、JWT、增强认证以及 PSK、X.509 证书，提供了基于 ACL 的发布订阅授权机制。认证与授权数据支持通过 LDAP、HTTP 服务、SQL 和 NoSQL 数据库 等外部企业安全系统进行集成管理，实现灵活多样的客户端安全保护方案。同时，TMQP 还提供了Websocke调试、JsonForm调试、API调试，满足多元化调试场景，同时提供日志监控、系统告警等功能，用户根据自己的业务设置专属的告警规则，实时监控运维故障，避免业务损失。
• 规则引擎与资源配置​
  TMQP 包含一个强大的规则引擎，您可以根据您的需求在TMQP 中配置规则 ，对传入的数据进行处理和路由。您还可以使用 TMQP 内置的 资源管理来实现将 TMQP 与云端服务或数据库集成，以便将 IoT 数据传输到云端进行存储和分析。
• 即时数据处理​
  内置基于 SQL 的规则引擎，能够轻松编排设备事件与消息处理流程，实时地提取、验证、过滤和转换物联网数据。
• 企业资源整合​
  通过开箱即用的 Webhook 与 数据集 成组件，将物联网数据与 40 多个 云服务 和企业系统进行完美整合，包括 Kafka、AWS RDS、MongoDB、Oracle、SAP 以及 时序数据库 等。助力企业有效地管理、分析和利用来自物联网设备的数据，从而支持各种应用和业务需求。
• 集群监控​
  TMQP 提供图形化的管理系统 ，能够实时监控关键统计数据、服务器和节点运行状态，轻松管理客户端连接与功能配置。它还允许对客户端和集群异常行为进行诊断与调试，在线进行 MQTT 设备端到端的问题分析，大大缩短 故障排查 的时间。除此之外，还支持将可观测性数据统计集成到外部 Prometheus，Datadog 以及支持 OpenTelemetry 的服务中，实现更完善的运维监控能力。
• 使用场景
  双向通信
  TMQP 支持各类设备与应用端连接，为设备及应用程序提供双向通信。例如智能家居场景下，手机 App 能够获取各类设备传感器数据，并在需要时将控制指令下发到设备。此模式允许设备与设备、设备与应用进行灵活的一对一或一对多通信。  

• 云端控制指令下发
  TMQP 允许通过 MQTT 消息、REST API 以及 Kafka 进行消息下发，推送数据或远程控制设备。例如金融交易场景下，云端服务可以根据用户关注列表，进行分组实时数据推送。此模式提供了主题映射、下发数据处理以及数据触达统计，能够实现灵活且可靠的数据下发。