如何使用 Socket io 从函数中发出数据

问题描述

我是 NodeJS 的初学者，我正在使用 node7 库从 S71200 PLC 设备获取数据，我想使用 socket io emit 传递数据，但我无法将数据传递到我的代码下方的 socket io发射

app.js

var app = require('express')();
var http = require('http').Server(app);
var io = require('socket.io')(http);
var nodes7 = require('nodes7');  // This is the package name,if the repository is cloned you may need to require 'nodeS7' with uppercase S
var conn = new nodes7;
var doneReading = false;
var doneWriting = false;
var variables = { 
        
          TEST7: 'DB1,INT2.3',TEST1: 'DB1,X0.0.3',TEST2: 'DB1,INT2'
};

conn.initiateConnection({port: 102,host: '127.0.0.1',rack: 0,slot: 1},connected); 
function connected(err) {
    if (typeof(err) !== "undefined") {
        // We have an error.  Maybe the PLC is not reachable.
        console.log(err);
        process.exit();
    }
    conn.setTranslationCB(function(tag) {return variables[tag];});  // This sets the "translation" to allow us to work with object names
    conn.addItems(['TEST7','TEST1']);
    //conn.writeItems('TEST2',90,valuesWritten);
    setInterval(function(){
        conn.readAllItems(valuesReady);
    },1000)
    
}

function valuesReady(anythingBad,values) {
    if (anythingBad) { console.log("SOMETHING WENT WRONG READING VALUES!!!!"); }
   
    console.log(values.TEST1[0],values.TEST1[1],values.TEST1[2],values.TEST7[0],values.TEST7[1],values.TEST7[2]);
   
    //console.log( typeof(temp));
    doneReading = true;
     
}
function valuesWritten(anythingBad) {
    if (anythingBad) { console.log("SOMETHING WENT WRONG WRITING VALUES!!!!"); }
    console.log("Done writing.");
    doneWriting = true;
}
io.on('connection',function(socket){
    console.log('one user connected '+socket.id);
    socket.emit("channelname",{
        message: "Passing S71200 data"
      });
      
    socket.on('disconnect',function(){
        console.log('one user disconnected '+socket.id);
    });

})

http.listen(3000,function(){
    console.log('server listening on port 3000');
})

我正在使用间隔函数，因为每秒从 PLC 设备获取数据，我从 values.TEST1[0],values.TEST7[0] 获取所有数据， values.TEST7[1],values.TEST7[2] 这个数据传给

io.on('connection',{
        message: "Passing S71200 data"
      });

    socket.on('disconnect',function(){
        console.log('one user disconnected '+socket.id);
    });

})

帮我解决这个问题

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）