21ic电子技术开发论坛 › 单片机与嵌入式系统 › ST MCU › STM32移植lwip之建立web服务器
12下一页
返回列表 发新帖我要提问

[信息] STM32移植lwip之建立web服务器

[复制链接]
4535|25
 楼主| 小明的同学 发表于 2018-5-13 19:29 | 显示全部楼层 |阅读模式
stm32移植, lwIP, web服务器, 浏览器, AC
本篇目标：在之前能ping通pc机的工程基础上搭建web服务器，借鉴官方web服务器的程序与网页，能够用pc机浏览器访问web服务器，并返回设置的网页

ps：通过修改官方搭建web服务器的代码，来了解搭建的过程，其中暂时去掉了ssi和cgi的程序，仅仅实现网页数据的返回和网页的跳转，并将官方的代码简化到相对最简，以便以后的学习之用

浏览器请求指令探索

要搭建服务器，首先肯定要先了解远程客户端是怎么访问服务器的，这里pc机的浏览器则作为客户端：

  • 打开浏览器（谷歌浏览器测试），输入服务器ip；
  • 浏览器发送请求命令给服务器；
  • 服务器接收到指令后，通过程序来解析指令，找到对应应该返回的网页；
  • 服务器发送网页代码给浏览器；
  • 浏览器显示网页；

接下来再用搭建虚拟服务器的方法，来模拟一下上面的过程：

  • 打开网络调试助手，切换到网络服务器，在服务器操作端口输入80，点击创建，如图；这样我们就创建了一个虚拟的服务器，这个服务器的ip就是pc机的本地ip


000.png
确认一下本地ip地址，可以在网络连接里面查看，也可以在cmd输命令查看，这里的ip地址为192.168.6.104，如图：
001.png


打开浏览器（谷歌浏览器测试），输入刚才确认的本地ip地址，这里输入192.168.6.104
返回去看看刚才搭建的服务器有什么变化，会发现有接收到的数据，只要重点观察第一行的数据“GET / HTTP/1.1”，这个字符串将会被服务器解析，然后将网页代码返回回去：
002.png

回复

收藏 举报

相关帖子
 楼主| 小明的同学 发表于 2018-5-13 19:33 | 显示全部楼层
找到一个官方程序有一个fs文件夹，里面有已经做好的网页，打开网页index.html，右击-查看源代码，然后全选复制下来，在网络调试助手的发送区粘贴，并点击发送，如图：
003.png

  • 这时，会发现浏览器已经显示了一张网页，但是好像又有点不全，因为图片没有显示，为什么呢？返回网络调试助手，发现接收区又有好多请求，看字面意思，好像就是图片的请求，然而服务器没有返回图片数据，所以图片无法显示

  • 这时候，将所有的浏览器请求列出来比较一下：
    “GET / HTTP/1.1”
    “GET /STM32F4x7_files/ST.gif HTTP/1.1”
    “GET /inchtml-pages-stm32_connectivity_files/pixel.gif HTTP/1.1”
    “GET /STM32F4x7_files/stm32.jpg HTTP/1.1”
    发现请求中 / 后面一部分的内容不相同，所以服务器只需要解析这一部分的字符串内容，来返回对应的网页数据即可



回复

收藏 举报

 楼主| 小明的同学 发表于 2018-5-13 19:34 | 显示全部楼层
搭建web服务器

现在创建一个新的c文件，取名为 http_server.c ,接下来写几个函数来建立web服务器，抽重要的函数进行总结一下：

  • web服务器初始化函数 Http_Server_Init()：
复制
  1. void Http_Server_Init(void)
    

  2. {
    

  3.     struct tcp_pcb *http_server_pcb;
    


  4. 

  5.     /* 为web服务器分配一个tcp_pcb结构体 */
    

  6.     http_server_pcb = tcp_new();
    


  7. 

  8.     /* 绑定本地端号和IP地址 */
    

  9.     tcp_bind(http_server_pcb, IP_ADDR_ANY, 80);
    


  10. 

  11.     /* 监听之前创建的结构体http_server_pcb */
    

  12.     http_server_pcb = tcp_listen(http_server_pcb);
    


  13. 

  14.     /* 初始化结构体接收回调函数 */
    

  15.     tcp_accept(http_server_pcb, http_server_accept);
    

  16. }

小结：上面函数主要就是为搭建web服务器做准备，包括申请网络结构体、设置80端口号、监听数据、设置接收数据回调函数；

  • 接收数据回调函数 tcp_server_accept() ：
复制
  1. static err_t http_server_accept(void *arg, struct tcp_pcb *pcb, err_t err)
    

  2. {
    

  3.     struct http_state *hs;
    


  4. 

  5.     /* 分配内存空间 */
    

  6.     hs = (struct http_state *)mem_malloc(sizeof(struct http_state));
    


  7. 

  8.     if (hs != NULL)
    

  9.     {
    

  10.         memset(hs, 0, sizeof(struct http_state));
    

  11.     }
    


  12. 

  13.     /* 确认监听和连接 */
    

  14.     tcp_arg(pcb, hs);
    


  15. 

  16.     /* 配置接收回调函数 */
    

  17.     tcp_recv(pcb, http_server_recv);
    


  18. 

  19.     /* 配置轮询回调函数 */
    

  20.     tcp_poll(pcb, http_server_poll, 4);
    


  21. 

  22.     /* 配置发送回调函数 */
    

  23.     tcp_sent(pcb, http_sent);
    


  24. 

  25.     return ERR_OK;
    

  26. }




