c# 开源tcp框架（c#实现tcp）

1、tcp/ip层次模型

当然这里我们只讨论重要的四层

01，应用层(application)：应用层是个很广泛的概念，有一些基本相同的系统级tcp/ip应用以及应用协议，也有许多的企业应用和互联网应用。http协议在应用层运行。

02，传输层(tanspot)：传输层包括udp和tcp，udp几乎不对报文进行检查，而tcp提供传输保证。

03，网络层(netwok):网络层协议由一系列协议组成，包括icmp、igmp、rip、ospf、ip(v4,v6)等。

04，链路层(link):又称为物理数据网络接口层，负责报文传输。

然后我们来看下tcp层次模型图

从上图中可以看出，应用程序在应用层运行，在传输层，在数据前加上了tcp头，在

网络层加上的ip头，在数据链路层加上了帧。

2、端口

端口号范围:0-65535，总共能表示65536个数。

按端口号可分为3大类

　　（1）公认端口（wellknownports）：从0到1023，它们紧密绑定（binding）于一些服务。通常这些端口的通讯明确表明了某种服务的协议。例如：80端口实际上总是http通讯。

　　（2）注册端口（registeredports）：从1024到49151。它们松散地绑定于一些服务。也就是说有许多服务绑定于这些端口，这些端口同样用于许多其它目的。例如：许多系统处理动态端口从1024左右开始。

　　（3）动态和/或私有端口（dynamicand/orprivateports）：从49152到65535。理论上，不应为服务分配这些端口。实际上，机器通常从1024起分配动态端口。

3.tcp和udp报文

下面一起来看下tcp和udp的报文图

从图中我们可以看出tcp和udp中都有校验和，但是在udp报文中，一般不使用校验和，这样可以加快数据传输的速度，但是数据的准确性可能会受到影响。换句话说，tcp协议都有校验和，为了保证传输数据的准确性。

3.socket

socket包括ip地址和端口号两部分，程序通过socket来通信，socket相当于操作系统的一个组件。socket作为进程之间通信机制，通常也称作”套接字”，用于描述ip地址和端口号，是一个通信链的句柄。说白了，就是两个程序通信用的。

生活案例对比：

socket之间的通信可以类比生活中打电话的案例。任何用户在通话之前，首先要占有一部电话机，相当于申请一个socket，同时要知道对方的号码，相当于对方有一个固定的socket，然后向对方拨号呼叫，相当于发出连接请求。假如对方在场并空闲，拿起 电话话筒，双方就可以进行通话了。双方的通话过程，是一方向电话机发出信号和对方从电话机接收信号的过程，相当于向socket发送数据和从socket接收数据。通话结束后，一方挂起电话机，相当于关闭socket，撤销连接。

注意：socket不仅可以在两台电脑之间通信，还可以在同一台电脑上的两个程序间通信。

4，端口进阶(深入)

通过ip地址确定了网络中的一台电脑后，该电脑上可能提供很多提供服务的应用，每一个应用都对应一个端口。

在internet上有很多这样的主机，这些主机一般运行了多个服务软件 ，同时提供几种服务，每种服务都打开一个socket，并绑定到一个端口上，不同的端口对应于不同的服务(应用程序)

例如：http 使用80端口， ftp使用21端口 smtp使用25端口

5.socket分类

socket主要有两种类型：

流式socket

是一种面向连接的socket，针对于面向连接的tcp服务应用，安全，但是效率低

2，数据报式socket

是一种无连接的socket，对应于无连接的udp服务应用，不安全，但效率高

6. socket一般应用模式(服务器端和客户端)

服务器端的socket(至少需要两个)

01.一个负责接收客户端连接请求(但不负责与客户端通信)

02.每成功接收到客户端的连接便在服务器端产生一个对应的复杂通信的socket

021.在接收到客户端连接时创建

022. 为每个连接成功的客户端请求在服务器端都创建一个对应的socket(负责和客户端通信)

客户端的socket

必须指定要连接的服务器地址和端口

通过创建一个socket对象来初始化一个到服务器端的tcp连接

通过上图，我们可以看出，首先服务器会创建一个负责监听的socket，然后客户端通过socket连接到服务器指定端口，最后服务器端负责监听的socket，监听到客户端有连接过来了，就创建一个负责和客户端通信的socket。

下面我们来看下socket更具体的通信过程：

socket的通讯过程

服务器端：

01，申请一个socket

02，绑定到一个ip地址和一个端口上

03，开启侦听，等待接收连接

客户端：

01，申请一个socket

02，连接服务器(指明ip地址和端口号)

服务器端接收到连接请求后，产生一个新的socket(端口大于1024)与客户端建立连接并进行通信，原监听socket继续监听。

注意：负责通信的socket不能无限创建，创建的数量和操作系统有关。

7.socket的构造函数

public socket(addressfamily addressfamily,sockettype sockettype,protocoltype protocoltype)

addressfamily：指定socket用来解析地址的寻址方案。例如：internetwork指示当socket使用一个ip版本4地址连接

sockettype：定义要打开的socket的类型

socket类使用protocoltype枚举向windows sockets api通知所请求的协议

注意：

1，端口号必须在 1 和 65535之间，最好在1024以后。

2，要连接的远程主机必须正在监听指定端口，也就是说你无法随意连接远程主机。

如：

ipaddress addr = ipaddress.parse("127.0.0.1");

ipendpoint endp = new ipendpoint(addr,,9000);

服务端先绑定：serverwelcomesocket.bind(endp)

客户端再连接：clientsocket.connect(endp)

3,一个socket一次只能连接一台主机

4,socket关闭后无法再次使用

5,每个socket对象只能与一台远程主机连接。如果你想连接到多台远程主机，你必须创建多个socket对象。

8.socket常用类和方法

