運行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連接多個事件

回答

相關問題