回复

收藏 举报

 楼主| 小明的同学 发表于 2018-5-13 19:36 | 显示全部楼层

小结：函数中主要配置一些回调函数，比如接收，轮询，发送；

  • 接收数据处理函数 http_server_recv() ：
复制
  1. static err_t http_server_recv(void *arg, struct tcp_pcb *pcb, struct pbuf *http_recv_pbuf, err_t err)
    

  2. {
    

  3.     err_t parsed = ERR_ABRT;
    

  4.     struct http_state *hs = (struct http_state *)arg;
    


  5. 

  6.     /* 告诉tcp已经接收到数据 */
    

  7.     tcp_recved(pcb, http_recv_pbuf->tot_len);
    


  8. 

  9.     if (hs->handle == NULL)
    

  10.     {
    

  11.          /* 解析接收到的浏览器请求数据 */
    

  12.          parsed = http_parse_request(&http_recv_pbuf, hs, pcb);
    

  13.     }
    


  14. 

  15.     /* 清空请求字符串 */
    

  16.     if (parsed != ERR_INPROGRESS) 
    

  17.     {       
    

  18.         if (hs->req != NULL) 
    

  19.         {
    

  20.             pbuf_free(hs->req);
    

  21.             hs->req = NULL;
    

  22.         }
    

  23.     }
    


  24. 

  25.     if (parsed == ERR_OK)
    

  26.     {
    

  27.         /* 发送网页数据 */
    

  28.         http_send_data(pcb, hs);
    

  29.     }
    

  30.     else if (parsed == ERR_ARG)
    

  31.     {
    

  32.         /* 关闭连接 */
    

  33.         close_conn(pcb, hs);
    

  34.     }
    


  35. 

  36.     return ERR_OK;
    

  37. }

小结：函数主要工作将接收到的数据放入 http_parse_request() 函数进行解析，然后把网页数据发送出去；

  • 接收数据解析函数 http_parse_request()：
复制
  1. static err_t http_parse_request(struct pbuf **inp, struct http_state *hs, struct tcp_pcb *pcb)
    

  2. {
    

  3.     char *data;
    

  4.     char *crlf;
    

  5.     u16_t data_len;
    

  6.     struct pbuf *p = *inp;
    


  7. 

  8.     char *sp1, *sp2;
    

  9.     u16_t uri_len;
    

  10.     char *uri;
    


  11. 

  12.     /* 排列字符串 */
    

  13.     if (hs->req == NULL)
    

  14.     {
    

  15.         hs->req = p;
    

  16.     }
    

  17.     else
    

  18.     {
    

  19.         /* 将多次的请求字符串进行连接排序 */
    

  20.         pbuf_cat(hs->req, p);
    

  21.     }
    


  22. 

  23.     /* 拷贝输入数据 */ 
    

  24.     if (hs->req->next != NULL)
    

  25.     {
    

  26.         data_len = hs->req->tot_len;
    

  27.         pbuf_copy_partial(hs->req, data, data_len, 0);
    

  28.     }
    

  29.     else
    

  30.     {
    

  31.         data = (char *)p->payload;
    

  32.         data_len = p->len;
    

  33.     }
    


  34. 

  35.     /* 提取接收到的浏览器字符串，浏览器请求示例："GET / HTTP/1.1" */
    

  36.     if (data_len > 7) 
    

  37.     {
    

  38.         crlf = strstr(data, "\r\n");
    


  39. 

  40.         if (crlf != NULL) 
    

  41.         {
    

  42.             /* 比较前4个字符是否为 "GET " */
    

  43.             if (strncmp(data, "GET ", 4) == 0) 
    

  44.             {
    

  45.                 /* sp1指向字符串 "/ HTTP/1.1" */
    

  46.                 sp1 = (data + 4);
    

  47.             }
    


  48. 

  49.             /* 在sp1字符串中寻找字符" "，sp2指向字符串 " HTTP/1.1" */
    

  50.             sp2 = strstr(sp1, " ");
    


  51. 

  52.             /* uri_len获取sp1字符串首地址到sp2字符串首地址的长度 */
    

  53.             uri_len = sp2 - (sp1);
    


  54. 

  55.             if ((sp2 != 0) && (sp2 >= (sp1))) 
    

  56.             {
    

  57.                 /* 将解析的字符串赋给uri，并在最后加上结束符\0，
    

  58.                    uri指向字符串 "/\0" */
    

  59.                 uri = sp1;
    

  60.                 *(sp1 - 1) = 0;
    

  61.                 uri[uri_len] = 0;
    


  62. 

  63.                 /* 根据字符串寻找对应网页数据 */
    

  64.                 return http_find_file(hs, uri, 0); 
    

  65.             }
    

  66.         }
    

  67.     }
    


  68. 

  69.     return ERR_OK;
    

  70. }

