欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

C# Socket的TCP通讯的实例代码

程序员文章站 2022-04-01 09:07:45
socket的tcp通讯 一、 socket的通讯原理 服务器端的步骤如下。 (1)建立服务器端的socket,开始侦听整个网络中的连接请求。 (2)当检测到来自客...

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的一些心得,希望对大家的学习有所帮助,也希望大家多多支持。