socket演示程序3(udp)

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;
}