小结：这个函数是重要的请求数据解析函数，函数将接收到的字符串（例：“GET /STM32F4x7_files/ST.gif HTTP/1.1”）
分离出重要的判断字符串（例：“ /STM32F4x7_files/ST.gif”），然后根据这个字符串的内容来读取对应的网页数据；

  • 读取对应网页数据函数 http_find_file()：
复制
  1. static err_t http_find_file(struct http_state *hs, const char *uri, int is_09)
    

  2. {
    

  3.     struct fs_file *file = NULL;
    


  4. 

  5.     /* 如果字符串为 "/\0",则打开index网页 */
    

  6.     if((uri[0] == '/') && (uri[1] == 0)) 
    

  7.     {
    

  8.         file = fs_open("/index.html");
    

  9.         uri = "/index.html";
    

  10.     } 
    

  11.     else 
    

  12.     {
    

  13.         /* 如果为其他请求，则打开相应网页 */
    

  14.         file = fs_open(uri);
    

  15.     }
    


  16. 

  17.     /* 将网页文件数据赋值给http_state结构体，之后发送出去 */
    

  18.     return http_init_file(hs, file, is_09, uri);
    

  19. }





回复

收藏 举报

 楼主| 小明的同学 发表于 2018-5-13 19:37 | 显示全部楼层
小结：此函数就是网页数据读取函数，里面最重要的函数就是 fs_open() 函数了，这个函数在官方建立web服务器工程里的 fs.c 文件里面，这个函数的解析放到后面；

ps：http_server.c 还有头文件的包含，函数的定义；另外再编写一个http_server.h文件，包含宏定义，结构体定义，函数定义；在下面贴出这两个文件的源码；

上面基本包括了几个重要的函数，当然还有其他的函数，包括发送函数等等，这些函数可以看源代码的注释来理解
回复

收藏 举报

 楼主| 小明的同学 发表于 2018-5-13 19:37 | 显示全部楼层
  • http_server.c
