WHITE PAPER
MQTT Platform for AI: Empowering AI with Real-Time Data →

Introduction

JAGAT is a location-based mobile social app with the goal of strengthening acquaintance relationships and improving user safety. Its users expect real-time information, personalized recommendations, and secure data transmission.

Since its launch less than a year ago, JAGAT has made frequent appearances on the Apple Store homepage and has consistently ranked as the most downloaded app in countries such as Japan, Vietnam, Indonesia, Russia, Ukraine, and other parts of the Asia-Pacific region. With close to 15 million downloads to date, JAGAT is gaining popularity in the Asian market and is emerging as a fashionable social product among the new generation globally.

JAGAT

With rapid growth, traditional messaging systems have struggled to keep up with JAGAT's global expansion. To address these challenges, EMQ provides JAGAT with a global, large-scale messaging service solution through its EMQX MQTT Platform. This solution utilizes cross-regional communication and message routing, high concurrency, and low latency to enhance JAGAT's data collection and processing efficiency, resulting in a more responsive platform for faster information delivery, better user needs response, and enhanced data potential.

Needs and Challenges

Global Cross-Regional Communication

JAGAT's market strategy prioritizes expansion in the Asia-Pacific region and gradual global outreach. This requires a system capable of cross-regional and cross-continental message routing while adhering to data privacy and compliance requirements of various countries and regions.

High Concurrency, Low Latency, and Reliable Message Transmission

JAGAT needs to handle a large number of concurrent users, frequent location updates, and the operation of forwarding messages to all friends. The system must support high message throughput and meet high demands for message transmission latency. Additionally, instant messaging (IM) must ensure high security and reliability, and location messages must maintain proper sequencing.

System Scalability

The system must be highly scalable to adapt to changes in the total number of users and fluctuations in online user activity.

Powerful and Convenient Integration

The messaging system often needs to interact with multiple external systems (e.g., databases, payment platforms) and requires quick integration with various cloud services, middleware, and databases.

Enabling Global Large-Scale Messaging Service with EMQX

EMQX is the world’s leading enterprise MQTT platform. It flawlessly caters to JAGAT's requirements for constructing a global messaging system for social applications, offering unparalleled reliability and performance in real-time data movement, processing, and integration. This paves the way for JAGAT to delve into analyzing user behavior patterns and extracting substantial value from user data.

Low Latency Global Communication with Distributed Architecture

Using EMQX's high-availability distributed architecture, JAGAT has built a multi-center data processing framework, ensuring users in the same region can directly forward messages through edge nodes. This reduces message delays caused by network links and alleviates the pressure on central servers, enabling low-latency processing of massive messages even with high user growth and concurrency.

Distributed Architecture

Outstanding Performance Ensuring Massive Message Transmission

EMQX supports a massive number of concurrent connections, with a single cluster capable of handling tens of millions, or even hundreds of millions, of MQTT connections. Thanks to Erlang's concurrent programming design, EMQX excels in concurrent processing, with a single server capable of processing and transmitting millions of messages per second. EMQX provides comprehensive SSL/TLS support and, along with the ACK mechanism, ensures message security and reliability.

Elastic Scalability to Handle Data Scale Changes

EMQX supports horizontal scaling, providing JAGAT's data platform with elastic scalability. This allows dynamic expansion during real-time fluctuations in user numbers and data peaks, maintaining stable system operation.

Out-of-Box Data Integration Capabilities

Through EMQX's rule engine and data bridging features, quick integration with cloud services and various middleware databases can be achieved with simple configurations on a visual interface, without writing code. This enables real-time data extraction, filtering, enrichment, and transformation.

Message Retention and Offline Messaging

EMQX supports retaining only the latest status of similar messages, reducing unnecessary data transmission and ensuring real-time updates of the latest social dynamics. Additionally, in cases of no or weak mobile signals, EMQX's offline messaging feature allows the server to cache data and send it to users as soon as the network signal recovers.

Proxy Subscription Reducing Development Workload

Through proxy subscription for similar data, message publishing and subscription can be easily controlled on the server side, without requiring the client to handle message reception and sending. This reduces the business development workload on the SDK side.

Future Prospects

Global Development

With the new Mira architecture introduced in EMQX 5.0, cluster horizontal scaling capabilities have been significantly enhanced, providing reliable support for JAGAT's global expansion.

High Availability Services

As JAGAT's user base grows and commercialization improves, the demand for service reliability and security will increase. EMQX's powerful features, such as zero-downtime rolling upgrades, will further enhance system stability and security.

Ultimate User Experience

EMQX is the first to introduce MQTT over QUIC, whose features like multiplexing and connection migration can greatly enhance message transmission quality, offering vast potential for improving JAGAT's product performance and user experience.