I’m going to create a .NET core console application to demonstrate using Fleck. <\/p>\n
So create yourself a project and add the Fleck nuget package or simply add the Fleck nuget package to an existing project.<\/p>\n
Creating a websocket server<\/strong><\/p>\n To begin with, we simply create a websocket server, supplying the “location”, i.e. <\/p>\n Don’t forget the using Fleck; line at the start of your code<\/em><\/p>\n In this example we’re using 0.0.0.0 (the non-routable meta-address) along with the port 8181 and ofcourse we prefix this with the ws<\/em> protocol.<\/p>\n Interacting with clients<\/strong><\/p>\n Next up we’ll want to start the server and intercept various events\/messages. Fleck uses a callback function\/delegate style, so we simply supply our functions for each of the connection methods that we wish to intercept, for example<\/p>\n Note: if we’re handling different state for different connections to the same url, it’s our responsibility to create our own form “session state”.<\/em><\/p>\n In this example, we’ve listed all the OnXXX actions that we can intercept.<\/p>\n Obviously OnOpen<\/em> occurs when a new client connects to the server (on ws:\/\/0.0.0.0:8181) and OnClose<\/em> occurs if the client closes the connection.<\/p>\n OnMessage<\/em> is called when string messages are sent over the websocket, whereas OnBinary<\/em> is, ofcourse, the binary equivalent (in the example above we’re assuming the bytes represent a string, obviously change this if you’re sending raw byte data).<\/p>\n OnError<\/em> is called with an Exception for instances where exceptions occur (as you’ll have surmised).<\/p>\n OnPing<\/em> is used when being pinged and like wise OnPong<\/em> is used when receiving a pong – ping and pong are used as ways to, in essence, check if the client or server are still running. If supported, a server might send a ping to the connected clients then mark the clients as stopped (and hence dispose of any connections) if the server does not receive a pong within a specified timeout period. Obviously one of the biggest problems for any server that is maintaining some form of state is at what point they can assume the client is no longer around. Obviously if the client closes the connection the server can handle this, but what about if they just disconnect – this is where ping and pong come into play.<\/p>\n Obviously we also need to be able to send data to the client, hence we use the connection’s Send<\/em> method. For example let’s change the OnMessage delegate to send an “Echo” of the message back to the client<\/p>\n Writing a client to test our server<\/strong><\/p>\n Let’s now create a simple console app to test our server code. This will use the System.Net.WebSockets ClientWebSocket class. <\/p>\n We will need to actually specify a network address for the client, so we’ll use the loopback 127.0.0.1.<\/p>\n Below are the contents of our client console application’s Main method<\/p>\n Hopefully it’s fairly self explanatory what’s going on – we create a websocket client and a cancellation token (as the methods all required one). We connect to the server and when a connection is established we send and receive data (strings and then binary). Eventually we close the connection.<\/p>\n What and ping and pong?<\/strong><\/p>\n At this time I don’t have any examples to implement these. <\/p>\n In the case of the ClientWebSocket code, if you leave the client and server running you will periodically see OnPing being called.<\/p>\n I almost forgot…<\/strong><\/p>\n We can also interact with the connection’s ConnectionInfo property which gives us access to headers, cookies and whether path was specified, i.e. the client url ws:\/\/127.0.0.1:8181\/somepath will result in ConnectionInfo.Path having the value \/somepath.<\/p>\n Here’s an example of the server changes for OnOpen<\/p>\n From what I can tell, each connection is assigned a GUID (found in ConnectionInfo.Id), so when handling multiple different clients with different state requirements we should be able to use this Id.<\/p>\n References<\/strong><\/p>\n Fleck<\/a> I’m going to create a .NET core console application to demonstrate using Fleck. So create yourself a project and add the Fleck nuget package or simply add the Fleck nuget package to an existing project. Creating a websocket server To begin with, we simply create a websocket server, supplying the “location”, i.e. var websocketServer = […]<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"closed","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"_jetpack_memberships_contains_paid_content":false,"footnotes":""},"categories":[3,267],"tags":[],"class_list":["post-8146","post","type-post","status-publish","format-standard","hentry","category-c","category-websocket"],"jetpack_sharing_enabled":true,"jetpack_featured_media_url":"","_links":{"self":[{"href":"https:\/\/putridparrot.com\/blog\/wp-json\/wp\/v2\/posts\/8146","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/putridparrot.com\/blog\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/putridparrot.com\/blog\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/putridparrot.com\/blog\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/putridparrot.com\/blog\/wp-json\/wp\/v2\/comments?post=8146"}],"version-history":[{"count":5,"href":"https:\/\/putridparrot.com\/blog\/wp-json\/wp\/v2\/posts\/8146\/revisions"}],"predecessor-version":[{"id":8266,"href":"https:\/\/putridparrot.com\/blog\/wp-json\/wp\/v2\/posts\/8146\/revisions\/8266"}],"wp:attachment":[{"href":"https:\/\/putridparrot.com\/blog\/wp-json\/wp\/v2\/media?parent=8146"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/putridparrot.com\/blog\/wp-json\/wp\/v2\/categories?post=8146"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/putridparrot.com\/blog\/wp-json\/wp\/v2\/tags?post=8146"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}\r\nvar websocketServer = new WebSocketServer("ws:\/\/0.0.0.0:8181");\r\n<\/pre>\n\r\nwebsocketServer.Start(connection =>\r\n{\r\n connection.OnOpen = () => \r\n Console.WriteLine("OnOpen");\r\n connection.OnClose = () => \r\n Console.WriteLine("OnClose");\r\n connection.OnMessage = message => \r\n Console.WriteLine($"OnMessage {message}");\r\n connection.OnBinary = bytes => \r\n Console.WriteLine($"OnBinary {Encoding.UTF8.GetString(bytes)}");\r\n connection.OnError = exception => \r\n Console.WriteLine($"OnError {exception.Message}");\r\n connection.OnPing = bytes => \r\n Console.WriteLine("OnPing");\r\n connection.OnPong = bytes => \r\n Console.WriteLine("OnPong");\r\n});\r\n<\/pre>\n\r\nconnection.OnMessage = message =>\r\n{\r\n Console.WriteLine($"OnMessage {message}");\r\n connection.Send($"Echo: {message}");\r\n};\r\n<\/pre>\n\r\nvar websocketClient = new ClientWebSocket();\r\nvar cancellationToken = new CancellationTokenSource();\r\n\r\nvar connection = websocketClient.ConnectAsync(\r\n new Uri("ws:\/\/127.0.0.1:8181"), \r\n cancellationToken.Token);\r\n\r\nconnection.ContinueWith(async tsk =>\r\n{\r\n \/\/ sends a string\/text message causes OnMessage to be called\r\n await websocketClient.SendAsync(\r\n new ArraySegment<byte>(Encoding.UTF8.GetBytes("Hello World")),\r\n WebSocketMessageType.Text,\r\n true,\r\n cancellationToken.Token);\r\n\r\n \/\/ receives a string\/text from the server\r\n var buffer = new byte[128];\r\n await websocketClient.ReceiveAsync(\r\n new ArraySegment<byte>(buffer), cancellationToken.Token);\r\n Console.WriteLine(Encoding.UTF8.GetString(buffer));\r\n\r\n \/\/ sends a string\/text message causes OnBinary to be called\r\n await websocketClient.SendAsync(\r\n new ArraySegment<byte>(Encoding.UTF8.GetBytes("Hello World")),\r\n WebSocketMessageType.Binary,\r\n true,\r\n cancellationToken.Token);\r\n });\r\n\r\n Console.WriteLine("Press <enter> to exit");\r\n Console.Read();\r\n\r\n \/\/ close the connection nicely\r\n websocketClient.CloseAsync(\r\n WebSocketCloseStatus.NormalClosure, \r\n String.Empty, \r\n cancellationToken.Token);\r\n\r\n \/\/ this will cause OnError on the server if not closed first\r\n cancellationToken.Cancel();\r\n<\/pre>\n\r\nconnection.OnOpen = () =>\r\n{\r\n Console.WriteLine("OnOpen");\r\n Console.WriteLine(connection.ConnectionInfo.Path);\r\n};\r\n<\/pre>\n
\nWriting WebSocket servers<\/a><\/p>\n","protected":false},"excerpt":{"rendered":"