【设计实例】基于SoC FPGA的Linux UDP图像发送。

admin

如果您还没有注册本论坛，将无法下载论坛中附件，但是注册论坛非常简单，使用微   信 扫码即可注册。 也可以在小梅哥任意一个Q群内直接索取邀请码使用邀请码注册，小梅哥创建的任意一个群都可以。

以下代码为基本的Linux 使用UDP发送两个文件的图像数据到远端（192.168.0.106：6000）的程序，使用时，在DS-5或GCC下交叉编译得到可执行文件，然后拷贝到SoC 开发板中，同时，需要把附件的两bin格式图像二进制文件也拷贝到程序所在目录，然后执行，开发板就能不断的发送这两幅图像的数据到远端了。
图像源文件.rar (336.53 KB, 下载次数: 731)

2019-4-20 20:50 上传

点击文件名下载附件

需要注意的是，为了保证发送成功：
开发板的IP也需要设置为192.168.0.网段，比如设置为192.168.0.2
电脑的IP地址需要设置为192.168.0.168
图像接收软件的几个参数要与实际网络参数匹配（图像软件见下述附件）

小梅哥UDP摄像头V2.rar (25.96 KB, 下载次数: 488)

2019-4-20 20:52 上传

点击文件名下载附件

如果图像软件运行失败，提示找不到mfcxxx.dll，请安装运行环境，百度下载 vcredist_x86安装就可以了

1. 
   
2. #include <stdio.h>
   
3. #include <stdlib.h>
   
4. #include <unistd.h>
   
5. #include <fcntl.h>
   
6. #include <sys/mman.h>
   
7. #include <sys/types.h>
   
8. #include <dirent.h>
   
9. #include <inttypes.h>
   
10. #include <sys/time.h>
    
11. #include <stdbool.h>
    
12. #include <pthread.h>
    
13. #include <sys/ioctl.h>
    
14. #include "math.h"
    
15. #include <string.h>
    
16. 
    
17. #include <linux/fb.h>
    
18. 
    
19. #include <sys/socket.h>
    
20. #include <netinet/in.h>
    
21. #include <arpa/inet.h>
    
22. #include <netdb.h>
    
23. 
    
24. #include <signal.h>
    
25. 
    
26. char* ReadBmpFile(const char* szFile)
    
27. {
    
28.         FILE* fTmp = fopen(szFile, "rb");
    
29.         if (fTmp == NULL) return NULL;
    
30. 
    
31.         fseek(fTmp, 0, SEEK_END);
    
32.         int nLen = ftell(fTmp);
    
33.         if (nLen <= 0)
    
34.         {
    
35.                 fclose(fTmp);
    
36.                 return NULL;
    
37.         }
    
38. 
    
39.         char* szContent = (char*)malloc(nLen + 1);
    
40.         memset(szContent, 0, nLen + 1);
    
41.         fseek(fTmp, 0, SEEK_SET);
    
42.         char szTmp[1024] = { 0 };
    
43.         int nHaveRead = 0;
    
44.         while (!feof(fTmp))
    
45.         {
    
46.                 int nRead = fread(szTmp, 1, 1024, fTmp);
    
47.                 if (nRead <= 0) break;
    
48. 
    
49.                 memcpy(szContent + nHaveRead, szTmp, nRead);
    
50.                 nHaveRead += nRead;
    
51.         }
    
52.         fclose(fTmp);
    
53. 
    
54.         return szContent;
    
55. }
    
56. 
    
57. unsigned char STOP = 0;
    
58. 
    
59. void signalFunc(int _signal)
    
60. {
    
61.         STOP = 1;
    
62. }
    
63. 
    
