Designing a Chat System Like WhatsApp / iMessage

Difficulty: Intermediate Prerequisites:Message Queues, Caching, and WebSockets


TL;DR

A chat system delivers messages in real-time using WebSockets for online users and stores-then-forwards for offline users.

flowchart LR
    SENDER["Sender"]:::client
    WS["WebSocket Servers"]:::service
    CHAT["Chat Service"]:::service
    STORE[("Message Store<br/>Cassandra")]:::data
    K["Kafka<br/>fan-out"]:::async
    PUSH["Push Notifications<br/>FCM APNs"]:::external
    RECEIVER["Receiver"]:::client

    SENDER -->|"1. Open WebSocket"| WS
    WS -->|"2. Forward message"| CHAT
    CHAT -->|"3. Persist message"| STORE
    CHAT -->|"4. Publish to fan-out"| K
    K -->|"5. Fan out"| WS
    CHAT -->|"6. Push offline alert"| PUSH
    WS -->|"7. Deliver to recipient"| RECEIVER

    classDef client fill:#4c3a5e,stroke:#818cf8,color:#e2e8f0
    classDef service fill:#1a3a2a,stroke:#4ade80,color:#e2e8f0
    classDef async fill:#AB47BC,stroke:#4A148C,color:#fff
    classDef data fill:#3b3520,stroke:#fbbf24,color:#e2e8f0
    classDef external fill:#4a1942,stroke:#f472b6,color:#e2e8f0

In 3 sentences: Clients maintain a persistent WebSocket connection to the server. When a message is sent, the server persists it, looks up which server the receiver is connected to, and pushes it down their WebSocket. If the receiver is offline, the message waits in a queue and a push notification is sent.


Understanding the Problem

πŸ’¬ What is a chat system? A real-time messaging platform that lets users send text, images, and files to individuals or groups. Messages must be delivered reliably (even if the recipient is offline), ordered correctly, and displayed in real-time. Think WhatsApp, Telegram, Facebook Messenger, or Slack. The hard parts: guaranteed delivery across flaky mobile networks, real-time push without polling, group fan-out at scale, and end-to-end encryption.

Naive First Cut

flowchart LR
    SENDER["Sender"]:::client
    API["Chat API"]:::service
    DB[("Messages DB<br/>one table")]:::data
    RECEIVER["Receiver<br/>polls every 5s"]:::client

    SENDER --> API
    API --> DB
    RECEIVER --> API

    classDef client fill:#4c3a5e,stroke:#818cf8,color:#e2e8f0
    classDef service fill:#1a3a2a,stroke:#4ade80,color:#e2e8f0
    classDef data fill:#3b3520,stroke:#fbbf24,color:#e2e8f0

Sender POSTs message to an API, stored in a DB. Receiver polls the API every 5 seconds for new messages.

Why this breaks:

Prior Art

Technology Choices

Tier Purpose Primary pick Alternatives
Real-time transport Push messages to online clients WebSocket (long-lived) SSE, MQTT (IoT/mobile-optimized), gRPC streaming
Connection management Track who’s online on which server Redis Pub/Sub + connection registry Kafka, custom session store
Message storage Durable, ordered message log Cassandra (partition per conversation) ScyllaDB, DynamoDB, TiDB
Message queue Decouple sender from fan-out Kafka (per-user topic or partition) SQS, RabbitMQ, Pulsar
Offline delivery Store messages until recipient connects Redis sorted set per user SQS per user, Cassandra unread table
Presence Who’s online Redis with TTL per user Dedicated presence service
Media storage Images, files, voice notes S3 / GCS with CDN MinIO, Azure Blob
Push notifications Offline users FCM + APNs OneSignal, SNS
E2E encryption Message privacy Signal Protocol (Double Ratchet) Custom, Noise Protocol

Functional Requirements

Core:

  1. Users can send messages (text) to another user in real-time (1:1 chat).
  2. Users can create groups and send messages to all group members.
  3. Messages are delivered reliably even if the recipient is offline (store-and-forward).

Below the line:

Non-Functional Requirements

Core:

Below the line:

Scale Estimation (Back-of-Envelope)

Core Entities

API / System Interface

WebSocket: wss://chat.example.com/ws
  β†’ Client authenticates on connect (JWT)
  β†’ Bidirectional: send messages, receive messages, typing, presence

