UDP通信，server端在循环使用recvfrom时第一次成功，第二次就失败了

嵌入式陌生人

报错socket operation on non-socket

服务端代码：
#include<stdlib.h>//不加会报隐式声明与内建函数'exit'不兼容
#include<stdio.h>
#include<sys/socket.h>
#include<string.h>
#include<netinet/in.h>//因用了地址(网络编程用的地址)

#define portnum 6666
#define MSG_SIZE 128
int main()
{
       
        int sockfd;
        int checkBind;
        char buf[MSG_SIZE];
        struct sockaddr_in sever_addr; //服务器的IP地址
        struct sockaddr_in client_addr; //用来存客户端的IP地址
        int addrlen;
        int n;//用来定位到buf的尾巴，添加字符串结束符‘\0’
       
        //1.创建套接字
        sockfd = socket(AF_INET,SOCK_DGRAM,0);//SOCK_DGRAM表示的是UDP协议的套接字，AF_INET表IPV4
        if(sockfd < 0)
        {
                perror("server socket error!\n");
                exit(1);
        }
       
       
        //2.0设置要绑定的服务器地址
        bzero(&sever_addr,sizeof(struct sockaddr_in));
        sever_addr.sin_family = AF_INET;
        sever_addr.sin_port = htons(portnum);//先要将主机字节序转换成网络字节序
        //sever_addr.sin_addr.s_addr = htonl(INADDR_ANY);//绑定任意的IP地址，要和网络上所有的IP地址通讯
        sever_addr.sin_addr.s_addr = INADDR_ANY;
       
       
        //2.1绑定地址
        checkBind = bind(sockfd,(struct sockaddr *)(&sever_addr),sizeof(struct sockaddr_in));
        if(checkBind < 0)
        {
                perror("server bind error!\n");
                exit(1);
        }
       
        addrlen = sizeof(struct sockaddr_in);
       
        //3.接收数据
        while(1)
        {
               
                bzero(buf,sizeof(buf));
                memset(&client_addr,0,sizeof(struct sockaddr_in));
                n = recvfrom(sockfd,buf,MSG_SIZE,0,(struct sockaddr *)(&client_addr),&addrlen);
                if(n < 0)
                {
                        perror("sever recvfrom error!\n");
                        printf("n = %d\n",n);
                        exit(1);
                }
                printf("sever get connection from %s\n",inet_ntoa(client_addr.sin_addr.s_addr));
                buf[n] = 0;//0即为‘\0’
                printf("server received: %s\n",buf);
               
        }
        //4.关闭连接
        close(sockfd);
        return 0;
       
}





客户端代码：

#include<stdlib.h>//不加会报隐式声明与内建函数'exit'不兼容
#include<stdio.h>
#include<sys/socket.h>
#include<string.h>
#include<netinet/in.h>//因用了地址(网络编程用的地址)

#define portnum 6666
#define BUF_SIZE 128

int main(int argc,char** argv)
{
        int sockfd;
        char buf[BUF_SIZE];
        struct sockaddr_in sever_addr; //服务器的IP地址
       
        if(argc != 2)//输入格式检查
        {
                printf("Usage: %s  server_ip\n",argv[0]);
                exit(1);
        }
       
        //1.创建套接字
        sockfd = socket(AF_INET,SOCK_DGRAM,0);
        if(sockfd < 0)
        {
                perror("server socket error\n");
                exit(1);
        }
       
        //2.0初始化服务器地址
        bzero(&sever_addr,sizeof(struct sockaddr_in));
        sever_addr.sin_family = AF_INET;
        sever_addr.sin_port = htons(portnum);//先要将主机字节序转换成网络字节序
        inet_aton(argv[1],&sever_addr.sin_addr.s_addr);//inet_aton是一个改进的方法来将一个字符串IP地址转换为一个32位的网络序列IP地址。
       
        //2.1发送数据
        while(1)
        {
                printf("please input char:\n");
                fgets(buf,BUF_SIZE,stdin);
                sendto(sockfd,buf,BUF_SIZE,0,(struct sockaddr *)(&sever_addr),sizeof(struct sockaddr));
                bzero(buf,BUF_SIZE);
        }
       
        //3.关闭连接
        close(sockfd);
        return 0;
}

嵌入式陌生人

求前辈指点

jeppeter

回复 1# 嵌入式陌生人
我修改了你的代码，没有你说的问题，下面是服务端的代码

1. #include <stdlib.h>//不加会报隐式声明与内建函数'exit'不兼容
   
