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.mzph.cn/news/52791.shtml

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

相关文章

《基于 Vue 组件库 的 Webpack5 配置》4. 压缩 CSS 和 js 文件

压缩 CSS 使用 webpack 插件 css-minimizer-webpack-plugin&#xff0c;需要额外安装 npm i css-minimizer-webpack-pluginlatest -D&#xff1b;压缩 js 使用 webpack 自带插件 terser-webpack-plugin&#xff0c;无需额外安装&#xff1b;package.json 的配置如下 const Css…

深度学习入门教学——二分分类

1、什么是二分分类&#xff1f; 二分分类就是判断“有”和“没有”、“是”和“不是”的问题&#xff0c;也就是监督学习中的分类问题。例如&#xff0c;输入一张图片&#xff0c;输出识别该图片的标签。计算机输入图片转化过程如下&#xff1a; 2、神经网络常用符号表示 (x, …

蓝蓝设计UI设计公司-界面设计与开发案例

天津航天中为项目 中国南方电网十二个软件交互优化和界面设计 图标设计 | 交互设计 | 界面设计 天津航天中为数据系统科技有限公司是航天503所控股的专业化公司&#xff0c;坐落于天津滨海新区航天技术产业园&#xff0c;是航天五院家入住天津未来科技城的军民融合型企业&…

Qt文件系统操作和文件的读写

一、文件操作类概述 QIODevice&#xff1a;所有输入输出设备的基础类 QFile&#xff1a;用于文件操作和文件数据读写的类QSaveFile&#xff1a;用于安全保存文件的类QTemporaryFile&#xff1a;用于创建临时文件的类QTcpSocket和QUdpSocket&#xff1a;分别实现了TCP和UDP的类…

git配置代理(github配置代理)

命令行配置代理方式一git config --global http.proxy http://代理服务器地址:端口号git config --global https.proxy https://代理服务器地址:端口号如果有用户名密码按照下面命令配置 git config --global http.proxy http://用户名:密码代理服务器地址:端口号git config --…

解决问题:C++ [某变量名] was not declared in this scope

目录 程序报错的问题 查看程序问题 发现错误代码 错误原因 修改代码 再次运行 程序报错的问题 查看程序问题 发现错误代码 cout<<c; 错误原因 c 这个变量还没有在这个程序中定义 修改代码 加上 int c; 再次运行

使用Dockerfile部署java项目

1、移动java包到创建的目录下 2、编写Dockerfile文件 在同一目录下使用如下命令创建文件 touch Dockerfile 文件内容如下&#xff1a; #依赖的父镜像 FROM java:8 #作者 MAINTAINER maxurui #jar包添加到镜像中 ADD springboot3-0.0.1-SNAPSHOT.jar springboot3-0.0.1-SNAPSHO…

go gorm创建记录

