Pub/Sub Messaging Architecture

High-performance messaging with sub-millisecond latency across millions of concurrent connections. Real-time updates, live collaboration, and instant notifications work automatically without custom WebSocket management.

Try Messaging View Documentation

Message-Driven Architecture

EMQX Foundation

ZBlox Platform uses EMQX, the world's most scalable MQTT messaging platform, providing highly scalable multi-broker architecture with low latency and high throughput that outperforms traditional messaging solutions.

Unlike platforms that bolt messaging onto HTTP APIs, ZBlox is built around MQTT messaging from the ground up, creating naturally real-time applications with automatic collaboration capabilities and sub-millisecond response times.

Pub/Sub at Scale

The messaging system supports millions of concurrent connections with intelligent routing, automatic load balancing, and distributed clustering. Publishers and subscribers connect seamlessly without knowing about each other's existence.

Built-in quality-of-service levels ensure reliable message delivery, while topic-based routing enables sophisticated event patterns including real-time UI updates, collaborative editing, and instant notifications across all connected platforms.

Real-Time Everything

Every aspect of the platform leverages messaging for instant updates. Service functions communicate through topics, UI changes propagate automatically, and collaborative features work naturally without custom WebSocket implementation.

This messaging-centric architecture eliminates API maintenance overhead while providing the foundation for modern real-time applications that users expect from collaborative platforms.

Messaging Features

Sub-Millisecond Latency

Optimized configuration delivers messages in under 1ms for real-time collaboration and instant user feedback.

🌐

Millions of Connections

Horizontal scaling supports millions of concurrent connections with automatic load balancing and failover capabilities.

🔒

Built-in Security

Every message includes OIDC bearer tokens for authentication, with topic-level authorization and automatic audit logging.

📱

Cross-Platform

Native MQTT support across web browsers, mobile apps, IoT devices, and server applications with unified API.

🔄

Reliable Delivery

QoS levels ensure message delivery guarantees from fire-and-forget to exactly-once delivery with persistent sessions.

📊

Complete Observability

Built-in metrics, message tracing, and performance monitoring provide full visibility into messaging patterns and bottlenecks.

Message Topic Patterns

Standardized topic patterns enable predictable, scalable messaging across all platform components

Service Function Calls

service/{serviceName}
Examples:
service/UserManagement - User management operations
service/PaymentProcessing - Payment service calls
service/DocumentGeneration - Document processing functions

Real-Time UI Updates

ui/change/{user-id}
ui/change/group/{group-id}
ui/change/global
Examples:
ui/change/user123 - Personal dashboard updates
ui/change/group/team-alpha - Team collaboration updates
ui/change/global - System-wide announcements

Data Change Events

ui/data/{entity-type}/{entity-id}
Examples:
ui/data/order/12345 - Order status changes
ui/data/document/doc-789 - Document updates
ui/data/user/user456 - Profile changes

Session Management

session/{session-id}/{event-type}
Examples:
session/sess123/connected - User session start
session/sess123/activity - User activity tracking
session/sess123/notification - Session notifications

Performance at Scale

Real-world performance metrics from production deployments

<1ms
Message Latency
5M+
Concurrent Connections
1M+
Messages/Second
99.99%
Uptime SLA
Auto
Scaling
Zero
Message Loss

Real-World Benefits

Eliminate Integration Complexity

Traditional applications spend 60-90% of development time on integration between services, APIs, and databases. MQTT messaging eliminates this overhead by providing a unified communication layer.

Developers focus on business logic while the platform handles message routing, delivery guarantees, error handling, and scaling automatically. No more custom WebSocket implementations or API versioning headaches.

Natural Collaboration

Real-time collaboration features that typically require months of custom development work automatically through the messaging infrastructure. Multiple users can work on the same data with instant updates and conflict resolution.

Live cursors, collaborative editing, instant notifications, and presence indicators work seamlessly across web, mobile, and desktop applications without additional development effort.

Experience Real-Time Messaging

See how MQTT messaging transforms application architecture and user experience

Live Demo Technical Documentation