2. #include <stdio.h>
   
3. #include <sys/socket.h>
   
4. #include <string.h>
   
5. #include <netinet/in.h>//因用了地址(网络编程用的地址)
   
6. #include <arpa/inet.h>
   
7. #include <unistd.h>
   
8. 
   
9. #define MSG_SIZE 128
   
10. int main(int argc,char* argv[])
    
11. {
    
12. 
    
13.     int sockfd;
    
14.     int checkBind;
    
15.     char buf[MSG_SIZE];
    
16.     struct sockaddr_in sever_addr; //服务器的IP地址
    
17.     struct sockaddr_in client_addr; //用来存客户端的IP地址
    
18.     socklen_t addrlen;
    
19.     int n;//用来定位到buf的尾巴，添加字符串结束符‘\0’
    
20.     int portnum = 6666;
    
21. 
    
22.     //1.创建套接字
    
23.     sockfd = socket(AF_INET, SOCK_DGRAM, 0); //SOCK_DGRAM表示的是UDP协议的套接字，AF_INET表IPV4
    
24.     if (sockfd < 0) {
    
25.         perror("server socket error!\n");
    
26.         exit(1);
    
27.     }
    
28. 
    
29.     if (argc > 1) {
    
30.         portnum = atoi(argv[1]);
    
31.     }
    
32. 
    
33. 
    
34.     //2.0设置要绑定的服务器地址
    
35.     bzero(&sever_addr, sizeof(struct sockaddr_in));
    
36.     sever_addr.sin_family = AF_INET;
    
37.     sever_addr.sin_port = htons(portnum);//先要将主机字节序转换成网络字节序
    
38.     //sever_addr.sin_addr.s_addr = htonl(INADDR_ANY);//绑定任意的IP地址，要和网络上所有的IP地址通讯
    
39.     sever_addr.sin_addr.s_addr = INADDR_ANY;
    
40. 
    
41. 
    
42.     //2.1绑定地址
    
43.     checkBind = bind(sockfd, (struct sockaddr *)(&sever_addr), sizeof(struct sockaddr_in));
    
44.     if (checkBind < 0) {
    
45.         perror("server bind error!\n");
    
46.         exit(1);
    
47.     }
    
48. 
    
49.     addrlen = sizeof(struct sockaddr_in);
    
50. 
    
51.     //3.接收数据
    
52.     while (1) {
    
53. 
    
54.         bzero(buf, sizeof(buf));
    
55.         memset(&client_addr, 0, sizeof(struct sockaddr_in));
    
56.         n = recvfrom(sockfd, buf, MSG_SIZE, 0, (struct sockaddr *)(&client_addr), &addrlen);
    
57.         if (n < 0) {
    
58.             perror("sever recvfrom error!\n");
    
59.             printf("n = %d\n", n);
    
60.             exit(1);
    
61.         }
    
62.         printf("sever get connection from %s\n", inet_ntoa(client_addr.sin_addr));
    
63.         buf[n] = 0;//0即为‘\0’
    
64.         printf("server received: %s\n", buf);
    
65. 
    
66.     }
    
67.     //4.关闭连接
    
68.     close(sockfd);
    
69.     return 0;
    
70. 
    
71. }

复制代码

下面是客户端的代码

1. #include <stdlib.h>//不加会报隐式声明与内建函数'exit'不兼容
   
2. #include <stdio.h>
   
3. #include <sys/socket.h>
   
4. #include <string.h>
   
5. #include <netinet/in.h>//因用了地址(网络编程用的地址)
   
6. #include <arpa/inet.h>
   
7. #include <unistd.h>
   
8. 
   
9. 
   
10. #define BUF_SIZE 128
    
11. 
    
12. int main(int argc, char** argv)
    