REST (fallback + media):
POST /v1/messages         β†’ send a message (fallback if WS down)
GET  /v1/conversations/:id/messages?after=<seqNo>  β†’ sync history
POST /v1/media/upload     β†’ upload image/file, get a mediaUrl
POST /v1/groups           β†’ create group

Wire format (over WebSocket):

{"type": "message", "to": "conv_123", "text": "hello", "clientMsgId": "uuid"}
{"type": "ack", "messageId": "msg_456", "status": "delivered"}
{"type": "typing", "conversationId": "conv_123", "userId": "u_789"}

Security: WebSocket authenticated via JWT on handshake. clientMsgId is for client-side dedupe (idempotency). Server generates the authoritative messageId and timestamp.

High-Level Design

1) User sends a 1:1 message (both online)

New components we need:

  1. WebSocket Servers - maintain persistent two-way connections with every online user.
    πŸ’‘ WebSocket = a persistent connection that stays open so the server can push messages instantly without the client asking. Unlike HTTP (ask β†’ answer β†’ done), WebSocket keeps the line open. Learn more β†’
  2. Chat Service - the brain. Receives messages, persists them, and figures out where the recipient is connected.
  3. Message Store (Cassandra) - permanent storage for all messages. Partitioned by conversation so β€œload chat history” is a single partition read.
    πŸ’‘ Cassandra is a distributed wide-column database designed for heavy writes. Partitioning by conversation_id means loading a chat history is a single-partition read - O(1) regardless of total messages in the system.
  4. Connection Registry (Redis) - a fast lookup table mapping userId β†’ which WebSocket server they're on. When a message arrives for Bob, we check Redis to find which server is holding Bob’s connection.
flowchart LR
    SENDER["Sender"]:::client
    WS1["WebSocket Server A"]:::service
    CHAT["Chat Service"]:::service
    STORE[("Message Store<br/>Cassandra")]:::data
    ROUTE["Connection Registry<br/>Redis"]:::data
    WS2["WebSocket Server B"]:::service
    RECEIVER["Receiver"]:::client

    SENDER -->|"1. Open WebSocket"| WS1
    WS1 -->|"2. Forward message"| CHAT
    CHAT -->|"3. Persist message"| STORE
    CHAT -->|"4. Lookup receiver server"| ROUTE
    ROUTE -->|"5. Route to Server B"| WS2
    WS2 -->|"6. Deliver to recipient"| RECEIVER

    classDef client fill:#4c3a5e,stroke:#818cf8,color:#e2e8f0
    classDef service fill:#1a3a2a,stroke:#4ade80,color:#e2e8f0
    classDef data fill:#3b3520,stroke:#fbbf24,color:#e2e8f0

Step-by-step flow:

  1. Sender types β€œHey, are you free tonight?” and hits send β†’ message travels over their open WebSocket connection to Server A
  2. Server A forwards the message to the Chat Service
  3. Chat Service persists the message to Cassandra (partition key = conversationId, so all messages in a chat live together) - now it’s durable, even if everything crashes
  4. Chat Service asks Redis: β€œWhich server is the receiver connected to?” β†’ answer: Server B
  5. Chat Service pushes the message to Server B (via internal gRPC or pub/sub)
  6. Server B pushes the message down the receiver’s WebSocket β†’ message appears on their screen instantly
  7. Receiver’s app sends back a delivered acknowledgment β†’ this receipt flows back to the sender so they see the double-check βœ“βœ“

Why WebSocket instead of HTTP polling? With polling, each user would hit our servers every 2 seconds asking β€œany new messages?” - for 500M users, that’s 250M requests/second of mostly-empty responses. WebSocket keeps a persistent connection open so the server pushes messages the instant they arrive - zero wasted requests, sub-second delivery.

2) Receiver is offline - store and forward

New components we need (in addition to the ones above):

  1. Offline Queue (Redis sorted set) - when the receiver isn’t connected, we park message IDs here. Scored by sequence number so when they reconnect, we drain messages in perfect order.
  2. Push Service - sends push notifications to wake up the user’s phone.
    πŸ’‘ Think of it as the β€œtap on the shoulder” that tells the user to open the app.
  3. FCM / APNs - Firebase Cloud Messaging (Android) and Apple Push Notification service (iOS). External services that deliver notifications to locked phones.
    πŸ’‘ FCM doesn’t β€œknow” a message arrived - YOUR server tells FCM to send the push. When Bob installs the app, FCM gives his device a unique token. Your server stores this token. When Bob is offline and a message arrives, your server calls FCM’s API with Bob’s token + notification content. FCM maintains its own persistent connection to every Android device in the world and routes the push through that always-on channel. APNs works the same way for iOS. Learn more about real-time communication β†’

