求助!基于F429+OV5640+esp8266的无线图传

快乐的修狗

最近根据原子哥的例程弄了一个摄像头图像采集和图像无线传输

为了提高传输速度，已经将esp8266的波特率改成了2mhz，且图像采集使用jpeg压缩格式
并选择了支持的最小图像大小，单个图像5-10kb，但是使用原子哥的网络摄像头软件测试的时候，画面依旧卡顿

希望大伙可以帮忙看看

1. #include "demo.h"
   
2. #include "./BSP/ATK_MC5640/atk_mc5640.h"
   
3. #include "./BSP/ATK_MC5640/atk_mc5640_dcmi.h"
   
4. #include "./BSP/ATK_MW8266D/atk_mw8266d.h"
   
5. #include "./SYSTEM/usart/usart.h"
   
6. #include "./SYSTEM/delay/delay.h"
   
7. #include "./BSP/LED/led.h"
   
8. #include "./BSP/KEY/key.h"
   
9. #include "./BSP/LCD/lcd.h"
   
10. #include "string.h"
    
11. 
    
12. 
    
13. #define JPEG_OUTPUT_WIDTH  160 //320
    
14. #define JPEG_OUTPUT_HEIGHT 120 //240
    
15. #define JPEG_BUF_SIZE  (20*1024)
    
16. uint32_t g_jpeg_buf[JPEG_BUF_SIZE / sizeof(uint32_t)];
    
17. 
    
18. 
    
19. #define DEMO_WIFI_SSID          "Xiaomi 12S Pro"
    
20. #define DEMO_WIFI_PWD           "88888888"
    
21. #define DEMO_TCP_SERVER_IP      "192.168.37.84"
    
22. #define DEMO_TCP_SERVER_PORT    "8080"
    
23. 
    
24. 
    
25. static void demo_show_ip(char *buf)
    
26. {
    
27.     printf("IP: %s\r\n", buf);
    
28.     lcd_show_string(60, 151, 128, 16, 16, buf, BLUE);
    
29. }
    
30. 
    
31. 
    
32. static void Receivedata()
    
33. {
    
34.     uint8_t *buf;
    
35. 
    
36.         buf = atk_mw8266d_uart_rx_get_frame();
    
37.         if (buf != NULL)
    
38.         {
    
39.             printf("%s", buf);
    
40.             atk_mw8266d_uart_rx_restart();
    
41.         }
    
42. }
    
43. 
    
44. void ErrLight(){
    
45.         while (1)
    
46.         {
    
47.             LED0_TOGGLE();
    
48.             delay_ms(200);
    
49.         }
    
50. }
    
51. 
    
52. void send_image_data_via_uart(const uint32_t *image_data, uint32_t length)
    
53. {
    
54.   atk_mw8266d_uart_send_data((const uint8_t *)image_data, length);
    
55. }
    
56. 
    
57. void demo_run(void)
    
