• l8-d9 UDP通信实现


    一、函数接口扩展与UDP通信实现流程

    1.write/read到send/recv

    函数原型:

            ssize_t send(int sockfd, const void *buf, size_t len, int flags);

            ssize_t recv(int sockfd, void *buf, size_t len, int flags);

    前三个参数同read/write一样;

             ssize_t read(int fd, void *buf, size_t count);

            ssize_t write(int fd, const void *buf, size_t count);

    常见flags:

            1. 一般设置为0

            2. MSG_PEEK:窥视传入的数据。数据被复制到缓冲区中,但不会从输入队列中删除。

             3. MSG_OOB:处理带外(OOB)数据

    2.sendto与recvfrom

    函数原型:

            ssize_t recvfrom(int sockfd, void *buf, size_t len, int flags, struct sockaddr *src_addr, socklen_t *addrlen);

            ssize_t sendto(int sockfd, const void *buf, size_t len, int flags, const struct sockaddr *dest_addr, socklen_t addrlen);

    1. 前四个参数同recv/send一样;

    2. 后两个参数是通信结构体和结构体的宽度; 

    3.UDP通信的实现过程

    二、UDP服务器代码 

    1. #include
    2. #include
    3. #include
    4. #include
    5. #include
    6. #include
    7. #include
    8. #include
    9. int main(int argc, char *argv[])
    10. {
    11. int fd;
    12. struct sockaddr_in addr;
    13. char buf[BUFSIZ] = {};
    14. if(argc < 3){
    15. fprintf(stderr, "%s\n", argv[0]);
    16. exit(EXIT_FAILURE);
    17. }
    18. /*创建套接字*/
    19. if( (fd = socket(AF_INET, SOCK_DGRAM, 0) ) < 0){
    20. perror("socket");
    21. exit(EXIT_FAILURE);
    22. }
    23. /*设置通信结构体*/
    24. bzero(&addr, sizeof(addr) );
    25. addr.sin_port = htons( atoi(argv[2]) );
    26. if(inet_aton(argv[1], &addr.sin_addr) == 0) {
    27. fprintf(stderr, "Invalid address\n");
    28. exit(EXIT_FAILURE);
    29. }
    30. /*绑定通信结构体*/
    31. if(bind(fd, (struct sockaddr *)&addr, sizeof(addr) ) == -1){
    32. perror("bind");
    33. exit(EXIT_FAILURE);
    34. }
    35. while(1){
    36. bzero(buf, BUFSIZ);
    37. recvfrom(fd, buf, BUFSIZ, 0, NULL, NULL);
    38. printf("buf=%s\n", buf);
    39. }
    40. close(fd);
    41. return 0;
    42. }

    三、客户端

    1. #include
    2. #include
    3. #include
    4. #include
    5. #include
    6. #include
    7. #include
    8. #include
    9. #include
    10. int main(int argc, char *argv[])
    11. {
    12. int fd;
    13. struct sockaddr_in addr;
    14. char buf[BUFSIZ] = {};
    15. socklen_t addrlen = sizeof(addr);
    16. if(argc < 3){
    17. fprintf(stderr, "%s\n", argv[0]);
    18. exit(EXIT_FAILURE);
    19. }
    20. /*创建套接字*/
    21. if( (fd = socket(AF_INET, SOCK_DGRAM, 0) ) < 0){
    22. perror("socket");
    23. exit(EXIT_FAILURE);
    24. }
    25. /*设置通信结构体*/
    26. bzero(&addr, sizeof(addr) );
    27. addr.sin_port = htons( atoi(argv[2]) );
    28. if(inet_aton(argv[1], &addr.sin_addr) == 0) {
    29. fprintf(stderr, "Invalid address\n");
    30. exit(EXIT_FAILURE);
    31. }
    32. while(1){
    33. bzero(buf, BUFSIZ);
    34. printf("Input->");
    35. fgets(buf, BUFSIZ, stdin);
    36. sendto(fd, buf, strlen(buf), 0, (struct sockaddr *)&addr, addrlen);
    37. }
    38. close(fd);
    39. return 0;
    40. }

    Makefile

    CC=gcc
    CFLAGS=-Wall
    all:server client

    clean:
        rm server client
     

  • 相关阅读:
    华贝甄选干细胞科技,揭秘生命修复的奥秘
    MyEclipse2019配置TomCat8.0
    C goto 语句
    【C++数据结构】性能测量
    Python OpenCV #1 - OpenCV介绍
    第二张微服务的调用与注册
    Leetcode 1486.数组异或操作
    3. Spring Boot starter入门
    园区网典型配置案例
    分析系统变慢或卡死
  • 原文地址:https://blog.csdn.net/revengeman/article/details/132759761