How does the notification show the actual message text (with E2E encryption)?

For E2E encrypted apps like WhatsApp/Signal, FCM does NOT carry the message content (the server can’t read it). Instead:

  1. Server sends a silent data message via FCM - just a β€œwake up, you have a new message” signal with sender ID and message reference
  2. FCM wakes up the app’s background process on the device
  3. The app connects to the server, pulls the encrypted message, and decrypts it locally on the device
  4. The app constructs the notification itself (β€œAlice: Hey, are you free?”) and hands it to the OS for display

For non-E2E apps, the server CAN send the message text directly in the FCM payload (notification message type) - simpler but less secure.

flowchart LR
    SENDER["Sender"]:::client
    CHAT["Chat Service"]:::service
    STORE[("Message Store")]:::data
    OFFLINE[("Offline Queue<br/>Redis sorted set")]:::data
    PUSH["Push Service"]:::service
    FCM["FCM and APNs"]:::external

    SENDER -->|"1. Send message"| CHAT
    CHAT -->|"2. Persist message"| STORE
    CHAT -->|"3. Queue for offline user"| OFFLINE
    CHAT -->|"4. Trigger push alert"| PUSH
    PUSH -->|"5. Deliver via FCM APNs"| FCM

    classDef client fill:#4c3a5e,stroke:#818cf8,color:#e2e8f0
    classDef service fill:#1a3a2a,stroke:#4ade80,color:#e2e8f0
    classDef data fill:#3b3520,stroke:#fbbf24,color:#e2e8f0
    classDef external fill:#4a1942,stroke:#f472b6,color:#e2e8f0

Step-by-step flow:

  1. Chat Service checks the Connection Registry β†’ receiver is NOT online (no WebSocket entry found)
  2. Message is still persisted to Cassandra (same as before - always store first, deliver second)
  3. Message ID is added to the receiver’s offline queue in Redis (sorted by sequence number for ordering)
  4. Push Service sends a notification via FCM/APNs: β€œNew message from Alice” β†’ phone buzzes
  5. Later, receiver opens the app and reconnects via WebSocket β†’ server drains the offline queue, sending all pending messages in order
  6. Receiver’s app acknowledges each message β†’ server removes them from the offline queue

Why store-and-forward instead of just β€œretry later”? Mobile networks are unreliable. A user might be offline for hours (on a flight, in a tunnel, phone dead). Store-and-forward guarantees zero message loss - once the server acknowledges receipt from the sender, that message WILL reach the recipient eventually, no matter how long it takes.

3) Group message fan-out

New components we need (in addition to the ones above):

  1. Kafka - an event bus for group message fan-out.
    πŸ’‘ We use Kafka here because group messages need to be delivered to N members reliably. If a fan-out worker crashes mid-delivery, Kafka retries automatically - no message gets lost. Learn more β†’
  2. Fan-out Workers - consume group message events and deliver to each member individually (online β†’ push via WebSocket, offline β†’ queue + push notification).
flowchart LR
    SENDER["Sender"]:::client
    CHAT["Chat Service"]:::service
    STORE[("Message Store")]:::data
    K["Kafka<br/>fan-out topic"]:::async
    FAN["Fan-out Workers"]:::service
    WS["WebSocket Servers"]:::service
    MEMBERS["Group Members"]:::client

    SENDER -->|"1. Send group message"| CHAT
    CHAT -->|"2. Store single copy"| STORE
    CHAT -->|"3. Publish fan-out event"| K
    K -->|"4. Process group delivery"| FAN
    FAN -->|"5. Push to online members"| WS
    WS -->|"6. Deliver to each member"| MEMBERS

    classDef client fill:#4c3a5e,stroke:#818cf8,color:#e2e8f0
    classDef service fill:#1a3a2a,stroke:#4ade80,color:#e2e8f0
    classDef async fill:#AB47BC,stroke:#4A148C,color:#fff
    classDef data fill:#3b3520,stroke:#fbbf24,color:#e2e8f0

