趁最近空闲点，有点时间，先把任务完成。实现传感器的数据互通。最终效果见顶部的视频。
最开始定的任务是包含温湿度数据的，但是OK527N开发板上并不带温湿度传感器，所以就用了cpu的温度作为参考，目前无法检测外部环境温度和湿度数据。
可以参考之前写的文章，验证了ADC功能，led功能，wifi功能、can功能、gpio功能、蜂鸣器功能、usb等设备。这里只挑选了一部分比较直观的功能在上位机中显示。
上位机界面：
程序见下面，主要是创建线程，创建tcp service，监听tcp client的连接，连接上后发送温度信息给客户端，客户端可以下发控制命令控制板子上的器件如led，蜂鸣器等。
有时间再研究下linux的can发送和接收。
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <netinet/in.h>
#include <sys/socket.h>
#include <fcntl.h>
#include <unistd.h>
#include <string.h>
#include <signal.h>
#include <pthread.h>
#include<sys/ioctl.h>
#include<sys/types.h>
#include<sys/stat.h>
#include<termios.h>
#include<errno.h>
#define PORT 8080
#define BUFFER_SIZE 1024
#define MAXLINE 256
extern int wifi_Connect(void);
static int stop = 0;
pthread_t read_id, write_id;
int server_fd, new_socket;
void beep_onoff(int sta)
{
if(sta == 1)
{
system("echo 8 > /sys/class/pwm/pwmchip0/export");
system("echo 10000000 > /sys/class/pwm/pwmchip0/pwm8/period");
system("echo 5000000 > /sys/class/pwm/pwmchip0/pwm8/duty_cycle");
system("echo 1 > /sys/class/pwm/pwmchip0/pwm8/enable");
}
else if(sta == 0)
{
system("echo 0 > /sys/class/pwm/pwmchip0/pwm8/enable");
system("echo 8 > /sys/class/pwm/pwmchip0/unexport");
}
}
void led_onoff(int sta)
{
if(sta == 1)
{
system("echo none > /sys/class/leds/heartbeat/trigger");
system("echo 1 > /sys/class/leds/heartbeat/brightness");
}
else if(sta == 0)
{
system("echo none > /sys/class/leds/heartbeat/trigger");
system("echo 0 > /sys/class/leds/heartbeat/brightness");
}
else if(sta == 2)
{
system("echo heartbeat > /sys/class/leds/heartbeat/trigger");
}
}
int read_CpuTemp(void)
{
int fd;
char buffer[1024];
int bytesRead;
fd = open("/sys/class/thermal/thermal_zone0/temp", O_RDONLY);
if (fd == -1) {
perror("Error opening file");
return EXIT_FAILURE;
}
// 读取文件内容
bytesRead = read(fd, buffer, sizeof(buffer) - 1);
if (bytesRead == -1) {
perror("Error reading file");
close(fd);
return EXIT_FAILURE;
}
printf("%d bytes read)\n", bytesRead);
buffer[bytesRead] = '\0';
int temp = atoi(buffer);
return temp;
}
static void quit(int sig)
{
(void)sig;
stop = 1;
close(new_socket);
close(server_fd);
_exit(0);
}
/*
当客户端断开连接的时候，
在服务端socket send进程可以收到收到信号SIGPIPE，
收到SIGPIPE信号进入该函数结束创建的线程。
*/
void signal_pipe(int signo)
{
pthread_kill(read_id, SIGQUIT);//向read线程发送SIGQUIT
pthread_join(read_id, NULL); //阻塞线程运行，直到read 线程退出。
close(new_socket); //关闭连接
printf("read pthread out \n");
pthread_exit(0); //结束write 线程
}
/*
read 线程接收到SIGQUIT信号，
执行线程退出操作
*/
void pthread_out(int signo)
{
pthread_exit(0);
}
/*
read 线程执行函数
*/
void* read_func(void* arg)
{
char readbuff[MAXLINE];
int n = 0;
int fd;
fd = *(int*)arg; /*main 主进程传递过来的连接文件描述符*/
memset(&readbuff,0,sizeof(readbuff));
signal(SIGQUIT,pthread_out); /* 注册SIGQUIT 信号*/
while(1)
{
n = recv(fd, readbuff, MAXLINE, 0); /*recv 在这里是阻塞运行*/
if(n > 0)
{
if(readbuff[0] == 0xA0 && readbuff[1] == 0x5A)
{
if(readbuff[2] == 0x33)
{
beep_onoff(readbuff[3]);
printf("beep sta:%d\n", readbuff[3]);
}
else if(readbuff[2] == 0x34)
{
led_onoff(readbuff[3]);
printf("led sta:%d\n", readbuff[3]);
}
}
}
};
}
/*
write 线程执行函数
*/
void* write_func(void* arg)
{
char writebuff[MAXLINE];
int fd;
int cpu_Temp;
fd = *(int*)arg;
memset(&writebuff,0,sizeof(writebuff));
signal(SIGPIPE,signal_pipe); /* 注册 SIGPIPE信号 */
while(1)
{
sleep(1);
cpu_Temp = read_CpuTemp();
printf("temp: %d\n", cpu_Temp);
send(fd, &cpu_Temp, sizeof(int),0);/*向客户端发送数据*/
}
}
int main(int argc, char *argv[])
{
int ret = 0;
struct sockaddr_in address;
int opt = 1;
int addrlen = sizeof(address);
char *hello = "Hello from server";
int cpu_Temp = 0;
ret = wifi_Connect();
if(ret != 0)
{
printf("Failed to connect to WiFi\n");
return -1;
}
// 创建套接字
if ((server_fd = socket(AF_INET, SOCK_STREAM, 0)) == 0)
{
perror("socket failed");
exit(EXIT_FAILURE);
}
// Forcefully attaching socket to the port 8080
if (setsockopt(server_fd, SOL_SOCKET, SO_REUSEADDR | SO_REUSEPORT, &opt, sizeof(opt)))
{
perror("setsockopt");
exit(EXIT_FAILURE);
}
address.sin_family = AF_INET;
address.sin_addr.s_addr = INADDR_ANY;
address.sin_port = htons(PORT);
if(bind(server_fd, (struct sockaddr *)&address, sizeof(address)) < 0)
{
printf("bind failed");
exit(EXIT_FAILURE);
}
if(listen(server_fd, 3) < 0)
{
printf("listen error");
exit(EXIT_FAILURE);
}
printf("creat tcp server succeeded\n");
signal(SIGINT, quit);
while(1)
{
if((new_socket = accept(server_fd, (struct sockaddr *)&address, (socklen_t *)&addrlen)) < 0)
{
printf("accept errror");
exit(EXIT_FAILURE);
}
printf("%d connect succeeded\n", new_socket);
if(pthread_create(&read_id,NULL,read_func,&new_socket))/*创建 read 线程*/
{
printf("pthread_create read_func err\n");
}
if(pthread_create(&write_id,NULL,write_func,&new_socket))/*创建 write 线程*/
{
printf("pthread_create write_func err\n");
}
pthread_join(write_id,NULL); /*阻塞，直到write进程退出后才进行新的客户端连接*/
printf("write pthread out \n");
send(new_socket, hello, sizeof(hello), 0);
printf("Hello message sent to client\n");
// read(new_socket, buffer, BUFFER_SIZE);
// printf("Client: %s\n", buffer);
send(new_socket, &cpu_Temp, sizeof(int), 0);
sleep(1);
}
return 0;
}
更多回帖
