请问大家一个linux网络传输的问题？

dingzhou2008

下面是两个linux下网络传输程序，server.c和client.c，分别发送和接收照片数据。照片大小32K。编译后在ubuntu下运行正常图片正确，但交叉编译后server在开发板上运行，client在ubuntu下运行，接收到的图片数据能显示，但有错位。请大家帮忙分析一下。

1. 
   
2. server.c如下：
   
3. #include <stdio.h>
   
4. #include <stdlib.h>
   
5. #include <unistd.h>
   
6. #include <sys/socket.h>
   
7. #include <netinet/in.h>
   
8. #include <sys/types.h>
   
9. #include <string.h>
   
10. #include "proto.h"
    
11. 
    
12. #define BUFSIZE 128 //1024
    
13. #define STRSIZE 40
    
14. 
    
15. static void server_job(int sd) {
    
16. 
    
17.     char buf[BUFSIZE];
    
18.     int len, i, count;
    
19.     char jpgbuf[1024 * 500];
    
20.     char statebuf[40];
    
21.     FILE *input_file;
    
22.     if ((input_file = fopen("1.jpg", "rb")) == NULL) {
    
23.         fprintf(stderr, "can't open 1.jpg\n");
    
24.         return;
    
25.     }
    
26.     fread(jpgbuf, 32768, 1, input_file);
    
27.     for (count = 0; count < 32; count++) {
    
28.         if (send(sd, jpgbuf+count*1024, 1024, 0) < 0) {
    
29.             printf("Send File:\t JPEG picture Failed\n");
    
30.         }
    
31.     }
    
32. }
    
33. 
    
34. int main() {
    
35.     char ipstr[STRSIZE];
    
36.     int sd, newsd;
    
37.     struct sockaddr_in laddr, raddr;
    
38.     socklen_t raddr_len;
    
39.     pid_t pid;
    
40.     sd = socket(AF_INET, SOCK_STREAM, 0/*IPPROTO_TCP,IPPROTO_SCTP*/);
    
41.     if (sd < 0) {
    
42.         perror("socket()");
    
43.         exit(1);
    
44.     }
    
45. 
    
46.     int val = 1;
    
47.     if (setsockopt(sd, SOL_SOCKET, SO_REUSEADDR, &val, sizeof(val)) < 0) {
    
48.         perror("setsockopt(SO_REUSEADDR)");
    
49.     }
    
50. 
    
51.     laddr.sin_family = AF_INET;
    
52.     laddr.sin_port = htons(atoi(SERVERPORT));
    
53.     inet_pton(AF_INET, "0.0.0.0", &laddr.sin_addr);
    
54. 
    
55.     if (bind(sd, (void *) &laddr, sizeof(laddr)) < 0) {
    
56.         perror("bind()");
    
57.         exit(1);
    
58.     }
    
59. 
    
60.     if (listen(sd, 200) < 0) {
    
61.         perror("listen()");
    
62.         exit(1);
    
63.     }
    
64. 
    
65.     raddr_len = sizeof(raddr); /*!!!!!!!!*/
    
66.     while (1) {
    
67.         newsd = accept(sd, (void *) &raddr, &raddr_len);
    
68.         if (newsd < 0) {
    
69.             perror("accept()");
    
70.             exit(1);
    
71.         }
    
72.         pid = fork();
    
73.         if (pid < 0) {
    
74.             fprintf(stderr, "fork()");
    
75.             exit(1);
    
76.         }
    
77.         if (pid == 0) {
    
78.             close(sd);
    
79.             inet_ntop(AF_INET, &raddr.sin_addr, ipstr, STRSIZE);
    
80.             printf("Client:%s:%d\n", ipstr, ntohs(raddr.sin_port));
    
81.             server_job(newsd);
    
82.             close(newsd);
    
83.             exit(1);
    
84.         }
    
85.         close(newsd);
    
86.         wait(NULL);
    
87.     }
    
88.     exit(0);
    
89. }
    
90. client.c如下：
    
91. #include <stdio.h>
    
92. #include <stdlib.h>
    
93. #include <string.h>
    
94. #include <unistd.h>
    
95. #include <sys/socket.h>
    
96. #include <netinet/in.h>
    
97. 
    
98. #include "proto.h"
    
99. /* Address to accept any incoming messages.  */
    
100. #define    INADDR_ANY        ((in_addr_t) 0x00000000)
     
101. #define BUFFER_SIZE 1024
     
102. /* Set N bytes of S to 0.  */
     
103. extern void bzero(void *__s, size_t __n)
     
104. __THROW __nonnull ((1));
     
105. 
     
106. char recieveBuffer[BUFFER_SIZE];
     
107. int leftRecieveChars;
     
108. int currentIndex = 0;
     
109. int sd;
     
110. char getOneChar() {
     
111.     currentIndex++;
     
112.     if (leftRecieveChars == 0) {
     
113.         bzero(recieveBuffer, BUFFER_SIZE);
     
114.         do {
     
115.             leftRecieveChars = recv(sd, recieveBuffer, BUFFER_SIZE, 0);
     
116.             if (leftRecieveChars < 0) {
     
117.                 printf("Server Recieve Data Failed!\n");
     
118.                 exit(1);
     
119.             }
     
120.         } while (leftRecieveChars == 0);
     
121.         currentIndex = 0;
     
122.     }
     
123.     leftRecieveChars--;
     
124.     return recieveBuffer[currentIndex];
     
125. }
     
