C#基于Socket的網(wǎng)絡(luò)通信類你了解嗎
更新時間:2022年03月29日 11:37:25 作者:IT技術(shù)猿猴
這篇文章主要為大家詳細(xì)介紹了C#基于Socket的網(wǎng)絡(luò)通信類,文中示例代碼介紹的非常詳細(xì),具有一定的參考價值,感興趣的小伙伴們可以參考一下,希望能夠給你帶來幫助
摘要
之所以要進行Socket套接字通信庫封裝,主要是直接使用套接字進行網(wǎng)絡(luò)通信編程相對復(fù)雜,特別對于初學(xué)者而言。實際上微軟從.net 2.0開始已經(jīng)提供了TCP、UDP通信高級封裝類如下:
TcpListener TcpClient UdpClient
微軟從.net 4.0開始提供基于Task任務(wù)的異步通信接口。而直接使用socket封裝庫,很多socket本身的細(xì)節(jié)沒辦法自行控制,本文目就是提供一種socket的封裝供參考。文中展示部分封裝了TCP通信庫,UDP封裝也可觸類旁通:
CusTcpListener CusTcpClient
代碼
using System; using System.Text; using System.Net.Sockets; using System.Net; namespace NetDemo { // 網(wǎng)絡(luò)操作相關(guān)的類 public class InternetProHelper { // 檢查設(shè)置的端口號是否正確,并返回正確的端口號,無效端口號返回-1 public static int GetNetPort(string NetPort) { //聲明返回的正確端口號 int resPort = -1; //檢測端口號 try { //傳入的端口號為空則拋出異常 if (NetPort == "") { throw new Exception("端口號不能為空!"); } //檢測端口范圍 if ((Convert.ToInt32(NetPort) < ushort.MinValue) || (Convert.ToInt32(NetPort) > ushort.MaxValue)) { throw new Exception("端口號范圍無效!"); } //為端口號賦值 resPort = Convert.ToInt32(NetPort); } catch (Exception ex) { string errMessage = ex.Message; } return resPort; } public static IPAddress StringToIPAddress(string NetIP) { // 將字符串形式的IP地址轉(zhuǎn)換成IPAddress對象 return IPAddress.Parse(NetIP); } public static string LocalHostName { // 獲取本機的計算機名 get { return Dns.GetHostName(); } } public static string LANIP { // 獲取本機的局域網(wǎng)IP get { //獲取本機的IP列表,IP列表中的第一項是局域網(wǎng)IP,第二項是廣域網(wǎng)IP IPAddress[] IPaddrList = Dns.GetHostEntry(Dns.GetHostName()).AddressList; //如果本機IP列表為空,則返回空字符串 if (IPaddrList.Length < 1) { return ""; } //返回本機的局域網(wǎng)IP return IPaddrList[0].ToString(); } } public static string GetClientIP(Socket clientSocket) { // 獲取遠程客戶機的IP地址 IPEndPoint client = (IPEndPoint)clientSocket.RemoteEndPoint;//客戶端的NetSocket對象 return client.Address.ToString(); } public static IPEndPoint CreateIPEndPoint(string NetIP, int NetPort) { // 創(chuàng)建一個IPEndPoint對象 IPAddress ipAddress = StringToIPAddress(NetIP); return new IPEndPoint(ipAddress, NetPort); } public static TcpListener CreateTcpListener() { //創(chuàng)建一個自動分配的網(wǎng)絡(luò)節(jié)點 IPAddress ipAddress = IPAddress.Any; IPEndPoint localEndPoint = new IPEndPoint(ipAddress, 0); return new TcpListener(localEndPoint); } public static TcpListener CreateTcpListener(string NetIP, int NetPort) { //創(chuàng)建一個網(wǎng)絡(luò)節(jié)點 IPAddress ipAddress = StringToIPAddress(NetIP); IPEndPoint localEndPoint = new IPEndPoint(ipAddress, NetPort); return new TcpListener(localEndPoint); } public static Socket CreateTcpSocket() { // 創(chuàng)建一個基于TCP協(xié)議的Socket對象 return new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); } public static Socket CreateUdpSocket() { // 創(chuàng)建一個基于UDP協(xié)議的Socket對象 return new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp); } public static IPEndPoint GetLocalPoint(TcpListener tcpListener) { // 獲取TcpListener對象的本地終結(jié)點 return (IPEndPoint)tcpListener.LocalEndpoint; } public static string GetLocalPoint_IP(TcpListener tcpListener) { // 獲取TcpListener對象的本地終結(jié)點的IP地址 IPEndPoint localEndPoint = (IPEndPoint)tcpListener.LocalEndpoint; return localEndPoint.Address.ToString(); } public static int GetLocalPoint_Port(TcpListener tcpListener) { // 獲取TcpListener對象的本地終結(jié)點的端口號 IPEndPoint localEndPoint = (IPEndPoint)tcpListener.LocalEndpoint; return localEndPoint.Port; } public static IPEndPoint GetLocalPoint(Socket NetSocket) { // 獲取Socket對象的本地終結(jié)點 return (IPEndPoint)NetSocket.LocalEndPoint; } public static string GetLocalPoint_IP(Socket NetSocket) { // 獲取Socket對象的本地終結(jié)點的IP地址 IPEndPoint localEndPoint = (IPEndPoint)NetSocket.LocalEndPoint; return localEndPoint.Address.ToString(); } public static int GetLocalPoint_Port(Socket NetSocket) { // 獲取Socket對象的本地終結(jié)點的端口號 IPEndPoint localEndPoint = (IPEndPoint)NetSocket.LocalEndPoint; return localEndPoint.Port; } public static void BindEndPoint(Socket NetSocket, IPEndPoint endPoint) { // 綁定終結(jié)點 if (!NetSocket.IsBound) { NetSocket.Bind(endPoint); } } public static void BindEndPoint(Socket NetSocket, string NetIP, int NetPort) { //創(chuàng)建終結(jié)點 IPEndPoint endPoint = CreateIPEndPoint(NetIP, NetPort); //綁定終結(jié)點 if (!NetSocket.IsBound) { NetSocket.Bind(endPoint); } } public static void StartListen(Socket NetSocket, int NetPort) { //創(chuàng)建本地終結(jié)點 IPEndPoint localPoint = CreateIPEndPoint(InternetProHelper.LocalHostName, NetPort); //綁定到本地終結(jié)點 BindEndPoint(NetSocket, localPoint); //開始監(jiān)聽 NetSocket.Listen(200); } public static void StartListen(Socket NetSocket, int NetPort, int maxConnection) { //創(chuàng)建本地終結(jié)點 IPEndPoint localPoint = CreateIPEndPoint(InternetProHelper.LocalHostName, NetPort); //綁定到本地終結(jié)點 BindEndPoint(NetSocket, localPoint); //開始監(jiān)聽 NetSocket.Listen(maxConnection); } public static void StartListen(Socket NetSocket, string NetIP, int NetPort, int maxConnection) { //綁定到本地終結(jié)點 BindEndPoint(NetSocket, NetIP, NetPort); //開始監(jiān)聽 NetSocket.Listen(maxConnection); } public static bool Connect(Socket NetSocket, string NetIP, int NetPort) { // 連接到基于TCP協(xié)議的服務(wù)器,連接成功返回true,否則返回false try { //連接服務(wù)器 NetSocket.Connect(NetIP, NetPort); //檢測連接狀態(tài) return NetSocket.Poll(-1, SelectMode.SelectWrite); } catch (SocketException ex) { throw new Exception(ex.Message); } } // 以同步方式向指定的Socket對象發(fā)送消息 public static void SendMsg(Socket NetSocket, byte[] dataStr) { //發(fā)送消息 NetSocket.Send(dataStr, dataStr.Length, SocketFlags.None); } // 使用UTF8編碼格式以同步方式向指定的Socket對象發(fā)送消息 public static void SendMsg(Socket NetSocket, string dataStr) { //將字符串消息轉(zhuǎn)換成字符數(shù)組 byte[] NetBuf = System.Text.Encoding.UTF8.GetBytes(dataStr); //發(fā)送消息 NetSocket.Send(NetBuf, NetBuf.Length, SocketFlags.None); } // 以同步方式接收消息 public static void ReceiveMsg(Socket NetSocket, byte[] NetBuf) { NetSocket.Receive(NetBuf); } // 以同步方式接收消息 public static string ReceiveMsg(Socket NetSocket) { //定義接收緩沖區(qū) byte[] NetBuf = new byte[10000]; //接收數(shù)據(jù),獲取接收到的字節(jié)數(shù) int RecvNum = NetSocket.Receive(NetBuf); //定義臨時緩沖區(qū) byte[] DataBuf = new byte[RecvNum]; //將接收到的數(shù)據(jù)寫入臨時緩沖區(qū) Buffer.BlockCopy(NetBuf, 0, DataBuf, 0, RecvNum); //對DataBuf進行處理 return Convert.ToString(DataBuf); } // 關(guān)閉基于Tcp協(xié)議的Socket對象 public static void Close(Socket NetSocket) { try { //禁止Socket對象接收和發(fā)送數(shù)據(jù) NetSocket.Shutdown(SocketShutdown.Both); } catch (SocketException ex) { throw ex; } finally { //關(guān)閉Socket對象 NetSocket.Close(); } } } }
總結(jié)
本篇文章就到這里了,希望能夠給你帶來幫助,也希望您能夠多多關(guān)注腳本之家的更多內(nèi)容!