13. {
    
14.     int sockfd;
    
15.     char buf[BUF_SIZE];
    
16.     struct sockaddr_in sever_addr; //服务器的IP地址
    
17.     int portnum = 6666;
    
18.     char *prets=NULL;
    
19. 
    
20.     if (argc != 2) { //输入格式检查
    
21.         printf("Usage: %s  server_ip\n", argv[0]);
    
22.         exit(1);
    
23.     }
    
24.     if (argc > 2) {
    
25.         portnum = atoi(argv[2]);
    
26.     }
    
27. 
    
28.     //1.创建套接字
    
29.     sockfd = socket(AF_INET, SOCK_DGRAM, 0);
    
30.     if (sockfd < 0) {
    
31.         perror("server socket error\n");
    
32.         exit(1);
    
33.     }
    
34. 
    
35.     //2.0初始化服务器地址
    
36.     bzero(&sever_addr, sizeof(struct sockaddr_in));
    
37.     sever_addr.sin_family = AF_INET;
    
38.     sever_addr.sin_port = htons(portnum);//先要将主机字节序转换成网络字节序
    
39.     inet_aton(argv[1], &sever_addr.sin_addr); //inet_aton是一个改进的方法来将一个字符串IP地址转换为一个32位的网络序列IP地址。
    
40. 
    
41.     //2.1发送数据
    
42.     while (1) {
    
43.         printf("please input char:\n");
    
44.         prets = fgets(buf, BUF_SIZE, stdin);
    
45.         if (prets == NULL) {
    
46.             break;
    
47.         }
    
48.         sendto(sockfd, buf, BUF_SIZE, 0, (struct sockaddr *)(&sever_addr), sizeof(struct sockaddr));
    
49.         bzero(buf, BUF_SIZE);
    
50.     }
    
51. 
    
52.     //3.关闭连接
    
53.     close(sockfd);
    
54.     return 0;
    
55. }

复制代码

jeppeter

回复 1# 嵌入式陌生人
我修改了你的代码，没有你说的问题，下面是服务端的代码

1. #include <stdlib.h>//不加会报隐式声明与内建函数'exit'不兼容
   
2. #include <stdio.h>
   
3. #include <sys/socket.h>
   
4. #include <string.h>
   
5. #include <netinet/in.h>//因用了地址(网络编程用的地址)
   
6. #include <arpa/inet.h>
   
7. #include <unistd.h>
   
8. 
   
9. #define MSG_SIZE 128
   
10. int main(int argc,char* argv[])
    
11. {
    
12. 
    
13.     int sockfd;
    
14.     int checkBind;
    
15.     char buf[MSG_SIZE];
    
16.     struct sockaddr_in sever_addr; //服务器的IP地址
    
17.     struct sockaddr_in client_addr; //用来存客户端的IP地址
    
18.     socklen_t addrlen;
    
19.     int n;//用来定位到buf的尾巴，添加字符串结束符‘\0’
    
20.     int portnum = 6666;
    
21. 
    
22.     //1.创建套接字
    
23.     sockfd = socket(AF_INET, SOCK_DGRAM, 0); //SOCK_DGRAM表示的是UDP协议的套接字，AF_INET表IPV4
    
24.     if (sockfd < 0) {
    
25.         perror("server socket error!\n");
    
26.         exit(1);
    
27.     }
    
28. 
    
29.     if (argc > 1) {
    
30.         portnum = atoi(argv[1]);
    
31.     }
    
32. 
    
33. 
    
34.     //2.0设置要绑定的服务器地址
    
35.     bzero(&sever_addr, sizeof(struct sockaddr_in));
    
36.     sever_addr.sin_family = AF_INET;
    
37.     sever_addr.sin_port = htons(portnum);//先要将主机字节序转换成网络字节序
    
38.     //sever_addr.sin_addr.s_addr = htonl(INADDR_ANY);//绑定任意的IP地址，要和网络上所有的IP地址通讯
    
39.     sever_addr.sin_addr.s_addr = INADDR_ANY;
    
40. 
    
41. 
    
42.     //2.1绑定地址
    
43.     checkBind = bind(sockfd, (struct sockaddr *)(&sever_addr), sizeof(struct sockaddr_in));
    
44.     if (checkBind < 0) {
    
45.         perror("server bind error!\n");
    
46.         exit(1);
    
47.     }
    
48. 
    
49.     addrlen = sizeof(struct sockaddr_in);
    
50. 
    
51.     //3.接收数据
    
52.     while (1) {
    
53. 
    
54.         bzero(buf, sizeof(buf));
    
55.         memset(&client_addr, 0, sizeof(struct sockaddr_in));
    
56.         n = recvfrom(sockfd, buf, MSG_SIZE, 0, (struct sockaddr *)(&client_addr), &addrlen);
    
57.         if (n < 0) {
    
58.             perror("sever recvfrom error!\n");
    
59.             printf("n = %d\n", n);
    
60.             exit(1);
    
61.         }
    
62.         printf("sever get connection from %s\n", inet_ntoa(client_addr.sin_addr));
    
63.         buf[n] = 0;//0即为‘\0’
    
64.         printf("server received: %s\n", buf);
    
65. 
    
66.     }
    
67.     //4.关闭连接
    
68.     close(sockfd);
    
69.     return 0;
    
70. 
    
71. }