复制
  1. #include "lwip/debug.h"
    

  2. #include "lwip/stats.h"
    

  3. #include "lwip/tcp.h"
    

  4. #include "http_server.h"
    

  5. #include "fs.h"
    


  6. 

  7. #include <string.h>
    

  8. #include <stdio.h>
    

  9. #include <stdlib.h>
    


  10. 

  11. /*
    

  12. *********************************************************************************************************
    

  13. *                                            LOCAL TABLES
    

  14. *********************************************************************************************************
    

  15. */
    

  16. static err_t http_server_accept(void *arg, struct tcp_pcb *pcb, err_t err);
    

  17. static err_t http_server_recv(void *arg, struct tcp_pcb *pcb, struct pbuf *tcp_recv_pbuf, err_t err);
    

  18. static err_t http_server_poll(void *arg, struct tcp_pcb *pcb);
    

  19. static err_t http_init_file(struct http_state *hs, struct fs_file *file, int is_09, const char *uri);
    

  20. static err_t http_find_file(struct http_state *hs, const char *uri, int is_09);
    

  21. static err_t http_parse_request(struct pbuf **inp, struct http_state *hs, struct tcp_pcb *pcb);
    

  22. static u8_t http_send_data(struct tcp_pcb *pcb, struct http_state *hs);
    

  23. static err_t http_sent(void *arg, struct tcp_pcb *pcb, u16_t len);
    

  24. static void close_conn(struct tcp_pcb *pcb, struct http_state *hs);
    


  25. 

  26. /*
    

  27. *********************************************************************************************************
    

  28. *                                      LOCAL FUNCTION PROTOTYPES
    

  29. *********************************************************************************************************
    

  30. */
    


  31. 

  32. /***
    

  33.  * 函数名称 : Http_Server_Init();
    

  34.  *
    

  35.  * 函数描述 : web服务器初始化;
    

  36.  *
    

  37.  * 传递值    : 无;
    

  38.  *
    

  39.  * 返回值   : 无;
    

  40.  *
    

  41.  **/
    

  42. void Http_Server_Init(void)
    

  43. {
    

  44.     struct tcp_pcb *http_server_pcb;
    


  45. 

  46.     /* 为web服务器分配一个tcp_pcb结构体 */
    

  47.     http_server_pcb = tcp_new();
    


  48. 

  49.     /* 绑定本地端号和IP地址 */
    

  50.     tcp_bind(http_server_pcb, IP_ADDR_ANY, 80);
    


  51. 

  52.     /* 监听之前创建的结构体http_server_pcb */
    

  53.     http_server_pcb = tcp_listen(http_server_pcb);
    


  54. 

  55.     /* 初始化结构体接收回调函数 */
    

  56.     tcp_accept(http_server_pcb, http_server_accept);
    

  57. }
    


  58. 

  59. /***
    

  60.  * 函数名称 : http_server_accept();
    

  61.  *
    

  62.  * 函数描述 : lwip数据接收回调函数，包含对tcp连接的确认，接收回调函数的配置;
    

  63.  *
    

  64.  * 传递值    : *arg, *pcb, err ;
    

  65.  *
    

  66.  * 返回值   : ERR_OK 无错误;
    

  67.  *
    

  68.  **/
    

  69. static err_t http_server_accept(void *arg, struct tcp_pcb *pcb, err_t err)
    

  70. {
    

  71.     struct http_state *hs;
    


  72. 

  73.     /* 分配内存空间 */
    

  74.     hs = (struct http_state *)mem_malloc(sizeof(struct http_state));
    


  75. 

  76.     if (hs != NULL)
    

  77.     {
    

  78.         memset(hs, 0, sizeof(struct http_state));
    

  79.     }
    


  80. 

  81.     /* 确认监听和连接 */
    

  82.     tcp_arg(pcb, hs);
    


  83. 

  84.     /* 配置接收回调函数 */
    

  85.     tcp_recv(pcb, http_server_recv);
    


  86. 

  87.     /* 配置轮询回调函数 */
    

  88.     tcp_poll(pcb, http_server_poll, 4);
    


  89. 

  90.     /* 配置发送回调函数 */
    

  91.     tcp_sent(pcb, http_sent);
    


  92. 

  93.     return ERR_OK;
    

  94. }
    


  95. 

  96. /***
    

  97.  * 函数名称 : http_server_recv();
    

  98.  *
    

  99.  * 函数描述 : 接受到数据后，根据接收到数据的内容，返回网页;
    

  100.  *
    

  101.  * 传递值    : *arg, *pcb, *http_recv_pbuf, err;
    

  102.  *
    

  103.  * 返回值   : ERR_OK无错误;
    

  104.  *
    

  105.  **/
    

  106. static err_t http_server_recv(void *arg, struct tcp_pcb *pcb, struct pbuf *http_recv_pbuf, err_t err)
    

  107. {
    

  108.     err_t parsed = ERR_ABRT;
    

  109.     struct http_state *hs = (struct http_state *)arg;
    


  110. 

  111.     /* 告诉tcp已经接收到数据 */
    

  112.     tcp_recved(pcb, http_recv_pbuf->tot_len);
    


  113. 

  114.     if (hs->handle == NULL)
    

  115.     {
    

  116.         /* 解析接收到的浏览器请求数据 */
    

  117.         parsed = http_parse_request(&http_recv_pbuf, hs, pcb);
    

  118.     }
    


  119. 

  120.     /* 清空请求字符串 */
    

  121.     if (parsed != ERR_INPROGRESS) 
    

  122.     {       
    

  123.         if (hs->req != NULL) 
    

  124.         {
    

  125.             pbuf_free(hs->req);
    

  126.             hs->req = NULL;
    

  127.         }
    

  128.     }
    


  129. 

  130.     if (parsed == ERR_OK)
    

  131.     {
    

  132.         /* 发送网页数据 */
    

  133.         http_send_data(pcb, hs);
    

  134.     }
    

  135.     else if (parsed == ERR_ARG)
    

  136.     {
    

  137.         /* 关闭连接 */
    

  138.         close_conn(pcb, hs);
    

  139.     }
    


  140. 

  141.     return ERR_OK;
    

  142. }
    


  143. 

  144. /***
    

  145.  * 函数名称 : http_server_poll();
    

  146.  *
    

  147.  * 函数描述 : 轮询函数;
    

  148.  *
    

  149.  * 传递值    : *arg, *pcb;
    

  150.  *
    

  151.  * 返回值   : ERR_OK无错误;
    

  152.  *
    

  153.  **/
    

  154. static err_t http_server_poll(void *arg, struct tcp_pcb *pcb)
    

  155. {
    

  156.     struct http_state *hs = arg;
    


  157. 

  158.     if (hs == NULL)
    

  159.     {
    

  160.         close_conn(pcb, hs);
    

  161.         return ERR_OK;
    

  162.     }
    

  163.     else
    

  164.     {
    

  165.         hs->retries++;
    

  166.         if (hs->retries == 4)
    

  167.         {
    

  168.             close_conn(pcb, hs);
    

  169.             return ERR_OK;
    

  170.         }
    


  171. 

  172.         /* 如果连接存在打开的文件，则将会发送剩下的数据；
    

  173.          * 如果一直没有收到GET请求，那么连接将会立刻关闭 */
    

  174.         if (hs && (hs->handle))
    

  175.         {
    

  176.             if (http_send_data(pcb, hs))
    

  177.             {
    

  178.                 tcp_output(pcb);
    

  179.             }
    

  180.         }
    

  181.     }
    


  182. 

  183.     return ERR_OK;
    

  184. }
    


  185. 

  186. /***
    

  187.  * 函数名称 : http_parse_request();
    

  188.  *
    

  189.  * 函数描述 : 对接收到的数据进行解析，根据不同的浏览器请求，返回对应的网页数据;
    

  190.  *
    

  191.  * 传递值    : **inp, *hs, *pcb;
    

  192.  *
    

  193.  * 返回值   : ERR_OK无错误;
    

  194.  *
    

  195.  **/
    

  196. static err_t http_parse_request(struct pbuf **inp, struct http_state *hs, struct tcp_pcb *pcb)
    

  197. {
    

  198.     char *data;
    

  199.     char *crlf;
    

  200.     u16_t data_len;
    

  201.     struct pbuf *p = *inp;
    


  202. 

  203.     char *sp1, *sp2;
    

  204.     u16_t uri_len;
    

  205.     char *uri;
    


  206. 

  207.     /* 排列字符串 */
    

  208.     if (hs->req == NULL)
    

  209.     {
    

  210.         hs->req = p;
    

  211.     }
    

  212.     else
    

  213.     {
    

  214.         /* 将多次的请求字符串进行连接排序 */
    

  215.         pbuf_cat(hs->req, p);
    

  216.     }
    


  217. 

  218.     /* 拷贝输入数据 */ 
    

  219.     if (hs->req->next != NULL)
    

  220.     {
    

  221.         data_len = hs->req->tot_len;
    

  222.         pbuf_copy_partial(hs->req, data, data_len, 0);
    

  223.     }
    

  224.     else
    

  225.     {
    

  226.         data = (char *)p->payload;
    

  227.         data_len = p->len;
    

  228.     }
    


  229. 

  230.     /* 提取接收到的浏览器字符串，浏览器请求示例："GET / HTTP/1.1" */
    

  231.     if (data_len > 7) 
    

  232.     {
    

  233.         crlf = strstr(data, "\r\n");
    

  234.         if (crlf != NULL) 
    

  235.         {
    

  236.             /* 比较前4个字符是否为 "GET " */
    

  237.             if (strncmp(data, "GET ", 4) == 0) 
    

  238.             {
    

  239.                 /* sp1指向字符串 "/ HTTP/1.1" */
    

  240.                 sp1 = (data + 4);
    

  241.             }
    

  242.             /* 在sp1字符串中寻找字符" "，sp2指向字符串 " HTTP/1.1" */
    

  243.             sp2 = strstr(sp1, " ");
    

  244.             /* uri_len获取sp1字符串首地址到sp2字符串首地址的长度 */
    

  245.             uri_len = sp2 - (sp1);
    


  246. 

  247.             if ((sp2 != 0) && (sp2 >= (sp1))) 
    

  248.             {
    

  249.                 /* 将解析的字符串赋给uri，并在最后加上结束符\0，
    

  250.                    uri指向字符串 "/\0" */
    

  251.                 uri = sp1;
    

  252.                 *(sp1 - 1) = 0;
    

  253.                 uri[uri_len] = 0;
    


  254. 

  255.                 /* 根据字符串寻找对应网页数据 */
    

  256.                 return http_find_file(hs, uri, 0); 
    

  257.                 }
    

  258.             }
    

  259.     }
    


  260. 

  261.     return ERR_OK;
    

  262. }
    


  263. 

  264. /***
    

  265.  * 函数名称 : http_find_file();
    

  266.  *
    

  267.  * 函数描述 : 对提取的数据进行判断，读取对应的网页数据;
    

  268.  *
    

  269.  * 传递值    : *hs, *uri, is_09;
    

  270.  *
    

  271.  * 返回值   : ERR_OK无错误;
    

  272.  *
    

  273.  **/
    

  274. static err_t http_find_file(struct http_state *hs, const char *uri, int is_09)
    

  275. {
    

  276.     struct fs_file *file = NULL;
    


  277. 

  278.     /* 如果字符串为 "/\0",则打开index网页 */
    

  279.     if((uri[0] == '/') && (uri[1] == 0)) 
    

  280.     {
    

  281.         file = fs_open("/index.html");
    

  282.         uri = "/index.html";
    

  283.     } 
    

  284.     else 
    

  285.     {
    

  286.         /* 如果为其他请求，则打开相应网页 */
    

  287.         file = fs_open(uri);
    

  288.     }
    


  289. 

  290.     /* 将网页文件数据赋值给http_state结构体，之后发送出去 */
    

  291.     return http_init_file(hs, file, is_09, uri);
    

  292. }
    


  293. 

  294. /***
    

  295.  * 函数名称 : http_init_file();
    

  296.  *
    

  297.  * 函数描述 : 将要发送的数据保存到http_state结构体当中;
    

  298.  *
    

  299.  * 传递值    : *hs, *file, is_09, *uri;
    

  300.  *
    

  301.  * 返回值   : ERR_OK无错误;
    

  302.  *
    

  303.  **/
    

  304. static err_t http_init_file(struct http_state *hs, struct fs_file *file, int is_09, const char *uri)
    

  305. {
    

  306.     if (file != NULL) 
    

  307.     {
    

  308.         hs->handle = file;
    

  309.         /* 将网页数据赋值给http_state */
    

  310.         hs->file = (char*)file->data;
    

  311.         /* 将网页长度赋值给http_state */
    

  312.         hs->left = file->len;
    

  313.         hs->retries = 0;
    

  314.     } 
    

  315.     else 
    

  316.     {
    

  317.         hs->handle = NULL;
    

  318.         hs->file = NULL;
    

  319.         hs->left = 0;
    

  320.         hs->retries = 0;
    

  321.     }
    


  322. 

  323.     return ERR_OK;
    

  324. }
    


  325. 

  326. /***
    

  327.  * 函数名称 : http_send_data();
    

  328.  *
    

  329.  * 函数描述 : 数据发送函数;
    

  330.  *
    

  331.  * 传递值    : *pcb, *hs;
    

  332.  *
    

  333.  * 返回值   : ERR_OK无错误;
    

  334.  *
    

  335.  **/
    

  336. static u8_t http_send_data(struct tcp_pcb *pcb, struct http_state *hs)
    

  337. {
    

  338.     err_t err = ERR_OK;
    

  339.     u16_t len;
    

  340.     u8_t data_to_send = 0;
    


  341. 

  342.     /* 配置发送数据长度，如果发送数据过长则分批发送 */
    

  343.     if (tcp_sndbuf(pcb) < hs->left)
    

  344.     {
    

  345.         len = tcp_sndbuf(pcb);
    

  346.     }
    

  347.     else
    

  348.     {
    

  349.         len = (u16_t)hs->left;
    

  350.     }       
    


  351. 

  352.     /* 发送网页数据 */
    

  353.     err = tcp_write(pcb, hs->file, len, 1);
    


  354. 

  355.     if (err == ERR_OK)
    

  356.     {
    

  357.         data_to_send = 1;
    

  358.         hs->file += len;
    

  359.         hs->left -= len;
    

  360.     }
    


  361. 

  362.     if ((hs->left == 0) && (fs_bytes_left(hs->handle) <= 0))
    

  363.     {
    

  364.         /* 关闭连接 */
    

  365.         close_conn(pcb, hs);
    

  366.         return 0;
    

  367.     }
    


  368. 

  369.     return data_to_send;
    

  370. }
    


  371. 


  372. 

  373. /***
    

  374.  * 函数名称 : http_sent();
    

  375.  *
    

  376.  * 函数描述 : 数据已经被发送，并且被远程主机确定;
    

  377.  *
    

  378.  * 传递值    : *arg, *pcb, len;
    

  379.  *
    

  380.  * 返回值   : ERR_OK无错误;
    

  381.  *
    

  382.  **/
    

  383. static err_t http_sent(void *arg, struct tcp_pcb *pcb, u16_t len)
    

  384. {
    

  385.     struct http_state *hs = (struct http_state *)arg;
    


  386. 

  387.     if (hs == NULL)
    

  388.     {
    

  389.         return ERR_OK;
    

  390.     }
    


  391. 

  392.     hs->retries = 0;
    


  393. 

  394.     http_send_data(pcb, hs);
    


  395. 

  396.     return ERR_OK;
    

  397. }
    


  398. 

  399. /***
    

  400.  * 函数名称 : close_conn();
    

  401.  *  * 函数描述 : 关闭tcp连接;
    

  402.  *  * 传递值     : *pcb, *hs;
    

  403.  *  * 返回值   : 无;
    

  404.  *  **/
    

  405. static void close_conn(struct tcp_pcb *pcb, struct http_state *hs)
    

  406. {
    

  407.     tcp_arg(pcb, NULL);
    

  408.     tcp_recv(pcb, NULL);
    

  409.     tcp_err(pcb, NULL);
    

  410.     tcp_poll(pcb, NULL, 0);
    

  411.     tcp_sent(pcb, NULL);
    


  412. 

  413.     if (hs != NULL) 
    

  414.     {
    

  415.         if(hs->handle) 
    

  416.         {
    

  417.             fs_close(hs->handle);
    

  418.             hs->handle = NULL;
    

  419.         }
    

  420.             mem_free(hs);
    

  421.     }
    


  422. 

  423.     tcp_close(pcb);
    

  424. }



