服务端
#include<stdio.h>
#include<unistd.h>
#include<string.h>
#include<netinet/in.h>//struct sockaddr_in 结构
#include<stdlib.h>
#include<arpa/inet.h>//字节序转换接口文件
#include<sys/socket.h>//socket接口文件int main()
{//实现udp 服务器//创建套接字int sockfd = socket(AF_INET,SOCK_DGRAM,IPPROTO_UDP);if(sockfd < 0){perror("socket error !");return -1;}//绑定地址信息bindstruct sockaddr_in addr;addr.sin_family = AF_INET;addr.sin_port = htons(9090);addr.sin_addr.s_addr = inet_addr("10.0.8.12");socklen_t len = sizeof(struct sockaddr_in);int ret = bind(sockfd,(struct sockaddr* ) &addr ,len );if(ret < 0){close(sockfd);perror("bind error !");return -1;}while (1){//接受数据char buf[1024] = {0};struct sockaddr_in cliaddr;ret = recvfrom(sockfd,buf,1023,0,(struct sockaddr *) &cliaddr,&len);if(ret < 0){perror("recvfrom error !"); close(sockfd);return -1;}printf("客户端: %s : %d 说: %s \n",inet_ntoa(cliaddr.sin_addr),ntohs(cliaddr.sin_port),buf);//发送数据printf("服务器: ");fflush(stdout);char data [1024] = {0};fgets(data,1023,stdin);ret = sendto(sockfd,data,strlen(data),0,(struct sockaddr*)&cliaddr,len);if(ret < 0){perror("sento error !");close (sockfd);return -1;}}// 关闭套接字close(sockfd);return 0;
}
接收端
//封装一个udpsocket类
//通过实例化对象来调用成员函数完成客户端服务器搭建
#include<iostream>
#include<string>
#include<netinet/in.h>
#include<unistd.h>
#include<arpa/inet.h>
#include<sys/socket.h>
using namespace std;
class UdpSocket{private:int _sockfd;public:UdpSocket():_sockfd(-1){}~UdpSocket(){if(_sockfd != -1){close(_sockfd);}}bool Socket(){_sockfd = socket(AF_INET,SOCK_DGRAM,IPPROTO_UDP);if(_sockfd < 0){perror("socket error !");return false;}return true;}bool Bind(const string &ip,uint16_t port){struct sockaddr_in addr;addr.sin_family = AF_INET;addr.sin_port = htons(port);addr.sin_addr.s_addr = inet_addr(ip.c_str());socklen_t len = sizeof(struct sockaddr_in);int ret;ret = bind(_sockfd,(struct sockaddr*)&addr,len);if(ret < 0){perror("bind error !");return false;}return true;}bool Send(const string &data,const string &ip,uint16_t port){struct sockaddr_in addr;addr.sin_family = AF_INET;addr.sin_port = htons(port);addr.sin_addr.s_addr = inet_addr(ip.c_str());socklen_t len = sizeof(struct sockaddr_in);int ret;ret = sendto(_sockfd,data.c_str(),data.size(),0,(struct sockaddr*) &addr,len);if(ret < 0){perror("sendto error");return false;}return true;}bool Recv(string *buf, string *ip = NULL,uint16_t *port = NULL){struct sockaddr_in addr;socklen_t len = sizeof(struct sockaddr_in);char temp [4096] = {0};int ret;ret = recvfrom(_sockfd,temp,4096,0,(struct sockaddr *)&addr,&len);if(ret < 0){perror ("recvfrom error !");return false;}if(ip != NULL){*ip = inet_ntoa(addr.sin_addr);}if(port != NULL){*port = ntohs(addr.sin_port);}*buf = temp;return true;}bool Close(){if(_sockfd != -1){close(_sockfd);}return true;}
};