乐刻运动:基于 RocketMQ + MQTT 实现健身产业数字化升级

本文涉及的产品
Serverless 应用引擎免费试用套餐包,4320000 CU,有效期3个月
注册配置 MSE Nacos/ZooKeeper,118元/月
云原生网关 MSE Higress,422元/月
简介: 乐刻运动通过采用阿里云的云消息队列 RocketMQ 版和云消息队列 MQTT 版,不仅提升了系统的实时数据处理能力,还增强了系统的可扩展性、可靠性和性能,为业务的持续发展和流畅的用户体验,提供了坚实的技术支持,进一步推动了数字经济与健身产业的深度融合。

作者:吉宪、稚柳


乐刻运动:助推数字经济与健身产业深度融合发展


乐刻运动,2015 年创立于杭州的健身产业互联网平台,以让每个人平等享有运动健康的资源和权利为使命,以每天响应 1 亿人次的运动健康需求为愿景。乐刻以用户运营为核心,构建数智中台,打通场景、用户、教练、服务,对健身产业进行数字化升级改造,提高运营效率和供应链管理能力,搭建健身服务新零售生态,助推数字经济与健身产业深度融合发展。截至 2024 年 12月,乐刻运动已在全国 30 多个城市开设超过 1700 家门店。

image.png


乐刻运动在数字化升级中的挑战


在数字化升级过程中,乐刻运动计划在各门店部署物联网设备,覆盖用户进门、签到以及运动器材等场景,以便实时、持续地收集相关信息并对其进行维护管理,从而进一步提升门店运营效率和服务质量。然而,随着业务规模的持续扩大,终端设备数量也在不断增加,带来了以下挑战:


  1. 高并发连接与实时监控:鉴于健身房门店众多,且设备种类和数量繁多,需要一个能够支持大规模并发连接的可靠通信架构,确保所有终端设备的状态被及时监测,并迅速响应任何异常情况。
  2. 轻量低带宽的消息传输:由于网络资源的限制,在客户端设备与服务端之间的连接上,需要采用一种轻量级、低带宽的消息传输协议,以优化数据传输效率并减少对现有网络基础设施的压力。
  3. 高效的消息处理机制:在业务高峰期时,客户端上报数据量大且频率高,需要一套高效的消息处理机制,来避免因服务器应用有限,无法及时消费,而造成消息堆积的问题。


结合 RocketMQ 与 MQTT 的高效解决方案


image.png

为应对上述挑战,乐刻运动采用 RocketMQ 与 MQTT 协议相结合的解决方案,显著提升了整体架构的稳定性和可扩展性,提高了消息处理效率,确保了高并发场景下的业务连续性,最终优化了用户体验。


  1. MQTT - 海量终端数据实时收集:通过 MQTT 协议,系统能够实时收集健身房内各类物联网设备上报的数据,满足高并发需求,确保数据传输的高效与可靠。
  2. RocketMQ - 消息缓存与负载均衡:将 MQTT 的消息流出挂载到 RocketMQ,通过 RocketMQ 对客户端采集到的大量消息进行消息缓存和负载均衡,从而有效缓解服务端的压力,确保系统的稳定运行。


云消息队列助力乐刻运动数字化升级


在实施上述方案的过程中,乐刻运动选择了阿里云的云消息队列 RocketMQ 版和云消息队列 MQTT 版作为核心消息中间件,这两个产品在实际生产环境中展现出显著的优势和价值。


1. 产品简介

  • 云消息队列 RocketMQ 版:云消息队列 RocketMQ 版是阿里云基于 Apache RocketMQ 构建的低延迟、高并发、高可用、高可靠的分布式“消息、事件、流”统一处理平台。
  • 云消息队列 MQTT 版:云消息队列 MQTT 版是专为移动互联网(MI)、物联网(IoT)领域设计的消息产品,覆盖直播互动、金融支付、智能餐饮、即时聊天、移动 Apps、智能设备、车联网等多种应用场景;通过对 MQTT、WebSocket 等协议的全面支持,连接端云之间的双向通信,实现 C2C、C2B、B2C 等业务场景之间的消息通信,可支撑千万级设备与消息并发。


2. 实际生产环境中的优势和价值

  • 实时数据处理:云消息队列 MQTT 版通过 MQTT 协议实现终端设备与服务器之间的实时通信,利用发布/订阅模式,确保设备状态和用户行为的及时监控和响应,从而实现高效的实时数据处理能力。
  • 高度可扩展性:云消息队列 MQTT 版具备强大的横向扩展能力,能够轻松支持海量终端设备和传感器的接入,能够轻松应对健身房规模不断扩大带来的设备接入需求。
  • 可靠性和稳定性:云消息队列 MQTT 版的 MQTT 协议支持多种服务质量(QoS)级别,可以根据业务需求选择合适的级别,确保消息可靠传递,防止数据丢失。
  • 性能表现卓越:服务端应用之间隐含着对等和任务分摊的关系,云消息队列 RocketMQ 版的集群消费模式提供原生的负载均衡机制,能够提升系统的整体性能,确保高并发场景下的高效稳定运行。


乐刻运动通过采用阿里云的云消息队列 RocketMQ 版和云消息队列 MQTT 版,不仅提升了系统的实时数据处理能力,还增强了系统的可扩展性、可靠性和性能,为业务的持续发展和流畅的用户体验,提供了坚实的技术支持,进一步推动了数字经济与健身产业的深度融合。

