用户注册



邮箱:

密码:

用户登录


邮箱:

密码:
记住登录一个月忘记密码?

发表随想


还能输入:200字

芙蓉妹妹    -  云代码空间

——

利用UDP实现套接字通信

2018-11-05|20阅||

摘要:利用UDP实现简单的数据收发

一、服务器代码
server.c

#include <stdio.h>

#include <stdlib.h>

#include <string.h>

#include <errno.h>

#include <sys/socket.h>

#include <arpa/inet.h>

#include <netinet/in.h>

#include <sys/types.h>

#include <unistd.h>

#define BUFLEN 100

const char* IP = "127.0.0.1";

const unsigned int SERV_PORT = 8888;

void Chat(int sockfd);

int main(int argc, char *argv[])

{

    int sockfd;

    struct sockaddr_in s_addr, c_addr;

    char buf[BUFLEN];

    socklen_t len;

    /*建立socket*/

    if((sockfd = socket(AF_INET, SOCK_DGRAM, 0)) == -1){

        perror("socket");

        exit(errno);

    }

    /*设置服务器ip*/

    bzero(&s_addr, sizeof(s_addr));

    s_addr.sin_family = AF_INET;

    s_addr.sin_port = htons(SERV_PORT);

    s_addr.sin_addr.s_addr = htonl(INADDR_ANY);

    /*把地址和端口帮定到套接字上*/

    if((bind(sockfd, (struct sockaddr*) &s_addr,sizeof(struct sockaddr))) == -1){

        perror("bind");

        exit(errno);

    }

    printf("*****************server start***************\n");

    len = sizeof(struct sockaddr);

    while(1)

    {

        int n = 0;

        /******接收消息*******/

        bzero(buf,BUFLEN);

        n = recvfrom(sockfd, buf, BUFLEN, 0, (struct sockaddr*)&c_addr, &len);

        if(n > 0)

            printf("receive massage:%s\n",buf);

        else

        {

            if(n < 0 )

                printf("receive failed\n");

            else//服务器调用close函数后,系统阻塞函数调用,返回0

                printf("client stop\n");

            break;        

        }

    _retry:

        /******发送消息*******/

        bzero(buf,BUFLEN);

        printf("enter your words:");

        /*fgets函数:从流中读取BUFLEN-1个字符*/

        fgets(buf,BUFLEN,stdin);

        if(!strncasecmp(buf,"quit",4))

        {

            printf("server stop\n");

            break;

        }

        /*如果输入的字符串只有"\n",即回车,那么请重新输入*/

        if(!strncmp(buf,"\n",1))

            goto _retry;  

        /*如果buf中含有'\n',那么要用strlen(buf)-1,去掉'\n'*/            

        if(strchr(buf,'\n'))

            n = sendto(sockfd, buf, strlen(buf)-1, 0, (struct sockaddr*)&c_addr, len);

        /*如果buf中没有'\n',则用buf的真正长度strlen(buf)*/    

        else

            n = sendto(sockfd,buf,strlen(buf),0, (struct sockaddr*)&c_addr, len);

        if(n > 0)

            printf("send successful\n");            

        else{

            printf("send failed\n");

            break;            

        }

      }

    /*关闭已连接套接字*/

    close(sockfd);

    return 0;

}
二、客户端
client.c

#include <stdio.h>

#include <stdlib.h>

#include <string.h>

#include <errno.h>

#include <sys/socket.h>

#include <arpa/inet.h>

#include <netinet/in.h>

#include <sys/types.h>

#include <unistd.h>

#define BUFLEN 100

const char* IP = "127.0.0.1";

const int SERV_PORT = 8888;

int main(int argc, char *argv[])

{

    int sockfd;

    struct sockaddr_in send_addr; //服务器套接字地址

    struct sockaddr_in recv_addr;

    socklen_t send_len, recv_len;

    char send_buf[BUFLEN], recv_buf[BUFLEN];    

    /*建立socket*/

    if((sockfd = socket(AF_INET, SOCK_DGRAM, 0)) == -1){

        perror("socket");

        exit(errno);

    }

    /*设置服务器ip*/

    bzero(&send_addr, sizeof(send_addr));

    send_addr.sin_family = AF_INET;

    send_addr.sin_port = htons(SERV_PORT);

    if(inet_aton(IP, (struct in_addr*)&send_addr.sin_addr) == 0)

    {

        perror("IP error");

        exit(errno);

    }

    printf("*****************client start***************\n");

    send_len = sizeof(struct sockaddr);

    while(1)

    {

        int n = 0;

    _retry:    

        /******发送消息*******/    

        bzero(send_buf,BUFLEN);

        printf("enter your words:");

        /*fgets函数:从流中读取BUFLEN-1个字符*/

        fgets(send_buf,BUFLEN,stdin);

        if(!strncasecmp(send_buf,"quit",4))

        {

            printf("client stop\n");

            break;

        }

        /*如果输入的字符串只有"\n",即回车,那么请重新输入*/

        if(!strncmp(send_buf,"\n",1))

            goto _retry;

        /*如果buf中含有'\n',那么要用strlen(buf)-1,去掉'\n'*/    

        if(strchr(send_buf,'\n'))

            n = sendto(sockfd,send_buf,strlen(send_buf)-1,0, (struct sockaddr*)&send_addr, send_len);

        /*如果buf中没有'\n',则用buf的真正长度strlen(buf)*/    

        else

        {

            n = sendto(sockfd,send_buf,strlen(send_buf),0, (struct sockaddr*)&send_addr, send_len);

        }

        if(n == -1)

        {

            printf("send failed\n");            

            break;

        }

        else

            printf("send successful\n");

        /******接收消息*******/

        bzero(recv_buf,BUFLEN);

        n = recvfrom(sockfd,recv_buf,BUFLEN,0, (struct sockaddr*)&recv_addr, &recv_len);

        if(n > 0)

            printf("receive massage:%s\n",recv_buf);

        else

        {

            if(n < 0 )

                printf("receive failed\n");

            else

                printf("server stop\n");

            break;    

        }

    }

    /*关闭连接*/

    close(sockfd);

    return 0;

}
三、实验截图
服务端:

客户端:


顶 0踩 0收藏
分享到:
更多
文章评论
    发表评论