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

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

(0)

相关推荐

  • TCP 四种定时器(重传定时器,坚持计时器,保活定时器,时间等待计时器)

    TCP 四种定时器 重传定时器 主要为了防止报文丢失或者阻塞.当A向B发送报文时,就会启动重传定时器,若在定时器到达之后,仍没有收到B的确认报文,则A会重新发送上次发送的报文.同时,令重传定时器复位.继续计时. 坚持计时器 此计时器针对下面场景: 当B向A发送了0窗口报文,B此时已经没有空间接受A发送的数据了,通知A停止发送.A在收到后即停止发送,等待一段时间后,B有了一些空间,可以继续接收了.此时再向A发送非0窗口报文.如果此非0窗口报文在网络中阻塞或者丢失了,那么A将永远以为B没有空间接收数

  • C++ boost::asio编程-异步TCP详解及实例代码

    C++ boost::asio编程-异步TCP 大家好,我是异步方式 和同步方式不同,我从来不花时间去等那些龟速的IO操作,我只是向系统说一声要做什么,然后就可以做其它事去了.如果系统完成了操作, 系统就会通过我之前给它的回调对象来通知我. 在ASIO库中,异步方式的函数或方法名称前面都有"async_ " 前缀,函数参数里会要求放一个回调函数(或仿函数).异步操作执行 后不管有没有完成都会立即返回,这时可以做一些其它事,直到回调函数(或仿函数)被调用,说明异步操作已经完成. 在ASI

  • python3.5实现socket通讯示例(TCP)

    TCP连接: tcp是面向连接的一个协议,意味着,客户端和服务器开发发送数据之前,需要先握手创建一个TCP连接.TCP连接的一端与客户端套接字相互联系,另一端与服务器套接字相联系.当创建该TCP连接的时,我们需要讲客户端与服务器的套接字地址(IP地址和端口号)关联起来.使用创建的TCP连接,当一侧要向另一侧发送数据的时候,它只需要经过其套接字将数据丢给TCP连接,不需要再次附上目的地址. 使用TCP连接的客户-服务器程序: TCPServer.py import socket import so

  • Java Socket编程实例(四)- NIO TCP实践

    一.回传协议接口和TCP方式实现: 1.接口: import java.nio.channels.SelectionKey; import java.io.IOException; public interface EchoProtocol { void handleAccept(SelectionKey key) throws IOException; void handleRead(SelectionKey key) throws IOException; void handleWrite(

  • java 基础知识之网络通信(TCP通信、UDP通信、多播以及NIO)总结

    java 基础知识之网路通信总结 在这篇文章里,我们主要讨论如何使用Java实现网络通信,包括TCP通信.UDP通信.多播以及NIO. TCP连接 TCP的基础是Socket,在TCP连接中,我们会使用ServerSocket和Socket,当客户端和服务器建立连接以后,剩下的基本就是对I/O的控制了. 我们先来看一个简单的TCP通信,它分为客户端和服务器端. 客户端代码如下: 简单的TCP客户端 import java.net.*; import java.io.*; public class

  • TCP的三次握手与四次挥手详细介绍

    TCP的三次握手与四次挥手详细介绍 为什么是三次握手? 目的:防止已失效的连接请求又传到了服务器端. 场景(A为客户,B为服务器):A向B发送一个请求连接报文,但是这个报文在网络中阻塞了,并没有传到B.所以B也无法向A发送确认报文,在A的重传计时器到达之后,A再次向B发送请求连接报文,这个报文B收到了,并且向A做出应答,建立连接,传输数据.数据传输完后,关闭连接.问题来了,就在B关闭连接之后,A第一次发送的请求连接报文到了(这个报文是已经失效的),B以为A要再次创建一个新连接,于是向A发送确认报

  • linux下2个检查tcp连接的命令

    1 检测web服务器的链接数量及状态: netstat -ant|awk '{print $5 "\t" $6}'|grep "::ffff:"|sed -e 's/::ffff://' -e 's/:[0-9]*//' |sort|uniq -c| sort -rn|head -10 结果: 122 125.162.71.199 TIME_WAIT 99 79.119.125.43 TIME_WAIT 81 125.167.243.77 TIME_WAIT 75

  • Android编程实现TCP、UDP客户端通信功能示例

    本文实例讲述了Android编程实现TCP.UDP客户端通信功能.分享给大家供大家参考,具体如下: 在进行Android开发的过程中,免不了,要开发TCP/UDP通讯的程序,下面这两段代码,分别介绍了TCP/UCP通过的一个实例: 代码一 TCP通讯: private void tcpdata() { try { Socket s = new Socket("192.168.0.25", 65500); // outgoing stream redirect to socket Out

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

    Socket的TCP通讯 一. socket的通讯原理 服务器端的步骤如下. (1)建立服务器端的Socket,开始侦听整个网络中的连接请求. (2)当检测到来自客户端的连接请求时,向客户端发送收到连接请求的信息,并建立与客户端之间的连接. (3)当完成通信后,服务器关闭与客户端的Socket连接. 客户端的步骤如下. (1)建立客户端的Socket,确定要连接的服务器的主机名和端口. (2)发送连接请求到服务器,并等待服务器的回馈信息. (3)连接成功后,与服务器进行数据的交互. (4)数据处

  • Python采用socket模拟TCP通讯的实现方法

    本文实例讲述了Python采用socket模拟TCP通讯的实现方法.分享给大家供大家参考.具体实现方法如下: 对于TCP server端的创建而言,分为如下几个步骤: 创建socket对象(socket):其中两个参数分别为Address Family(如AF_INET为IPV4,AF_INET6为IPV6,AF_UNIX为UNIX域协议族).socket类型(如SOCK_STREAM为TCP,SOCK_DGRAM为UDP). 绑定服务器地址(bind):参数为服务器地址二元组. 监听(list

  • 基于Python socket的端口扫描程序实例代码

    本文研究的主要是Python的端口扫描程序,具体实例代码如下. 先来看看第一个端口扫描程序代码,获取本机的IP和端口号: import socket def get_my_ip(): try: csock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) csock.connect(('8.8.8.8', 80)) (addr, port) = csock.getsockname() csock.close() return addr,port

  • python 使用raw socket进行TCP SYN扫描实例

    1. TCP SYN扫描 端口扫描常用于用于探测服务器或主机开放端口情况,被计算机管理员用于确认安全策略,同时被攻击者用于识别目标主机上的可运作的网络服务.端口扫描是向一定范围的服务器端口发送对应请求,以此确认可使用的端口.虽然其本身并不是恶意的网络活动,但也是网络攻击者探测目标主机服务,以利用该服务的已知漏洞的重要手段. TCP SYN扫描是端口扫描众多方式中的一种,其他方式包括TCP扫描,UDP扫描,ACK扫描,窗口扫描和FIN扫描等. TCP SYN扫描是另一种TCP扫描.端口扫描工具不使

  • socket unix domain IPC的实例代码

    仅供参考: 服务端:socket->bind->listen->send/recv->close 客户端:socket->bind->connect->send/recv->close #include <sys/socket.h> #include <sys/types.h> #include <netinet/in.h> #include <arpa/inet.h> #include <errno.h

  • Java Socket编程服务器响应客户端实例代码

    通过输入流来读取客户端信息,相应的时候通过输出流来实现. 服务端类的代码: import java.io.BufferedReader; import java.io.IOException; import java.io.InputStream; import java.io.InputStreamReader; import java.io.OutputStream; import java.io.PrintWriter; import java.net.ServerSocket; impo

  • Vue组件化通讯的实例代码

    1. Vue的组成文件(.vue) 分为三部分,分别对应html,js,css <template></template> <script></script> <style></style> 2. Vue的生命周期函数 beforeCreate() 创建数据之前 created() 创建数据 我们在这里的得到我们在data里面创建的数据 beforeMount() // Dom渲染完成前 mounted() //Dom渲染完成 bef

  • 利用thrift实现js与C#通讯的实例代码

    1.为什么要用thrift js C#? 1.1 首先,js 通过 thrift 访问C#,实际上是一种c/s模式.thrift是通信工具,js是客户端,C#是服务端. 1.2 使用js直接与thrift server通信.让web开发变得更简单.如果使用Web Service,你需要自己去实现C/S两端的序列化与反序列化操作,还需要自行处理异常,降低了开发效率.而thrift则会自动生成两端的操作类,你只需要处理方法内部的逻辑即可. 1.3 js直接与thrift server通信,可以提高性

  • C#基于Sockets类实现TCP通讯

    本文实例为大家分享了C#基于Sockets类实现TCP通讯的具体代码,供大家参考,具体内容如下 最终效果 TCPClient using System; using System.Collections.Generic; using System.ComponentModel; using System.Data; using System.Drawing; using System.Linq; using System.Text; using System.Threading.Tasks; u

  • Python3 socket即时通讯脚本实现代码实例(threading多线程)

    Python 提供了两个级别访问的网络服务.: 低级别的网络服务支持基本的 Socket,它提供了标准的 BSD Sockets API,可以访问底层操作系统Socket接口的全部方法. 高级别的网络服务模块 SocketServer, 它提供了服务器中心类,可以简化网络服务器的开发. ------------------------------------------------服务端代码-------------------------------------- __author__ = "

随机推荐