server.cpp
#include <stdio.h>
#include <string.h>
#include <stdlib.h>
#include <unistd.h>
#include <arpa/inet.h>
#include <sys/socket.h>#define SER_PORT 8888 //端口号
#define SER_IP "10.148.4.168" //服务器IP地址int main(int argc,const char*argv[]){//1、创建用于通信的套接字文件描述符int sfd =socket(AF_INET,SOCK_DGRAM,0);//SOCK_DGRAM表示基于UDP的通信方式if(sfd==-1){perror("socket error!");return -1;}printf("socket success sfd = %d\n",sfd);//2、绑定ip和端口号//2.1 填充要绑定的ip地址和端口号结构体struct sockaddr_in serv_sock;serv_sock.sin_family=AF_INET; //通信域serv_sock.sin_port=htons(SER_PORT); //端口号serv_sock.sin_addr.s_addr=inet_addr(SER_IP); //IP地址//2.2、绑定工作//参数1：要被绑定的套接字文件描述符//参数2：要绑定的地址信息结构体，需要进行强制类型转换，防止警告//参数3：参数2的大小if(bind(sfd,(struct sockaddr*)&serv_sock,sizeof(serv_sock))==-1){perror("bind error!");return -1;}printf("bind success\n");//3、数据的收发char rbuf[128]="";//定义容器接收对端的地址信息结构体struct sockaddr_in cin;socklen_t socklen =sizeof(cin);while(1){//清空容器bzero(rbuf,sizeof(rbuf));//从客户端中读取数据if(recvfrom(sfd,rbuf,sizeof(rbuf),0,(struct sockaddr*)&cin,&socklen)==-1){perror("recvfrom error!");return -1;}printf("[%s:%d]:%s\n",inet_ntoa(cin.sin_addr),ntohs(cin.sin_port),rbuf);//加个笑脸发送给客户端strcat(rbuf,"*_*");//将数据发送给客户端sendto(sfd,rbuf,sizeof(rbuf),0,(struct sockaddr*)&cin,sizeof(cin));printf("发送成功!\n");}//关闭套接字close(sfd);printf("hello world\n");return 0;
}
client.cpp
#include <stdio.h>
#include <string.h>
#include <stdlib.h>
#include <unistd.h>
#include <arpa/inet.h>
#include <sys/socket.h>#define SER_PORT 8888 //服务器端口号
#define SER_IP "10.148.4.168" //服务器IP地址
#define CLI_PORT 9999 //客户端端口号
#define CLI_IP "10.148.4.168" //客户端IP地址int main(int argc,const char*argv[]){//1、创建用于通信的客户端套接字文件描述符int cfd =socket(AF_INET,SOCK_DGRAM,0);if(cfd==-1){perror("socket error!");return -1;}printf("socket success cfd=%d\n",cfd);//2、绑定ip地址和端口号（可选）//2.1 填充要绑定的地址信息结构体struct sockaddr_in cin;cin.sin_family=AF_INET;cin.sin_port=htons(CLI_PORT);cin.sin_addr.s_addr=inet_addr(CLI_IP);//2.2 绑定工作if(bind(cfd,(struct sockaddr*)&cin,sizeof(cin))==-1){perror("bind error");return -1;}printf("bind success\n");//3、数据的收发char wbuf[128]="";//填充服务器的地址信息结构体struct sockaddr_in ser_sock;ser_sock.sin_family=AF_INET; //通信域ser_sock.sin_port=htons(SER_PORT); //端口号ser_sock.sin_addr.s_addr=inet_addr(SER_IP); //IP地址while(1){bzero(wbuf,sizeof(wbuf));fgets(wbuf,sizeof(wbuf),stdin);wbuf[strlen(wbuf)-1]=0;//把数据发送给服务器sendto(cfd,wbuf,sizeof(wbuf),0,(struct sockaddr*)&ser_sock,sizeof(ser_sock));//接收服务器发来的数据recvfrom(cfd,wbuf,sizeof(wbuf),0,NULL,NULL);printf("服务器发来的消息为:%s\n",wbuf);}//关闭套接字close(cfd);printf("hello world\n");return 0;
}
