当前位置: 首页 > news >正文

【智能家居】6、语音控制及网络控制代码实现

一、语音控制

1、指令结构体编写

68c492d2d9ee4d83ac17a14c916301d9.png

这个结构体定义了一个命令输入的模型。在这个模型中,包含以下几个部分:

  • cmdName:一个长度为128的字符串,用于存储命令名称。
  • dvicesName:一个长度为128的字符串,用于存储设备名称。
  • cmd:一个长度为32的字符串,用于存储具体的命令。
  • Init:一个函数指针,该函数接受三个参数:指向InputCmd结构体实例的指针(可以读取所有字段)、IP地址和端口号,并返回一个整数值。
  • getCmd:一个函数指针,该函数接受一个参指向InputCmd结构体实例的指针(可以读取所有字段)并返回一个整数值。
  • log:一个长度为1024的字符数组,用于存储日志信息。
  • fd:一个整数,文件描述符。
  • next:一个指向结构体本身的指针,用于操控链表。

imputCmd.h

#include <stdio.h>
#include <wiringPi.h>
#include <wiringSerial.h>
#include <unistd.h>
#include <stdlib.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <string.h>struct InputCmd{char cmdName[128];char devicesName[128];char cmd[32];int (*Init)(struct InputCmd *cmd,char *ipAdress,char *port);int (*getCmd)(struct InputCmd *cdm);char *log[1024];int fd;char port[12];char ipAddress[32];int s_fd;struct InputCmd *next;
};

2、实例化对象

(1)结构体变量初始化

29e01620ea5442e0a4f5997fffec7fb6.png

一个结构体变量初始化的例子,声明并初始化了一个`InputCmd`类型的变量`voice`,并将每个字段分别赋值。

  • cmdName字段被赋值为字符串"voice"。
  • devicesName字段被赋值为字符串"/dev/ttyAMA0"。
  • cmd字段被赋值为空字符串。
  • init字段被赋值为`voice_init`函数的地址。
  • getCmd字段被赋值为`voice_getCmd`函数的地址。
  • log字段被赋值为空字符串。

(2)对应字段函数编写

初始化串口,获取文件描述符

8e9b857ed03440b78b31614cfa617611.png

fd=serialOpen(voice->devicesName,9600)它将尝试以9600波特率打开名为 voice->devicesName 的串行端口,并将返回的文件描述符(File Descriptor)赋值给变量 fd。这里的 voice->devicesName 是指向一个字符串的指针,该字符串包含要打开的串行端口的名称或路径。例如,在Linux系统上,这可能是类似于 "/dev/ttyS0" 或 "/dev/ttyUSB0" 的设备文件路径。

9600 是波特率,它决定了数据传输的速度,表示每秒传输9600个数据位。如果 serialOpen 函数成功打开串行端口,它将返回一个非负整数。如果打开失败,函数通常会返回 -1

 

读取指令

bf95102f942244dbba2980f55b00478c.png

voicer->fd指向的串行端口读取数据,并将这些数据存储在voicer->command缓冲区中。

 

插入链表等待被调用

6af420ee2ff84b8e9a5bbcf347217816.png

Voice.c

#include "inputCmd.h"int voice_init(struct InputCmd *voice,char *ipAdress,char *port){int fd;if((fd=serialOpen(voice->devicesName,9600))==-1){exit(-1);}voice->fd=fd;return fd;
}int voice_getCmd(struct InputCmd *voice){int nread=0;nread=read(voice->fd,voice->cmd,sizeof(voice->cmd));if(nread==0){printf("usart for voice read over time\n");}elsereturn nread;
}struct InputCmd voice={.cmdName="voice",.devicesName="/dev/ttyAMA0",.cmd={'\0'},.Init=voice_init,.getCmd=voice_getCmd,.log={'\0'}
};struct InputCmd* addVoiceToInputCmdLink(struct InputCmd *phead){if(phead==NULL){return &voice;}else{voice.next=phead;phead=&voice;}
}

3、将插入链表函数加入inputCmd.h等待被调用

3d0f0ebbda874ef6a720deebe5f284c8.png

4、main函数编写

插入链表等待被调用

f342be3c504c4787a505108fec915cf0.png

mainPro.c