64. int main(int argc, char ** argv) {
    
65. 
    
66.         signal(SIGINT, signalFunc);
    
67.         signal(SIGTERM, signalFunc);
    
68. 
    
69.         int nX = 640;
    
70.         int nY = 480;
    
71.         char* szBmp1 = ReadBmpFile("640_480_01.bin");
    
72.         if (NULL == szBmp1)
    
73.         {
    
74.                 printf("read bmp file 1 error!");
    
75.                 return 0;
    
76.         }
    
77.         char* szBmp2 = ReadBmpFile("640_480_02.bin");
    
78.         if (NULL == szBmp2)
    
79.         {
    
80.                 printf("read bmp file 2 error!");
    
81.                 return 0;
    
82.         }
    
83. 
    
84.         int retval;
    
85. 
    
86.     char buf[2048];
    
87.     int socket_descriptor; //套接口描述字
    
88.         struct sockaddr_in address;//处理网络通信的地址
    
89.         int port=6000;
    
90.         bzero(&address,sizeof(address));
    
91.         address.sin_family=AF_INET;
    
92.         address.sin_addr.s_addr=inet_addr("192.168.0.106");//这里不一样
    
93.         address.sin_port=htons(port);
    
94.     unsigned char *p;
    
95.         //创建一个 UDP socket
    
96. 
    
97.         socket_descriptor=socket(AF_INET,SOCK_DGRAM,0);//IPV4  SOCK_DGRAM 数据报套接字（UDP协议）
    
98. 
    
99.         int rbufsz = 5 * 1024 * 1024; //5M
    
100.         setsockopt(socket_descriptor, SOL_SOCKET, SO_RCVBUF, &rbufsz, sizeof(rbufsz));
     
101.         int wbufsz = 5 * 1024 * 1024; //5M
     
102.         setsockopt(socket_descriptor, SOL_SOCKET, SO_SNDBUF, &wbufsz, sizeof(wbufsz));
     
103. 
     
104.         int maxfdp;
     
105.         fd_set fds;
     
106.         fd_set fdsErr;
     
107.     struct timeval timeout = {1, 0};//设置select等待3秒，3秒轮询，非阻塞就置0
     
108.         int nSendFile = 0;
     
109.         long iter = 0;
     
110. 
     
111.     connect(socket_descriptor, (struct sockaddr *)&address,sizeof(address));
     
112. 
     
113.         while (!STOP)
     
114.         {
     
115. 
     
116.             FD_ZERO(&fds);//每次循环都要清空集合，否则不能检测描述符变化
     
117.                 FD_SET(socket_descriptor, &fds);//添加描述符
     
118.                 //FD_ZERO(&fdsErr);//每次循环都要清空集合，否则不能检测描述符变化
     
119.                 //FD_SET(socket_descriptor, &fdsErr);//添加描述符
     
120.             maxfdp = socket_descriptor + 1;//描述符最大值加1
     
121.            // printf("1\n");
     
122.             retval = select(maxfdp, NULL, &fds, NULL, &timeout);
     
123.                 if (retval <= 0)
     
124.                 {
     
125.                         //usleep(1000);
     
126.                         continue;
     
127.                 }
     
128.                 p = (unsigned char *)((nSendFile == 0) ? szBmp1 : szBmp2);
     
129. 
     
130.                 buf[1]=iter >> 8;
     
131.                 buf[0]=iter & 0xff;
     
132.                 //memcpy(&buf[2],p,1280);
     
133.                 memcpy(&buf[2], p + iter * 1280, 1280);
     
134. 
     
135.             if(FD_ISSET(socket_descriptor,&fds))//测试skt是否可写，即网络上是否有数据
     
136.             {
     
137.                 retval = write(socket_descriptor, buf, 1282);
     
138.                 if(retval < 0){
     
139.                     perror("sendto error: ");
     
140.                     exit(1);
     
141.                 }
     
142.             }
     
143. 
     
144.                 iter++;
     
145. 
     
146.                 if (iter > nY - 1)
     
147.                 {
     
148.                         iter = 0;
     
149.                         nSendFile = (nSendFile + 1) % 2;
     
150.                         //usleep(1000);
     
151.                 }
     
152.         }
     
153.         free(szBmp1);
     
154.         free(szBmp2);
     
155.         printf("app exit\n");
     
156. 
     
157. }
     
158. 
     
159. 
     

复制代码

ccb97

请问小梅哥有完整的工程吗，我不知道怎么在qsys中配置以太网，能发一份原工程吗