C# NetHelper网络通信编程类[异步] - 苏飞论坛

/*
说明:Socket辅助类
作者:Ro4ters
编写时间: 26-06-2013
主要功能:
接收发送数据.(异步)
*/
class SocketHelper
{
public delegate void Uplistbox(string txt);
public Uplistbox uplb; //更新listbox委托变量
protected static readonly ILog logger = LogManager.GetLogger(typeof(TCPSocketServer2));
private ManualResetEvent allDone = new ManualResetEvent(false); //线程控制
protected Hashtable m_workerSocketHt = Hashtable.Synchronized(new Hashtable());//保存客户端socket哈希表
public AsyncCallback asyncCallBack; //声明异步完成时调用的方法.
private Socket m_mainSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);//主通信Socket
public bool isExit = false;//全局控制SOCKET启动和关闭
private long m_clientCount = 0L;//记录客户端数量
/// <summary>
/// 发送消息
/// </summary>
/// <param name="buffer">需要发送的字节</param>
public void Send(byte[] buffer)
{
try
{
//目标地址
IPEndPoint ip = new IPEndPoint(IPAddress.Parse("127.0.0.1"), 1234);
//发送通信socket
Socket sk = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
sk.Connect(ip);//连接
sk.Send(buffer);//发送
SocketUser su = new SocketUser();
su.CurrentSocket = sk;
su.DataBuffer = buffer;
//异步接收
asyncCallBack = new AsyncCallback(OnDataReceived);
sk.BeginReceive(su.DataBuffer, 0, su.DataBuffer.Length, SocketFlags.None, asyncCallBack, su);
}
catch (Exception ex)
{
string msg = ex.ToString() + " " + DateTime.Now.ToString();
uplb(msg);
logger.Debug(msg);
}
}
/// <summary>
/// 发送消息[重载]
/// </summary>
/// <param name="SocketUser">需要发送的SocketUser对象</param>
/// <param name="buffer">需要发送的字节</param>
public void Send(SocketUser su, byte[] buffer)
{
try
{
//目标地址
IPEndPoint ip = new IPEndPoint(IPAddress.Parse("127.0.0.1"), 1234);
//发送通信socket
su.CurrentSocket.Connect(ip);//连接
su.CurrentSocket.Send(buffer);//发送
su.DataBuffer = buffer;
//异步接收
asyncCallBack = new AsyncCallback(OnDataReceived);
su.CurrentSocket.BeginReceive(su.DataBuffer, 0, su.DataBuffer.Length, SocketFlags.None, asyncCallBack, su);
}
catch (Exception ex)
{
string msg = ex.ToString() + " " + DateTime.Now.ToString();
uplb(msg);
logger.Debug(msg);
}
}
/// <summary>
/// 建立监听连接
/// </summary>
/// <param name="port">监听的端口号</param>
private void AcceptConnection(object port)
{
try
{
IPEndPoint ipLocal = new IPEndPoint(IPAddress.Any, (int)port);
//绑定地址
m_mainSocket.Bind(ipLocal);
//开始监听
m_mainSocket.Listen(10000);
while (isExit == false)
{
try
{
allDone.Reset(); //线程阻塞
logger.Debug("TcpListener启动成功: " + ipLocal.Address.ToString() + "," + ipLocal.Port.ToString());
//接收异步连接并创建新的socket对象.
m_mainSocket.BeginAccept(new AsyncCallback(OnClientConnect), m_mainSocket);
allDone.WaitOne();
}
catch (SocketException sf)
{
logger.Error("客户连接请求异常" + sf.ToString());
}
catch (Exception f)
{
logger.Error("客户连接请求异常" + "错误信息:" + f.Message);
break;
}
}
}
catch (SocketException se)
{
logger.Error("TcpListener启动失败" + se.ToString() + "错误号:" + se.ErrorCode.ToString());
}
catch (Exception e)
{
logger.Error("TcpListener错误" + "错误信息:" + e.Message);
}
}
/// <summary>
/// 开始监听
/// </summary>
/// <param name="Port">监听的端口</param>
/// <param name="buffer">发送的字节</param>
public bool StartListening(int Port, params byte[] buffer)
{
if (Port == 0)
{
logger.Debug("TcpListener未启动,请指定监听的端口号.");
return false;
}
// 创建监听socket
Thread AcceptTh = new Thread(new ThreadStart(delegate
{
AcceptConnection(Port);
}));
AcceptTh.Start();
Thread sendth = new Thread(new ThreadStart(delegate
{
Send(buffer);
}));
sendth.Start();
logger.Debug("启动TCP监听,端口: " + Port);
return true;
}
//下面方法在二楼
}
}