#include <stdio.h>
#include <string.h>#include "controlDevices.h"
#include "inputCmd.h"struct Devices *findDevicesName(char *name,struct Devices *phead){struct Devices *tmp=phead;if(phead==NULL){return NULL;}else{while(tmp!=NULL){if(strcmp(tmp->devicesName,name)==0){return tmp;}tmp=tmp->next;}return NULL;}
}int main(){if(wiringPiSetup()==-1){return -1;}struct Devices *pdevicesHead=NULL;struct InputCmd *pinputCmdHead=NULL;pdevicesHead=addbathroomLightToDevicesLink(pdevicesHead);pdevicesHead=addupstairLightToDevicesLink(pdevicesHead);pdevicesHead=addlivingroomLightToDevicesLink(pdevicesHead);pdevicesHead=addrestaurantLightToDevicesLink(pdevicesHead);pdevicesHead=addFireToDevicesLink(pdevicesHead);pinputCmdHead=addVoiceToInputCmdLink(pinputCmdHead);char name[128]={'\0'};struct Devices *tmp=NULL;while(1){printf("INPUT:\n");scanf("%s",name);tmp=findDevicesName(name,pdevicesHead);if(tmp!=NULL){tmp->devicesInit(tmp->pinNum);tmp->open(tmp->pinNum);	tmp->readStatus(tmp->pinNum);}}return 0;
}

二、网络控制

1、结构体变量初始化

2dda3e6c52a94d928daa170980a39d80.png

2、对应字段函数编写

(1)socket_Init

1、创建一个服务器端的套接字并初始化服务器地址结构

9a82c105fee94404b26946eb0cc6263d.png

  • 定义两个socket描述符变量:s_fd 为服务端socket描述符,c_fd 为客户端socket描述符。
  • 定义两个sockaddr_in 结构体变量:s_addr 存储服务器端网络地址信息,c_addr 存储客户端网络地址信息。
  • 使用 memset() 函数清零这两个结构体变量,确保它们的所有成员初始化为0。
  • 创建服务器端socket

59282a7a09f54960a0787b5473c10f60.png

调用 socket() 函数创建一个基于IPv4协议的流式(TCP)socket。如果返回值 s_fd 为-1,则表示socket创建失败,程序通过 perror("socket") 输出错误信息,并使用 exit(-1) 终止程序执行。

  • 初始化服务器地址结构体:

49e9e0625e354569beee6ba2876e0ab9.png

s_addr.sin_family = AF_INET:设置地址族为Internet(IPv4)。

s_addr.sin_port = htons(atoi(socketInit->port)): 将字符串形式的端口号转换为整型数字,然后使用 htons() 函数将端口号从主机字节序转换为网络字节序。

