STM32 实现 TCP 服务器与多个设备通信

devtools/2024/10/18 18:29:34/

目录

一、引言

二、硬件准备

三、软件准备

四、LWIP 协议栈的配置与初始化

五、创建 TCP 服务器

1.创建 TCP 控制块

2.绑定端口 

3. 进入监听状态

4.设置接收回调函数 

六、处理多个客户端连接 

七、数据处理与通信管理 

八、错误处理与资源管理 

九、总结 

 


一、引言

        在嵌入式系统开发中,常常需要实现设备之间的网络通信。STM32 作为一款广泛应用的微控制器,结合网络通信功能可以实现与多个设备的交互。本文将介绍如何在 STM32 上实现 TCP 服务器端,以便与多个设备进行通讯。

二、硬件准备

  1. STM32 开发板:选择一款带有以太网接口的 STM32 开发板,如 STM32F429 系列等。
  2. 以太网模块(可选):如果开发板没有内置以太网接口,可以选择一个外接的以太网模块,如 W5500 等。
  3. 网络连接:将开发板连接到同一局域网内,确保其他设备可以通过网络访问到 STM32 开发板。

三、软件准备

  1. 开发环境:如 Keil MDK、IAR Embedded Workbench 等。
  2. LWIP(Lightweight IP)协议栈:LWIP 是一个轻量级的 TCP/IP 协议栈,适用于嵌入式系统。可以从 LWIP 官方网站下载并集成到开发环境中。
  3. STM32 库:使用 STM32 的官方库或者其他第三方库来进行硬件驱动和开发。

四、LWIP 协议栈的配置与初始化

  1. 将 LWIP 协议栈的源文件添加到 STM32 项目中,并设置正确的编译选项。
  2. 在项目的初始化代码中,调用 LWIP 的初始化函数lwip_init(),完成协议栈的初始化。
  3. 根据实际需求,配置 LWIP 的参数,如 IP 地址、子网掩码、默认网关等。可以通过修改lwipopts.h文件来实现。

五、创建 TCP 服务器

1.创建 TCP 控制块

使用 LWIP 的 API 函数tcp_new()创建一个新的 TCP 控制块。

  struct tcp_pcb *tcp_server_pcb;tcp_server_pcb = tcp_new();

2.绑定端口 