相关文章
|
7月前
|
消息中间件 人工智能 Apache
Apache RocketMQ 中文社区全新升级!
RocketMQ 中文社区升级发布只是起点,我们将持续优化体验细节,推出更多功能和服务,更重要的是提供更多全面、深度、高质量的内容。
660 19
|
1月前
|
消息中间件 运维 Java
招行面试:RocketMQ、Kafka、RabbitMQ,如何选型?
45岁资深架构师尼恩针对一线互联网企业面试题,特别是招商银行的高阶Java后端面试题,进行了系统化梳理。本文重点讲解如何根据应用场景选择合适的消息中间件(如RabbitMQ、RocketMQ和Kafka),并对比三者的性能、功能、可靠性和运维复杂度,帮助求职者在面试中充分展示技术实力,实现“offer直提”。此外,尼恩还提供了《尼恩Java面试宝典PDF》等资源,助力求职者提升架构、设计、开发水平,应对高并发、分布式系统的挑战。更多内容及技术圣经系列PDF,请关注【技术自由圈】获取。
|
6月前
|
消息中间件 Java Kafka
消息传递新纪元:探索RabbitMQ、RocketMQ和Kafka的魅力所在
【8月更文挑战第29天】这段内容介绍了在分布式系统中起到异步通信与解耦作用的消息队列,并详细探讨了三种流行的消息队列产品:RabbitMQ、RocketMQ 和 Kafka。其中,RabbitMQ 是一个基于 AMQP 协议的开源消息队列系统,支持多种消息模型;RocketMQ 则是由阿里巴巴开源的具备高性能、高可用性和高可靠性的分布式消息队列,支持事务消息等多种特性;而 Kafka 作为一个由 LinkedIn 开源的分布式流处理平台,以高吞吐量和良好的可扩展性著称。此外,还提供了使用这三种消息队列发送和接收消息的代码示例。总之,这三种消息队列各有优势,适用于不同的业务场景。
88 3
|
3月前
|
消息中间件 大数据 Kafka
大厂面试高频:Kafka、RocketMQ、RabbitMQ 的优劣势比较
本文深入探讨了消息队列的核心概念、应用场景及Kafka、RocketMQ、RabbitMQ的优劣势比较,大厂面试高频,必知必会,建议收藏。关注【mikechen的互联网架构】,10年+BAT架构经验倾囊相授。
大厂面试高频:Kafka、RocketMQ、RabbitMQ 的优劣势比较
|
5月前
|
消息中间件 存储 Cloud Native
基于 RocketMQ 的云原生 MQTT 消息引擎设计
本文将介绍阿里云如何将 Serverless 架构应用于消息队列,有效降低运营成本,同时利用云原生环境的特性,为 IoT 设备提供快速响应和灵活伸缩的通讯能力。
274 30
|
3月前
|
消息中间件 存储 监控
ActiveMQ、RocketMQ、RabbitMQ、Kafka 的区别
【10月更文挑战第24天】ActiveMQ、RocketMQ、RabbitMQ 和 Kafka 都有各自的特点和优势,在不同的应用场景中发挥着重要作用。在选择消息队列时,需要根据具体的需求、性能要求、扩展性要求等因素进行综合考虑,选择最适合的消息队列技术。同时,随着技术的不断发展和演进,这些消息队列也在不断地更新和完善,以适应不断变化的应用需求。
146 1
|
5月前
|
消息中间件 监控 物联网
MQTT协议对接及RabbitMQ的使用记录
通过合理对接MQTT协议并利用RabbitMQ的强大功能,可以构建一个高效、可靠的消息通信系统。无论是物联网设备间的通信还是微服务架构下的服务间消息传递,MQTT和RabbitMQ的组合都提供了一个强有力的解决方案。在实际应用中,应根据具体需求和环境进行适当的配置和优化,以发挥出这两个技术的最大效能。
294 0
|
7月前
|
消息中间件 安全 API
Apache RocketMQ ACL 2.0 全新升级
RocketMQ 作为一款流行的分布式消息中间件,被广泛应用于各种大型分布式系统和微服务中,承担着异步通信、系统解耦、削峰填谷和消息通知等重要的角色。随着技术的演进和业务规模的扩大,安全相关的挑战日益突出,消息系统的访问控制也变得尤为重要。然而,RocketMQ 现有的 ACL 1.0 版本已经无法满足未来的发展。因此,我们推出了 RocketMQ ACL 2.0 升级版,进一步提升 RocketMQ 数据的安全性。本文将介绍 RocketMQ ACL 2.0 的新特性、工作原理,以及相关的配置和实践。
13689 9
|
6月前
|
消息中间件 存储 监控
RabbitMQ、Kafka对比(超详细),Kafka、RabbitMQ、RocketMQ的区别
RabbitMQ、Kafka对比(超详细),Kafka、RabbitMQ、RocketMQ的区别,设计目标、适用场景、吞吐量、消息存储和持久化、可靠性、集群负载均衡
RabbitMQ、Kafka对比(超详细),Kafka、RabbitMQ、RocketMQ的区别
|
6月前
|
消息中间件 存储 Cloud Native
RocketMQ从4.9.7 升级到5.3.0有什么变化?
【8月更文挑战第25天】RocketMQ从4.9.7 升级到5.3.0有什么变化?
405 4

相关产品

  • 云消息队列 MQ