回复

收藏 举报

 楼主| 小明的同学 发表于 2018-5-13 19:38 | 显示全部楼层
http_server.h
复制
  1. #ifndef HTTP_SERVER_H
    

  2. #define HTTP_SERVER_H
    


  3. 

  4. /*
    

  5. *********************************************************************************************************
    

  6. *                                              INCLUDE FILES
    

  7. *********************************************************************************************************
    

  8. */
    


  9. 


  10. 

  11. /*
    

  12. *********************************************************************************************************
    

  13. *                                               CONSTANTS
    

  14. *********************************************************************************************************
    

  15. */
    


  16. 


  17. 

  18. /*
    

  19. *********************************************************************************************************
    

  20. *                                             PERIPH DEFINES
    

  21. *********************************************************************************************************
    

  22. */
    


  23. 


  24. 

  25. /*
    

  26. *********************************************************************************************************
    

  27. *                                               DATA TYPES
    

  28. *********************************************************************************************************
    

  29. */
    


  30. 


  31. 

  32. /*
    

  33. *********************************************************************************************************
    

  34. *                                            GLOBAL VARIABLES
    

  35. *********************************************************************************************************
    

  36. */
    


  37. 

  38. struct http_state {
    

  39.   struct fs_file *handle;
    

  40.   char *file;       /* Pointer to first unsent byte in buf. */
    


  41. 

  42. #if 1
    

  43.   struct pbuf *req;
    

  44. #endif /* LWIP_HTTPD_SUPPORT_REQUESTLIST */
    


  45. 

  46. #if 1
    

  47.   char *buf;        /* File read buffer. */
    

  48.   int buf_len;      /* Size of file read buffer, buf. */
    

  49. #endif /* LWIP_HTTPD_SSI || LWIP_HTTPD_DYNAMIC_HEADERS */
    

  50.   u32_t left;       /* Number of unsent bytes in buf. */
    

  51.   u8_t retries;
    

  52. #if 0
    

  53.   const char *parsed;     /* Pointer to the first unparsed byte in buf. */
    

  54. #if 1
    

  55.   const char *tag_started;/* Poitner to the first opening '<' of the tag. */
    

  56. #endif /* !LWIP_HTTPD_SSI_INCLUDE_TAG */
    

  57.   const char *tag_end;    /* Pointer to char after the closing '>' of the tag. */
    

  58.   u32_t parse_left; /* Number of unparsed bytes in buf. */
    

  59.   u16_t tag_index;   /* Counter used by tag parsing state machine */
    

  60.   u16_t tag_insert_len; /* Length of insert in string tag_insert */
    

  61. #if 0
    

  62.   u16_t tag_part; /* Counter passed to and changed by tag insertion function to insert multiple times */
    

  63. #endif /* LWIP_HTTPD_SSI_MULTIPART */
    

  64.   u8_t tag_check;   /* true if we are processing a .shtml file else false */
    

  65.   u8_t tag_name_len; /* Length of the tag name in string tag_name */
    

  66.   char tag_name[LWIP_HTTPD_MAX_TAG_NAME_LEN + 1]; /* Last tag name extracted */
    

  67.   char tag_insert[LWIP_HTTPD_MAX_TAG_INSERT_LEN + 1]; /* Insert string for tag_name */
    

  68.   enum tag_check_state tag_state; /* State of the tag processor */
    

  69. #endif /* LWIP_HTTPD_SSI */
    

  70. #if 0
    

  71.   char *params[LWIP_HTTPD_MAX_CGI_PARAMETERS]; /* Params extracted from the request URI */
    

  72.   char *param_vals[LWIP_HTTPD_MAX_CGI_PARAMETERS]; /* Values for each extracted param */
    

  73. #endif /* LWIP_HTTPD_CGI */
    

  74. #if 0
    

  75.   const char *hdrs[NUM_FILE_HDR_STRINGS]; /* HTTP headers to be sent. */
    

  76.   u16_t hdr_pos;     /* The position of the first unsent header byte in the
    

  77.                         current string */
    

  78.   u16_t hdr_index;   /* The index of the hdr string currently being sent. */
    

  79. #endif /* LWIP_HTTPD_DYNAMIC_HEADERS */
    

  80. #if 0
    

  81.   u32_t time_started;
    

  82. #endif /* LWIP_HTTPD_TIMING */
    

  83. #if 0
    

  84.   u32_t post_content_len_left;
    

  85. #if 0
    

  86.   u32_t unrecved_bytes;
    

  87.   struct tcp_pcb *pcb;
    

  88.   u8_t no_auto_wnd;
    

  89. #endif /* LWIP_HTTPD_POST_MANUAL_WND */
    

  90. #endif /* LWIP_HTTPD_SUPPORT_POST*/
    

  91. };
    


  92. 

  93. /*
    

  94. *********************************************************************************************************
    

  95. *                                                 MACRO'S
    

  96. *********************************************************************************************************
    

  97. */
    


  98. 


  99. 


  100. 

  101. /*
    

  102. *********************************************************************************************************
    

  103. *                                           FUNCTION PROTOTYPES
    

  104. *********************************************************************************************************
    

  105. */
    


  106. 

  107. void Http_Server_Init(void);
    


  108. 

  109. /*
    

  110. ********************************************************************************************************
    

  111. *                                             MODULE END
    

  112. *********************************************************************************************************
    

  113. */
    


  114. 

  115. #endif /* HTTP_SERVER_H */
