C# NetHelper网络通信编程类[异步]

ro4ters · 发表于 2013-6-26 17:02:36

之前飞哥发了一个同步的版本,我来个异步的吧.{:soso_e113:}(只写了tcp,udp懒得写了.)
http://www.sufeinet.com/thread-3678-1-1.html
注释都写了.过程也理清楚了.完全当学习的东西看吧..

/*
说明: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;
}
//下面方法在二楼
}
}

复制代码

Have Fun; {:soso_e121:}
26-06-2013

ro4ters · 发表于 2013-6-26 17:02:50

/// <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);
}

复制代码

ro4ters · 发表于 2013-6-26 17:06:20

还是发个全的吧.....

站长苏飞 · 发表于 2013-6-26 17:12:24

异步的我的库里也有，只是还不稳定，没开放，异步不同于同步的那么稳定，我目前还没有研究透彻，我建议你能个例子，大量数据测试一下，异步的功能和同步的就是多了个线程和委托控件，最关键的是稳定性。
其他的我感觉都是次要的。
楼主这个看着行，不知道实际怎么样。有时间给能个例子上来测试下吧

ro4ters · 发表于 2013-6-26 19:04:07

站长苏飞发表于 2013-6-26 17:12
异步的我的库里也有，只是还不稳定，没开放，异步不同于同步的那么稳定，我目前还没有研究透彻，我建议你能 ...

实际大批量数据效果还有待测试,我服务器上代码用的是异步,每天2000+客户端同时连接(5-15秒发送一条数据)...暂时没发现太大的问题,可能数据有点小的原因吧.

站长苏飞 · 发表于 2013-6-26 20:37:50

ro4ters 发表于 2013-6-26 19:04
实际大批量数据效果还有待测试,我服务器上代码用的是异步,每天2000+客户端同时连接(5-15秒发送一条数据). ...

那也不错了，还有一个就是并发，你这个量，并发的可能不大，不错了，挺好

x228223 · 发表于 2014-4-22 21:58:47

想学习这个但现在还在到基础。。

非对称 · 发表于 2014-6-4 14:34:41

强烈支持楼主ing……

coody · 发表于 2014-6-6 16:55:46

受教了，学习中……

忆如从前 · 发表于 2014-6-9 15:40:27

刚开始学习这个东西能不能给个实例呀 ,, 万分感谢 ,, ,,,zll88108@126.com

		自动登录	找回密码
密码			马上注册

[功能帮助类] C# NetHelper网络通信编程类[异步]

相关帖子