运行socket.io连接多个事件

如何在服务器上运行多个套接字事件/ socket.on（）？恩。运行socket.io连接多个事件

var express = require('express'), 
app = express(); 
server = require('http').createServer(app); 
io = require('socket.io').listen(server) 

server.listen(8080); 

io.sockets.on('connection', function(socket) { 

     socket.on('node1', function(data){ 
       io.sockets.emit('node1 message', data); 
     }); 
     socket.on('node2', function(data){ 
       io.sockets.emit('node2 message', data); 
     }); 

});

当我运行客户端如下，消息得到广播。

socket.emit('node1','Hello World');

但是在node2上，什么都没有发生。

socket.emit('node2','Hello World');

谢谢！

对不起，

这就是我在客户端运行（发送数据）。

<!DOCTYPE html> 
<html> 
<head> 
<title>nodes_update</title> 
</head> 
<body> 
<script src="http://192.168.0.1:8080/socket.io/socket.io.js"></script> 
<script type="text/JavaScript"> 

    var socket = io('http://192.168.0.1:8080/'); 
     socket.emit('<?php echo $_REQUEST["node"] ?>','<?php echo $_REQUEST["node_message"] ?>'); 
</script> 
</body> 
</html>

在接收端。

<!DOCTYPE html> 
<head> 
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8"> 
</head> 
<body> 
</body> 
<script src="http://192.168.0.1:8080/socket.io/socket.io.js"></script> 
<script type="text/JavaScript"> 

      var socket = io('http://192.168.0.1:8080/'); 
      socket.on('<?php echo $_REQUEST["node"] ?>', function(data) { 

       // plot_data(data); 

      }); 
</script> 
</html> 



<?php echo $_REQUEST["node"] ?> //is the node number ex "node1" or "node2" 
<?php echo $_REQUEST["node_message"] ?> //is the data of the node ex "Temp-90".

http://192.168.0.1/show_node_data.php?node=node1+message&node_message=Temp-90

这是绘制多个节点的数据

谢谢！

来源

2017-08-17 QLion

无法重现。你的客户端代码是什么样的？ – robertklep

喜页上node_data.php <脚本类型= “文本/ JavaScript的”> \t var socket = io（'http://192.168.0.1:8080/'）; （''？php echo $ _REQUEST [“node”];？>'，'<？php echo $ _REQUEST [“node_data”];？>'）; – QLion

请将此添加到您的问题。另外，我没有看到这两种类型的消息（“node1消息”和“node2消息”）的侦听器。 – robertklep

好吧我重新编码服务器使用mysql做节点名称查找，然后发送数据到页面与节点名称发现其他什么都不发送。

server.js

var express = require('express'), 
app = express(); 
server = require('http').createServer(app); 
io = require('socket.io').listen(server) 
server.listen(8080); 
var mysql = require('mysql'); 
var connection = mysql.createConnection('mysql://moo:[email protected]/node_db'); 
connection.connect(); 





io.sockets.on('connection', function(socket) { 

     socket.on('send message', function(data){ 
       var token = data.token; 
       var message = data.message; 

       var queryToken = 'SELECT COUNT(*) as num FROM `node_token` where node_token = ' + connection.escape(token); 

       connection.query(queryToken, function(err, rows, fields) { 
         if (err) throw err; 
         //console.log(rows[0].num); 
         //console.log(token); 
         //console.log(message); 

         var node_name = rows[0].num; 

         if(node_name != 0) { 
           console.log("Node name found in DB"); 
           io.sockets.emit(token, message); 
         }else{ 
         console.log("Node name not found in db"); 
         } 

       }); 
     }); 

});

数据库表;

+----+------------+---------------+ 
| id | node_token | node_owner_id | 
+----+------------+---------------+ 
| 2 | node1  |    1 | 
| 3 | node2  |    1 | 
+----+------------+---------------+ 
2 rows in set (0.00 sec)

发送数据页 “node_update.php？节点=节点1 & node_message = TEMP-90”

<!DOCTYPE html> 
<html> 
<head> 
<title>nodes_update</title> 
</head> 
<body> 
<script src="http://192.168.0.1:8080/socket.io/socket.io.js"></script> 
<script type="text/JavaScript"> 

    var token = <?php echo $_REQUEST["node"]; ?>; 
    var message = <?php echo $_REQUEST["node_message"]; ?>; 

    var socket = io('http://192.168.0.1:8080/'); 
    socket.emit('send message',{token:token, message:message}); 
</script> 
</body> 
</html>

收到数据页 “node_get_data.php？节点=节点1”

<!DOCTYPE html> 
<head> 
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8"> 
</head> 
<body> 
</body> 
<script src="http://192.168.0.1:8080/socket.io/socket.io.js"></script> 
<script type="text/JavaScript"> 

      var socket = io('http://192.168.0.1:8080/'); 
      socket.on('<?php echo $_REQUEST["node"]; ?>', function(data) { 

       //plot(data); 

      }); 
</script> 
</html>

这样我可以使用无限节点并将它们添加到数据库。

感谢您的帮助！

来源

2017-08-17 11:49:53 QLion

运行socket.io连接多个事件

回答

相关问题