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

目录

一、引言

二、硬件准备

三、软件准备

四、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.xdnf.cn/news/1560467.html

如若内容造成侵权/违法违规/事实不符,请联系一条长河网进行投诉反馈,一经查实,立即删除!

相关文章

【STM32单片机_(HAL库)】4-5-2【定时器TIM】【感应开关盖垃圾桶项目】HC-SR04超声波模块实验

1.硬件 STM32单片机最小系统HC-SR04超声波模块 2.软件 hcsr04驱动文件添加main.c程序 #include "sys.h" #include "delay.h" #include "led.h" #include "uart1.h" #include "hcsr04.h"int main(void) {HAL_Init(); …

华为云应用侧Android Studio开发

本文将介绍如何使用AndroidStudio开发APP完成与接入华为云IoTDA设备的对接,包括属性参数获以及取命令下发。 一、鉴权认证 应用侧需要通过IAM服务鉴权,获取token,华为账号创建 IAM 用户, 可以为创建的用户分配权限 认证鉴权_设…

CSS @规则(At-rules)系列详解___@charset规则使用方法

CSS 规则(At-rules)系列详解 ___charset规则使用方法 本篇目录: 零、时光宝盒 一、charset规则定义和用法 二、CSS charset语法 三、charset 使用方法例子 1、正确使用方法 2、无效的,错误的使用方法 零、时光宝盒 (https://blog.csd…

C++ | Leetcode C++题解之第472题连接词

题目&#xff1a; 题解&#xff1a; struct Trie {bool isEnd;vector<Trie *> children;Trie() {this->children vector<Trie *>(26, nullptr);this->isEnd false;} };class Solution { public:Trie * trie new Trie();vector<string> findAllConc…

C语言 | Leetcode C语言题解之第472题连接词

题目&#xff1a; 题解&#xff1a; typedef struct Trie {struct Trie * children[26];bool isEnd; }Trie;#define TRIE_INITIAL(node) do { \for (int i 0; i < 26; i) { \(node)->children[i] NULL; \} \(node)->isEnd false; \ }while(0);static void freeTri…

第二阶段:mysql(学完就隐藏版)

第一章&#xff1a;部署数据库系统&#xff08;注意关闭防火墙&#xff0c;selinux安装&#xff09; 安装mysql配置的相关文件&#xff1a;yum install https://dev.mysql.com/get/mysql80-community-release-el7-5.noarch.rpm&#xff08;centos9&#xff1a;yum install http…

iOS--理解MVC与MVVM

MVC MVC 是一种将应用程序分为三部分的架构模式&#xff1a;Model&#xff08;模型&#xff09;、View&#xff08;视图&#xff09;、Controller&#xff08;控制器&#xff09;。每部分负责不同的职责&#xff0c;使代码更加模块化、易于维护。 • Model&#xff1a;负责业…

jmeter入门:脚本录制

1.设置代理。 网络连接-》代理-》手动设置代理. ip&#xff1a; 127.0.0.1&#xff0c; port&#xff1a;8888 2. add thread group 3. add HTTP(s) test script recorder, target controller chooses Test plan-> thread Group 4. click start. then open the browser …

Java | Leetcode Java题解之第472题连接词

题目&#xff1a; 题解&#xff1a; class Solution {Trie trie new Trie();public List<String> findAllConcatenatedWordsInADict(String[] words) {List<String> ans new ArrayList<String>();Arrays.sort(words, (a, b) -> a.length() - b.length(…

PyQt 的Tree Widget中拖放和点击的异常行为

在 PyQt 的 QTreeWidget 中&#xff0c;如果你遇到 拖放 和 点击 的异常行为&#xff0c;可能是由于信号处理、事件拦截、拖放设置或树结构配置等问题导致的。以下是一些可能的常见问题和解决方案。 1、问题背景 一个 PyQt 应用程序中包含两个 Tree Widget&#xff0c;当用户从…

QUUID 使用详解

UUID 通常由 128 位&#xff08;16 字节&#xff09;组成&#xff0c;通常表示为 32 个十六进制数字&#xff0c;分为五个部分&#xff0c;格式如下&#xff1a; QUuid 是 Qt 框架中用于生成和处理 UUID&#xff08;通用唯一标识符&#xff09;的类。UUID 是一种标准的标识符格…

(27)QPSK信号在非相关平坦莱斯(Rician)衰落信道上的误码率性能MATLAB仿真

文章目录 前言一、Rician衰落信道模型的MATLAB代码二、在非相关的平坦Rician衰落信道上传输QPSK符号模型1.MATLAB仿真代码2.仿真结果 前言 本文首先给出莱斯衰落信道的建模函数&#xff0c;然后基于该函数给出在非相关的平坦Rician衰落信道上传输QPSK数字调制符号的MATLAB仿真…

6. 继承、重写、super、final

文章目录 一、重新定义需求二、继承1. 继续分析2. 概念3. 代码① 父类② 子类③ 测试结果 4. 饿狼传说之多层继承① 概念② 代码 5. 多继承 三、方法的重写1. 情境2. 代码① 吃什么② 怎么叫(Override重写) 3. 小结 四、super1. 啃老2. 啃老啃到底 五、final1. 用途及特征2. 举…

快速解决urllib3.exceptions.MaxRetryError: HTTPSConnectionPool

正题 使用pip命令查看urllib3版本 pip list发现版本为 1.26.9 urllib3 v1.26.9此时如下报错&#xff0c;无法正常使用&#xff08;使用了代理&#xff09; urllib3.exceptions.MaxRetryError: HTTPSConnectionPool(hostxxx.xxxxx.com, port443): Max retries exceeded wit…

智能的三大问题:何以、所以、可以

智能具有三大问题&#xff0c;即何以、所以、可以。“何以&#xff08;Why&#xff09;”涉及探讨智能的本质及其产生的原因。智能是什么&#xff1f;它的定义和特征是什么&#xff1f;为什么人类或机器需要智能&#xff1f;它如何帮助我们解决复杂问题、做出决策和适应环境&am…

(五)Proteus仿真STM32单片机串口数据流收发

&#xff08;五&#xff09;Protues仿真STM32单片机串口数据流收发 – ARMFUN 1&#xff0c;打开STM32CubeMX&#xff0c;找到USART1,配置模式Asynchronous&#xff0c;此时PA9、PA10自动变成串口模式 串口默认参数:115200bps 8bit None 1stop 2&#xff0c;NVIC Settings使能…

【Ubuntu】在Ubuntu上安装IDEA

【Ubuntu】在Ubuntu上安装IDEA 零、前言 最近换了Ubuntu系统&#xff0c;但是还得是要写代码&#xff0c;这样就不可避免地用到IDEA&#xff0c;接下来介绍一下如何在Ubuntu上安装IDEA。 壹、下载 这一步应该很容易的&#xff0c;直接打开IDEA的下载页面&#xff0c;点击下…

科研绘图系列:R语言绘制SCI文章图2

文章目录 介绍加载R包导入数据图a图b图d系统信息介绍 文章提供了绘制图a,图b和图d的数据和代码 加载R包 library(ggplot2) library(dplyr) library(readxl) library(ggpmisc)导入数据 数据可从以下链接下载(画图所需要的所有数据): 百度网盘下载链接: https://pan.baid…

2024年软件设计师中级(软考中级)详细笔记【3】数据结构(下)(分值5分)

上午题第3章数据结构下部目录 前言第3章 数据结构【下】(5分)3.5 查找3.5.1 查找的基本概念【考点】3.5.2 静态查找表的查找方法3.5.3 动态查找表3.5.4 哈希表3.5.4.1 哈希表的定义3.5.4.2 哈希函数的构造方法3.5.4.3 处理冲突的方法 3.6 排序3.6.1 排序的基本概念3.6.2 简单排…

Java 获取热搜并生成图片

效果图如下&#xff1a; 第一步获取热搜 public List<String> getHotNews4(Integer size) {if (size < 0 || StringUtils.isEmpty(size)) {return null;}try {//set 转listreturn new ArrayList<>(getHotNews(size));} catch (Exception e) {logger.error(&qu…