相关类：

ipaddress：包含了一个ip地址

ipendpoint：包含了一对ip地址和端口号

方法：

socket():创建一个socket

bind():绑定一个本地的ip和端口号（ipendpoint）

listen():让socket侦听传入的连接吃那个病，并指定侦听队列容量

connect():初始化与另一个socket的连接

accept（）：接收连接并返回一个新的socket

send（）：输出数据到socket

receive():从socket中读取数据

close():关闭socket，销毁连接

接下来，我们同一个简单的服务器和客户端通信的案例，来看下sokcet的具体用法，效果图如下：

关键代码：

服务器端代码：

复制代码 代码如下:
private void form1_load(object sender, eventargs e)
{
control.checkforillegalcrossthreadcalls = false;
}
private void btnlisten_click(object sender, eventargs e)
{
//ip地址
ipaddress ip = ipaddress.parse(txtip.text);
// ipaddress ip = ipaddress.any;
//端口号
ipendpoint point=new ipendpoint(ip,int.parse(txtport.text));
//创建监听用的socket
/*
* addressfamily.internetwork：使用 ip4地址。
sockettype.stream：支持可靠、双向、基于连接的字节流，而不重复数据。此类型的 socket 与单个对方主机进行通信，并且在通信开始之前需要远程主机连接。stream 使用传输控制协议 (tcp) protocoltype 和 internetworkaddressfamily。
protocoltype.tcp：使用传输控制协议。
*/
//使用ipv4地址，流式socket方式，tcp协议传递数据
socket socket=new socket(addressfamily.internetwork,sockettype.stream,protocoltype.tcp);
//创建好socket后，必须告诉socket绑定的ip地址和端口号。
//让socket监听point
try
{
//socket监听哪个端口
socket.bind(point);
//同一个时间点过来10个客户端，排队
socket.listen(10);
showmsg("服务器开始监听");
thread thread = new thread(acceptinfo);
thread.isbackground = true;
thread.start(socket);
}
catch (exception ex)
{
showmsg(ex.message);
}
}
//记录通信用的socket
dictionary<string,socket> dic=new dictionary<string, socket>();
// private socket client;
void acceptinfo(object o)
{
socket socket = o as socket;
while (true)
{
//通信用socket
try
{
//创建通信用的socket
socket tsocket = socket.accept();
string point = tsocket.remoteendpoint.tostring();
//ipendpoint endpoint = (ipendpoint)client.remoteendpoint;
//string me = dns.gethostname();//得到本机名称
//messagebox.show(me);
showmsg(point + "连接成功！");
cboipport.items.add(point);
dic.add(point, tsocket);
//接收消息
thread th = new thread(receivemsg);
th.isbackground = true;
th.start(tsocket);
}
catch (exception ex)
{
showmsg(ex.message);
break;
}
}
}
//接收消息
void receivemsg(object o)
{
socket client = o as socket;
while (true)
{
//接收客户端发送过来的数据
try
{
//定义byte数组存放从客户端接收过来的数据
byte[] buffer = new byte[1024 * 1024];
//将接收过来的数据放到buffer中，并返回实际接受数据的长度
int n = client.receive(buffer);
//将字节转换成字符串
string words = encoding.utf8.getstring(buffer, 0, n);
showmsg(client.remoteendpoint.tostring() + ":" + words);
}
catch (exception ex)
{
showmsg(ex.message);
break;
}
}
}
void showmsg(string msg)
{
txtlog.appendtext(msg+"\r\n");
}
private void form1_formclosing(object sender, formclosingeventargs e)
{
//主窗体关闭时关闭子线程
}
//给客户端发送消息
private void btnsend_click(object sender, eventargs e)
{
try
{
showmsg(txtmsg.text);
string ip = cboipport.text;
byte[] buffer = encoding.utf8.getbytes(txtmsg.text);
dic[ip].send(buffer);
// client.send(buffer);
}
catch (exception ex)
{
showmsg(ex.message);
}
}
客户端代码：
复制代码 代码如下:
socket client = new socket(addressfamily.internetwork, sockettype.stream, protocoltype.tcp);
private void btnconnection_click(object sender, eventargs e)
{
//连接到的目标ip
ipaddress ip = ipaddress.parse(txtip.text);
//ipaddress ip = ipaddress.any;
//连接到目标ip的哪个应用(端口号！)
ipendpoint point=new ipendpoint(ip,int.parse(txtport.text));
try
{
//连接到服务器
client.connect(point);
showmsg("连接成功");
showmsg("服务器" + client.remoteendpoint.tostring());
showmsg("客户端:" + client.localendpoint.tostring());
//连接成功后，就可以接收服务器发送的信息了
thread th=new thread(receivemsg);
th.isbackground = true;
th.start();
}
catch (exception ex)
{
showmsg(ex.message);
}
}
//接收服务器的消息
void receivemsg()
{
while (true)
{
try
{
byte[] buffer = new byte[1024 * 1024];
int n = client.receive(buffer);
string s = encoding.utf8.getstring(buffer, 0, n);
showmsg(client.remoteendpoint.tostring() + ":" + s);
}
catch (exception ex)
{
showmsg(ex.message);
break;
}
}
}
void showmsg(string msg)
{
txtinfo.appendtext(msg+"\r\n");
}
private void btnsend_click(object sender, eventargs e)
{
//客户端给服务器发消息
if (client!=null)
{
try
{
showmsg(txtmsg.text);
byte[] buffer = encoding.utf8.getbytes(txtmsg.text);
client.send(buffer);
}
catch (exception ex)
{
showmsg(ex.message);
}
}
}
private void clientform_load(object sender, eventargs e)
{
control.checkforillegalcrossthreadcalls = false;
}
好了，到这里我们对socket的讨论就告一个段落了。