Logo
  • Cases & Projects
  • Developers
  • Contact
Sign InSign Up

Here you can add a description about your company or product

© Copyright 2025 Makerkit. All Rights Reserved.

Product
  • Cases & Projects
  • Developers
About
  • Contact
Legal
  • Terms of Service
  • Privacy Policy
  • Cookie Policy
Development of an UltraLow Latency In-Memory Message Broker Supporting Real-Time Tree Data Updates
  1. case
  2. Development of an UltraLow Latency In-Memory Message Broker Supporting Real-Time Tree Data Updates

Development of an UltraLow Latency In-Memory Message Broker Supporting Real-Time Tree Data Updates

scalac.io
Information technology
Financial services
Gaming

High-Performance Real-Time Data Processing and Messaging Challenges

The client requires a high-performance message broker capable of processing thousands of in-memory data structure updates per second. The system must deliver updates to relevant subscribers with sub-millisecond latency, ensuring sequential and reliable data delivery. Existing solutions faced limitations in throughput, latency, and efficient memory management, which hindered the scalability and responsiveness of their core services.

About the Client

A large-scale, innovative technology firm specializing in real-time data processing and high-speed communication services for backend infrastructure.

Goals for Building a Next-Generation Low Latency Message Broker

  • Develop a stable and scalable in-memory message broker capable of handling over 50,000 leaf structure updates per second.
  • Ensure real-time delivery of message notifications to subscribers within less than 1 millisecond after receiving data updates.
  • Implement sequential, ordered processing of data updates and notifications, supporting complex path subscriptions with wildcards.
  • Optimize memory usage to minimize garbage collection impact and improve overall system performance.
  • Design a simple, elegant, and highly usable API with a refined DSL for ease of integration and maintenance.
  • Establish a robust CI/CD pipeline with comprehensive unit and integration testing to support reliable deployment and updates.

Core Functional Specs for Low Latency In-Memory Messaging System

  • High-throughput engine processing at minimum 50,000 leaf updates per second.
  • Low latency delivery (<1 ms) of messages to all relevant subscribers immediately after data update.
  • Sequential processing of data modifications and subscriber notifications to preserve input order.
  • Support for complex subscription paths with wildcards for flexible data access.
  • Optimized memory management to reduce garbage collection pauses and improve throughput.
  • Refined domain-specific language (DSL) for simplified configuration and usage.
  • Resilient architecture ensuring stability under high load conditions.

Architectural and Technology Stack Preferences for Real-Time Messaging

Typed Akka Actors for concurrent and distributed processing.
Akka gRPC for network communication in server-client interactions.
Low-level TCP protocol implementation for fine control over message flow and buffering.
Protobuf for efficient serialization/deserialization directly from raw bytes.

Essential External System Integrations

  • External subscriber notification services with support for complex subscription paths.
  • Monitoring and logging systems for performance metrics and health checks.
  • CI/CD tools for continuous integration and deployment pipelines.

Critical System Performance and Reliability Criteria

  • Process over 50,000 leaf updates per second with stable performance.
  • Deliver messages within less than 1 millisecond after update reception.
  • Minimize garbage collection pauses through memory optimizations.
  • Ensure high availability and fault tolerance under sustained high load.
  • Maintain over 99.9% uptime and resilience during network fluctuations.

Projected Business Benefits from the Advanced Messaging System

The new system aims to enable the client to handle high-volume, real-time data updates efficiently, significantly reducing message delivery latency to under 1 ms. This will improve the responsiveness and scalability of their core services, supporting growth in high-speed transaction processing, real-time analytics, and complex event handling, thereby strengthening their competitive position in the market.

More from this Company

Decentralized Advertisement Space Marketplace Utilizing ERC721 Tokens
Development of a Budget Tracking and Visualization Platform for NGOs and Development Agencies
Development of an Advanced Payroll Management System with Modernized Infrastructure and Reporting Capabilities
Advanced Data Ingestion and Stateful Stream Processing for Large-Scale Messaging Platforms
Design and Implementation of a Scalable, Reliable Cloud Infrastructure with CI/CD Automation