使用tcp_bind()函数将 TCP 控制块绑定到一个特定的端口号。通常选择一个未被其他应用程序占用的端口。

   err_t err = tcp_bind(tcp_server_pcb, IP_ADDR_ANY, SERVER_PORT);if (err!= ERR_OK) {// 处理绑定失败的情况}

这里的SERVER_PORT服务器监听的端口号。

3. 进入监听状态

使用tcp_listen()函数使 TCP 控制块进入监听状态,等待客户端的连接请求。

 tcp_server_pcb = tcp_listen(tcp_server_pcb);

4.设置接收回调函数 

使用tcp_accept()函数设置一个接收回调函数,当有客户端连接请求时,该回调函数将被调用。

tcp_accept(tcp_server_pcb, tcp_accept_callback);

tcp_accept_callback是自定义的回调函数,用于处理客户端的连接请求。

六、处理多个客户端连接 

1.在接收回调函数中,接受客户端的连接请求,并为每个连接创建一个新的 TCP 控制块来处理与该客户端的通信。

void tcp_accept_callback(void *arg, struct tcp_pcb *newpcb, err_t err){if (err == ERR_OK) {// 处理新的连接// 可以为每个连接分配一些资源,如缓冲区等tcp_recv(newpcb, tcp_receive_callback, NULL);}}

 

2.为每个连接设置接收回调函数,以便在有数据到达时进行处理。

void tcp_receive_callback(void *arg, struct tcp_pcb *tpcb, struct pbuf *p, err_t err){if (err == ERR_OK && p!= NULL) {// 处理接收到的数据// 可以根据需要将数据转发给其他连接或者进行其他处理tcp_write(tpcb, p->payload, p->len, TCP_WRITE_FLAG_COPY);// 释放接收到的数据包缓冲区pbuf_free(p);}}

3.使用数据结构管理多个连接 

可以使用链表、数组等数据结构来管理多个客户端连接。例如,可以创建一个链表,每个节点存储一个客户端连接的信息,包括 TCP 控制块、客户端地址等。

typedef struct _client_connection{struct tcp_pcb *pcb;ip_addr_t client_ip;u16_t client_port;struct _client_connection *next;} client_connection_t;client_connection_t *client_list = NULL;

在连接建立时,将新的连接添加到链表中;在连接关闭时,从链表中删除相应的节点。

void add_client_connection(struct tcp_pcb *pcb, const ip_addr_t *client_ip, u16_t client_port){client_connection_t *new_connection = (client_connection_t *)malloc(sizeof(client_connection_t));new_connection->pcb = pcb;new_connection->client_ip = *client_ip;new_connection->client_port = client_port;new_connection->next = client_list;client_list = new_connection;}void remove_client_connection(struct tcp_pcb *pcb){client_connection_t *prev = NULL;client_connection_t *current = client_list;while (current!= NULL) {if (current->pcb == pcb) {if (prev == NULL) {client_list = current->next;} else {prev->next = current->next;}free(current);break;}prev = current;current = current->next;}}

七、数据处理与通信管理 

1.在接收回调函数中,可以根据接收到的数据进行相应的处理。例如,可以解析数据、执行特定的操作或者将数据转发给其他连接。

void tcp_receive_callback(void *arg, struct tcp_pcb *tpcb, struct pbuf *p, err_t err){if (err == ERR_OK && p!= NULL) {// 处理接收到的数据char *data = (char *)p->payload;// 根据数据内容进行处理// 可以将数据转发给其他连接client_connection_t *current = client_list;while (current!= NULL) {if (current->pcb!= tpcb) {tcp_write(current->pcb, data, strlen(data), TCP_WRITE_FLAG_COPY);}current = current->next;}// 释放接收到的数据包缓冲区pbuf_free(p);}}

2.如果需要向特定的客户端发送数据,可以遍历链表找到相应的客户端连接,并使用tcp_write函数进行数据发送。

void send_data_to_client(const ip_addr_t *client_ip, u16_t client_port, char *data){client_connection_t *current = client_list;while (current!= NULL) {if (ip_addr_cmp(&current->client_ip, client_ip) && current->client_port == client_port) {tcp_write(current->pcb, data, strlen(data), TCP_WRITE_FLAG_COPY);break;}current = current->next;}}

八、错误处理与资源管理 

1.在整个通信过程中,需要进行适当的错误处理。例如,当连接失败、数据发送失败或接收超时等情况发生时,需要采取相应的措施,如重新连接、报告错误或释放资源等。

void tcp_error_callback(void *arg, err_t err){// 处理错误情况struct tcp_pcb *tpcb = (struct tcp_pcb *)arg;remove_client_connection(tpcb);}

2.当连接关闭时,需要及时释放相关的资源,如缓冲区、TCP 控制块等,以避免内存泄漏。

 void tcp_close_callback(void *arg, err_t err){// 处理连接关闭情况struct tcp_pcb *tpcb = (struct tcp_pcb *)arg;remove_client_connection(tpcb);}

九、总结 

通过以上步骤,我们可以在 STM32 上实现一个 TCP 服务器,与多个设备进行通信。在实际应用中,可以根据具体的需求进行进一步的优化和扩展,例如添加安全认证、数据加密、流量控制等功能。同时,还需要注意网络稳定性和可靠性,以确保通信的正常进行。

希望本文对大家在 STM32 上实现 TCP 服务器与多个设备通信有所帮助。如果有任何问题或建议,欢迎在评论区留言交流。

 

 

 

 


http://www.ppmy.cn/devtools/124105.html

相关文章

《C++编程新探索:实现高效视频拼接算法》

在当今数字化时代,视频内容的创作和处理变得越来越重要。视频拼接作为一种常见的视频处理技术,能够将多个视频片段组合成一个连续的视频,为视频创作者和用户带来了更多的可能性。本文将探讨如何在 C中实现高效的视频拼接算法,为开…

Redis 数据类型list(列表)

目录 1 基本特性 2 主要操作命令 2.1 LPUSH key value [value ...] 2.2 RPUSH key value [value ...] 2.3 LRANGE key start stop 2.4 LINDEX key index 2.5 LLEN key 2.6 LPOP key 2.7 RPOP key 2.8 LTRIM key start stop 2.9 BLPOP key [key ...] timeout 2.10 B…

Spring Boot洗衣店订单系统:简化您的业务流程

1系统概述 1.1 研究背景 如今互联网高速发展,网络遍布全球,通过互联网发布的消息能快而方便的传播到世界每个角落,并且互联网上能传播的信息也很广,比如文字、图片、声音、视频等。从而,这种种好处使得互联网成了信息传…

【NIO基础】NIO(非阻塞 I/O)和 IO(传统 I/O)的区别,以及 NIO 的三大组件详解

目录 1、NIO 2、NIO 和 IO 的区别 1. 阻塞 vs 非阻塞 2. 一个线程 vs 多个连接 3. 面向流 vs 面向缓冲 4. 多路复用 3、Channel & Buffer (1)Channel:双向通道 (2)Buffer:缓冲区 (3)ByteBuffer&#xff…

彩族相机内存卡恢复多种攻略:告别数据丢失

在数字时代,相机内存卡作为我们存储珍贵照片和视频的重要媒介,其数据安全性显得尤为重要。然而,意外删除、错误格式化、存储卡损坏等情况时有发生,导致数据丢失,给用户带来不小的困扰。本文将详细介绍彩族相机内存卡数…

新电脑 Windows 系统初始配置

文章目录 前言1 前置配置2 安装软件2.1 通讯工具2.2 后端开发工具2.3 硬件开发工具2.4 前端开发工具2.4 其它工具 3 Windows 11 优化4 写在最后 前言 分区(个人习惯):1TB SSD 分为 2 个分区,一个 256GB 分区为系统盘,剩…

重生之我在代码随想录刷算法第二十一天 | 93.复原IP地址、78.子集、 90.子集II

参考文献链接:代码随想录 本人代码是Java版本的,如有别的版本需要请上代码随想录网站查看。 93.复原IP地址 力扣题目链接 解题思路 这道题目感觉跟昨天的分割回文串很像。 首先明确思路,先是一个一个字符去添加到StringBuilder&#xf…

2024中国新媒体技术展 | 蓝海创意云vLive虚拟直播即将亮相!

​​ 2024中国新媒体大会由中央宣传部指导,中华全国新闻工作者协会、湖南省人民政府联合主办,旨在推动媒体深度融合发展,促进新闻事业高质量发展,为中国式现代化贡献力量。中国新媒体技术展(CMTE)是中国新…