如何使用 Socket.io、node.js 发出传感器流式传输的响应

Question

我有一个 URL，它从传感器传输数据，例如温度和湿度。现在，如果我的 API 使用 socket.io 对特定路由进行调用，我需要获取数据流并将其显示在客户端仪表板的图表中。我对如何从传感器的 URL 获取响应以及如何在仪表板上显示为图表感到困惑。以下是我的示例代码，它以 json 对象的形式连续返回日期、小时、分钟和秒。我想将传感器数据的动态响应作为 json 对象在套接字发射函数中流式传输。

const express = require('express');
const app = express();
const port = 3000;
var url = require('url');
var fs = require('fs');
const server = require('http').createServer();
var link = "http:www.xample.com/usr/api/data/:deviceId";
server.listen(port,function(){
    console.log("Server Listening on port: "+port);
});

const io = require('socket.io')(server);
io.on('connection',function(socket){
setInterval(function(){
    socket.emit('date', 
    {
        'date': new Date().getDate(),
        'hour': new Date().getHours(),
        'minutes': new Date().getMinutes(),
        'seconds': new Date().getSeconds()
    });           
}, 1000);

socket.emit("welcome","Socket Connection is successful!");
});

const iot = require('socket.io-client');
let socket = iot.connect("http://localhost:3000");
socket.on("date",function(data){
    console.log(data);
});

socket.on("welcome",function(data){
    console.log("Connection Status: ", data);
});

Answer 1

我强烈建议阅读 Socket.io Client API Docs 和 Server API Docs

您可以开始使用的示例代码：

Client.js：

import React, {useState} from 'react';
import io from 'socket.io-client';

let socket;

const Client = () => {

    const [temperature, setTemperature] = useState(0);
    const [humidity, setHumidity] = useState(0);

    if (!socket) {
        socket = io('https://localhost:8080', {
            path: '/sensorInfo' 
        });

        socket.on('temperatureChange', (value) => {
            setTemperature(value);
        });

        socket.on('humidityChange', (value) => {
            setHumidity(value);
        })
    }

    return (
        <div>
            <p>The temperature logged is: {temperature}</p>
            <p>The humidity logged is: {humidity}</p>
        </div>
    );

}

export default Client;

Sensor.js：

const handleTemperatureChange = (v) => {
    let temperature = v;
    socket.emit('temperatureChange', {temperature});
}

const handleHumidityChange = (v) => {
    let humidity = v;
    socket.emit('humidityChange', {humidity});
}

这绝对不是一个完整的解决方案，因为它确实取决于您的系统设计，但希望它足以开始。