Quest for serverless WebSockets - an adventure with Azure Functions and Durable Functions

@MarcDuiker

@MarcDuiker 2 Marc Duiker Sr Developer Advocate

@MarcDuiker 3 Marc Duiker Sr Developer Advocate

@MarcDuiker https://quest.ably.dev/

@MarcDuiker 5 Durable Functions Learnings & Alternatives Entity Functions Synchronizing
State Code Tour WebSockets Solution

@MarcDuiker

@MarcDuiker 7 Client 1 Client 2 Client 3

@MarcDuiker 8 Client 1 Client 2 Client 3 Server

@MarcDuiker 9 Client 1 Client 2 Client 3 Serverless HTTP
HTTP HTTP WS WS WS

@MarcDuiker 10 Client 1 Client 2 Client 3 HTTP HTTP
HTTP WS WS WS HTTP Ably

@MarcDuiker

@MarcDuiker 12

@MarcDuiker 13

@MarcDuiker 14

@MarcDuiker 15

@MarcDuiker 16 https://github.com/marcduiker/durable-functions-use-cases

@MarcDuiker

@MarcDuiker 18

@MarcDuiker 19 public class Counter : ICounter { [JsonProperty("value")] public
int CurrentValue { get; set; } public void Add(int amount) => this.CurrentValue += amount; public void Reset() => this.CurrentValue = 0; [FunctionName(nameof(Counter))] public static Task Run([EntityTrigger] IDurableEntityContext ctx) => ctx.DispatchAsync<Counter>(); }

@MarcDuiker 20 await _durableClient.SignalEntityAsync<ICounter>( counterEntityId, proxy => proxy.Add(1)); var counter
= await _durableClient.ReadEntityStateAsync<Counter>( counterEntityId); var current = counter.EntityState.CurrentValue; var counterEntityId = new EntityId(nameof(Counter), counterId); https://learn.microsoft.com/en-us/azure/azure-functions/durable/durable-functions-dotnet-entities

@MarcDuiker

@MarcDuiker 22 Request Response Connection is terminated

@MarcDuiker 23 Handshake Request Handshake Response Bi-directional Connection remains open
until client or server terminates

@MarcDuiker 24 let webSocket = new WebSocket(”ws://...”); webSocket.onopen = ()
=> { ... }; webSocket.onmessage = (event) => { ... }; webSocket.send(...);

@MarcDuiker 25 var ablyClient = new AblyRealtime(ABLY_API_KEY); var channel =
ablyClient.Channels.Get(CHANNEL_NAME); channel.Subscribe(“chat-message”, message => { ... }); await channel.PublishAsync( “chat-message", new { user = "Marc“, message = "Hi there!" }); ablyClient.Connection.On(ConnectionEvent.Connected, args => { ... });

@MarcDuiker 26

@MarcDuiker

@MarcDuiker 29 Client Function App Monster (Player Entity) GameState (Entity)
GameEngine Ably Signal InitGameState Signal AddPlayerName Publish UpdatePhase Publish AddPlayer CreateQuest Signal InitPlayer CreateQuest

@MarcDuiker https://github.com/ably-labs/serverless-websockets-quest/

@MarcDuiker

@MarcDuiker 33

@MarcDuiker 34

@MarcDuiker

@MarcDuiker 36

@MarcDuiker 37

@MarcDuiker

@MarcDuiker Twitter: @marcduiker GitHub: https://github.com/ably-labs/serverless-websockets-quest/ Ably Discord: http://go.ably.com/discord

Quest for serverless WebSockets - an adventure ...

Quest for serverless WebSockets - an adventure with Azure Functions and Durable Functions

Transcript

More Decks by Marc Duiker

Other Decks in Programming

Featured