【飞凌嵌入式OK527N-C开发板体验】终章-传感器数据互通

趁最近空闲点，有点时间，先把任务完成。实现传感器的数据互通。最终效果见顶部的视频。

最开始定的任务是包含温湿度数据的，但是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;
}