• 基于Linux的智能家居（工厂模式）

    目录

    1.项目概述

    2.程序框架

    3.函数准备

    3.1需要函数知识点

    3.2编码提醒

    4.代码

    5.注意事项

    1.项目概述

    控制端有两个，语音串口UART和Tcp通讯。

    执行端有IO输出和IO输入。

    2.程序框架

    程序分为3部分-------------1.输入控制  2.输出设备  3.主函数-多线程

    输入控制的模块----实现指令的收集，并将数据放在一个定义的头文件种。

    输出设备模块----实现设备初始化、设备启动、设备关闭的函数封装放在种。

    主函数-----实现UART和Tcp两个接收线程，不断接收指令并解析指令调用不同的设备函数封装

    亮点，在<.h>封装了一个类，调用<.h>可以编码一个对象，然后用链表将一类对象串起来。

    将对象的功能实现都封装成了函数，放在对象的结构体中，使用时直接调用。

    3.函数准备

    3.1需要函数知识点

    main中

    • 线程创建、线程退出、线程等待、wiringPi库、链表增加、链表查找

    中

    • 链表创建、函数指针

    设备控制、输入控制中

    • wiringPi库、结构体赋值、链表增加

    3.2编码提醒

    出现不能用NULL指针，包含头文件

    香橙派编译wiringpi库时用gcc  buzzer.c -o test -lwiringPi -lwiringPiDev -lpthread -Im -Icrypt -Irt

    C语言函数没有return语句时,会返回最后一次赋值的变量的值

    函数指针是定义一个指针指向函数，调用时直接用P()或者（*p）()都行，函数名和函数地址一样

    指针有点神奇，指针是一个地址，但是同时也可以直接用指针使用地址里的值

    没办法：这里的代码在结构体实现里用了函数的递归。错错错。第575课，添加声音识别模块，形参和实参不一样的。形参只是形式，需要函数调用时赋予实参。

    炫技：这里的代码用了链表串联设备

    堆栈的存储：在函数体前面的变量，后面的函数可以直接用

    Orangepi的引脚图

    4.代码

    main中

    1. #include 
    2. #include 
    3. #include "contrldevice.h"  
    4. #include "inputcmd.h"
    5. #include 
    6. #include 
    7. #include 
    8. #include
    9.  
    10. struct OutputDevice * pdevicehead=NULL; /*device head */
    11. struct InputDevice  *  pInputhead=NULL;  /*Input head */
    12. struct InputDevice  *  tmp=NULL;
    13.  
    14. struct OutputDevice *find_cmd_device(char *name,struct OutputDevice * pdevicehead)
    15. {
    16. 	struct OutputDevice *tmp=pdevicehead;
    17. 	
    18. 	if(tmp==NULL ){   /* compare is correct*/
    19. 		return NULL;
    20. 	}else{
    21. 		while(tmp!=NULL){
    22. 			if(0==strcmp(tmp->device_name,name)){
    23. 				return tmp;
    24. 			}
    25. 			tmp=tmp->next;
    26. 		}
    27. 		return NULL;
    28. 	}
    29. }
    30.  
    31. struct InputDevice *find_input_device(char *name,struct InputDevice * pdevicehead)
    32. {
    33. 	struct InputDevice *tmp=pdevicehead;
    34. 	
    35. 	if(tmp==NULL ){   /* compare is correct*/
    36. 		return NULL;
    37. 	}else{
    38. 		while(tmp!=NULL){
    39. 			if(0==strcmp(tmp->cmddevice_name,name)){
    40. 				return tmp;
    41. 			}
    42. 			tmp=tmp->next;
    43. 		}
    44. 		return NULL;
    45. 	}
    46. }
    47.  
    48. void * voice_thread(void *data)  /* voice_thread */
    49. {   
    50. 	int nread;
    51. 	struct InputDevice * tmp=find_input_device("voice",pInputhead);
    52. 	if(tmp==NULL){
    53. 		printf("no find voice phead!\r\n");
    54. 		pthread_exit(NULL);
    55. 		
    56. 	}else{
    57. 		if(tmp->init(tmp)==-1){
    58. 			printf("voice init faild!\r\n");
    59. 			pthread_exit(NULL);
    60. 		}
    61. 	}
    62. 	
    63. 	while(1){
    64. 		memset(tmp->cmd,0,sizeof(tmp->cmd));  
    65. 		nread=tmp->getcmd(tmp);            /* when uart no data come cmd while get uart overtime */
    66. 		if(nread==0){
    67. 			printf("voice cmd no data arival!\r\n");
    68. 		}else{
    69. 			printf("voice recive %d data:%s\r\n",nread,tmp->cmd);
    70. 		}
    71. 	}	
    72.  
    73. }
    74.  
    75. void * sockread_thread(void *data) 
    76. {
    77. 	int nread;
    78. 	while(1){
    79. 		memset(tmp->cmd,'\0',sizeof(tmp->cmd));
    80. 		nread=read(tmp->ss_fd,&tmp->cmd,sizeof(tmp->cmd));
    81. 		if(nread==0){                 /* cannot recv cmd */ 
    82. 			printf("connect is cutdon! \r\n");
    83. 			pthread_exit(NULL);
    84. 		}else{                         /*can recive cmd */ 
    85. 			printf("server  receved %d cmd:%s \r\n",nread,tmp->cmd); 	
    86. 		}
    87. 	}
    88. 			
    89. }
    90.  
    91.  
    92. void * socket_thread(void *data) 
    93. {
    94. 	int nread;
    95. 	pthread_t socketreadthread;
    96. 	tmp=find_input_device("socket",pInputhead);
    97. 	if(tmp==NULL){
    98. 		printf("no find socket phead!\r\n");
    99. 		pthread_exit(NULL);
    100. 		
    101. 	}else{
    102. 		if(tmp->init(tmp)==-1){
    103. 			printf("socket init faild!\r\n");
    104. 			pthread_exit(NULL);
    105. 		}
    106. 	}
    107. 		
    108. 	while(1){
    109. 		
    110. 		if(tmp->getcmd(tmp)==-1){
    111. 			perror("error");  /* get ss_fd error  */
    112. 		}
    113. 		/*socket  read线程*/
    114. 		pthread_create(&socketreadthread,NULL,sockread_thread,NULL);
    115. 		pthread_join(socketreadthread,NULL);   /* 等读线程退出在进行  */
    116. 	}
    117. }
    118.  
    119.  
    120.  
    121. int main(void)
    122. {
    123. 	char device_name[32];
    124.  
    125. 	pthread_t voicethread; 
    126. 	pthread_t socketthread; 
    127. 	
    128.  
    129. 	
    130. 	if(-1==wiringPiSetup()){
    131. 		printf("wiringpi init fail!\r\n");
    132. 		return 0;
    133. 	}
    134. 	/*1.指令工厂初始化  加入设备 */
    135. 	pInputhead=add_input_voice(pInputhead);
    136. 	pInputhead=add_input_socket(pInputhead);
    137. 	
    138. 	/*2.设备工厂初始化   加入设备 */
    139. 	pdevicehead=add_device_dingnerlight(pdevicehead);
    140. 	pdevicehead=add_device_restlight(pdevicehead);
    141. 	pdevicehead=add_device_firedetect(pdevicehead);
    142. 	
    143. 	/*2.1找设备 */
    144. 	/*struct OutputDevice * tmp=find_cmd_device(device_name,pdevicehead);
    145. 	while(1){
    146. 		printf("input device name:");
    147. 		scanf("%s",device_name);
    148. 		tmp=find_cmd_device(device_name,pdevicehead);
    149. 		printf("input cmd name 1/2:");
    150. 		scanf("%d",&cmd);
    151. 		switch(cmd){
    152. 			case 1:
    153. 				tmp->init();
    154. 				tmp->open();
    155. 				break;
    156. 			case 2:
    157. 				tmp->init();
    158. 				tmp->close();
    159. 				break;
    160. 			default:
    161. 				printf("no this cmd");
    162. 				break;
    163. 		}
    164. 	}*/
    165. 	
    166. 	
    167. /*3. 线程池建立*/
    168. 	/*3.1 语音线程*/
    169. 	pthread_create(&voicethread,NULL,voice_thread,NULL);
    170. 	
    171. 	/*3.2socket线程*/
    172. 	pthread_create(&socketthread,NULL,socket_thread,NULL);
    173. 	
    174. 	
    175. 	
    176. 	/*3.3摄像头线程*/
    177. 	/*3.4 火灾线程*/
    178. 	
    179. 	pthread_join(voicethread,NULL);  /*线程等待不让主程序退出*/
    180. 	pthread_join(socketthread,NULL);  /*线程等待不让主程序退出*/
    181. 	return 0; 
    182. }

    contrldevice.h

    1. #include 
    2.  
    3. struct OutputDevice{
    4. 	char device_name[32];
    5. 	int status;
    6. 	
    7. 	int (*init)();
    8. 	int (*open)();
    9. 	int (*close)();
    10. 	
    11. 	int (*read)();
    12. 	int (*changeStatus)();
    13. 	
    14. 	struct OutputDevice *next;
    15. 	
    16. };
    17. struct OutputDevice * add_device_dingnerlight(struct OutputDevice *phead);
    18. struct OutputDevice * add_device_restlight(struct OutputDevice *phead);
    19. struct OutputDevice * add_device_firedetect(struct OutputDevice *phead);

    inputcmd.h

    1. #include  
    2.  
    3.  
    4. struct InputDevice{
    5. 	
    6. 	char cmddevice_name[32];
    7. 	char  cmd[32];
    8. 	int  fd;
    9. 	int  ss_fd;
    10. 	
    11. 	int (*init)();
    12. 	int (*getcmd)();
    13. 	
    14. 	struct InputDevice *next;
    15. 	
    16. };
    17.  
    18. struct InputDevice * add_input_voice(struct InputDevice *phead);
    19. struct InputDevice * add_input_socket(struct InputDevice *phead);

    dingnerlight.c

    1. #include  
    2. #include "contrldevice.h"  //include i can use struct
    3. #include 
    4.  
    5. #define dingnerlightPin 2
    6. /*struct OutputDevive{
    7. 	char device_name[32];
    8. 	int status;
    9. 	
    10. 	int (*init)();
    11. 	int (*open)();
    12. 	int (*close)();
    13. 	
    14. 	int (*read)();
    15. 	int (*changeStatus)();
    16. 	
    17. 	sturct OutputDevive *next;
    18. 	
    19. } */
    20.  
    21. int dingnerlight_init(void)
    22. {
    23. 	pinMode(dingnerlightPin,OUTPUT);
    24. 	digitalWrite(dingnerlightPin,HIGH);
    25. 	
    26. 	return 0;
    27. 	
    28. }
    29. int dingnerlight_open(void)
    30. {
    31. 	digitalWrite(dingnerlightPin,LOW);
    32. 	return 0;
    33. }
    34.  
    35. int dingnerlight_close(void)
    36. {
    37. 	digitalWrite(dingnerlightPin,HIGH);
    38. 	return 0;
    39. }
    40.  
    41. struct OutputDevice dingnerlight={      /*"this give valve not init"*/
    42. 	.device_name="dingnerlight",
    43. 	.init=dingnerlight_init,
    44. 	.open=dingnerlight_open,
    45. 	.close=dingnerlight_close
    46. };
    47.  
    48. struct OutputDevice * add_device_dingnerlight(struct OutputDevice *phead)
    49. {
    50. 	if(phead==NULL){
    51. 		return &dingnerlight;	
    52. 	}else{
    53. 		dingnerlight.next=phead;
    54. 		phead=&dingnerlight;
    55. 		return phead;
    56. 			
    57. 	}
    58. }
    59.

    firedetect.c

    1. #include  
    2. #include "contrldevice.h"  //include i can use struct
    3. #include 
    4.  
    5. #define firedetectPin 6
    6. /*struct OutputDevice{
    7. 	char device_name[32];
    8. 	int status;
    9. 	
    10. 	int (*init)();
    11. 	int (*open)();
    12. 	int (*close)();
    13. 	
    14. 	int (*read)();
    15. 	int (*changeStatus)();
    16. 	
    17. 	sturct OutputDevive *next;
    18. 	
    19. } */
    20.  
    21. int firedetect_init(void)
    22. {
    23. 	pinMode(firedetectPin,INPUT);
    24. 	
    25. 	
    26. 	return 0;	
    27. }
    28.  
    29. int firedetect_read(void)
    30. {
    31. 	return digitalRead(firedetectPin);
    32. }
    33.  
    34.  
    35. struct OutputDevice firedetect={      /*"this give valve not init"*/
    36. 	.device_name="firedetect",
    37. 	.init=firedetect_init,
    38. 	.read=firedetect_read
    39. };
    40.  
    41. struct OutputDevice * add_device_firedetect(struct OutputDevice *phead)
    42. {
    43. 	if(phead==NULL){
    44. 		return &firedetect;	
    45. 	}else{
    46. 		firedetect.next=phead;
    47. 		phead=&firedetect;
    48. 		return phead;
    49. 			
    50. 	}
    51. }
    52.

    restlight.c

    1. #include  
    2. #include "contrldevice.h"  //include i can use struct
    3. #include 
    4.  
    5. #define restlightPin 8
    6. /*struct OutputDevice{
    7. 	char device_name[32];
    8. 	int status;
    9. 	
    10. 	int (*init)();
    11. 	int (*open)();
    12. 	int (*close)();
    13. 	
    14. 	int (*read)();
    15. 	int (*changeStatus)();
    16. 	
    17. 	sturct OutputDevice *next;
    18. 	
    19. } */
    20.  
    21. int restlight_init(void)
    22. {
    23. 	pinMode(restlightPin,OUTPUT);
    24. 	digitalWrite(restlightPin,HIGH);
    25. 	
    26. 	return 0;
    27. 	
    28. }
    29. int restlight_open(void)
    30. {
    31. 	digitalWrite(restlightPin,LOW);
    32. 	return 0;
    33. }
    34.  
    35. int restlight_close(void)
    36. {
    37. 	digitalWrite(restlightPin,HIGH);
    38. 	return 0;
    39. }
    40.  
    41. struct OutputDevice restlight={      /*"this give valve not init"*/
    42. 	.device_name="restlight",
    43. 	.init=restlight_init,
    44. 	.open=restlight_open,
    45. 	.close=restlight_close
    46. };
    47.  
    48. struct OutputDevice * add_device_restlight(struct OutputDevice *phead)
    49. {
    50. 	if(phead==NULL){
    51. 		return &restlight;	
    52. 	}else{
    53. 		restlight.next=phead;
    54. 		return &restlight;		
    55. 	}
    56. }
    57.

    socketcmd.c

    1. #include 
    2. #include 
    3. #include 
    4. #include 
    5. #include 
    6. #include 
    7. #include 
    8. #include "inputcmd.h"/*include i can use struct*/ 
    9.  
    10. /*struct InputDevice{
    11. 	
    12. 	char cmddevice_name[32];
    13. 	char  cmd[32];
    14. 	int  fd;
    15. 	int  ss_fd;
    16. 	
    17. 	int (*init)();
    18. 	int (*getcmd)();
    19. 	
    20. 	struct InputDevice *next;
    21. 	
    22. }; */
    23.  
    24. int socket_getcmd(struct InputDevice *phead)
    25. {
    26. 	int len;
    27. 	
    28. 	struct sockaddr_in c_ddr;  /*save clinet msg*/ 
    29. 	
    30. 	/*4.accept come and connect for once*/ 
    31. 	len=sizeof(c_ddr);
    32.  
    33. 	
    34. 	phead->ss_fd=accept(phead->fd,(struct sockaddr *)&c_ddr,&len);
    35. 	if(phead->ss_fd == -1){
    36. 		perror("accept:");
    37. 	}
    38. 	/*5.read from connect ss_fd*/ 
    39. 	/*5.2 read*/ 
    40. 	
    41. 	
    42. 	printf("conect succese!==========\r\n");
    43. 		
    44.  
    45. 				
    46. 	return phead->ss_fd;
    47. }
    48.  
    49. int socket_init(struct InputDevice *phead)
    50. {
    51. 	
    52. 	int s_fd;
    53.  
    54. 	struct sockaddr_in s_ddr;  /*build server msg*/ 
    55.  
    56. 	s_fd= socket(AF_INET, SOCK_STREAM, 0);/*1.build a soket specified*/ 
    57. 	if(s_fd==-1){
    58. 		perror("error is");
    59. 	}
    60. 	/*2.build all bind*/ 
    61. 	s_ddr.sin_family=AF_INET;
    62. 	s_ddr.sin_port=htons(8880);
    63. 	s_ddr.sin_addr.s_addr=htonl(INADDR_ANY);
    64. 	/*give the bind*/ 
    65. 	bind(s_fd,(struct sockaddr *)&s_ddr,sizeof(s_ddr));
    66. 	/*3.waite for client*/ 
    67. 	listen(s_fd,8);
    68. 	
    69. 	phead->fd=s_fd;
    70.  
    71. 	return s_fd;
    72. }
    73.  
    74. struct InputDevice struc_socket={
    75. 	.cmd={0},
    76. 	.cmddevice_name="socket",
    77. 	.init=socket_init,
    78. 	.getcmd=socket_getcmd
    79. 	
    80. };
    81.  
    82. struct InputDevice * add_input_socket(struct InputDevice *phead)
    83. {
    84. 	if(phead==NULL){
    85. 		return &struc_socket;	
    86. 	}else{
    87. 		struc_socket.next=phead;
    88. 		phead=&struc_socket;
    89. 		return phead;		
    90. 	}
    91. }

    voicecmd.c

    1.   //include i can use struct
    2. #include 
    3. #include 
    4. #include 
    5. #include 
    6. #include "inputcmd.h"
    7.  
    8. /*struct InputDevice{
    9. 	
    10. 	char cmddevice_name[32];
    11. 	char  cmd[32];
    12. 	int fd;
    13. 	
    14. 	int (*init)();
    15. 	int (*getcmd)();
    16. 	
    17. 	sturct InputDevice *next;
    18. 	
    19. } */
    20.  
    21. int voice_getcmd(struct InputDevice *phead)
    22. {
    23. 	int nread;
    24. 	nread=read(phead->fd,phead->cmd,sizeof(phead->cmd));
    25. 	
    26. 	return nread;
    27. 	
    28.  
    29. }
    30.  
    31. int voice_init(struct InputDevice *phead)
    32. {
    33. 	int fd1;
    34. 	if((fd1=serialOpen("/dev/ttyS5",115200))<0){
    35. 		printf("uart init fail!\r\n");
    36. 		exit(-1);
    37. 	}
    38. 	phead->fd=fd1;
    39. 	return fd1;
    40. }
    41.  
    42. struct InputDevice voice={
    43. 	.cmd={0},
    44. 	.cmddevice_name="voice",
    45. 	.init=voice_init,
    46. 	.getcmd=voice_getcmd
    47. 	
    48. };
    49.  
    50. struct InputDevice * add_input_voice(struct InputDevice *phead)
    51. {
    52. 	if(phead==NULL){
    53. 		return &voice;	
    54. 	}else{
    55. 		voice.next=phead;
    56. 		phead=&voice;
    57. 		return phead;		
    58. 	}
    59. }

    5.注意事项

  • 相关阅读:
    VScode配置 github 上传代码
    Python使用大漠插件前的准备工作
    最新接口自动化面试题
    MySQL的卸载与安装
    [题]当天是该年的第几天？ #switch的小用法
    CleanMyMacX4.11.3最新版mac电脑磁盘清理工具功能
    30.【十进制和二进制的相互转化(超详解)】
    Redis 规范部署手册
    【广州华锐互动】VR模拟真实火灾场景，教你如何正确逃生和自救
    图像的高频和低频细节
  • 原文地址：https://blog.csdn.net/m0_67794575/article/details/132665056