首先来介绍一下Sockets类中的函数:
SocketType |
ProtocolType |
描述 |
||||||
Stream |
Tcp |
面向连接 |
||||||
Dgram |
Udp |
面向无连接 |
||||||
Raw |
Icmp |
网际消息控制 |
||||||
Raw |
Raw |
基础传输协议 |
||||||
Socket类的公共属性: |
||||||||
属性名 |
描述 |
|||||||
AddressFamily |
获取Socket的地址族 |
|||||||
Available |
获取已经从网络接收且可供读取的数据量 |
|||||||
Blocking |
获取或设置一个值,只是socket是否处于阻塞模式 |
|||||||
Connected |
获取一个值,指示当前连接状态 |
|||||||
Handle |
获取socket的操作系统句柄 |
|||||||
LocalEndPoint |
获取本地终端EndPoint |
|||||||
RemoteEndPoint |
获取远程终端EndPoint |
|||||||
ProtocolType |
获取协议类型 |
|||||||
SocketType |
获取SocketType类型 |
|||||||
Socket常用方法: |
||||||||
Bind(EndPoint) |
服务器端套接字需要绑定到特定的终端,客户端也可以先绑定再请求连接 |
|||||||
Listen(int) |
监听端口,其中parameters表示最大监听数 |
|||||||
Accept() |
接受客户端链接,并返回一个新的链接,用于处理同客户端的通信问题 |
|||||||
|
||||||||
Send() |
发送数据 |
|||||||
Send(byte[]) |
简单发送数据 |
|||||||
Send(byte[],SocketFlag) |
使用指定的SocketFlag发送数据 |
|||||||
Send(byte[], int, SocketFlag) |
使用指定的SocketFlag发送指定长度数据 |
|||||||
Send(byte[], int, int, SocketFlag) |
使用指定的SocketFlag,将指定字节数的数据发送到已连接的socket(从指定偏移量开始) |
|||||||
Receive() |
接受数据 |
|||||||
Receive(byte[]) |
简单接受数据 |
|||||||
Receive (byte[],SocketFlag) |
使用指定的SocketFlag接受数据 |
|||||||
Receive (byte[], int, SocketFlag) |
使用指定的SocketFlag接受指定长度数据 |
|||||||
Receive (byte[], int, int, SocketFlag) |
使用指定的SocketFlag,从绑定的套接字接收指定字节数的数据,并存到指定偏移量位置的缓冲区 |
|||||||
|
||||||||
Connect(EndPoint) |
连接远程服务器 |
|||||||
ShutDown(SocketShutDown) |
禁用套接字,其中SocketShutDown为枚举,Send禁止发送,Receive为禁止接受,Both为两者都禁止 |
|||||||
Close() |
关闭套接字,释放资源 |
|||||||
异步通信方法: |
||||||||
BeginAccept(AsynscCallBack,object) |
开始一个一步操作接受一个连接尝试。参数:一个委托。一个对象。对象包含此请求的状态信息。其中回调方法中必须使用EndAccept方法。应用程序调用BegineAccept方法后,系统会使用单独的线程执行指定的回调方法并在EndAccept上一直处于阻塞状态,直至监测到挂起的链接。EndAccept会返回新的socket对象。供你来同远程主机数据交互。不能使用返回的这个socket接受队列中的任何附加连接。调用BeginAccept当希望原始线程阻塞的时候,请调用WaitHandle.WaitOne方法。当需要原始线程继续执行时请在回调方法中使用ManualResetEvent的set方法 |
|||||||
BeginConnect(EndPoint, AsyncCallBack, Object) |
回调方法中必须使用EndConnect()方法。Object中存储了连接的详细信息。 |
|||||||
BeginSend(byte[], SocketFlag, AsyncCallBack, Object) |
|
|||||||
BegineReceive(byte[], SocketFlag, AsyncCallBack, Object) |
|
|||||||
BegineDisconnect(bool, AsyncCallBack, Object) |
|
如果这上面的你都非常熟悉,那其实写代码就非常容易了
在C#网络框架搭建系列(一) ------ 基础知识中我们知道了服务端与客户端的连接步骤,接下来我们就来看看实现的代码:
1.服务端(server脚本) :
serverSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
serverSocket.Bind(ipEndPoint); //绑定IP与端口号
serverSocket.Listen(maxConn);
serverSocket.BeginAccept(AcceptCB, null); //开始监听客户端的连接
当有客户端接入时:
private void AcceptCB(IAsyncResult ar)
{
try
{
Socket socket = serverSocket.EndAccept(ar);
int index = NewIndex();
if (index < 0)
{
socket.Close();
Console.Write("[AcceptCB警告]链接已满");
}
else
{
Client client = clientConn[index];
client.Init(socket,this);
Console.WriteLine("客户端连接 [" + client.GetAdress() + "] conn池ID:" + index);
}
serverSocket.BeginAccept(AcceptCB, null);
}
catch (Exception e)
{
Console.WriteLine("AcceptCb失败:" + e.Message);
}
}
在这里我维护了一个客户端连接的对象池,以下是得到其索引的函数:
public int NewIndex()
{
if (clientConn == null)
return -1;
for (int i = 0; i < clientConn.Length; i++)
{
if (clientConn[i] == null)
{
clientConn[i] = new Client();
return i;
}
else if (clientConn[i].isUse == false)
{
return i;
}
}
return -1;
}
2.客户端(ClientFramework中的ClientManage脚本):
初始化时连接服务器
//连接服务器
public void OnInit()
{
clientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
try
{
clientSocket.Connect(IP, PORT);
Console.WriteLine("连接到服务器");
Start(); //开始监听服务器发送的消息
}
catch (Exception e)
{
Console.WriteLine("无法连接到服务器端,请检查您的网络!!" + e);
}
}
监听接收:
private void Start()
{
clientSocket.BeginReceive(msg.Data, msg.StartIndex, msg.RemainSize, SocketFlags.None, ReceiveCB, null);
}