C#完成異步套接字封裝server與client處理方案 發(fā)表時間：2023-07-28 來源：明輝站整理相關(guān)軟件相關(guān)文章人氣： [摘要]C#實現(xiàn)異步套接字封裝server與client解決方案 之前一直用C#些了很多管理軟件，包括c/s , b/s ,之前一直都是同步寫法，相信大家都用ajax異步請求數(shù)據(jù)，那能不能實... C#實現(xiàn)異步套接字封裝server與client解決方案
之前一直用C#些了很多管理軟件，包括c/s , b/s ,之前一直都是同步寫法，相信大家都用ajax異步請求數(shù)據(jù)，那能不能實現(xiàn) C#實現(xiàn)異步套接字封裝server與client 呢，答案是肯定的。
今天文章中寫的是異步，純粹的異步，當(dāng)然很多人看來很簡單了，而且里面很多東西值得商榷，不過說真的，我真心感謝C#的線程池，不然我還要自己去寫個threadpool。而且我沒辦法保證我寫的沒問題。
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Net.Sockets;
using System.Net;
using System.Threading;
namespace PPT.Comm
{
///
/// 接收數(shù)據(jù)流
///
/// 異步套接字
/// 接收到的數(shù)據(jù)流
public delegate void AsyncDataAcceptedEventHandler(AsyncSocket m_pSocket, byte[] m_pDatagram);
///
/// 發(fā)送完畢
///
/// 異步套接字
/// 發(fā)送結(jié)果
public delegate void AsyncDataSendedEventHandler(AsyncSocket m_pSocket, bool m_pIsSuccess);
///
/// 接收連接委托
///
/// 異步套接字
public delegate void AsyncSocketAcceptEventHandler(AsyncSocket m_pSocket);
///
/// 關(guān)閉連接委托
///
/// 異步套接字
public delegate void AsyncSocketClosedEventHandler(AsyncSocket m_pSocket);
///
/// State object for receiving data from remote device.
///
class StateObject
{
// Client socket.
public Socket workSocket = null;
// Size of receive buffer.
public const int BufferSize = 1024 * 256;
// Receive buffer.
public byte[] buffer = new byte[BufferSize];
// Received data string.
public StringBuilder sb = new StringBuilder();
}
///
/// 異步SOCKET
///
public class AsyncSocket
{
#region 私有字段 成員
private Socket m_socket = null; //socket
string m_id = ""; //socket唯一標(biāo)識，GUID
private readonly bool m_isSerevr; //服務(wù)器標(biāo)志位
private int m_iBackBag;
private string m_ipAddress;
private int m_port;
private AsyncDataAcceptedEventHandler m_onAsyncDataAcceptedEvent = null; //接收數(shù)據(jù)流
private AsyncDataSendedEventHandler m_onAsyncDataSendedEvent = null; //發(fā)送結(jié)束
private AsyncSocketAcceptEventHandler m_onAsyncSocketAcceptEvent = null; //接收連接
private AsyncSocketClosedEventHandler m_onAsyncSocketClosedEvent = null; //關(guān)閉連接
#endregion
#region 公共屬性 成員
///
/// 獲取SOCKET標(biāo)志位
///
public string ID
{
get
{
return m_id;
}
}
///
/// 設(shè)置或獲取機器標(biāo)志位
///
public string MachineKey
{
set;
get;
}
///
/// 獲取、設(shè)置連接對象
///
public Socket LinkObject
{
get
{
return m_socket;
}
set
{
m_socket = value;
}
}
///
/// 設(shè)置或獲取線程退出標(biāo)識
///
public bool IsExit { set; get; }
#endregion
#region 公共事件 成員
///
/// 連接關(guān)閉事件
///
public event AsyncSocketClosedEventHandler AsyncSocketClosedEvent
{
add
{
m_onAsyncSocketClosedEvent += value;
}
remove
{
m_onAsyncSocketClosedEvent -= value;
}
}
///
/// 連接接收事件
///
public event AsyncSocketAcceptEventHandler AsyncSocketAcceptEvent
{
add
{
m_onAsyncSocketAcceptEvent += value;
}
remove
{
m_onAsyncSocketAcceptEvent -= value;
}
}
///
/// 數(shù)據(jù)接收完成事件
///
public event AsyncDataAcceptedEventHandler AsyncDataAcceptedEvent
{
add
{
this.m_onAsyncDataAcceptedEvent += value;
}
remove
{
this.m_onAsyncDataAcceptedEvent -= value;
}
}
///
/// 數(shù)據(jù)發(fā)送完成事件
///
public event AsyncDataSendedEventHandler AsyncDataSendedEvent
{
add
{
m_onAsyncDataSendedEvent += value;
}
remove
{
m_onAsyncDataSendedEvent -= value;
}
}
#endregion
#region 構(gòu)造函數(shù) 成員
///
/// 構(gòu)造函數(shù)
///
/// 主機地址，可為機器名或者IP
/// 主機端口
/// 是否作為服務(wù)器，默認(rèn)為false
/// 支持多少個客戶端
public AsyncSocket(string m_pHostAddrss, int m_pHostPort, bool m_pIsAsServer = false, int m_pIBackBag = 10)
{
m_isSerevr = m_pIsAsServer;
m_iBackBag = m_pIBackBag;
m_ipAddress = m_pHostAddrss;
m_port = m_pHostPort;
m_id = Guid.NewGuid().ToString();
}
///
/// 構(gòu)造函數(shù)，用于服務(wù)器構(gòu)造與客戶端的異步socket
///
/// 客戶端socket
private AsyncSocket(Socket linkObject)
{
m_socket = linkObject;
m_id = Guid.NewGuid().ToString();
}
#endregion
#region 公共方法
///
/// 打開通道
///
public void AsyncOpen()
{
if (m_isSerevr)
{
IPAddress ip = Dns.GetHostAddresses(m_ipAddress)[0];
IPEndPoint ipe = new IPEndPoint(ip, m_port);
m_socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
m_socket.Bind(ipe);
m_socket.Listen(m_iBackBag);
m_socket.BeginAccept(new AsyncCallback(AcceptCallBack), null);//異步
}
else
{
IPAddress ip = Dns.GetHostAddresses(m_ipAddress)[0];
IPEndPoint ipe = new IPEndPoint(ip, m_port);
m_socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
m_socket.Connect(ipe);
}
}
///
/// 發(fā)送二進制數(shù)據(jù)
///
///
public void AsyncSend(byte[] SendData)
{
m_socket.BeginSend(SendData, 0, SendData.Length, 0, new AsyncCallback(SendCallBack), m_socket);
}
///
/// 關(guān)閉通道
///
public void AsyncClose()
{
if (!m_isSerevr)
{
m_socket.Shutdown(SocketShutdown.Both);//關(guān)閉接收發(fā)送流
m_socket.BeginDisconnect(false, CloseCallBack, m_socket);//開始嘗試斷開
}
else
{
m_socket.Shutdown(SocketShutdown.Both);//關(guān)閉接收發(fā)送流
Thread.Sleep(200);//等待現(xiàn)有任務(wù)處理完成
m_socket.Dispose();//釋放所有本地資源
}
}
///
/// 開始接受數(shù)據(jù)，連接建立之后，調(diào)用此方法
///
public void BeginAcceptData()
{
//開始接收數(shù)據(jù)
StateObject state = new StateObject();
state.workSocket = m_socket;
m_socket.BeginReceive(state.buffer, 0, StateObject.BufferSize, 0, new AsyncCallback(ReceiveCallback), state);
}
#endregion
#region 私有方法 成員
#endregion
#region 回調(diào)函數(shù) 成員
///
/// 接受客戶端連接處理
///
///
private void AcceptCallBack(IAsyncResult ar)
{
Socket handler = m_socket.EndAccept(ar);
AsyncSocket NewSocket = new AsyncSocket(handler);
//激發(fā)事件，異步觸發(fā)
if (m_onAsyncSocketAcceptEvent != null)
foreach (AsyncSocketAcceptEventHandler item in m_onAsyncSocketAcceptEvent.GetInvocationList())
item.BeginInvoke(NewSocket, null, null);
//繼續(xù)投遞監(jiān)聽請求
m_socket.BeginAccept(new AsyncCallback(AcceptCallBack), null);
}
///
/// 接受字節(jié)流處理
///
///
private void ReceiveCallback(IAsyncResult ar)
{
try
{
StateObject state = ar.AsyncState as StateObject;
//讀取數(shù)據(jù)
int bytesRead = m_socket.EndReceive(ar);
if (bytesRead > 0)
{
byte[] _Readbyte = new byte[bytesRead];
Array.Copy(state.buffer, 0, _Readbyte, 0, bytesRead);
//接收完成，激發(fā)事件
if (m_onAsyncDataAcceptedEvent != null)
foreach (AsyncDataAcceptedEventHandler item in m_onAsyncDataAcceptedEvent.GetInvocationList())
item.BeginInvoke(this, _Readbyte, null, null);
state = new StateObject();//繼續(xù)投遞接收委托
state.workSocket = m_socket;
m_socket.BeginReceive(state.buffer, 0, StateObject.BufferSize, 0, new AsyncCallback(ReceiveCallback), state);
}
}
catch (SocketException)
{
if (m_onAsyncSocketClosedEvent != null)
foreach (AsyncSocketClosedEventHandler item in m_onAsyncSocketClosedEvent.GetInvocationList())
item.BeginInvoke(this, null, null);
}
}
///
/// 發(fā)送結(jié)束處理
///
///
private void SendCallBack(IAsyncResult ar)
{
try
{
m_socket.EndSend(ar);
if (m_onAsyncDataSendedEvent != null)
foreach (AsyncDataSendedEventHandler item in m_onAsyncDataSendedEvent.GetInvocationList())
item.BeginInvoke(this, true, null, null);
}
catch (SocketException)
{
if (m_onAsyncDataSendedEvent != null)
foreach (AsyncDataSendedEventHandler item in m_onAsyncDataSendedEvent.GetInvocationList())
item.BeginInvoke(this, false, null, null);
if (m_onAsyncSocketClosedEvent != null)
foreach (AsyncSocketClosedEventHandler item in m_onAsyncSocketClosedEvent.GetInvocationList())
item.BeginInvoke(this, null, null);
}
}
///
/// 關(guān)閉后處理
///
///
private void CloseCallBack(IAsyncResult ar)
{
try
{
m_socket.EndDisconnect(ar);
m_socket.Dispose();
if (m_onAsyncDataSendedEvent != null)
foreach (AsyncSocketClosedEventHandler item in m_onAsyncSocketClosedEvent.GetInvocationList())
item.BeginInvoke(this, null, null);
}
catch (SocketException)
{
if (m_onAsyncSocketClosedEvent != null)
foreach (AsyncSocketClosedEventHandler item in m_onAsyncSocketClosedEvent.GetInvocationList())
item.BeginInvoke(this, null, null);
}
}
#endregion
}
}
主要的代碼全部放出，注釋也寫的很詳細(xì)，當(dāng)然不能保證我寫的代碼沒有問題，但是本人測試過，應(yīng)該沒有打的問題。 學(xué)習(xí)教程快速掌握從入門到精通的電腦知識 | |
