0

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

应用程序.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.TEST1[1],values.TEST1[2],values.TEST7[0],values.TEST7 获取所有数据[1],values.TEST7[2] 这个数据传递给

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);
    });

})

帮我解决这个问题

4

0 回答 0