4.物联网LWIP之C/S编程，stm32作为服务器，stm32作为客户端，代码的优化

LWIP配置

服务器端实现

客户端实现

错误分析

一。LWIP配置（FREERTOS配置，ETH配置，LWIP配置）

1.FREERTOS配置

 为什么要修改定时源为Tim1？不用systick？

原因：HAL库与FREERTOS都需要使用systick，两者冲突，所以修改时钟源，让FREERTOS使用Tim1。

 2.ETH配置

 3.LWIP配置

不使用DHCP

 4.步骤：
（1）freertos.c中会自己出现一个Lwip初始化

运行后结果：命令行中输入ping 192.168.1.10有回复

 二。服务器端

实验一：《stm32作为服务器端，COMMBOX串口作为客户端》

1.功能分析

小写转大写

 2.步骤：

（1）建立socket_tcp_server.h

#ifndef SOCKET_TCP_SERVER_H
#define SOCKET_TCP_SERVER_H#define SERVER_IP				"192.168.1.11"
#define SERVER_PORT			6666
#define BUFF_SIZE				1024void vTcpServerTask(void);#endif

 （2）建立socket_tcp_server.c，并添加到文件中

#include "socket_tcp_server.h"
#include "lwip/sockets.h"
#include "ctype.h"char ReadBuff[BUFF_SIZE];/*** @brief  TCP 服务器任务* @param  None* @retval None*/
void vTcpServerTask(void){int 	 sfd, cfd, n, i;struct sockaddr_in server_addr, client_addr;socklen_t	client_addr_len;//创建socketsfd = socket(AF_INET, SOCK_STREAM, 0);server_addr.sin_family 			= AF_INET;server_addr.sin_port   			= htons(SERVER_PORT);server_addr.sin_addr.s_addr = htonl(INADDR_ANY);//绑定socketbind(sfd, (struct sockaddr *)&server_addr, sizeof(server_addr));//监听socketlisten(sfd, 5);//等待客户端连接client_addr_len = sizeof(client_addr);cfd = accept(sfd, (struct sockaddr *)&client_addr, &client_addr_len);printf("client is connect cfd = %d\r\n",cfd);while(1){//等待客户端发送数据n = read(cfd, ReadBuff, BUFF_SIZE);//进行大小写转换for(i = 0; i < n; i++){ReadBuff[i] = toupper(ReadBuff[i]);		}//写回客户端write(cfd, ReadBuff, n);}
}

（3）freertos.c中网络任务中，添加服务器运行函数。

 不要忘记添加头文件

	vTcpServerTask();

3.现象演示

（1）使用COMMBOX串口调试工程，添加socket网络客户端 ，目标ip为stm32的ip.端口在.h中

（2）stm32客户端发送的字母变大写

 三。客户端创建

实验二：《stm32作为客户端，COMMBOX串口作为服务器端》

1.创建socket_tcp_client.c与socket_tcp_client.h

（1）socket_tcp_client.c

#include "socket_tcp_server.h"
#include "socket_tcp_client.h"
#include "lwip/sockets.h"
#include "ctype.h"static char ReadBuff[BUFF_SIZE];void vTcpClientTask(void)
{int 	 cfd, n, i;struct sockaddr_in server_addr;//创建socketcfd = socket(AF_INET, SOCK_STREAM, 0);server_addr.sin_family 			= AF_INET;server_addr.sin_port   			= htons(SERVER_PORT);server_addr.sin_addr.s_addr = inet_addr(SERVER_IP);//连接到服务器connect(cfd, (struct sockaddr*)&server_addr, sizeof(server_addr));printf("server is connect ok\r\n");while(1){//等待服务器发送数据n = read(cfd, ReadBuff, BUFF_SIZE);//进行大小写转换for(i = 0; i < n; i++){ReadBuff[i] = toupper(ReadBuff[i]);		}//写回服务器write(cfd, ReadBuff, n);}
}

（2）socket_tcp_client.h

#ifndef _SOCKET_TCP_CLIENT_H
#define _SOCKET_TCP_CLIENT_Hvoid vTcpClientTask(void);#endif

可能遇到的问题：

        由于打开了防火墙，所以无法连接

 

 补充：上述代码的问题

        1.代码封装性不好

        2.代码对边界错误提示太少

四。代码的优化