inet_aton(socketInit->ipaddress, &s_addr.sin_addr): 将字符串形式的IP地址转换为二进制格式,并存入到s_addr.sin_addr中。这样就完成了服务器地址的配置,接下来可以调用bind()函数绑定这个地址和端口到刚创建的socket上。(需要包含头文件#include <arpa/inet.h>)

 2、将创建的socket与特定的IP地址和端口号绑定

a87a05b4a9e843cea01b514bdf4c5efe.png

  • s_fd 是之前通过 socket() 函数创建的socket描述符。
  • (struct sockaddr *)&s_addr 指向已经初始化好的服务器地址结构体 s_addr。由于 bind() 函数的第二个参数要求指向一个通用套接字地址结构(struct sockaddr *),所以我们需要类型转换。

如果 bind() 调用成功,那么该socket就会监听指定的IP地址和端口上的连接请求。如果失败,则会返回一个错误码,通常需要通过 perror() 或检查 errno 来获取错误信息并进行相应的处理。

3、 将socket设置为监听模式

32c2803c1e9c48c7a21ec41a56e60f8e.png

  • s_fd 是之前创建并绑定到特定IP地址和端口的socket描述符。
  • 第二个参数(这里是10)表示backlog,即在服务器开始拒绝连接请求前,可以排队等待处理的最大连接数。当这个数目达到后,新的连接请求将会被拒绝,直到服务器完成对已有连接的处理。

9fafa7c9b3dc4c3e86bd08c91bdd10d7.png

 将已经初始化并设置为监听状态的socket描述符 s_fd 赋值给结构体 socketInit 的成员变量 s_fd

(2) socket_getCmd

1、声明变量与初始化c_addr结构体

022a2b6e211d4b5cb2c3ccecec7ef887.png

int c_fd;:声明一个整型变量 c_fd,用于存储接受到的客户端socket描述符。

int n_read = 0;:声明一个整型变量 n_read,用于记录从客户端socket读取数据的数量。

struct sockaddr_in c_addr;:定义一个结构体变量 c_addr,用于存储客户端的网络地址信息。

memset(&c_addr, 0, sizeof(struct sockaddr_in));:清零 c_addr 结构体,确保所有成员初始化为0。

int len = sizeof(struct sockaddr_in);:声明并初始化一个整型变量 len,表示要获取的客户端地址结构体的大小。

2、等待并接受来自客户端的连接请求

0f1dbcd658ca4478817ee0f3bf4193e6.png

c_fd = accept(socketGet.s_fd, (struct sockaddr *)&c_addr, &len);:使用 accept() 函数等待并接受来自客户端的连接请求。

  • 第一个参数是服务端监听的socket描述符(即之前创建并调用 listen()s_fd)。
  • 第二个参数是一个指向 sockaddr_in 结构体的指针,用于接收已连接客户端的地址信息。
  • 第三个参数是一个指向整数的指针,用于接收实际填充到地址结构体中的字节数。

3、从已连接的客户端socket (c_fd) 读取数据

a5e9c35cea9e4085a553458b45e5a167.png

n_read = read(c_fd, socketGet->command, sizeof(socket_command));:使用 read() 函数从已连接的客户端socket (c_fd) 读取数据,并将数据存入 socketGet 结构体中 command 成员指定的缓冲区。第二个参数是缓冲区的起始地址,第三个参数是期望读取的最大字节数。

960cb01d36e54d8992925e4751cc90c5.png

对于 read() 函数的返回值进行判断:

  • 如果 n_read == -1,说明读取过程中发生错误,通过 perror("read") 输出错误信息。
  • 如果 n_read > 0,则打印出读取到的数据长度。
  • 如果 n_read == 0,通常意味着客户端已经关闭了连接,此时输出 "client quit!",然后可能执行相应的退出循环操作(这里没有显示完整的上下文,所以无法确定是否有break语句所在的循环)。

b1f25cfd1ace43558c91ac452795adc0.png

最后返回 n_read,代表本次从客户端读取数据的实际字节数。

(3)插入链表等待被调用

eb769fcc28b54284bed90cd7350f2ea2.png

socket.c

#include "inputCmd.h"int socket_init(struct InputCmd *socketInit,char *ipAdress,char *port){int s_fd,c_fd;//s_fd:服务(service)端socket描述符;c_fd:客户(client)端socket描述符struct sockaddr_in s_addr;//s_addr:存储服务器端网络地址信息struct sockaddr_in c_addr;//c_addr:存储客户端网络地址信息memset(&s_addr,0,sizeof(struct sockaddr_in));//初始化结构体memset(&c_addr,0,sizeof(struct sockaddr_in));//sockets_fd=socket(AF_INET,SOCK_STREAM,0);if(s_fd==-1){perror("socket");exit(-1);}s_addr.sin_family=AF_INET;s_addr.sin_port=htons(atoi(socketInit->port));inet_aton(socketInit->ipAddress,&s_addr.sin_addr);//bindbind(s_fd,(struct sockaddr *)&s_addr,sizeof(struct sockaddr_in));//listenlisten(s_fd,10);socketInit->s_fd=s_fd;return s_fd;
}int socket_getCmd(struct InputCmd *Socket){int c_fd;int n_read=0;struct sockaddr_in c_addr;memset(&c_addr,0,sizeof(struct sockaddr_in));int len=sizeof(struct sockaddr_in);c_fd=accept(Socket->s_fd,(struct sockaddr *)&c_addr,&len);n_read=read(c_fd,Socket->cmd,sizeof(Socket->cmd));if(n_read==-1){perror("read");}else if(n_read>0){printf("\n");printf("get:%d\n",n_read);}else{printf("client quit!\n");}return n_read;
}struct InputCmd Socket={.cmdName="socket",.cmd={'\0'},.Init=socket_init,.getCmd=socket_getCmd,.log={'\0'},.port="8080",.ipAddress="172.20.10.9"
};struct InputCmd* addSocketToInputCmdLink(struct InputCmd *phead){if(phead==NULL){return &Socket;}else{Socket.next=phead;phead=&Socket;}
}

3、将插入链表函数加入inputCmd.h等待被调用