复制代码

下面是客户端的代码

1. #include <stdlib.h>//不加会报隐式声明与内建函数'exit'不兼容
   
2. #include <stdio.h>
   
3. #include <sys/socket.h>
   
4. #include <string.h>
   
5. #include <netinet/in.h>//因用了地址(网络编程用的地址)
   
6. #include <arpa/inet.h>
   
7. #include <unistd.h>
   
8. 
   
9. 
   
10. #define BUF_SIZE 128
    
11. 
    
12. int main(int argc, char** argv)
    
13. {
    
14.     int sockfd;
    
15.     char buf[BUF_SIZE];
    
16.     struct sockaddr_in sever_addr; //服务器的IP地址
    
17.     int portnum = 6666;
    
18.     char *prets=NULL;
    
19. 
    
20.     if (argc != 2) { //输入格式检查
    
21.         printf("Usage: %s  server_ip\n", argv[0]);
    
22.         exit(1);
    
23.     }
    
24.     if (argc > 2) {
    
25.         portnum = atoi(argv[2]);
    
26.     }
    
27. 
    
28.     //1.创建套接字
    
29.     sockfd = socket(AF_INET, SOCK_DGRAM, 0);
    
30.     if (sockfd < 0) {
    
31.         perror("server socket error\n");
    
32.         exit(1);
    
33.     }
    
34. 
    
35.     //2.0初始化服务器地址
    
36.     bzero(&sever_addr, sizeof(struct sockaddr_in));
    
37.     sever_addr.sin_family = AF_INET;
    
38.     sever_addr.sin_port = htons(portnum);//先要将主机字节序转换成网络字节序
    
39.     inet_aton(argv[1], &sever_addr.sin_addr); //inet_aton是一个改进的方法来将一个字符串IP地址转换为一个32位的网络序列IP地址。
    
40. 
    
41.     //2.1发送数据
    
42.     while (1) {
    
43.         printf("please input char:\n");
    
44.         prets = fgets(buf, BUF_SIZE, stdin);
    
45.         if (prets == NULL) {
    
46.             break;
    
47.         }
    
48.         sendto(sockfd, buf, BUF_SIZE, 0, (struct sockaddr *)(&sever_addr), sizeof(struct sockaddr));
    
49.         bzero(buf, BUF_SIZE);
    
50.     }
    
51. 
    
52.     //3.关闭连接
    
53.     close(sockfd);
    
54.     return 0;
    
55. }

复制代码

jeppeter

回复 1# 嵌入式陌生人

1. #include <stdlib.h>//不加会报隐式声明与内建函数'exit'不兼容
   
2. #include <stdio.h>
   
3. #include <sys/socket.h>
   
4. #include <string.h>
   
5. #include <netinet/in.h>//因用了地址(网络编程用的地址)
   
6. #include <arpa/inet.h>
   
7. #include <unistd.h>
   
8. 
   
9. 
   
10. #define BUF_SIZE 128
    
11. 
    
12. int main(int argc, char** argv)
    
13. {
    
14.     int sockfd;
    
15.     char buf[BUF_SIZE];
    
16.     struct sockaddr_in sever_addr; //服务器的IP地址
    
17.     int portnum = 6666;
    
18.     char *prets=NULL;
    
19. 
    
20.     if (argc != 2) { //输入格式检查
    
21.         printf("Usage: %s  server_ip\n", argv[0]);
    
22.         exit(1);
    
23.     }
    
24.     if (argc > 2) {
    
25.         portnum = atoi(argv[2]);
    
26.     }
    
27. 
    
28.     //1.创建套接字
    
29.     sockfd = socket(AF_INET, SOCK_DGRAM, 0);
    
30.     if (sockfd < 0) {
    
31.         perror("server socket error\n");
    
32.         exit(1);
    
33.     }
    
34. 
    
35.     //2.0初始化服务器地址
    
36.     bzero(&sever_addr, sizeof(struct sockaddr_in));
    
37.     sever_addr.sin_family = AF_INET;
    
38.     sever_addr.sin_port = htons(portnum);//先要将主机字节序转换成网络字节序
    
39.     inet_aton(argv[1], &sever_addr.sin_addr); //inet_aton是一个改进的方法来将一个字符串IP地址转换为一个32位的网络序列IP地址。
    
40. 
    
41.     //2.1发送数据
    
42.     while (1) {
    
43.         printf("please input char:\n");
    
44.         prets = fgets(buf, BUF_SIZE, stdin);
    
45.         if (prets == NULL) {
    
46.             break;
    
47.         }
    
48.         sendto(sockfd, buf, BUF_SIZE, 0, (struct sockaddr *)(&sever_addr), sizeof(struct sockaddr));
    
49.         bzero(buf, BUF_SIZE);
    
50.     }
    
51. 
    
52.     //3.关闭连接
    
53.     close(sockfd);
    
54.     return 0;
    
55. }