1.函数在封装，文件为socket_warp.c与socket_warp.h

（1）socket_warp.h

#ifndef _SOCKET_WRAP_H
#define _SOCKET_WRAP_H#include "lwip/sockets.h"int Socket(int domain, int type, int protocol);int Bind(int sockfd, const struct sockaddr *addr, socklen_t addrlen);int Listen(int sockfd, int backlog);int Accept(int sockfd, struct sockaddr *addr, socklen_t *addrlen);
int Connect(int sockfd, const struct sockaddr *addr, socklen_t addrlen);int Write(int fd,const void *buf,size_t nbytes);
int Read(int fd,void *buf,size_t nbyte);int Sendto(int sockfd, const void *msg, int len, unsigned int flags, const struct sockaddr *to, int tolen);
int Recvfrom(int sockfd, void *buf, int len, unsigned int flags, struct sockaddr *from, socklen_t *fromlen);#endif

(2)socket_warp.c

#include "socket_wrap.h"
#include "FreeRTOS.h"
#include "task.h"int Socket(int domain, int type, int protocol){int fd;fd=socket(domain,type,protocol);if(fd<0){printf("create socket error\n");//没有创建完成，那么这个任务也没有必要运行，直接切换上下文//返回一个小于零的数vTaskDelete(NULL);}return fd;
}int Bind(int sockfd, const struct sockaddr *addr, socklen_t addrlen){int ret;ret=bind(sockfd,addr,addrlen);if(ret < 0){printf("bind socket error\r\n");//当调用删除任务，就会切换上下文，CPU执行其他任务vTaskDelete(NULL);		}return ret;
}int Listen(int sockfd, int backlog){int ret;ret=listen(sockfd,backlog);if(ret<0){printf("listen socket error\n");vTaskDelete(NULL);}return ret;
}int Accept(int sockfd, struct sockaddr *addr, socklen_t *addrlen){int fd;
again:	fd=accept(sockfd,addr,addrlen);if(fd<0){printf("accept socket error\n");goto again;}return fd;
}
int Connect(int sockfd, const struct sockaddr *addr, socklen_t addrlen){int ret;ret=connect(sockfd,addr,addrlen);if(ret<0){printf("connect socket error\n");//先关闭当前的socket，其实内部是删除这个socket的内存块，不删除会导致下次无法生成close(sockfd);}return ret;
}int Write(int fd,const void *buf,size_t nbytes){int ret;ret=write(fd,buf,nbytes);//没有书写完成就关闭socketif(ret<0){printf("write socket error\n");close(fd);}return ret;
}
int Read(int fd,void *buf,size_t nbyte){int ret;ret=read(fd,buf,nbyte);if(ret==0){printf("read socket is close\n");close(fd);}else if(ret<0){printf("read socket error\n");close(fd);}
}int Sendto(int sockfd, const void *msg, int len, unsigned int flags, const struct sockaddr *to, int tolen){int ret;
again:	ret=sendto(sockfd,msg,len,flags,to,tolen);if(ret<0){printf("sendto socket error\n");goto again;}return ret;
}int Recvfrom(int sockfd, void *buf, int len, unsigned int flags, struct sockaddr *from, socklen_t *fromlen){int ret;
again:	ret=recvfrom(sockfd,buf,len,flags,from,fromlen);if(ret<0){printf("recvfrom socket error\n");goto again;				}return ret;
}

上述为封装函数，包括tcp_server,tcp_client已经后续的udp_server

2.socket_tcp_server.c与socket_tcp_client.c

1.socket_tcp_server.c

#include "socket_udp_server.h"
#include "socket_tcp_server.h"
#include "socket_wrap.h"
#include "ctype.h"static char ReadBuff[BUFF_SIZE];void vUdpServerTask(){int 	 sfd, n, i;struct sockaddr_in server_addr, client_addr;socklen_t	client_addr_len;int optval=1;//创建socketsfd=Socket(AF_INET, SOCK_DGRAM, 0);setsockopt(sfd,SOL_SOCKET ,SO_BROADCAST,&optval,sizeof(optval));//绑定socketserver_addr.sin_family 			= AF_INET;server_addr.sin_port   			= htons(SERVER_PORT);server_addr.sin_addr.s_addr = htonl(INADDR_ANY);Bind(sfd, (struct sockaddr *)&server_addr, sizeof(server_addr));//处理client_addr_len=sizeof(client_addr);while(1){//等待客户端发送数据n = Recvfrom(sfd, ReadBuff, BUFF_SIZE, 0, (struct sockaddr *)&client_addr, &client_addr_len);ReadBuff[n] = '\0';printf("recv data:%s\r\n",ReadBuff);//进行大小写转换for(i = 0; i < n; i++){	ReadBuff[i] = toupper(ReadBuff[i]);		}//写回客户端Sendto(sfd, ReadBuff, n, 0, (struct sockaddr *)&client_addr, client_addr_len);}}

2.socket_tcp_client.c

#include "socket_tcp_server.h"
#include "socket_tcp_client.h"
#include "socket_wrap.h"
#include "ctype.h"
#include "FreeRTOS.h"
#include "task.h"#include "string.h"static char ReadBuff[BUFF_SIZE];void vTcpClientTask(void)
{int 	 cfd, n, i, ret;struct sockaddr_in server_addr;//	int so_reuseaddr_val = 1;
again://创建socketcfd = Socket(AF_UNSPEC, SOCK_STREAM, 0);//使能socket层 心跳检测
//	setsockopt(cfd, SOL_SOCKET, SO_REUSEADDR, &so_reuseaddr_val, sizeof(int));server_addr.sin_family 			= AF_INET;server_addr.sin_port   			= htons(SERVER_PORT);server_addr.sin_addr.s_addr = inet_addr(SERVER_IP);	//连接到服务器//connect 其实是一个阻塞接口，内部要完成TCP的三次握手，当然有超时机制，所以我们需要等一段时间，才能重新连接到服务器ret = connect(cfd, (struct sockaddr*)&server_addr, sizeof(server_addr));if(ret < 0){//100ms去连接一次服务器vTaskDelay(1000);printf("connect fail\r\n");goto again;}printf("server is connect ok\r\n");while(1){//等待服务器发送数据n = Read(cfd, ReadBuff, BUFF_SIZE);if(n <= 0){goto again;}//进行大小写转换for(i = 0; i < n; i++){ReadBuff[i] = toupper(ReadBuff[i]);		}//写回服务器n = Write(cfd, ReadBuff, n);if(n <= 0){goto again;}}
}

结果：pc端的COMMBOX创建或者关闭服务器或者客户端时，串口都会打印出内容，提示打开或者关闭。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.rhkb.cn/news/105548.html

如若内容造成侵权/违法违规/事实不符，请联系长河编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

Flink、Yarn架构，以Flink on Yarn部署原理详解

Flink、Yarn架构，以Flink on Yarn部署原理详解

Flink、Yarn架构&#xff0c;以Flink on Yarn部署原理详解 Flink 架构概览 Apache Flink是一个开源的分布式流处理框架&#xff0c;它可以处理实时数据流和批处理数据。Flink的架构原理是其实现的基础&#xff0c;架构原理可以分为以下四个部分&#xff1a;JobManager、TaskM…
阅读更多...
arm安装docker与docker-copose

arm安装docker与docker-copose

一、银河麒麟Arm64安装docker 1、docker 安装包地址&#xff1a; https://download.docker.com/linux/static/stable 2、解压&#xff0c;然后将docker目录下文件拷贝到/usr/bin里 tar -xf docker-18.09.3.tgz mv docker/* /usr/bin/ 3、准备 docker.service系统配置文件 &…
阅读更多...
[蓝帽杯 2022 初赛]domainhacker

[蓝帽杯 2022 初赛]domainhacker

打开流量包&#xff0c;追踪TCP流&#xff0c;看到一串url编码 放到瑞士军刀里面解密 最下面这一串会觉得像base64编码 删掉前面两个字符就可以base64解码 依次类推&#xff0c;提取到第13个流&#xff0c;得到一串编码其中里面有密码 导出http对象 发现最后有个1.rar文件 不出…
阅读更多...
回归预测 | MATLAB实现BES-ELM秃鹰搜索优化算法优化极限学习机多输入单输出回归预测（多指标，多图）

回归预测 | MATLAB实现BES-ELM秃鹰搜索优化算法优化极限学习机多输入单输出回归预测（多指标，多图）

回归预测 | MATLAB实现BES-ELM秃鹰搜索优化算法优化极限学习机多输入单输出回归预测&#xff08;多指标&#xff0c;多图&#xff09; 目录 回归预测 | MATLAB实现BES-ELM秃鹰搜索优化算法优化极限学习机多输入单输出回归预测&#xff08;多指标&#xff0c;多图&#xff09;效…
阅读更多...
【已解决】记 Vue3+SpringBoot 前后端分离项目部署时的一次跨域问题

【已解决】记 Vue3+SpringBoot 前后端分离项目部署时的一次跨域问题

问题背景是在一次部署开发环境时&#xff0c;由于是前后端分离项目&#xff08;前端Vue3&#xff0c;后端SpringBoot&#xff09;&#xff0c;SpringBoot 使用 Docker 部署&#xff0c;前端访问服务接口时出现跨域问题。 不知道什么是跨域问题的小伙伴可以查看另一篇文章&…
阅读更多...
二叉树中的最大路径和-递归

二叉树中的最大路径和-递归

路径 被定义为一条从树中任意节点出发&#xff0c;沿父节点-子节点连接&#xff0c;达到任意节点的序列。同一个节点在一条路径序列中 至多出现一次 。该路径 至少包含一个 节点&#xff0c;且不一定经过根节点。 路径和 是路径中各节点值的总和。 给你一个二叉树的根节点 root…
阅读更多...
Spring 与【MyBatis 】和【 pageHelper分页插件 】整合

Spring 与【MyBatis 】和【 pageHelper分页插件 】整合

目录 一、Spring整合MyBatis 1. 导入pom依赖 2. 利用mybatis逆向工程生成模型层层代码 3. 编写配置文件 4. 注解式开发 5. 编写Junit测试类 二、AOP整合pageHelper分页插件 1. 创建一个AOP切面 2. Around("execution(* *..*xxx.*xxx(..))") 表达式解析 3. 编…
阅读更多...
智慧互联，有序充电--多场景充电

智慧互联，有序充电--多场景充电

企业微电网能效及充电管理解决方案 安科瑞 崔丽洁 1、企业需求&#xff08;目的地充电&#xff09; 站在企业的角度&#xff0c;除了要主动承担碳达峰、碳中和的社会责任&#xff0c;也需要考虑自身的经营和利润&#xff0c;需要结合企业的现状进行改造 企业微电网平台——与…
阅读更多...
【QT5-自我学习-线程qThread练习-两种使用方式-1：通过继承线程类来使用-基础样例】

【QT5-自我学习-线程qThread练习-两种使用方式-1：通过继承线程类来使用-基础样例】

【QT5-自我学习-线程qThread练习-两种使用方式-1&#xff1a;通过继承线程类来使用-基础样例】 1、前言2、实验环境3-1、学习链接-参考文章3-2、先前了解-自我总结&#xff08;1&#xff09;线程处理逻辑事件&#xff0c;不能带有主窗口的事件&#xff08;2&#xff09;一般考虑…
阅读更多...
【LeetCode75】第三十五题 统计二叉树中好节点的数目

【LeetCode75】第三十五题 统计二叉树中好节点的数目

目录 题目&#xff1a; 示例&#xff1a; 分析&#xff1a; 代码&#xff1a; 题目&#xff1a; 示例&#xff1a; 分析&#xff1a; 给我们一棵二叉树&#xff0c;让我们统计这棵二叉树中好节点的数目。 那么什么是好节点&#xff0c;题目中给出定义&#xff0c;从根节点…
阅读更多...
华为OD机试之报文重排序【Java源码】

华为OD机试之报文重排序【Java源码】

题目描述 对报文进行重传和重排序是常用的可靠性机制&#xff0c;重传缓中区内有一定数量的子报文&#xff0c;每个子报文在原始报文中的顺序已知&#xff0c;现在需要恢复出原始报文。 输入描述 输入第一行为N&#xff0c;表示子报文的个数&#xff0c;0 &#xff1c;N ≤ …
阅读更多...
UE4/5Niagara粒子特效之Niagara_Particles官方案例：1.5-＞2.3

UE4/5Niagara粒子特效之Niagara_Particles官方案例：1.5-＞2.3

目录 之前的文章&#xff1a; 1.5 Blend Attributes by Value 发射器更新 粒子生成 粒子更新 2.1 Static Beams ​编辑 发射器更新&#xff1a; 粒子生成 粒子更新 2.2 Dynamic Beams 没有开始模拟前的效果是&#xff1a; 开始模拟后的效果是&#xff1a; 发射器更新 …
阅读更多...
【C++入门到精通】C++入门 —— 继承（基类、派生类和多态性）

【C++入门到精通】C++入门 —— 继承（基类、派生类和多态性）

阅读导航 前言一、继承的概念及定义1. 继承的概念2.继承的定义⭕定义格式⭕继承关系和访问限定符⭕继承基类成员访问方式的变化 二、基类和派生类对象赋值转换三、继承中的作用域四、派生类的默认成员函数五、继承与友元六、继承与静态成员七、复杂的菱形继承及菱形虚拟继承⭕单…
阅读更多...
C# OpenCvSharp DNN 二维码增强 超分辨率

C# OpenCvSharp DNN 二维码增强 超分辨率

效果 项目 代码 using System; using System.Collections.Generic; using System.ComponentModel; using System.Data; using System.Drawing; using System.Linq; using System.Text; using System.Windows.Forms; using OpenCvSharp; using OpenCvSharp.Dnn; using OpenCvSh…
阅读更多...
如何将储存在Mac或PC端的PDF文件传输到移动设备呢？

如何将储存在Mac或PC端的PDF文件传输到移动设备呢？

iMazing是一款iOS设备管理软件&#xff0c;用户借助它可以将iPad或iPhone上的文件备份到PC或Mac上&#xff0c;还能实现不同设备之间的文件传输&#xff0c;能很大程度上方便用户进行文件管理。 在阅读方面&#xff0c;iPad和iPhone是阅读PDF的优秀选择&#xff0c;相较于Mac或…
阅读更多...
Java 基于 SpringBoot+Vue 的在线考试系统的研究与实现，2.0 版本

Java 基于 SpringBoot+Vue 的在线考试系统的研究与实现，2.0 版本

博主介绍&#xff1a;✌程序员徐师兄、7年大厂程序员经历。全网粉丝30W,Csdn博客专家、掘金/华为云/阿里云/InfoQ等平台优质作者、专注于Java技术领域和毕业项目实战✌ 文章目录 第一章第二章.主要技术第三章第四章 系统设计4.1功能结构4.2 数据库设计4.2.1 数据库E/R图4.2.2 数…
阅读更多...
docker-compose管理创建LNMP服务并运行Wordpress网站平台

docker-compose管理创建LNMP服务并运行Wordpress网站平台

文章目录 一&#xff0e;项目环境1. 环境描述2.项目需求 二&#xff0e;部署过程1.安装Docker2.安装Docker加速器3.Docker-Compose安装部署4.准备依赖文件、配置nginx5.配置mysql6.配置php7.编写docker-compose.yml8.验证 三.容器快照&#xff0c;然后将Docker镜像打包成tar包备…
阅读更多...
JDBC概述

JDBC概述

JDBC概述 核心JDBC组件 JDBC驱动程序连接声明结果集 常见JDBC用例 查询数据库查询数据库元数据更新数据库执行事务 JDBC组件交互图 JDBC API由以下核心部分组成&#xff1a; JDBC驱动程序连接声明结果集 有四个基本的JDBC用例&#xff0c;大多数JDBC工作都围绕这些用例发展…
阅读更多...
C++信息学奥赛1138：将字符串中的小写字母转换成大写字母

C++信息学奥赛1138：将字符串中的小写字母转换成大写字母

#include<bits/stdc.h> using namespace std; int main() {string arr;// 输入一行字符串getline(cin, arr);for(int i0;i<arr.length();i){if(arr[i]>97 and arr[i]<122){char aarr[i]-32; // 将小写字母转换为大写字母cout<<a; // 输出转换后的字符}els…
阅读更多...
电工-学习电工有哪些好处

电工-学习电工有哪些好处

学习电工有哪些好处&#xff1f;在哪学习电工&#xff1f; 学习电工有哪些好处&#xff1f;在哪学习电工&#xff1f;学习电工可以做什么&#xff1f;优势有哪些&#xff1f; 学习电工可以做什么&#xff1f;学习电工有哪些好处&#xff1f; 就业去向&#xff1a;可在企业单位…
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023