开放生态EMQ：高并发MQTT消息助力全球化物联网 消息应用部署

高并发MQTT消息助力全球化物联网/消息应用部署APSARA云栖大会APSARA云栖大会11K+GithubStars100M+20K+40K+37M+50+OASISStartdardorgOASISStartdardorgMQTTCorememberLinuxFoundationmemberCNCFcloud-nativeFoundationmemberEdgeXFoundrysilvermemberEMQ与阿里云网络合作方案EMQ与阿里云网络合作方案APSARA云栖大会单集群提供千万级移动设备的统一接入弹性、可靠、多协议，连接物联网设备实时移动、分发与处理物联网核心数据基于规则引擎的低代码数据处理与集成基于云原生分布式架构的跨云多活部署大规模分布式物联网接入平台，为高可靠、高性能的MQTT平台强大且可定制的规则引擎强大且可定制的规则引擎产品内部集成规则引擎作为基础设施，提供了数据提取、过滤、转换和处理的统一功此外，我们还灵活地集成了关系型数据库、非关系型数据库、时间序列数据库和MQ流处理中间件，实现了多样化的系统集成和应用程序开发，从而快速、持续地实现了这些应对复杂的混合云环境多样的接入协议高并发的数据路由等集成的能力，可以提供百万TPS的性能高可用性及易运维性集成多种数据库实现数据持久化•TDengine、InfluxDB、OpenTSDB、TimescaleDB时序数据库集成多种权限管控和认证协议支持第三方应用集成能力•系统支持TLS/DTLS加密协议，确保数据通信的安全性。•系统支持将设备的在线/离线事件以及消息发送状态•提供代理订阅功能，当设备上线时会自动从数据库中•通过RESTfulAPI，可以与外部应用程序进行集私有化部署私有化部署APSARA云栖大会在阿里云上搜索“EMQX购买”直接本地化布署一键式自动部署和管理集群专用集群确保数据安全和99.99%一键式自动部署和管理集群专用集群确保数据安全和99.99%使用RBAC进行多项目管理开箱即用达到物联网数据集成和企业应用集成能力APSARA云栖大会在阿里云上的全托管MQTT服务标准的标准的MQTTV3.0/3.1.1/5.0协议以及其它标准物联网协议支持内置高性能规则引擎内置高性能规则引擎APSARA云栖大会在阿里云上部署EMQXEnterprise可以为客户带来私有化的EMQXEnterprise的服务部署。目前支持NLB+EC2及K8S的私有化部署方式。设备数据库大数据API软件客户端安全/认证EMQXEnterprise是一款基于Erlang/OTP平台开发的高性能、可扩展的分布式MQTT消息服务器。目前已经与阿里云服务深度集成和对接。为阿里/database/emqsolution?spm=5176.28261954.J_7341193060.7.3dae2f3dExofHM&scm=20140722.S_activity@@%E6%B4%BB%E5%8A%A8@@2452576._.ID_activity@@%E6%B4%BB%E5%8A%A8@@2452576-RL_EMQ-LOC_llm-OR_ser-V_3-RK_rerank-P0_1EMQXCloud是EMQ提供的一种托管式MQTT服务，它可以帮助用户快•Serverless服务：这种服务类型为用户提供了一个完全托管的EMQX服•Dedicated服务：这种服务类型为用户提供了一个独立EMQX集群。资源不可见、由EMQ运维。•BYOC（BringYourOwnCloud）服务：这种服务类型允许用户将EMQXCloud部署在自己的云账户中，从而实现对基础设施的完全控制。软0EMQX产品与阿里云云网络产品整合Broker集群，流式数据处理，数据路由的数据接入服务。通过云计算云布署，做到云-边-端的算力均匀部署，数据实时处理。整体提高IoT场景的应用灵活性、多样性以及数据的完整性、实时性。China(Beijing)China(Hohhot)China(Qingdao)AsiaPacific(Seoul)AsiaPacific(Tokyo)China(Chengdu)China(Shanghai)China(Heyuan)China(Hangzhou)MiddleEast(Dubai)China(Guangzhou)GreenChina(Beijing)China(Hohhot)China(Qingdao)AsiaPacific(Seoul)AsiaPacific(Tokyo)China(Chengdu)China(Shanghai)China(Heyuan)China(Hangzhou)MiddleEast(Dubai)China(Guangzhou)GreenDataCentersAPSARA云栖大会USWest(SiliconValley)USEast(Virginia)AlibabaCloudGlobalInfrastructureEurope(London)China(Ulanqab)EuropeEurope(London)China(Ulanqab)Europe(Frankfurt)China(Fuzhou)ChinaChina(Fuzhou)China(HongKong)China(HongKong)AsiaAsiaPacific(Mumbai)Pacific(Bangkok)AsiaAsiaPacificPacific(Bangkok)Asia30AlibabaCloudRegions89AvailabilityZones依托阿里云全球在30区基础设施部署一中心多区域EMQX5跨区域集群=AsiaPacific(KualaLumpur)AsiaPacific(Singapore)AsiaPacific(Jakarta)结合阿里云业界领先的组网能力结合阿里云业界领先的组网能力可靠多条冗余线路互备独家Rerouting技术极速故障收敛灵活跨地域QoS/flowlog精细管理跨域带宽弹性单TR连接1000VPC单TR支持40000路由智能全链路智能诊断分析全网统一管理AsiaPacific(Sydney)APSARA云栖大会Next-GenofstandardprotocolforloTQUIC(RFC9000)是下一代互联网协议HTTP/3的底层传输协议，与TCP/TLS协议相比，它在减少连接开销与消息延迟的同时，为现代移动避免队头阻塞的多路复用无状态负载均衡现有网络无需改造升级即可支持APSARA云栖大会Howweimplementit双协议兼容，完美融合双协议兼容，完美融合QUIC+MQTT特性EMEMQX5.0：第一个可商用的MQTToverQUIC消息服务NanoMNanoMQ：兼容转换传统MQTT客户端为QUIC连接NanoNanosDK：第一个可商用的MQTToverQUIC客户端MQTToverQUIMQTToverQUIC极大改善了消息延迟，重连速度数据消费进理API进行节点管理、规则创建等数据消费进理API进行节点管理、规则创建等APSARA云栖大会APSARA云栖大会EMQXEMQXECP：云边协同管理平台状态监控规则创建/下发/启停状态监控规则创建/下发/启停异常告警指标统计eKuiper算节点的管控数据传输、配置数据接收可热更新热加载的实时车端数据采集处理/计算/ 轻量化边缘计算引擎可热更新热加载的实时车端数据采集处理/计算/周期性采集变化采集事件统一自定义模板EMQX：高性能MQTT服务器NanoMQ轻量化MQTT消息服务器+车载数据总线在车机端负责车端数据接入、汇聚、分发流转的MQTT消息总轻量化MQTT消息服务器+车载数据总线在车机端负责车端数据接入、汇聚、分发流转的MQTT消息总线作用；业务数据+管理数据统一桥接云端地址迁移聚APSARA云栖大会快速实现边缘端异三层架构实现异常事件告警、调度、处理体化运维管理平台边缘端工业协议网现各类工业设备的接入，可基于轻量输，实现在工业生产弱网环境下的各类数据实时感知与在云端，大规模分布式物联网MQTT消息服务器在云端，大规模分布式物联网MQTT消息服务器EMQX部署在集团云上，可为集团调度指挥中心提供工厂各类工业设备和智慧物联设备的数据汇聚能力，为设备异常事件和处理提供对接AI算法的能力，为集团提供所有工厂的异常事件总集合和持久化能力。EMQ提供的超轻量物联网边缘数据流式分析引擎eKuiper能够在近设备端部署，高EMQ提供的超轻量物联网边缘数据流式分析引擎eKuiper能够在近设备端部署，高效、独立判断异常事件并通过各类智能终现数据的汇聚和缓存，打通处于不同网络中设备、不同系统间的数据壁垒，去除信现数据断点续传，通过QUIC的0-RTT快速重连机制，保证全天候的连接监控，防API服务APPBigDataredisRDSEMQ高可用集群EMQ企业版Suite负载KAFKA集群1规则引擎KAFKASDKKAFKA2GB32960APISDKKAFKANDBPKI/CA认证中心产品全生命周期原厂7*24小时技术服务支持APSARA云栖大会某合资主机厂百万接级高吞吐车联网构建API服务APPBigDataredisRDSEMQ高可用集群EMQ企业版Suite负载KAFKA集群1规则引擎KAFKASDKKAFKA2GB32960APISDKKAFKANDBPKI/CA认证中心产品全生命周期原厂7*24小时技术服务支持2018年，该企业部门开始自研开发全新的智慧车联系统，配合新一代发配置、推送消息、运营关怀等全新车联网业务。智慧车机系统主要规划智能语音、智趣出行、智慧导航、智联控车、智享娱乐、智选充电等六智功能。系统采用EMQXEnterprise集群作为车机接入的MQTT消息中间件。系统于2019年发布，目前已经累计接入十几款车型，近百万车机。日消息通信量超2亿。客户挑战提供车与平台间大并发高吞吐量的数据交互能力；支持对车辆上报的二进制报文进行解析；支持根据业务需求对报文进行数据拆分、数据过滤与分流，对接不同业务系统。阿里云与EMQ解决方案EMQXEnterprise结合阿里云的网络型负载均衡NLB等产品，提供一站式物联网服务，实现百万级TPS高吞吐数据接入能力；基于EMQXEnterprise的编解码功能在接入层实现对国秘报文的实时解析能力；基于EMQXEnterprise规则引擎实现基于业务规则的动态数据拆分与数据分流。私有私有协议APSARA云栖大会应用场景某能源是国内最早也是现有最大的独立目的地充电运营商，拥有全国保有量最大的社区充电站。依威能源重点从以社区场景为代表的目的地充电进行业务布局，关注私人乘用车用户群体，占据用户常规长时间停留的位置，利用汽车空闲时间为其充电，解决没有固定车位、无法安装充电桩用户的充电需求。业务需求•设备接入平台需要解决设备异构化问题，需要支持多种协议接入；•考虑到设备分布区域分散、网络信号差的问题，需要支持弱网环境•充电设备数量大，需要平台能够提供海量设备接入与高吞吐数据持EMQ与阿里云解决方案通过EMQXEnterprise提供的百万级设备接入能力以及TimescaleDB数据持久化插件进行时序数据存储分析，消息队列桥接插件将数据对接自有的微服务运营系统，可实现包括联网状态、充电实时日志、场地电力情况、用户使用记录等在内的最高理论并发3万条/秒、总计高达3千万条/日的数据入库，并实时分析计费。APSARA云栖大会应用场景与业务需求客户挑战•物联网团队属于创新部门，需要快速实现平台原型设计，为创新业务提供快速试错能•研发团队对MQTT协议理解不深，开发过程中问