socke网络通信,UDP协议,C/C++

发布于:2022-12-03 ⋅ 阅读:(621) ⋅ 点赞:(0)

        在进行网络通信时,免不了使用用户数据报协议UDP协议来传输报文,UDP通信跟TCP通信的最大区别在于 它是它是不可靠的、无连接的、面向报文的,就像打电话和发短信的区别。本文将给出一个简单的,使用udp协议通信的代码,下面直接看代码。

 

一,server服务器端

        1.初始化各种需要用到的参数,启动Winsock

   WSAData wsd;           //初始化信息
    SOCKET soRecv;         //接收的SOCKET
    char* pszRecv = NULL;  //接收数据的数据缓冲区指针
    int nRet = 0;          //接收数据大小
    int dwSendSize = 0;
    // MTU以太网数据帧的长度在46-1500字节之间,1500:链路层的最大传输单元
    // 单个UDP传输的最大内容为1472字节(1500-20-8)
    // 网络中标准UDP值为576字节,最好在编程中将数据长度控制在548字节以内
    int SIZEOFBUF = 4096; //接收数组大小
    int nPort = 5150;      //设置本机服务的端口号
    SOCKADDR_IN siRemote{}, siLocal{};    //远程发送机地址和本机接收机地址
    //启动Winsock
    if (WSAStartup(MAKEWORD(2, 2), &wsd) != 0)
    {
        cout << "WSAStartup Error = " << WSAGetLastError() << endl;
        return 0;
    }
    else
    {
        cout << "start Success" << endl;
    }

        2.创建套接字,绑定本地地址到socket

        int setsockopt(int sockfd, int level, int optname, void* optval, socklen_t * optlen);
        sockfd:要设置的套接字描述符。
        level:选项定义的层次。或为特定协议的代码(如IPv4,IPv6,TCP,SCTP),或为通用套接字代码(SOL_SOCKET)。
       optname:选项名。level对应的选项,SO_REUSEADDR让端口释放后立即就可以被再次使用。
      optval:指向某个变量的指针,该变量是要设置新值的缓冲区。可以是一个结构体,也可以是普通变量
      optlen:optval的长度。

 siLocal.sin_family = AF_INET;
    siLocal.sin_port = htons(nPort);
    //siLocal.sin_addr.S_un.S_addr = inet_addr("127.0.0.1");
    //和上一行一样
    inet_pton(AF_INET, "127.0.0.1", (void*)&siLocal.sin_addr.s_addr);
    //将点分十进制的ip地址转化为用于网络传输的数值格式

    //创建socket
    soRecv = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP);
    if (soRecv == SOCKET_ERROR)
    {
        cout << "socket Error = " << WSAGetLastError() << endl;
        closesocket(soRecv);
        WSACleanup();
        return 1;
    }
    else
    {
        cout << "socket Success" << endl;
    }

    char on = 1;
    // 设置端口复用
    
    setsockopt(soRecv, SOL_SOCKET, SO_REUSEADDR, &on, sizeof(on));
    // 绑定本地地址到socket
    if (bind(soRecv, (SOCKADDR*)&siLocal, sizeof(siLocal)) == SOCKET_ERROR)
        //socket通用地址类型指针
        //通用地址类型长度
    {
        cout << "bind Error = " << WSAGetLastError() << endl;
        closesocket(soRecv);
        WSACleanup();
        return 0;
    }
    else
    {
        cout << "bind Success" << endl;
    }

         3.申请内存,等待客户端连接

         int recvfrom(int s, void* buf, int len, unsigned int flags, struct sockaddr* from, int* fromlen);
         recvfrom()用来接收远程主机经指定的socket 传来的数据, 并把数据存到由参数buf 指向的内存空间,
        参数len 为可接收数据的最大长度.参数flags 一般设0, 其他数值定义请参考recv().
        参数from 用来指定欲传送的网络地址, 结构sockaddr 请参考bind().
        参数fromlen 为sockaddr 的结构长度。

