简介

• udp协议
• udp通信流程
• 示例

udp协议

中文叫用户数据报协议，属于传输层。UDP是面向非连接的协议，它不与对方建立连接，而是直接把我要发的数据报发给对方。所以UDP适用于一次传输数据量很少、对可靠性要求不高的或对实时性要求高的应用场景。正因为UDP无需建立类如三次握手的连接，而使得通信效率很高。

2.jpg

udp通信流程

1.jpg

示例

• 运行服务端
• 运行客户端，客户端等待用户输入，回车后，消息发出到服务端，服务端接受数据并打印。
• 客户端输入 exit后自动退出。

server

#include <iostream>
#include <sys/types.h>          /* See NOTES */
#include <sys/socket.h>
#include <netinet/in.h>
#include <errno.h>
#include <arpa/inet.h>
#include <unistd.h>
#include <string.h>
using namespace std;
#define BUFF_LEN 1024
int main(){
        int sock=socket(AF_INET,SOCK_DGRAM,0);
        int ret=0;
        sockaddr_in addr;
        addr.sin_family=AF_INET;
        //本地Ip
        addr.sin_addr.s_addr=htonl(INADDR_ANY);
        addr.sin_port=8888;
        ret=bind(sock,(sockaddr*)&addr,sizeof(addr));
        if(ret<0) {
                cout<<"bind failed"<<endl;
        }
        char buf[BUFF_LEN]; //接收缓冲区，1024字节
        int recvRet;
        sockaddr_in clientAddr;
        socklen_t len=sizeof(clientAddr);
        char clientIp[16]={0};
        while (true) {
                /* code */
                memset(buf,0,BUFF_LEN);
                //0表示对方关闭，-1为发生错误。
                recvRet=recvfrom(sock,buf,BUFF_LEN,NULL,(sockaddr *)&clientAddr,&len);
                if(recvRet<=0) {
                        cout<<"receive failed"<<endl;
                        break;
                }else{
                        memset(clientIp,0,sizeof(clientIp));
                        int clientPort=ntohs(clientAddr.sin_port);
                        inet_ntop(AF_INET,(void *)&clientAddr.sin_addr,clientIp,16);
                        cout<<"receive data from "<<clientIp<<":"<<clientPort<<endl;
                        cout<<buf<<endl;
                }
        }
        if(sock>0) {
                close(sock);
        }
        return 0;
}

client

#include <iostream>
#include <sys/types.h>          /* See NOTES */
#include <sys/socket.h>
#include <netinet/in.h>
#include <errno.h>
#include <arpa/inet.h>
#include <unistd.h>
#include <string.h>
#include <stdio.h>
using namespace std;
#define BUFF_LEN 1024
int main(){
        int sock=socket(AF_INET,SOCK_DGRAM,0);
        int ret=0;
        sockaddr_in addr;
        addr.sin_family=AF_INET;
        //INADDR_ANY为本地Ip
        addr.sin_addr.s_addr=htonl(INADDR_ANY);
        addr.sin_port=8888;

        char buf[BUFF_LEN]={0};
        int recvRet;
        //0表示对方关闭，-1为发生错误。
        while (true) {
                //标准输入，会带上'\n'
                fgets(buf,BUFF_LEN,stdin);
                if(string(buf)=="exit\n") {
                        break;
                }else{
                        recvRet=sendto(sock,buf,strlen(buf),NULL,(sockaddr *)&addr,sizeof(addr));
                        if(recvRet<=0) {
                                cout<<"receive failed"<<endl;
                        }
                }
        }
        if(sock>0) {
                close(sock);
                sock=-1;
        }
        return 0;
}