#include <stdio.h>
#include <wiringPi.h>
#include <wiringSerial.h>
#include <unistd.h>
#include <stdlib.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <string.h>struct InputCmd{char cmdName[128];char devicesName[128];char cmd[32];int (*Init)(struct InputCmd *cmd,char *ipAdress,char *port);int (*getCmd)(struct InputCmd *cdm);char *log[1024];int fd;char port[12];char ipAddress[32];int s_fd;struct InputCmd *next;
};struct InputCmd* addVoiceToInputCmdLink(struct InputCmd *phead);
struct InputCmd* addSocketToInputCmdLink(struct InputCmd *phead);

4、main函数编写

a8f2e5452987477eb6a52744c5fe2ff9.png

mainPro.c

#include <stdio.h>
#include <string.h>#include "controlDevices.h"
#include "inputCmd.h"struct Devices *findDevicesName(char *name,struct Devices *phead){struct Devices *tmp=phead;if(phead==NULL){return NULL;}else{while(tmp!=NULL){if(strcmp(tmp->devicesName,name)==0){return tmp;}tmp=tmp->next;}return NULL;}
}int main(){if(wiringPiSetup()==-1){return -1;}struct Devices *pdevicesHead=NULL;struct InputCmd *pinputCmdHead=NULL;pdevicesHead=addbathroomLightToDevicesLink(pdevicesHead);pdevicesHead=addupstairLightToDevicesLink(pdevicesHead);pdevicesHead=addlivingroomLightToDevicesLink(pdevicesHead);pdevicesHead=addrestaurantLightToDevicesLink(pdevicesHead);pdevicesHead=addFireToDevicesLink(pdevicesHead);pinputCmdHead=addVoiceToInputCmdLink(pinputCmdHead);pinputCmdHead=addSocketToInputCmdLink(pinputCmdHead);char name[128]={'\0'};struct Devices *tmp=NULL;while(1){printf("INPUT:\n");scanf("%s",name);tmp=findDevicesName(name,pdevicesHead);if(tmp!=NULL){tmp->devicesInit(tmp->pinNum);tmp->open(tmp->pinNum);	tmp->readStatus(tmp->pinNum);}}return 0;
}

三、测试

将工程放入树莓派中,编译通过,无错误无警告

7b285dd651ad40bd8ad9070974e7e25b.png

四、当前阶段源代码

链接:https://pan.baidu.com/s/1vh8smf725jrxSUlDOHFOfg
提取码:sail

 

http://www.lryc.cn/news/291149.html

相关文章:

  • Windows断开映射磁盘提示“此网络连接不存在”,并且该磁盘直在资源管理器中
  • Java项目要不要部署在Docker里?
  • Linux 入门基础知识(一)—— Linux的基本使用
  • 纯静态微信小程序水果商城
  • 操作系统-线程的实现方式和多线程模型(用户级线程 内核级线程 多线程模型的情况)和线程的状态,转换,组织,控制
  • 计算机网络 应用层
  • 拥有你的微调大模型,零代码定制+算力免费送
  • 《Docker技术革命:从虚拟机到容器化,全面解析Docker的原理与应用-上篇》
  • C,C++,C# 的区别
  • 操作筛选器的 1 个应用实例:自动启用事务
  • 搭建基于Java的分布式爬虫系统
  • rancher证书过期问题处理
  • Spring Boot 中文件上传
  • 2023年06月CCF-GESP编程能力等级认证Python编程一级真题解析
  • unity 使用数字图片来代替数字0到9显示
  • 单片机如何实现延时1ms或者1us
  • 全国网络安全行业职业技能大赛WP
  • 【Python函数与模块】(7)模块的分类与好处
  • 如何安全地多开Facebook/Twitter/TK/Ins等账号?
  • ChatGPT学python: 用json文件传参
  • 【C++航海王:追寻罗杰的编程之路】引用、内联、auto关键字、基于范围的for、指针空值nullptr
  • 已实现:vue、h5项目如何使用echarts实现雷达图、六边形图表
  • JUC并发编程-四大函数式接口、Stream 流式计算、ForkJoin并行执行任务
  • 【Tomcat与网络4】Tomcat的连接器设计
  • k8s中调整Pod数量限制的方法
  • 在Java中,实现扩展性通常有几种方法,其中包括接口、抽象类、插件架构和服务加载等方式
  • 【乳腺肿瘤诊断分类及预测】基于自适应SPREAD-PNN概率神经网络
  • 蓝桥杯AT24C02问题记录
  • adb控制设备状态
  • 订婚支出及共同生活消费是否属于彩礼?应否返还?