回复

收藏 举报

 楼主| 小明的同学 发表于 2018-5-13 19:39 | 显示全部楼层
官方部分函数解析
读取网页数据文件 fs.c （路径：Project->Standalone->web_server->http）：
复制
  1. struct fs_file *fs_open(const char *name)
    

  2. {
    

  3.     struct fs_file *file;
    

  4.     const struct fsdata_file *f;
    


  5. 

  6.     /* 分配空间 */
    

  7.     file = fs_malloc();
    

  8.     if(file == NULL) 
    

  9.     {
    

  10.         return NULL;
    

  11.     }
    


  12. 

  13.     for(f = FS_ROOT; f != NULL; f = f->next) 
    

  14.     {
    

  15.         /* 循环比较，如果输入的请求与网页的头数据一致，则返回该网页数据 */
    

  16.         if (!strcmp(name, (char *)f->name)) 
    

  17.         {
    

  18.             file->data = (const char *)f->data;
    

  19.             file->len = f->len;
    

  20.             file->index = f->len;
    

  21.             file->pextension = NULL;
    

  22.             file->http_header_included = f->http_header_included;
    


  23. 

  24.             return file;
    

  25.         }
    

  26.     }
    

  27.     fs_free(file);
    

  28.     return NULL;
    

  29. }


