搭建简易的物联网服务端和客户端-Nodejs_express服务(六)

时间:2022-07-23
本文章向大家介绍搭建简易的物联网服务端和客户端-Nodejs_express服务(六),主要内容包括其使用实例、应用技巧、基本知识点总结和需要注意事项,具有一定的参考价值,需要的朋友可以参考一下。

昨天完成了将STM32采集到的温湿度数据传到服务端,存入Mysql数据库的操作。今天做的是通过express连接数据库,提供接口,让前端页面通过fetch获取数据。其中遇到了跨域问题,在express中解决了。 代码地址:https://github.com/klren0312/stm32_wifi 2017.3.21

搭建简易的物联网服务端和客户端目录

Express服务端与前端获取

1.Express服务端代码

1)连接数据库(前面已经有介绍了)

var mysql = require('mysql');
//数据库配置
var conn = mysql.createConnection({
    host:'localhost',
    user:'root',
    password:'root',
    database:'nodemysql',
    port:3306
});
//连接数据库
conn.connect();

2)Express跨域解决

解决了前端的已拦截跨源请求:同源策略禁止读取位于 http://127.0.0.1:3000/mysql 的远程资源。(原因:CORS 头缺少 'Access-Control-Allow-Origin')。错误

//设置所有路由无限制访问,不需要跨域
app.all('*',function(req,res,next){
    res.header("Access-Control-Allow-Origin","*");
    res.header("Access-Control-Allow-Headers","X-Requested-With");
    res.header("Access-Control-Allow-Methods","PUT,POST,GET,DELETE,OPTIONS");
    res.header("X-Powered-By",'3.2.1');
    res.header("Content-Type","application/json;charset=utf-8");
    next();
})

3)路由配置(提供接口)

两个接口,分别是温度和湿度数据。提供最新的五个数据

app.get('/tem',function(req,res){
    var tem = [];
    conn.query('SELECT * FROM env',function(err,rows,fields){
        var i  = rows.length;
        var i = rows.length;
        var j =i-5;
        var c= 0;
        while(j < i ){
            tem[c] = rows[j].tem;
            c++;
            j++;
        }
        res.send(JSON.stringify(tem));
    })
})
//湿度
app.get('/hum',function(req,res) {
    var hum = [];
    conn.query('SELECT * FROM env',function(err,rows,fields){
        var i = rows.length;
        var j =i-5;
        var c= 0;
        while(j<i){
            hum[c] = rows[j].hum;
            c++;
            j++;
        }
        res.send(JSON.stringify(hum));
    }) 
});

4)express服务器配置

设置端口为3000

//端口:3000
var server = app.listen(3000,function(){
    var host = server.address().address;
    var port = server.address().port;

    console.log(host + "  " + port);
})

2.前端代码

使用fetch取代ajax(fetch与XMLHttpRequest(XHR)类似,fetch()方法允许你发出AJAX请求。区别在于Fetch API使用Promise,因此是一种简洁明了的API,比XMLHttpRequest更加简单易用。)

<!DOCTYPE html>
<html lang="en">
<head>
    <meta charset="UTF-8">
    <title>jsonptest</title>
</head>
<body>
    <script>
        function status(response){
            if(response.status>=200 && response.status<300){
                return Promise.resolve(response);
            }
            else{
                return Promise.reject(new Error(response.statusText));
            }
        }
        function json(response){
            return response.json();
        }
        //设置接口地址
        fetch("http://127.0.0.1:3000/tem")
        .then(status)
        .then(json)
        .then(function(data){
            console.log("请求成功,JSON解析后的响应数据为:",data);
        })
        .catch(function(err){
            console.log("Fetch错误:"+err);
        });
    </script>
</body>
</html>

3.结果截图

1)postman请求温度截图

tem

2)postman请求湿度截图

3)前端fetch获取到的温度数据截图

@治电小白菜 20170321