Step-by-step flow:

  1. Sender sends a message to group conv_123 (256 members) β†’ hits Chat Service
  2. Chat Service stores ONE copy of the message (partition key = conv_123) - not 256 copies!
  3. Publishes a fan-out event to Kafka: β€œdeliver message M to these 256 members”
  4. Fan-out workers consume the event and look up each member’s connection - online members get real-time WebSocket delivery, offline members get the offline queue + push notification treatment
  5. If a fan-out worker crashes, Kafka retries - at-least-once delivery is guaranteed

Why store once, fan-out on delivery? Writing 256 copies of the same message would waste massive storage. Instead, we store one copy and fan out references (message IDs) to each member’s timeline. This also makes edits and deletes trivial - change one row, and everyone sees the update.

Potential Deep Dives

Deep Dive 1 - How to handle 2M WebSocket connections per server

Problem: A chat system with 50M concurrent users needs to maintain 50M persistent WebSocket connections. If each server handles 500K connections, that’s 100 servers just for connection holding. The challenge: each connection is stateful (long-lived TCP), consumes memory, and requires efficient event handling.

Bad - one thread per connection (Java BIO / traditional blocking I/O).

Classic Java ServerSocket.accept() β†’ spawn a thread per client. At 10K threads you hit OS limits, context-switching overhead makes the CPU thrash, and each thread stack takes ~512KB. 2M threads Γ— 512KB = 1TB RAM. Impossible.

Good - NIO event loop model (Netty, Node.js, Go goroutines).

Instead of one thread per connection, use a small pool of threads (event loops) that multiplex thousands of connections using OS-level I/O selectors (epoll on Linux, kqueue on macOS).

What Netty is: An asynchronous, event-driven network framework for Java. It implements the Reactor pattern - a single thread monitors many sockets, and only wakes up when there’s data to read/write. No blocking, no idle threads.

Event Loop (1 thread) monitors 100K connections via epoll
    β†’ Connection has data? β†’ Read it, process, respond
    β†’ Connection idle? β†’ Costs nothing (just a file descriptor)

Real numbers:

Tech used in production:

Great - tiered architecture separating connection from logic.

At extreme scale (100M+ connections), even Netty hits limits on a single machine. The problem: the server holding connections ALSO processes messages (routing, persistence, fan-out). Under load, message processing slows down AND connection handling suffers - they compete for the same CPU/memory.

The solution: split into two independent layers, each doing one job.

Edge Tier (connection holding) - the β€œreceptionist”:

Logic Tier (message processing) - the β€œbrain”:

How a message flows through both tiers:

  1. Alice’s phone is connected to Edge Server #3 via WebSocket
  2. Alice sends β€œHey Bob” β†’ Edge Server #3 receives the raw bytes
  3. Edge Server #3 forwards to Logic Tier via internal gRPC: β€œmessage from userId=alice, payload=Hey Bob”
  4. Logic Tier stores in Cassandra, then checks Connection Registry: β€œBob is on Edge Server #7”
  5. Logic Tier sends to Edge Server #7: β€œdeliver this to Bob’s WebSocket connection”
  6. Edge Server #7 pushes the message down Bob’s WebSocket
  7. If Bob is offline β†’ Logic Tier calls Push Service instead (FCM/APNs)

The Connection Registry (Redis) ties both tiers together:

Redis Hash: connection_registry
  alice β†’ edge-server-3:conn-8842
  bob   β†’ edge-server-7:conn-1204
  carol β†’ edge-server-3:conn-9921

When Logic Tier needs to deliver to Bob, it looks up this registry and routes to the correct edge server. When Bob disconnects, Edge Server #7 removes the entry.

Why this is better than one server doing everything:

Real-world implementations:


Deep Dive 2 - Message ordering in distributed systems

Problem: Alice sends β€œHello” then β€œHow are you?” in quick succession. These hit different server instances (load balanced). Or one arrives via WebSocket, another via a retry. Bob must see them in the correct order. Out-of-order messages make conversations nonsensical.

Why this is hard: In a distributed system, there’s no global clock. Server A’s timestamp might be 50ms ahead of Server B. Network latency varies. Messages can be retried out of order.

Bad - rely on server timestamps.

Each server stamps the message with System.currentTimeMillis() on arrival. Sort by timestamp on display.

Fails because:

Good - per-conversation monotonic sequence number.

Assign a strictly increasing seqNo per conversation. Every message in a conversation gets the next number in sequence.

Implementation: Redis INCR on key conv_seq:{conversationId}.

