#include "net.h"　　　　　　 // 包含这个net.h就可以使用所有TCP/IP中间件的以下4个功能

 TcpClient     tcpc1;　　　　// 定义一个TCP客户端,用于主动连接目标主机

 TcpListener   tcpl1;　　　　// 定义一个TCP服务端,用于侦听来自远程主机的连接

 Socket        socket1;　　 // 定义一个符合Berkeley套接字标准的socket

 UdpClient     udp1;    　　// 定义一个UDP客户端

 // 测试TCP客户端

 void TestTcpClient(void){

     tcpc1.Init(“192.168.1.120”,);    // 建立默认远程主机

     tcpc1.Connect();    // 连接,任务将阻塞,连接成功或连接超时返回,.Connect(3000)表示3秒超时,无参数表示不超时

     tcpc1.Send("Hello, TcpClient !\n");

     tcp1.Close();                        // 关闭连接

 }

 // 测试TCP服务端

 void TestTcpListener(void){

     int len;

     byte rxbuf[];

     tcpl1.Init();    // 将本程序表示为11000端口

     tcpl1.Start();        // 开始异步侦听

     while(true){

         len = tcpl1.rxStream.GetNewLine(rxbuf,sizeof(rxbuf));    // 读数据,接收成功返回长度,否则返回0

         if(len){

             tcpl1.Send(“\n接收到:”)

             tcpl1.Send(rxbuf,len);        // 将接收到的数据发回

         }

     }

     tcp1.Close();                        // 关闭连接,示意性代码

 }

 // 测试socket

  void TestSocket(void){

     socket1.Init(SOCK_STREAM,);        // 使用流协议,也可以使用数据报协议SOCK_DGRAM

     socket1.Connect(“192.168.1.120”,);

     socket1.Send("Hello, Socket !\n");

     socket1.Close();

     // 另外还有Bind与Listen函数可用于侦听连接

 }

 // 测试UDP

 void TestUDP(void){

     int len;

     char* rxbuf;

     EndPoint* remoteEP;                　 // 用于存储远程地址

     udp1.Init();                    // 适用于接收

     //udp1.Init(“192.168.1.120”,11001);  // 适用于发送

     udp1.ReceQueueInit();            // 初始化接收队列,1024字节,如果没有此句,一次只能接收一个包

                                         // 如果使用接收队列,接收可在后台完成,前台慢慢处理,不丢包

     udp1.Open();                        // 打开端口

     remoteEP = new EndPoint;            // 使用动态分配,该动态内存分配算法是中间件的一部分

     rxbuf = new char[];

     while()

         if(udp1.IsReceived()){

             memset(rxbuf,,);

             len = udp1.ReceiveFrom(rxbuf,,remoteEP);

             if(len){

                 // 打印消息内容,长度,发送者IP地址,发送者端口

                 ComPrintf("msg = %s,len = %l,for:ip=%d.%d.%d.%d,port=%l\n",

                      rxbuf,

                      len,

                      remoteEP->Address.bytes[],

                      remoteEP->Address.bytes[],

                      remoteEP->Address.bytes[],

                      remoteEP->Address.bytes[],

                      remoteEP->Port);

             }

         }

     }

     delete remoteEP;

 }

 // 需要在第一个任务调用NetInit()函数即可启动网络服务