创建model package mysqltestimport ("errors""fmt""gorm.io/gorm" )type Product struct {gorm.ModelID uint gorm:"primarykey"Name string gorm:"column:name"Price float64 gorm:"column:price_value&quo…

LeetCode字符串数组最长公共前缀

编写一个函数来查找字符串数组中的最长公共前缀。 如果不存在公共前缀&#xff0c;返回空字符串 “”。 示例 1&#xff1a; 输入&#xff1a;strs [“flower”,“flow”,“flight”] 输出&#xff1a;“fl” 示例 2&#xff1a; 输入&#xff1a;strs [“dog”,“raceca…

SOPC之NIOS Ⅱ实现电机转速PID控制(调用中断函数)

通过FPGA开发板上的NIOS Ⅱ搭建电机控制的硬件平台&#xff0c;包括电机正反转、编码器的读取&#xff0c;再通过软件部分实现PID算法对电机速度进行控制&#xff0c;使其能够渐近设定的编码器目标值。 一、问题与改进 SOPC之NIOS Ⅱ实现电机转速PID控制_STATEABC的博客-CSDN…

关于Optix v6和Optix v7之间的种种区别

目录 Optix v6 基本构成组件 射线与求交 纹理 三角Mesh Optix v7结构 基本构成组件 管线 着色器绑定表(SBT) 第一个例子 第二个例子 全局光照(GI)有很多种解决方案&#xff0c;比如VXGI、Lumen、DDGI、SSGI、IBL、PRT、SurfelsGI等&#xff0c;其中&#xff0c;越来…

k8s-ingress-context deadline exceeded

报错&#xff1a; rancher-rke-01:~/rke # helm install rancher rancher-latest/rancher --namespace cattle-system --set hostnamewww.rancher.local Error: INSTALLATION FAILED: Internal error occurred: failed calling webhook "validate.nginx.ingress.kube…

C语言刷题训练DAY.13

1.有序序列判断 解题思路&#xff1a; 这里我们先看代码&#xff0c;我们定义了一个flag1和flag2&#xff0c;它的作用主要就是判断是不是升序&#xff0c;具体怎么使用的&#xff0c;我为大家画图展示。 解题代码&#xff1a; #include<stdio.h> int main() {int n 0;…

实验一 ubuntu 网络环境配置

ubuntu 网络环境配置 【实验目的】 掌握 ubuntu 下网络配置的基本方法&#xff0c;能够通过有线网络连通 ubuntu 和开发板 【实验环境】 ubuntu 14.04 发行版FS4412 实验平台 【注意事项】 实验步骤中以“$”开头的命令表示在 ubuntu 环境下执行&#xff0c;以“#”开头的…

介绍 Docker 的基本概念和优势,以及在应用程序开发中的实际应用。

Docker是一个开放源代码的容器化平台&#xff0c;可以将应用程序及其依赖项打包到一个轻量级的容器中&#xff0c;以便在任何地方运行。以下是Docker的基本概念和优势&#xff1a; 基本概念&#xff1a; 镜像&#xff08;image&#xff09;&#xff1a;Docker的基本构建块&am…

go 语法 基础包

目录 高性能go并发建议测试系统字符串flag日志reflect文件IOmath数字runtime远程调用限流注册中心链路跟踪监控日期时间time Decimal配置缓存异常开发工具包调试工具分布式调度json网络net/httphttp clientwebsocketpinguser_agent 并发sync 异步channelcontext异步并发 数据库…

改进YOLO系列:6.添加ECA注意力机制

添加ECA注意力机制 1. ECA注意力机制论文2. ECA注意力机制原理3. ECA注意力机制的配置3.1common.py配置3.2yolo.py配置3.3yaml文件配置1. ECA注意力机制论文 论文题目:ECA-Net: Efficient Channel Attention for Deep Convolutional Neural Networks 论文链接:ECA-N…

[国产MCU]-W801开发实例-按键与GPIO输入

按键与GPIO输入 文章目录 按键与GPIO输入1、硬件准备2、软件准备3、驱动实现4、驱动测试在前面的文章中,我们成功点亮了LED,同时也知道W801的GPIO是可软件配置的。在这里,将详细介绍如何通过按键控制LED。 1、硬件准备 W801开发板一块微动开关一个10K电阻一个导线若干1uF电容…

pytest fixture 创建一个 requests.session() 对象

当你运行这段代码时&#xff0c;它会执行以下操作&#xff1a; 1. 导入必要的库&#xff1a;pytest 和 requests。 2. 定义一个夹具&#xff08;fixture&#xff09;函数 session&#xff0c;使用 pytest.fixture(scopesession) 装饰器进行标记。这个夹具函数在整个测试会话期…

微服务参数透传实现

说明&#xff1a;在微服务架构中&#xff0c;用户身份经网关验证后&#xff0c;我们可以将用户信息&#xff0c;如ID加入到请求头上。后面的微服务中&#xff0c;可以设置一个拦截器&#xff0c;拦截请求&#xff0c;获取请求头上的用户ID&#xff0c;加入到ThreadLocal中。 最…