During our last Launch Week, we teased our plans for "multiplayer" features. If you need a refresher, take a glance at Supabase Realtime, with Multiplayer Features or go to multiplayer.dev for an interactive demo.
Today, we're excited to announce the general availability of Realtime's multiplayer features, Broadcast and Presence.
TLDR
Here are the key takeaways:
- We've added Broadcast and Presence to our Realtime server. You can use these features with the new supabase-js release.
- All active Supabase projects on the Free Plan have access to the these features.
- All new Supabase projects created from August 18th have access to these features.
- We will work with all other projects to migrate to the new Realtime over the next few weeks. If you want immediate access, reach out.
- Chris McCord, the creator of Phoenix Framework, is now a technical advisor.
Background
Before we discuss the new features, let's review what Realtime is and its significance to Supabase. Skip ahead if you just want to see the new features!
The first iteration of Realtime server was written by @kiwicopple, our CEO. At his previous startup, a chat application he built was facing performance issues while broadcasting database changes from Firestore to individual subscribers.
He turned to Postgres, which has two built-in pieces of functionality for emitting database changes:
- The first, Postgres's LISTEN/NOTIFY, seems like the obvious choice because it conveniently does what its name implies, listen for changes and notify subscribers. However, this approach has a hidden limitation - NOTIFY has a payload limit of 8,000 bytes. The workaround is to send only a unique identifier and then have the client query the database for the specific change. This would have been been too slow for the chat application.
- The second, Postgres's logical replication, doesn't face the same limitations, and Paul used this approach. This required the introduction of a server to listen to a logical replication slot. Paul chose Elixir and the Phoenix Framework for the server as it scales exceptionally well, especially when dealing with WebSockets. He named this server "Realtime," leveraging other open source projects, cainophile and pgoutput_decoder, to listen to the replication stream and decode changes. From there, the changes were serialized into JSON and sent on their merry way to clients.
Realtime was the very first open source project of Supabase and played a pivotal role in our founding. Over time, we've improved both the performance and security. During Launch Week 3, we announced Realtime RLS, which allows developers to tap into Postgres's Row Level Security to authorize changes before broadcasting them to clients. This enabled developers to use the same security framework across the entire Supabase stack.
Realtime Channels
We've modified the architecture of Realtime to introduce two core features: Broadcast and Presence.
In this new version, everything is a Channel. Channels are like “Rooms” where participants can join, and leave - very similar to Slack Channels or Discord Channels.
Broadcast and Presence are built into every Channel, and we've retro-fitted the Database change events into Channels too.
Broadcast
Broadcast follows the classic Publisher/Subscriber pattern. A client (publisher) “broadcasts” messages using a unique identifier. For example, a user could send a message to a #random channel.
Other clients (subscribers) can “listen” to these messages in real-time, using the unique identifier. If they are listening to the #random channel, then they will receive the message.
This functionality is baked into the Phoenix framework and we've already been using this to broadcast Postgres changes. With this release we're exposing the underlying primitives which unlocks a variety of use-cases for developers.
A common use-case is sharing a user's cursor position with other clients in an online game. Previously, developers were sending all the mouse movements through their Postgres database which added latency and degraded database performance. In contrast, Broadcasts are ephemeral - they bypass the database completely.
Presence
Presence synchronizes shared state between users. Presence is very similar to Broadcast, except that the state is “persisted” in the Channel so that new joiners immediately receive the state without waiting for another user to broadcast it. In our Slack example, when you turn on Slack you can see who's online without each individual user sending an “I'm online” message to the new-joiner.
Presence utilizes Broadcast as the transport layer, consolidating the state in an eventually-consistent and conflict-free manner. Users are free to come-and-go as they please, and as long as they are all subscribed to the same Channel then they will all have the same Presence state as each other.
The neat thing about Presence is that if a user is suddenly disconnected (for example, they go offline), their state will be automatically removed from the shared state. If you've ever tried to build an “I'm online” feature which handles unexpected disconnects, you'll appreciate how useful this is.
Client Library
We've introduced new functionality into the release candidate version of supabase-js.
Here's a taste of how you can start using Broadcast and Presence and continue to listen to Postgres changes.
Broadcast Example
In this example we'll send and receive mouse cursor positions to anyone in room_1.
_28const channel = supabase.channel('room_1')_28const MOUSE_EVENT = 'cursor'_28_28// Subscribe to mouse events._28// Our second parameter filters only for mouse events._28channel_28 .on('broadcast', { event: MOUSE_EVENT }, (event) => {_28 receivedCursorPosition(event)_28 })_28 .subscribe()_28_28// Handle a mouse event._28const receivedCursorPosition = ({ event, payload }) => {_28 console.log(`_28 User: ${payload.userId}_28 x Position: ${payload.x}_28 y Position: ${payload.y}_28 `)_28}_28_28// Helper function for sending our own mouse position._28const sendMousePosition = (channel, userId, x, y) => {_28 return channel.send({_28 type: 'broadcast',_28 event: MOUSE_EVENT,_28 payload: { userId, x, y },_28 })_28}
Presence Example
Let's create a contrived example where we could display a “user is typing” indicator. In this case, we'll send the timestamp for the last time that a user hit a key. Other clients can use this timestamp to display a “typing…” indicator.
_30const userId = 'user_1234'_30const slackRoomId = '#random'_30_30const channel = supabase.channel(slackRoomId, {_30 config: {_30 presence: { key: userId }_30 }_30})_30_30// We can subscribe to all Presence changes using the 'presence' -> 'sync' event._30channel_30 .on('presence', { event: 'sync' }, () => presenceChanged())_30 .subscribe()_30_30/*_30 A contrived example where we bind to all keyboard_30 events and send them over our channel_30*/_30document.addEventListener('keydown', function(event){_30 channel.track({ isTyping: Date.now() })_30})_30_30// Receive Presence updates_30const presenceChanged = () => {_30 const newState = channel.presenceState()_30 console.log(newState)_30}_30_30// When you no longer wish to track data_30channel.untrack().then(status => console.log(status)
Receiving Postgres Changes
You can receive Postgres changes on any channel. For this example, we'll receive all messages on the #random channel.
_19const channelId = '#random'_19_19// Create a filter only for new messages_19const databaseFilter = {_19 schema: 'public',_19 table: 'messages',_19 filter: `room_id=eq.${channelId}`,_19 event: 'INSERT',_19}_19_19const channel = supabase_19 .channel(channelId)_19 .on('postgres_changes', databaseFilter, (payload) => receivedDatabaseEvent(payload))_19 .subscribe()_19_19const receivedDatabaseEvent = (event) => {_19 const { payload } = event_19 console.log(payload)_19}
Future Plans
This is a big change, but it's only a small step towards the final goal. We have a few exciting plans for the future.
Extensions
Our postgres_changes listener is the first of many Extensions.
We've had requests add other integrations beyond Postgres:
- Finance: Listen to stock market events and broadcast them to connected users
- Web3: Listen to blockchain events and broadcast them to connected users
- Authoritative clocks: A server clock which broadcasts a timer (e.g. auction sites or ticketing systems)
Peer to Peer
A lot of users ask about using Realtime for peer to peer applications. We plan to use Realtime as a WebRTC signaling server which will enable developers to build collaborative software with even lower latency. A common example we've seen is collaborative code editors with a CRDT implementation, like Yjs.
Realtime Inspector
We're building a Realtime inspector into the Supabase Dashboard so it'll be easier to debug the messages that are getting passed through your Channels.
Technical Overview
Before this release, every Supabase project had a server running Realtime with the other Supabase services like Kong, GoTrue, and PostgREST.
In this release we take advantage of Elixir's strengths by running a distributed cluster of servers across the world. Each server communicates directly with the other nodes in the cluster. This improves performance by balancing the load across nodes.
Clients connect to the nearest node in the cluster, and we take advantage of the cluster's fast backbone network to improve client connection speeds, stability, and latency. This is especially useful for clients in regions with variable internet quality.
The entire cluster runs on Fly - we're big fans!
Much of the new functionality leverages the Phoenix Framework. This makes it relatively straightforward to offer Broadcast (Phoenix PubSub) and Presence (Phoenix Presence) in a globally-distributed cluster. Presence is built on top of Phoenix Tracker, a delta-based conflict-free replicated data type (CRDT) for eventually consistent and conflict-free synced state.
In the future, we'll document the challenges we faced migrating to this new architecture as well as a few challenges we expect to face in the future.
One More Thing
We have some great news! Chris McCord, the creator of the Phoenix framework, has agreed to become a Technical Advisor for Supabase.
Chris works at Fly, and will continue to work there. His role as an advisor is mostly to express our gratitude for the work he's already done (admittedly, we'll probably need his advice for some upcoming challenges). Realtime is made possible by his open source work.
We also want to thank José Valim, and everyone in the Erlang/Elixir ecosystem, for your open source contributions that have made our lives here on the Supabase Realtime team a lot easier.