复制代码

/// <summary>
/// 释放Socket
/// </summary>
/// <param name="user"></param>
public void ClientDisConnect(SocketUser user)
{
try
{
logger.Error("数据中心：" + user.ClientName + "," + user.LoginIP + " 断开连接");
if (user != null)
{
if (user.CurrentSocket != null)
{
//释放连接
user.CurrentSocket.Shutdown(SocketShutdown.Both);
user.CurrentSocket.Close();
user.CurrentSocket = null;
}
user = null;
}
}
catch (Exception e)
{
logger.Error("关闭TCP连接错误：" + e.ToString());
}
}
/// <summary>
/// 异步接收传入连接
/// </summary>
/// <param name="asyn"></param>
public void OnClientConnect(IAsyncResult asyn)
{
try
{
allDone.Set();
if (m_mainSocket == null)
{
logger.Debug("TCP监听服务已关闭");
return;
}
Socket workerSocket = (Socket)asyn.AsyncState;
Socket Temuser = m_mainSocket.EndAccept(asyn);//异步接收
Interlocked.Increment(ref m_clientCount); //连接数量
SocketUser user = new SocketUser(Temuser, m_clientCount);
WaitForData(user); //等待线程数据
}
catch (Exception ex)
{
System.Windows.Forms.MessageBox.Show(ex.ToString());
return;
}
}
/// <summary>
/// 线程等待数据
/// </summary>
/// <param name="soc"></param>
/// <param name="clientNumber"></param>
public void WaitForData(SocketUser theUser)
{
try
{
asyncCallBack = new AsyncCallback(OnDataReceived); //实例化委托.
if (theUser != null)
{
//异步接收
theUser.CurrentSocket.BeginReceive(theUser.DataBuffer, 0, theUser.DataBuffer.Length, SocketFlags.None, asyncCallBack, theUser);
}
}
catch (SocketException se)
{
logger.Error("数据处理异常1" + se.ToString());
}
}
byte[] buffer = new byte[1024 * 1024];
/// <summary>
/// 接收数据(异步回调)
/// </summary>
/// <param name="asyn">异步返回的连接状态</param>
public void OnDataReceived(IAsyncResult asyn)
{
SocketUser theUser = (SocketUser)asyn.AsyncState;
try
{
if (theUser.CurrentSocket == null)
{
logger.Error("socket is null ");
return;
}
int iRx = theUser.CurrentSocket.EndReceive(asyn); //接收到的消息长度
if (iRx == 0)
{
logger.Error("没有接收的数据，断开tcp连接");
throw new SocketException(10054);
}
//提取有效字节数据
byte[] data = new byte[iRx];
byte[] buff = theUser.DataBuffer;
for (int i = 0; i < iRx; i++)
{
data[i] = buff[i];
}
//数据处理
ProcessReceiveData(theUser, data);
//继续等待数据
if (isExit == false)
{
WaitForData(theUser);
}
}
catch (ObjectDisposedException ode)
{
logger.Error("数据处理异常2" + ode.ToString());
}
catch (SocketException se)
{
if (se.ErrorCode == 10054)
{
logger.Error("Tcp连接被关闭 " + se.Message);
ClientDisConnect(theUser);
}
else
{
logger.Error("数据处理异常3" + se.ToString());
}
}
}
/// <summary>
/// 处理数据.
/// </summary>
/// <param name="socketuser">接收消息的SocketUser</param>
/// <param name="buffer">接收的消息</param>
private void ProcessReceiveData(SocketUser socketuser, byte[] buffer)
{
string msg = System.Text.Encoding.ASCII.GetString(buffer);
uplb(msg);
}

复制代码