58. {
    
59.           uint8_t *p_jpeg_buf;
    
60.     uint32_t jpeg_len;
    
61.     uint32_t jpeg_index;
    
62.     uint32_t jpeg_start_index;
    
63.     uint32_t jpeg_end_index;
    
64.         
    
65.     uint8_t ret;
    
66.     char ip_buf[16];
    
67. 
    
68.     ret = atk_mw8266d_init(2000000);//2000000 921600 115200
    
69.     if (ret != 0)
    
70.     {
    
71.         printf("ATK-MW8266D init failed!\r\n");
    
72.                         ErrLight();
    
73.     }
    
74.    
    
75.     printf("Joining to AP...\r\n");
    
76.     //ret  = atk_mw8266d_restore();
    
77.     ret += atk_mw8266d_at_test();
    
78.     ret += atk_mw8266d_set_mode(1);
    
79.     ret += atk_mw8266d_sw_reset();
    
80.     ret += atk_mw8266d_ate_config(0);
    
81.     ret += atk_mw8266d_join_ap(DEMO_WIFI_SSID, DEMO_WIFI_PWD);
    
82.                 //ret += atk_mw8266d_changebaudrate(2000000);
    
83.     ret += atk_mw8266d_get_ip(ip_buf);
    
84.     if (ret != 0)
    
85.     {
    
86.         printf("Error to join ap!\r\n");
    
87.         ErrLight();
    
88.     }
    
89.     demo_show_ip(ip_buf);  
    
90.    
    
91.                 ret = atk_mw8266d_connect_tcp_server(DEMO_TCP_SERVER_IP, DEMO_TCP_SERVER_PORT);
    
92.     if (ret != 0){
    
93.       printf("Error to connect Service!\r\n");
    
94.                   ErrLight();
    
95.     }
    
96. 
    
97.     atk_mw8266d_uart_rx_restart();
    
98.                
    
99.                 ret = atk_mw8266d_enter_unvarnished();
    
100.                 if (ret != 0){
     
101.       printf("Error to enter Unvarnished!\r\n");
     
102.                   ErrLight();
     
103.     }
     
104.                
     
105.                 ret  = atk_mc5640_init();
     
106.     ret += atk_mc5640_set_output_format(ATK_MC5640_OUTPUT_FORMAT_JPEG);
     
107.     ret += atk_mc5640_auto_focus_init();
     
108.     ret += atk_mc5640_auto_focus_continuance();
     
109.     ret += atk_mc5640_set_light_mode(ATK_MC5640_LIGHT_MODE_ADVANCED_AWB);
     
110.     ret += atk_mc5640_set_color_saturation(ATK_MC5640_COLOR_SATURATION_4);
     
111.     ret += atk_mc5640_set_brightness(ATK_MC5640_BRIGHTNESS_4);
     
112.     ret += atk_mc5640_set_contrast(ATK_MC5640_CONTRAST_4);
     
113.     ret += atk_mc5640_set_hue(ATK_MC5640_HUE_6);
     
114.     ret += atk_mc5640_set_special_effect(ATK_MC5640_SPECIAL_EFFECT_NORMAL);
     
115.     ret += atk_mc5640_set_exposure_level(ATK_MC5640_EXPOSURE_LEVEL_5);
     
116.     ret += atk_mc5640_set_sharpness_level(ATK_MC5640_SHARPNESS_OFF);
     
117.     ret += atk_mc5640_set_mirror_flip(ATK_MC5640_MIRROR_FLIP_1);
     
118.     ret += atk_mc5640_set_test_pattern(ATK_MC5640_TEST_PATTERN_OFF);
     
119.     ret += atk_mc5640_set_output_size(JPEG_OUTPUT_WIDTH, JPEG_OUTPUT_HEIGHT);
     
120.     if (ret != 0)
     
121.     {
     
122.       printf("ATK-MC5640 init failed!\r\n");
     
123.                         ErrLight();
     
124.     }
     
125.                
     
126.                                 
     
127.     while (1)
     
128.     {
     
129.                                   p_jpeg_buf = (uint8_t *)g_jpeg_buf;
     
130.                 jpeg_len = JPEG_BUF_SIZE / (sizeof(uint32_t));
     
131.         
     
132.                 memset((void *)g_jpeg_buf, 0, JPEG_BUF_SIZE);
     
133.                
     
134.                 atk_mc5640_get_frame((uint32_t)g_jpeg_buf, ATK_MC5640_GET_TYPE_DTS_32B_INC, NULL);
     
135.                
     
136.                 /*
     
137.                 for (jpeg_start_index = UINT32_MAX, jpeg_index = 0; jpeg_index < JPEG_BUF_SIZE - 1; jpeg_index++)
     
138.                 {
     
139.                     if ((p_jpeg_buf[jpeg_index] == 0xFF) && (p_jpeg_buf[jpeg_index + 1] == 0xD8))
     
140.                     {
     
141.                         jpeg_start_index = jpeg_index;
     
142.                         break;
     
143.                     }
     
144.                 }
     
145.                 if (jpeg_start_index == UINT32_MAX)
     
146.                 {
     
147.                     continue;
     
148.                 }
     
149.                                                                 */
     
150.                                                                
     
151.                 jpeg_start_index=0;
     
152.                 for (jpeg_end_index = UINT32_MAX, jpeg_index = jpeg_start_index; jpeg_index < JPEG_BUF_SIZE - 1; jpeg_index++)
     
153.                 {
     
154.                     if ((p_jpeg_buf[jpeg_index] == 0xFF) && (p_jpeg_buf[jpeg_index + 1] == 0xD9))
     
155.                     {
     
156.                         jpeg_end_index = jpeg_index;
     
157.                         break;
     
158.                     }
     
159.                 }
     
160.                 if (jpeg_end_index == UINT32_MAX)
     
161.                 {
     
162.                     continue;
     
163.                 }
     
164.                                                                 if(jpeg_end_index<=jpeg_start_index+10){
     
165.                                                                         continue;
     
166.                                                                 }
     
167. 
     
168.                 jpeg_len = jpeg_end_index - jpeg_start_index + (sizeof(uint32_t) >> 1);
     
169.                                                                 send_image_data_via_uart(g_jpeg_buf, jpeg_len);
     
170.         
     
171.                                 Receivedata();
     
172.                                 
     
173.         //delay_ms(2);
     
174.     }
     
175. }
     

复制代码

其中，atk_mw8266d_uart_send_data 函数是我根据atk_mw8266d_uart_printf函数改的，代码：

1. void atk_mw8266d_uart_send_data(const uint8_t *data, uint16_t len)
   
2. {
   
3.     HAL_UART_Transmit(&g_uart_handle, data, len, HAL_MAX_DELAY);
   
4. }

复制代码

我还把发送缓冲区大小ATK_MW8266D_UART_TX_BUF_SIZE从默认的64改成了64000，但是不知道为什么摄像头软件调试卡顿明显

还有一个不明白的地方就是，esp8266可以正常连接到网络调试助手或者网络摄像头软件创建的tcp service，但是我自己用nodejs创建的tcp service，就无法连接上
已经确认node代码创建的tcp service没问题，这个service可以被网络调试助手作为client正常连接
这个是tcp service的代码：

1. const net = require('net');
   
2. 
   
3. let PORT = '8080';
   
4. let HOST = '192.168.37.84';
   
5. 
   
6. const server = net.createServer((socket) => {
   
7. 
   
8.     socket.on('data', (data) => {
   
9.         console.log('接收到的数据:', data.toString());
   
10.     });
    
11. 
    
12.     socket.on('end', () => {
    
13.         console.log('STM32已断开连接');
    
14.     });
    
15. 
    
16.     socket.on('error', (err) => {
    
17.         console.error('连接错误:', err);
    
18.     });
    
19. });
    
20. 
    
21. server.listen(PORT, HOST, () => {
    
22.     console.log(`服务器运行在 http://${HOST}:${PORT}`);
    
23. });

复制代码