126. 
     
127. int main(int argc, char *argv[]) {
     
128.     FILE *fp;
     
129. 
     
130.     int i, jpegSize;
     
131.     long long stamp;
     
132.     struct sockaddr_in raddr;
     
133.     char numberBuf[20];
     
134. 
     
135.     if (argc < 2) {
     
136.         fprintf(stderr, "Usage...\n");
     
137.         exit(1);
     
138.     }
     
139.     //创建用于internet的流协议(TCP)socket,用client_socket代表客户机socket
     
140.     sd = socket(AF_INET, SOCK_STREAM, 0);
     
141.     if (sd < 0) {
     
142.         perror("socket()");
     
143.         exit(1);
     
144.     }
     
145. 
     
146.     //设置一个socket地址结构client_addr,代表客户机internet地址, 端口
     
147.     struct sockaddr_in client_addr;
     
148.     bzero(&client_addr, sizeof(client_addr)); //把一段内存区的内容全部设置为0
     
149.     client_addr.sin_family = AF_INET; //internet协议族
     
150.     client_addr.sin_addr.s_addr = htons(INADDR_ANY); //INADDR_ANY表示自动获取本机地址
     
151.     client_addr.sin_port = htons(0); //0表示让系统自动分配一个空闲端口
     
152. 
     
153.     //把客户机的socket和客户机的socket地址结构联系起来
     
154.     if (bind(sd, (struct sockaddr*) &client_addr, sizeof(client_addr))) {
     
155.         printf("Client Bind Port Failed!\n");
     
156.         exit(1);
     
157.     }
     
158. 
     
159.     raddr.sin_family = AF_INET;
     
160.     raddr.sin_port = htons(atoi(SERVERPORT));
     
161.     inet_pton(AF_INET, argv[1], &raddr.sin_addr);
     
162. 
     
163.     if (connect(sd, (void *) &raddr, sizeof(raddr)) < 0) {
     
164.         perror("connect()");
     
165.         exit(1);
     
166.     }
     
167.     int count = 0, cnt = 0;
     
168.     char name[20];
     
169.     //while (1) {
     
170.     printf("Begin recieve data.the num is %d!\n", cnt);
     
171.     cnt++;
     
172.     jpegSize = 32768;
     
173.     char fileBuf[jpegSize];
     
174.     bzero(fileBuf, jpegSize);
     
175.     //printf("Begin receive JPG date !\n");
     
176.     for (count = 0; count < 32; count++) {
     
177.         leftRecieveChars = recv(sd, fileBuf + count * 1024, 1024, 0);
     
178.     }
     
179.     sprintf(name, "%d.jpg", count);
     
180.     count++;
     
181.     if (count >= 7)
     
182.         count = 0;
     
183.     fp = fopen(name, "w");
     
184.     int writeLength = fwrite(fileBuf, sizeof(char), 32768, fp);
     
185.     //printf("writeLength to file : %d\n", writeLength);
     
186.     if (writeLength < 32768) {
     
187.         printf("File:\t%s Write Failed\n", "1.jpeg");
     
188.         fclose(fp);
     
189.         exit(1);
     
190.     }
     
191.     fclose(fp);
     
192.     return 0;
     
193. }
     
194. 
     

复制代码

dingzhou2008

顶一个！大家帮忙啊！

huangya90

程序能运行，一般情况下是不会出问题的。但还是一个错误的程序。
tcp是面向字节流的，对于什么是面向字节流，请参考任何一本网络教材（其实很多人对tcp是面向字节流根本没有理解）。

1. for (count = 0; count < 32; count++) {
   
2.         leftRecieveChars = recv(sd, fileBuf + count * 1024, 1024, 0);
   
3.     }

复制代码

这段代码中的每调用一次recv，不一定会收到1024个字节，所以调用32次可能收到小于1024*32个字节。这里就发生了这种情况。用命令

od -Ad -t u1 正确的图片.jpg >正确的图片.jpg.udecimal;  od -Ad -t u1 错误的图片.jpg >错误的图片.jpg.udecimal;  

可以得到两张图片的无符号整数类型。用命令

cmp 正确的图片.jpg 错误的图片.jpg

可以发现在第3921个字节出现了第一个不相同的字节。用vim打开文件：错误的图片.jpg.udecimal，正确的图片.jpg.udecimal。找到第3921个字节，如下图所示：
（左边的是文件错误的图片.jpg.udecimal，右边的是文件正确的图片.jpg.udecimal。图中的0003920表示第3921个字节)。错误的图片.jpg.udecimal从3921-4096个字节显示的数值是0（fileBuf是全局变量 ，每个字节默认值是0），而正确的图片.jpg.udecimal数值不是0。错误的图片.jpg.udecimal从地址0004960对应了正确的图片.jpg.udecima从地址0003920开始的数值，说明你在第四次调用recv的时候并没有收到 1024个字节。所以你接收了错误的数据。下面的recv调用也发生了这种情况。知道了原因， 我想你应该知道怎么改程序了。


另外说两点：
1.client.c中getOneChar() 有什么用？你都没有调用。
2.请以后粘贴代码的时候使用插入的方式，不要直接粘贴，代码中出现笑脸了。

dingzhou2008

多谢指点，说的太对了，严谨的作风让我自愧不如，我以后会改过，多谢大牛。