这里关注 f 变量的结构体 fsdata_file，定义在 fsdata.h：
复制
  1. struct fsdata_file 
    

  2. {
    

  3.     const struct fsdata_file *next;
    

  4.     const unsigned char *name;
    

  5.     const unsigned char *data;
    

  6.     int len;
    

  7.     u8_t http_header_included;
    

  8. };

结构体中有三个重要的变量*next、*name、*data
而在文件fsdata.c中，拉到最后，发现有几个 fsdata_file 的结构体变量，取其中一个来解析一下：
复制
  1. const struct fsdata_file file__index_html[] = 
    

  2. { 
    

  3.     {
    

  4.         /* 变量*next，指向下一个要循环比较的数据 */
    

  5.         file__404_html,
    

  6.         /* 变量*name，指向数据数组 data__index_html[] */
    

  7.         data__index_html,
    

  8.         /* 变量*data，指向数据数组 data__index_html[]12个之后的数据 */
    

  9.         data__index_html + 12,
    

  10.         /* 网页数据长度 */
    

  11.         sizeof(data__index_html) - 12,
    

  12.         1,
    

  13.     }
    

  14. };
回复

收藏 举报

 楼主| 小明的同学 发表于 2018-5-13 19:41 | 显示全部楼层
变量*name指向的数组前12个数据是字符串 “/index.html” 的ascii码，用于与输入的浏览器请求 “GET /index.html HTTP/1.1” 进行对比；
而*data指向数组的12个后的数据，便是网页源代码的16进制数据，这些数据将会由发送函数发送给浏览器，使浏览器显示网页；
web服务器测试
将工程编译后，烧进stm32，将网线与pc机连接：