Alice sends "Hello"     β†’ server does INCR conv_seq:alice_bob β†’ gets 42
Alice sends "How are you?" β†’ server does INCR conv_seq:alice_bob β†’ gets 43

Bob’s client sorts by seqNo regardless of arrival order. Even if msg 43 arrives before 42 (network jitter), the UI holds 43 and renders after 42 arrives.

Why Redis INCR? Atomic, single-threaded, sub-ms. Even at 100K messages/sec across all conversations, one Redis cluster handles it because each conversation is an independent key (no contention across conversations).

What about gaps? If Bob receives seqNo 42 then 44 (missed 43), client knows there’s a gap and requests: β€œgive me message 43 for this conversation.” Server fetches from the message store.

Great - sequence numbers + client vector clock + multi-device sync.

For apps with multiple devices (phone + web + desktop), ordering gets harder. User sends from phone (seqNo 42), then from desktop (seqNo 43). Both devices need to converge.

The approach (used by WhatsApp, Slack, Facebook Messenger):

  1. Server is the source of truth for sequence numbers. Server assigns seqNo on receipt - NOT the client.
  2. Each device maintains a cursor: lastSyncedSeqNo. On reconnect, device says β€œgive me everything after seqNo 38” and server sends the delta.
  3. Client embeds lastSeenSeqNo in outgoing messages so the server can detect if the client missed something and proactively push missing messages.
  4. Conflict resolution for near-simultaneous sends from multiple devices: Both get seqNos from the same atomic counter, so they’re naturally ordered by who hit the server first. No conflict possible at the ordering level.

Tech used in production:


Deep Dive 3 - Reliable delivery with at-least-once + client dedupe

Problem: Network is unreliable. Message might be delivered twice if the ack is lost.

In simple terms: The internet is flaky. A message might arrive twice if the β€˜got it’ confirmation gets lost. We need to make sure Bob sees each message exactly once, even if the system retries delivery.

Flow:

Sender β†’ Server: message (clientMsgId: "abc")
Server β†’ Sender: ack (messageId: "msg_1", clientMsgId: "abc")
Server β†’ Receiver: message (messageId: "msg_1")
Receiver β†’ Server: delivered ack (messageId: "msg_1")

What if receiver’s ack is lost? Server retries delivery. Receiver sees msg_1 twice. Client dedupes by messageId - if already in local DB, ignore.

What if sender’s send is retried? Server checks clientMsgId: "abc" against a short-lived dedupe cache. If seen, returns the same messageId without re-storing.

Result: at-least-once from server side, exactly-once from user’s perspective (client dedupe).


Deep Dive 4 - How to sync message history across devices

Problem: User has phone + web + desktop. All three must show the same messages.

In simple terms: You send a message from your phone. When you open WhatsApp on your laptop 5 minutes later, that same message should be there. All your devices need to stay in sync.

Solution: pull-based sync with sequence numbers.

This is the β€œordered log” model (Facebook Iris). The server is the source of truth; clients are materialized views with a cursor.


Deep Dive 5 - Group fan-out: write amplification vs read amplification

Write amplification (push model):

In simple terms: When you send a message to a 500-person group, should we write 500 copies (one per member) or write one copy and let each member fetch it? Each approach has trade-offs.

Read amplification (pull model):

Hybrid (what WhatsApp/Discord do):

Final Architecture

flowchart TD
    CLIENTS["Mobile and Web Clients"]:::client
    LB["Load Balancer<br/>sticky by userId"]:::edge
    WS["WebSocket Servers<br/>Netty edge tier"]:::service
    CHAT["Chat Service"]:::service
    REG[("Connection Registry<br/>Redis")]:::data
    STORE[("Message Store<br/>Cassandra")]:::data
    OFFLINE[("Offline Queue<br/>Redis sorted set")]:::data
    K["Kafka<br/>fan-out and events"]:::async
    FAN["Fan-out Workers"]:::service
    PUSH["Push Service"]:::service
    MEDIA[("S3 and CDN<br/>media")]:::data
    FCM["FCM and APNs"]:::external

    CLIENTS -->|"Open WebSocket"| LB
    CLIENTS -->|"Presigned upload"| MEDIA
    LB -->|"Sticky route by user"| WS
    WS -->|"Forward to chat logic"| CHAT
    CHAT -->|"Lookup receiver server"| REG
    CHAT -->|"Persist message"| STORE
    CHAT -->|"Queue for offline user"| OFFLINE
    CHAT -->|"Publish group fan-out"| K
    K -->|"Process group delivery"| FAN
    FAN -->|"Push to online members"| WS
    CHAT -->|"Trigger push alert"| PUSH
    PUSH -->|"Deliver via FCM APNs"| FCM

    classDef client fill:#4c3a5e,stroke:#818cf8,color:#e2e8f0
    classDef edge fill:#1e3a5f,stroke:#60a5fa,color:#e2e8f0
    classDef service fill:#1a3a2a,stroke:#4ade80,color:#e2e8f0
    classDef async fill:#AB47BC,stroke:#4A148C,color:#fff
    classDef data fill:#3b3520,stroke:#fbbf24,color:#e2e8f0
    classDef external fill:#4a1942,stroke:#f472b6,color:#e2e8f0

