socket的tcp通讯
一、 socket的通讯原理
服务器端的步骤如下。
（1）建立服务器端的socket，开始侦听整个网络中的连接请求。
（2）当检测到来自客户端的连接请求时，向客户端发送收到连接请求的信息，并建立与客户端之间的连接。
（3）当完成通信后，服务器关闭与客户端的socket连接。
客户端的步骤如下。
（1）建立客户端的socket，确定要连接的服务器的主机名和端口。
（2）发送连接请求到服务器，并等待服务器的回馈信息。
（3）连接成功后，与服务器进行数据的交互。
（4）数据处理完毕后，关闭自身的socket连接。
二、 socket的通讯方式
socket通讯方式有两种：同步和异步
同步工作方式:
用tcp协议进行编程时程序执行到发送、接收和监听语句的时候，在未完成工作前不再继续往下执行，即处于阻塞状态，直到该语句完成某个工作后才继续执行下一条语句。
异步工作方式
程序执行到发送、接收和监听语句的时候，不论工作是否完成，都会继续往下执行。
三、 socket的c#实现
1.1. 同步：
服务端客户端通信
在与服务端的连接建立以后，我们就可以通过此连接来发送和接收数据。端口与端口之间以流（stream）的形式传输数据，因为几乎任何对象都可以保存到流中，所以实际上可以在客户端与服务端之间传输任何类型的数据。对客户端来说，往流中写入数据，即为向服务器传送数据；从流中读取数据，即为从服务端接收数据。对服务端来说，往流中写入数据，即为向客户端发送数据；从流中读取数据，即为从客户端接收数据。
服务端：
（1）服务端对端口进行侦听：
服务器端建立一个socket，设置好本机的ip和监听的端口与socket进行绑定，开始监听连接请求，当接收到连接请求后，发送确认，同客户端建立连接，开始与客户端进行通信。
tcplistener listener =new tcplistener(new ipendpoint(ipaddress.parse(ip), port));//ip为服务器ip地址，port为监听的端口 listener.start();//开启监听
(2)检测来自客户端的连接请求
tcpclient remoteclient = listener.accepttcpclient(); //接收客户端 这里体现了同步的含义，如果客户端对该服务端发起连接的时候，程序在这里就会等待（阻塞），直到有客户端的连接请求为止
(3)建立和连接的客户端的数据流（传输数据）
networkstream streamtoclient = remoteclient.getstream();
该数据流只要是用来接收和发送数据，同步也分多客户端和单个客户端，如果分的详细一点的话，还有客户端的一条以及多条数据的情况，如果是单个客户端的多条数据的话，连接客户端之后，在建立数据流的前面添加一个循环就可以了，如果是多个客户端的话，在（2）前面加个循环就可以了。为了接收数据的效率，建议不管是同步还是异步，服务端都做成线程，详细见demo
(4)接收客户端发送过来的数据（用缓存来接收）
我要评论
byte[] buffer = new byte[buffersize]; // buffersize为缓存的大小
int bytesread;
try
{
lock (streamtoclient)//为了保证数据的完整性以及安全性 锁定数据流
{
bytesread = streamtoclient.read(buffer, 0, buffersize);
}
(5)向连接的客户端发送数据
lock (streamtoclient)
{
streamtoclient.write(buffer, 0, buffer.length);//buffer为发送的字符数组
}
(6)释放数据流和tcpclient（以便下次的数据以及客户端的收发）
streamtoclient.dispose();//释放数据流中的数据 remoteclient.close();//释放tcpclient实例
客户端
（1） 连接服务器
tcpclient tcp = new tcpclient();
tcp.connect(ip,port);//根据服务器的ip地址和侦听的端口连接
if (tcp.connected)
{
//连接成功的消息机制 详细见demo
showgetdata("成功连接上了服务器：", this.strip.text.tostring());
}
这里需要注意的是，不管是使用有参数的构造函数与服务器连接，或者是通过connect()方法与服务器建立连接，都是同步方法（或者说是阻塞的，英文叫block）。它的意思是说，客户端在与服务端连接成功、从而方法返回，或者是服务端不存、从而抛出异常之前，是无法继续进行后继操作的。这里还有一个名为beginconnect()的方法，用于实施异步的连接，这样程序不会被阻塞，可以立即执行后面的操作，这是因为可能由于网络拥塞等问题，连接需要较长时间才能完成。网络编程中有非常多的异步操作，凡事都是由简入难，关于异步操作，我们后面再讨论，现在只看同步操作。
（2） 建立连接服务端的数据流
networkstream streamtoserver = tcp.getstream();
（3） 接收和发送数据
//发送字符串
byte[] buffer = encoding.unicode.getbytes(msg); //msg为发送的字符串
try
{
lock (streamtoserver)
{
streamtoserver.write(buffer, 0, buffer.length); // 发往服务器
}
//接收字符串
buffer = new byte[buffersize];
lock (streamtoserver)
{
bytesread = streamtoserver.read(buffer, 0, buffersize);
}
}
1.2. 异步
相对于同步，异步中的连接，接收和发送数据的方法都不一样，都有一个回调函数，就是即使不能连接或者接收不到数据，程序还是会一直执行下去，如果连接上了或者接到数据，程序会回到这个回调函数的地方重新往下执行。详细见下面：
服务器：
1、 开启侦听接口
private tcplistener listener; //监听类 listener = new tcplistener(new ipendpoint(ipaddress.parse(ip), port)); listener.start();//开启侦听，对连接的客户端的数目没有限制
或者
listener.start(int i);// 开启侦听，最多只能连接i个客户端数目
2、 接收客户端
listener.beginacceptsocket(clientconnect, listener);//异步接受客户端的连接请求 clientconnect为连接的回调函数
/// <summary>
/// 接收回调函数
/// </summary>
/// <param name="ar"></param>
private void clientconnect(iasyncresult ar)
{
try
{
tcplistener listener = (tcplistener)ar.asyncstate;
//接受客户的连接,得到连接的socket
socket client = listener.endacceptsocket(ar);
}
catch { }
}
3、 接收客户端发送的数据
/// <summary>
/// 异步接收数据
/// </summary>
private void receivedata(socket client)
{
// 调用异步方法 beginreceive 来告知 socket 如何接收数据
iasyncresult iar = client.beginreceive(buffer, 0, bagsize, socketflags.none, out errorcode, receivecallback, buffer);
}
}
/// <summary>
/// 接收数据回调函数
/// </summary>
/// <param name="ar"></param>
private void receivecallback(iasyncresult ar)
{
//接收到的数据长度．
int recelen = 0;
try
{
recelen = client.endreceive(ar, out errorcode);
if (recelen > 0)
{
onreceivedata(client);//接收到数据之后的处理函数
}
}
catch { }
}
else { }
}
4、接收成功之后，回发数据给客户端
/// <summary>
/// 异步发送报文
/// </summary>
/// <param name="data"></param>
private void onreceivedata (socket socket)
{
string strlogin = “succeed recived”;
byte[] data = encoding.ascii.getbytes(strlogin);
socket.beginsend(data, 0, data.length, socketflags.none, out errorcode, sendcallback, socket);//异步发送数据
}
else
{ }
}
/// <summary>
/// 异步发送回调事件
/// </summary>
/// <param name="ar"></param>
private void sendcallback(iasyncresult ar)
{
socket.endsend(ar, out errorcode);
}
客户端
1、连接服务器
private tcpclient tcpcz = null
tcpcz = new tcpclient()
tcpcz.beginconnect(ipaddress, convert.toint32(port), new asynccallback(connectcallback), tcpcz);//根据服务器的ip地址和端口号 异步连接服务器
/// <summary>
/// 异步连接的回调函数
/// </summary>
/// <param name="ar"></param>
private void connectcallback(iasyncresult ar)
{
tcpclient t = (tcpclient)ar.asyncstate;
try
{
if (t.connected)
{
t.endconnect(ar);//函数运行到这里就说明连接成功
}
else
{
}
}
catch () { }
}
2、发送和接收字符串
networkstream stream = tcp.getstream();//创建于服务器连接的数据流
//发送字符串
string strlogin = “this is socket example”;
byte[] data = encoding.ascii.getbytes(strlogin);
stream.beginwrite(data, 0, data.length, new asynccallback(sendcallback),stream);//异步发送数据
//接收字符串
byte[] result = new byte[tcp.available]; // tcp.available为接受的字符串大小
try
{
stream.beginread(result, 0, result.length, new asynccallback(readcallback), stream);//异步接受服务器回报的字符串
}
catch { }
string strresponse = encoding.ascii.getstring(result).trim();//从服务器接受到的字符串
}
}
catch ()
{
}
}
以上是这一段时间对socket的一些心得，希望对大家的学习有所帮助，也希望大家多多支持移动技术网。
如对本文有疑问， 点击进行留言回复！！
使用Visual Studio2019创建C#项目(窗体应用程序、控制台应用程序、Web应用程序)
C#实现获取本地内网(局域网)和外网(公网)IP地址的方法分析
网友评论