打开浏览器（谷歌浏览器测试）
输入服务器ip（这里搭建的服务器ip：192.168.0.10），Enter；
浏览器会显示网页，点击网页上的按钮即可以切换不同的网页 004.png

总结：从上面的一系列过程可以get到搭建web服务器的核心思想，然而，现在并没有加入ssi和cgi，所以还无法用网页控制stm32，后面会加上ssi、cgi、post与get请求来完善整个web服务器；

ps：有部分细节的地方解析的不是很清楚，而且自己也没有想明白，需要再加把劲看一些其他的资料来填补空白，共勉~


回复

收藏 举报

幸福小强 发表于 2018-5-13 19:55 | 显示全部楼层
这个跟使用什么网络模块无关吧
回复

收藏 举报

734774645 发表于 2018-5-13 21:02 | 显示全部楼层
不清楚文中提到的CGI是什么，是个函数吗，还是个协议？
回复

收藏 举报

734774645 发表于 2018-5-13 21:02 | 显示全部楼层
CGI 是Web 服务器运行时外部程序的规范,按CGI 编写的程序可以扩展服务器功能。CGI 应用程序能与浏览器进行交互,还可通过数据库API 与数据库服务器等外部数据源进行通信,从数据库服务器中获取数据。格式化为HTML文档后，发送给浏览器，也可以将从浏览器获得的数据放到数据库中。几乎所有服务器都支持CGI,可用任何语言编写CGI,包括流行的C、C ++、VB 和Delphi 等。CGI 分为标准CGI 和间接CGI两种。标准CGI 使用命令行参数或环境变量表示服务器的详细请求，服务器与浏览器通信采用标准输入输出方式。间接CGI 又称缓冲CGI,在CGI 程序和CGI 接口之间插入一个缓冲程序，缓冲程序与CGI 接口间用标准输入输出进行通信
回复

收藏 举报

734774645 发表于 2018-5-13 21:02 | 显示全部楼层
百度了下，了解了，多谢分享。
回复

收藏 举报

无聊到看电视剧 发表于 2018-7-11 15:58 | 显示全部楼层
多谢楼主
回复

收藏 举报

kkzz 发表于 2018-7-11 22:50 | 显示全部楼层
web服务器
回复

收藏 举报

hudi008 发表于 2018-7-11 22:51 | 显示全部楼层
有网页版本的吗？
回复

收藏 举报

lzmm 发表于 2018-7-11 22:51 | 显示全部楼层
lwip支持哪些芯片呢？
回复

收藏 举报

minzisc 发表于 2018-7-11 22:51 | 显示全部楼层
以前见过他们点亮LED
回复

收藏 举报

selongli 发表于 2018-7-11 22:51 | 显示全部楼层
小明的同学 发表于 2018-5-13 19:34
搭建web服务器现在创建一个新的c文件，取名为 http_server.c ,接下来写几个函数来建立web服务器，抽重要的 ...

回复

收藏 举报

pixhw 发表于 2018-7-11 22:52 | 显示全部楼层
lwip占用多大的资源呢？
回复

收藏 举报

下一页 »
12下一页
返回列表 发新帖
高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 | 注册

本版积分规则

小明的同学

159

主题

1640

帖子

2

粉丝
快速回复 在线客服 返回列表 返回顶部