How it works end-to-end:

  1. Client opens WebSocket β€” connects through Load Balancer (sticky by userId) to a WebSocket Server
  2. Sender sends message β€” WebSocket Server forwards to Chat Service
  3. Chat Service persists message β€” writes to Cassandra (Message Store) with a per-conversation sequence number
  4. Connection Registry checked β€” Redis lookup finds which WebSocket Server holds the recipient
  5. Kafka fan-out for groups β€” message event published to Kafka, Fan-out Workers push to each member’s WebSocket Server
  6. Recipient online β€” message delivered in real-time through their WebSocket connection
  7. Recipient offline β€” message queued in Redis sorted set (Offline Queue) and push notification sent via FCM/APNs
  8. Recipient reconnects β€” drains Offline Queue in order, syncs from last seen sequence number

Summary

Decision Choice Why
Transport WebSocket Real-time bidirectional, sub-second delivery
Message store Cassandra Partition per conversation, append-only, handles billions
Connection registry Redis Sub-ms lookup of β€œwhich server has user X”
Offline delivery Redis sorted set + push notification Ordered drain on reconnect
Group fan-out Kafka β†’ workers Async, retryable, doesn’t block sender
Ordering Per-conversation sequence number Simple, no clock dependency
Delivery guarantee At-least-once + client dedupe Zero message loss, no duplicates visible to user
Multi-device Pull sync with seqNo cursor Ordered log model (Facebook Iris)

Key Technologies Mentioned

Term What it is
WebSocket A persistent two-way connection between client and server. Unlike HTTP (request β†’ response β†’ done), WebSocket stays open so the server can push messages to the client anytime.
Cassandra A distributed NoSQL database optimized for fast writes. Stores data across many machines. Perfect for append-only message logs.
Kafka A distributed event streaming platform. Producers write events, consumers read them. Used here to decouple message sending from delivery fan-out.
Redis In-memory key-value store (< 1ms reads). Used here for connection registry (which user is on which server) and offline message queues.
FCM / APNs Firebase Cloud Messaging (Android) and Apple Push Notification service (iOS). How you send push notifications to phones when the app is closed.
Sequence Number A monotonically increasing integer per conversation. Guarantees message ordering regardless of clock differences between servers.
Store-and-Forward Pattern where the server stores a message durably first, then delivers it when the recipient is available. Ensures zero message loss.
Fan-out Delivering one message to multiple recipients (group chat). β€œFan-out on write” = copy to each inbox. β€œFan-out on read” = store once, each client fetches.

What’s Expected at Each Level

This section helps you calibrate your depth. You don’t need to cover everything - just know what’s expected for your level.

Mid-level

Design basic 1:1 messaging with a server relaying messages. Propose WebSocket for real-time delivery. Understand offline message storage and why polling is wasteful. With prompting, discuss how to handle group messages by fanning out to multiple recipients.

Senior

Propose Cassandra for message storage (partition by conversation). Explain connection-level routing - how does a message find the right WebSocket server? Discuss read receipts, message ordering guarantees (per-conversation sequence numbers), and offline delivery queues. Articulate why eventual consistency is acceptable for message delivery.

Staff+

Address end-to-end encryption key exchange (Signal protocol double-ratchet), multi-device sync with ordered-log cursors, and message fan-out for large groups (1000+ members) using the hybrid push/pull model. Discuss graceful degradation when the chat service is overloaded (backpressure on WebSocket connections). Cover message retention policies and GDPR right-to-deletion across replicated stores.


🎯 Key Takeaways



Understand the building blocks used in this design:

Discussion

Newest first
You

Free system design + DSA prep. If it helped you crack an interview, consider supporting.