//申请内存
    pszRecv = new char[SIZEOFBUF];
    if (pszRecv == NULL)
    {
        cout << "pszRecv new char Error " << endl;
        return 0;
    }
    else
    {
        cout << "pszRecv new char Success" << endl;
    }
    // 一直等待数据
    while (true)
    {
        dwSendSize = sizeof(siRemote);
        cout << "...开始等待数据..." << endl;
        memset(pszRecv, 0, SIZEOFBUF);//初始化为0
        //开始接受数据
        
        nRet = recvfrom(soRecv, pszRecv, SIZEOFBUF, 0, (SOCKADDR*)&siRemote, &dwSendSize);
        if (nRet == SOCKET_ERROR)
        {
            cout << "recvfrom Error " << WSAGetLastError() << endl;
            continue;
        }
        else if (nRet == 0)
        {
            cout << "recvfrom Error " << WSAGetLastError() << endl;
            continue;
        }
        else
        {
            pszRecv[128] = '\0';
            char sendBuf[20] = { '\0' };
            //将IPv4或IPv6 Internet网络地址转换为 Internet标准格式的字符串。
            inet_ntop(AF_INET, (void*)&siRemote.sin_addr, sendBuf, 16);
            cout << "收到数据大小: " << nRet << " IP地址: " << sendBuf << " 端口号: " << siRemote.sin_port << " 数据: " << pszRecv << endl;
        }
    } 
    closesocket(soRecv);//关闭socket连接
    delete[] pszRecv; 
    WSACleanup();//清理
    system("pause");
    return 0;

二.client客户端

        1..初始化各种需要用到的参数,启动Winsock

  WSAData wsd;           //初始化信息
    SOCKET soSend;         //发送到的目的SOCKET
    int nRet = 0;
    int dwSendSize = 0;
    const int SIZEOFBUF = 4096;
    char recvBuf[SIZEOFBUF]={0};
    SOCKADDR_IN serverAddr{};    //服务器socket地址

    //启动Winsock
    if (WSAStartup(MAKEWORD(2, 2), &wsd) != 0)
    {/*进行WinSocket的初始化,windows 初始化socket网络库,申请2,2的版本,windows socket编程必须先初始化。*/
        cout << "WSAStartup Error = " << WSAGetLastError() << endl;
        return 0;
    }
    else
    {
        cout << "WSAStartup Success" << endl;
    }

        2.创建socket,设置端口号

 soSend = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP);
    if (soSend == SOCKET_ERROR)
    {
        cout << "socket Error = " << WSAGetLastError() << endl;
        return 1;
    }
    else
    {
        cout << "socket Success" << endl;
    }
    //设置端口号
    int nPort = 5150; // 服务器的端口号
    serverAddr.sin_family = AF_INET;
    serverAddr.sin_port = htons(nPort);
    //serverAddr.sin_addr.s_addr = inet_addr("127.0.0.1");
    inet_pton(AF_INET, "127.0.0.1", (void*)&serverAddr.sin_addr.s_addr);
    //将点分十进制的ip地址转化为用于网络传输的数值格式

        3.发送消息到服务器

        sendto(int sockfd, const void* buf, size_t len, int flags,const struct sockaddr* dest_addr, socklen_t addrlen);
        //函数说明
        //    sockfd:socket文件描述字
        //    buf:指明一个存放应用程序要发送数据的缓冲区
        //    len:指明buf的长度
        //    flag:一般设置为0
        //    dest_addr:表示目的机的地址和端口号信息
        //    addrlen:常被赋值为sizeof(struct sockaddr)

    while (1)
    {
        // 不断输入一些字符串,回车发送
        printf("input: ");
        scanf_s("%s", recvBuf, (unsigned int)sizeof(recvBuf));
        //发送数据到指定的IP地址和端口
        
        nRet = sendto(soSend, recvBuf, (int)strlen(recvBuf) + 1, 0, (SOCKADDR*)&serverAddr, sizeof(SOCKADDR));
        if (nRet == SOCKET_ERROR || nRet < 0)
        {
            cout << "sendto Error " << WSAGetLastError() << endl;
            break;
        }
        else
        {
            cout << "sendto Success!!" << endl;
        }
    }   
    closesocket(soSend);//关闭socket连接 
    WSACleanup();//清理

        接下来让我们看看显示结果

 完整代码如下:socket网络通信,udp-C++文档类资源-CSDN下载


网站公告

今日签到

点亮在社区的每一天
去签到