复制代码

1. #include <stdlib.h>//不加会报隐式声明与内建函数'exit'不兼容
   
2. #include <stdio.h>
   
3. #include <sys/socket.h>
   
4. #include <string.h>
   
5. #include <netinet/in.h>//因用了地址(网络编程用的地址)
   
6. #include <arpa/inet.h>
   
7. #include <unistd.h>
   
8. 
   
9. #define MSG_SIZE 128
   
10. int main(int argc,char* argv[])
    
11. {
    
12. 
    
13.     int sockfd;
    
14.     int checkBind;
    
15.     char buf[MSG_SIZE];
    
16.     struct sockaddr_in sever_addr; //服务器的IP地址
    
17.     struct sockaddr_in client_addr; //用来存客户端的IP地址
    
18.     socklen_t addrlen;
    
19.     int n;//用来定位到buf的尾巴，添加字符串结束符‘\0’
    
20.     int portnum = 6666;
    
21. 
    
22.     //1.创建套接字
    
23.     sockfd = socket(AF_INET, SOCK_DGRAM, 0); //SOCK_DGRAM表示的是UDP协议的套接字，AF_INET表IPV4
    
24.     if (sockfd < 0) {
    
25.         perror("server socket error!\n");
    
26.         exit(1);
    
27.     }
    
28. 
    
29.     if (argc > 1) {
    
30.         portnum = atoi(argv[1]);
    
31.     }
    
32. 
    
33. 
    
34.     //2.0设置要绑定的服务器地址
    
35.     bzero(&sever_addr, sizeof(struct sockaddr_in));
    
36.     sever_addr.sin_family = AF_INET;
    
37.     sever_addr.sin_port = htons(portnum);//先要将主机字节序转换成网络字节序
    
38.     //sever_addr.sin_addr.s_addr = htonl(INADDR_ANY);//绑定任意的IP地址，要和网络上所有的IP地址通讯
    
39.     sever_addr.sin_addr.s_addr = INADDR_ANY;
    
40. 
    
41. 
    
42.     //2.1绑定地址
    
43.     checkBind = bind(sockfd, (struct sockaddr *)(&sever_addr), sizeof(struct sockaddr_in));
    
44.     if (checkBind < 0) {
    
45.         perror("server bind error!\n");
    
46.         exit(1);
    
47.     }
    
48. 
    
49.     addrlen = sizeof(struct sockaddr_in);
    
50. 
    
51.     //3.接收数据
    
52.     while (1) {
    
53. 
    
54.         bzero(buf, sizeof(buf));
    
55.         memset(&client_addr, 0, sizeof(struct sockaddr_in));
    
56.         n = recvfrom(sockfd, buf, MSG_SIZE, 0, (struct sockaddr *)(&client_addr), &addrlen);
    
57.         if (n < 0) {
    
58.             perror("sever recvfrom error!\n");
    
59.             printf("n = %d\n", n);
    
60.             exit(1);
    
61.         }
    
62.         printf("sever get connection from %s\n", inet_ntoa(client_addr.sin_addr));
    
63.         buf[n] = 0;//0即为‘\0’
    
64.         printf("server received: %s\n", buf);
    
65. 
    
66.     }
    
67.     //4.关闭连接
    
68.     close(sockfd);
    
69.     return 0;
    
70. 
    
71. }

复制代码

嵌入式陌生人

jeppeter 发表于 2017-03-24 10:37
回复 1# 嵌入式陌生人

非常感谢前辈的指导，我后来自己改出来了，问题好像出在那个给字符串数组加结束符上边，buf[n]=0,我把它注释了好像又好了

kidknight

嵌入式陌生人 发表于 2017-03-25 08:12
非常感谢前辈的指导，我后&amp;# ...

你的sendto一次发size个字节，recvfrom收到size个，所以你那个buf满了，你在操作buf[n]就越界了