??????? BeetleX.FastHttpApi不僅是一個Webapi服務組件，它同時也是一個Websocket服務組件。由于BeetleX.FastHttpApi的實現是直接支持Websocket Upgrade操作，所以當啟動服務后是HTTP還是Websocket完全取決于請求方；其原理和aspcore一樣，同一個服務端口即是Webapi也是Websocket.

定義服務

????????構建Websocket服務需要引用BeetleX.FastHttpApi組件，然后定義相關HttpApiServer啟動即可。

static void Main(string[] args) {HttpApiServer server = new HttpApiServer();server.Options.SetDebug();server.Options.Port = 80;server.Options.LogLevel = EventArgs.LogType.Info;server.Options.LogToConsole = true;server.WebSocketReceive = (r, e) =>{DataBuffer<byte> data = (DataBuffer<byte>)e.Frame.Body;string message = Encoding.UTF8.GetString(data.Data, data.Offset, data.Length);Console.WriteLine();var result = e.CreateFrame($"hello {message} {DateTime.Now}");e.Sesson.Send(result);};server.Open();System.Threading.Thread.Sleep(-1); }

可以通過綁定WebSocketReceive事件來接管Websocket請求處理，以上代碼是獲取接收的數據然后返回一個對應的hello信息。

Web訪問

????????定義好服務后就可以通過頁面創建Websocket對象進行訪問.

<div id="app"><div><input type="text" v-model="message" /><button @click="doSend">發送</button></div><div><p v-for="item in items">{{item}}</p></div></div><script>var page = new Vue({el: '#app',data: {items: [],websocket: null,message: '',wsUri: "ws://localhost/",},methods: {onOpen(evt) {this.items.push('CONNECTED');},onClose(evt) {this.items.push('DISCONNECTED');},onMessage(evt) {this.items.push('Receive:' + evt.data);},onError(evt) {this.items.push('Error:' + evt.data);},doSend() {this.items.push('Send:' + this.message);websocket.send(this.message);},onConnect() {websocket = new WebSocket(this.wsUri);websocket.onopen = (evt) =>{ this.onOpen(evt) };websocket.onclose = (evt) =>{ this.onClose(evt) };websocket.onmessage = (evt)=> { this.onMessage(evt) };websocket.onerror = (evt) =>{ this.onError(evt) };}},mounted() {this.onConnect();}}); </script>

消息序列化

????????在處理Websocket消息的時候往往需要處理不同的情況，組件提供一個默認的實現，其接收數據是DataBuffer<byte>?結構；而返回如果是string直接輸出，當是對象的時候就直接Json序列化輸出。組件通過IDataFrameSerializer接口來規范這個行為，默認實現如下:

public virtual object FrameDeserialize(DataFrame data, PipeStream stream){DataBuffer<byte> buffer = new DataBuffer<byte>((int)data.Length);stream.Read(buffer.Data, 0, buffer.Length);return?buffer;}private?System.Collections.Concurrent.ConcurrentQueue<byte[]>?mBuffers?=?new?System.Collections.Concurrent.ConcurrentQueue<byte[]>();public virtual ArraySegment<byte> FrameSerialize(DataFrame data, object body){byte[] result;if (!mBuffers.TryDequeue(out result)){result = new byte[this.Options.MaxBodyLength];}string value;if (body is string){value = (string)body;int length = Options.Encoding.GetBytes(value, 0, value.Length, result, 0);return new ArraySegment<byte>(result, 0, length);}else{value = Newtonsoft.Json.JsonConvert.SerializeObject(body);int length = Options.Encoding.GetBytes(value, 0, value.Length, result, 0);return new ArraySegment<byte>(result, 0, length);}}public virtual void FrameRecovery(byte[] buffer){mBuffers.Enqueue(buffer);}

可以根據實際應用需要繼承HttpApiServer重寫以上幾個方法，如果不想繼承則實現IDataFrameSerializer接口，設置到HttpApiServer.FrameSerializer屬性上。

下載示例

鏈接：

https://pan.baidu.com/s/1Zuph6VdjewcX6Gc9y5amOA

提取碼：

ny4u

【BeetleX通訊框架代碼詳解】 【WebApi示例擴展】 BeetleX

開源跨平臺通訊框架(支持TLS)
輕松實現高性能:tcp、http、websocket、redis、rpc和網關等服務應用

https://beetlex.io

如果你想了解某方面的知識或文章可以把想法發送到

henryfan@msn.com|admin@beetlex.io

創作挑戰賽新人創作獎勵來咯，堅持創作打卡瓜分現金大獎

總結

以上是生活随笔為你收集整理的BeetleX之Websocket服务使用的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。