說到Socket,想必大家都或多或少有所涉及,從最初的計算機網絡課程,講述了tcp協議,而Socket就是對協議的進一步封裝,使我們開發人員能夠更加容易輕松的進行軟件之間的通信。
這個星期剛好接受一個共享車位鎖的項目,需要使用Socket與硬件進行通信控制,說白了也就是給鎖發送指令,控制其打開或者關閉,再就是對App開放操作接口,使其方便測試以及用戶的使用。這其中核心就是Socket的使用,再開發出這個功能之后,我發現使用起來很不方便,於是耗時2天抽象其核心功能並封裝成框架,最后使用這個框架將原來的項目重構並上線,極大的提高了軟件的可拓展性,健壯性,容錯率。
個人堅信的原則:萬物皆對象
好了,不廢話了,下面進入正文
正文:
1、首先簡單講下C#中Socket的簡單使用。
第一步:服務端監聽某個端口
第二步:客戶端向服務端地址和端口發起Socket連接請求
第三步:服務端收到連接請求后創建Socket連接,並維護這個連接隊列。
第四步:客戶端和服務端已經建立雙工通信(即雙向通信),客戶端和服務端可以輕松方便的給彼此發送信息。
至於簡單使用的具體實現代碼全部被我封裝到項目中了,如果需要學習簡單的實現,可以看我的源碼,也可以自行百度,有很多的教程
2、核心,框架的使用
其實,說其為框架,可能有點牽強,因為每個人對框架都有自己的理解,但是類庫和框架又有什么本質區別呢?全部都是代碼~哈哈,扯遠了
首先,空說無憑,先放上所有的代碼:
服務端源文件:
SocketServer.cs
using System; using System.Collections.Generic; using System.Net; using System.Net.Sockets; namespace Coldairarrow.Util.Sockets { /// <summary> /// Socket服務端 /// </summary> public class SocketServer { #region 構造函數 /// <summary> /// 構造函數 /// </summary> /// <param name="ip">監聽的IP地址</param> /// <param name="port">監聽的端口</param> public SocketServer(string ip, int port) { _ip = ip; _port = port; } /// <summary> /// 構造函數,監聽IP地址默認為本機0.0.0.0 /// </summary> /// <param name="port">監聽的端口</param> public SocketServer(int port) { _ip = "0.0.0.0"; _port = port; } #endregion #region 內部成員 private Socket _socket = null; private string _ip = ""; private int _port = 0; private bool _isListen = true; private void StartListen() { try { _socket.BeginAccept(asyncResult => { try { Socket newSocket = _socket.EndAccept(asyncResult); //馬上進行下一輪監聽,增加吞吐量 if (_isListen) StartListen(); SocketConnection newClient = new SocketConnection(newSocket, this) { HandleRecMsg = HandleRecMsg == null ? null : new Action<byte[], SocketConnection, SocketServer>(HandleRecMsg), HandleClientClose = HandleClientClose == null ? null : new Action<SocketConnection, SocketServer>(HandleClientClose), HandleSendMsg = HandleSendMsg == null ? null : new Action<byte[], SocketConnection, SocketServer>(HandleSendMsg), HandleException = HandleException == null ? null : new Action<Exception>(HandleException) }; newClient.StartRecMsg(); ClientList.AddLast(newClient); HandleNewClientConnected?.Invoke(this, newClient); } catch (Exception ex) { HandleException?.Invoke(ex); } }, null); } catch (Exception ex) { HandleException?.Invoke(ex); } } #endregion #region 外部接口 /// <summary> /// 開始服務,監聽客戶端 /// </summary> public void StartServer() { try { //實例化套接字(ip4尋址協議,流式傳輸,TCP協議) _socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); //創建ip對象 IPAddress address = IPAddress.Parse(_ip); //創建網絡節點對象包含ip和port IPEndPoint endpoint = new IPEndPoint(address, _port); //將 監聽套接字綁定到 對應的IP和端口 _socket.Bind(endpoint); //設置監聽隊列長度為Int32最大值(同時能夠處理連接請求數量) _socket.Listen(int.MaxValue); //開始監聽客戶端 StartListen(); HandleServerStarted?.Invoke(this); } catch (Exception ex) { HandleException?.Invoke(ex); } } /// <summary> /// 所有連接的客戶端列表 /// </summary> public LinkedList<SocketConnection> ClientList { get; set; } = new LinkedList<SocketConnection>(); /// <summary> /// 關閉指定客戶端連接 /// </summary> /// <param name="theClient">指定的客戶端連接</param> public void CloseClient(SocketConnection theClient) { theClient.Close(); } #endregion #region 公共事件 /// <summary> /// 異常處理程序 /// </summary> public Action<Exception> HandleException { get; set; } #endregion #region 服務端事件 /// <summary> /// 服務啟動后執行 /// </summary> public Action<SocketServer> HandleServerStarted { get; set; } /// <summary> /// 當新客戶端連接后執行 /// </summary> public Action<SocketServer, SocketConnection> HandleNewClientConnected { get; set; } /// <summary> /// 服務端關閉客戶端后執行 /// </summary> public Action<SocketServer, SocketConnection> HandleCloseClient { get; set; } #endregion #region 客戶端連接事件 /// <summary> /// 客戶端連接接受新的消息后調用 /// </summary> public Action<byte[], SocketConnection, SocketServer> HandleRecMsg { get; set; } /// <summary> /// 客戶端連接發送消息后回調 /// </summary> public Action<byte[], SocketConnection, SocketServer> HandleSendMsg {