2

我是 express.io 的新手。我有一组代码在 socket.io 中运行，带有 node.js 和 angular 在前端没有问题。我创建了服务器，它以 1000 毫秒的间隔发出一组数据。示例与客户端交互的服务器代码是

var serverjson = [
                 {"Product": "REL", "BBP": "10", "BSP": "10.2", "LTP": "10.1" }, 
                 {"Product": "BEL", "BBP": "20", "BSP": "20.4", "LTP": "20"    }, 
                 {"Product": "MTL", "BBP": "50", "BSP": "50.5", "LTP": "50.1"  }, 
                 {"Product": "BSL", "BBP": "100", "BSP": "101", "LTP": "100.2" }
                 ];
// define interactions with client
app.io.route('ready', function(req){
    //send data to client
    setInterval(function(){
        for(i=0;i<serverjson.length;i++)
        {
            serverjson[i].BBP = Math.round((parseInt(serverjson[i].BBP) + Math.random())*100)/100;
            serverjson[i].BSP = Math.round((parseInt(serverjson[i].BSP) + Math.random())*100)/100;
            serverjson[i].LTP = Math.round((parseInt(serverjson[i].LTP) + Math.random())*100)/100;
        }
        var serverjsonstr = JSON.stringify(serverjson);
        req.io.emit('msg', {'msg': serverjsonstr});
    }, 1000);

});

在客户端

<!doctype html>
<html>
  <head>
    <title>express.io Test</title>
    <script src="/socket.io/socket.io.js"></script>
    <script src="https://ajax.googleapis.com/ajax/libs/jquery/1.7.2/jquery.js"></script>
  </head>
    <body>
        <script>    
          var io = io.connect();
          io.emit('ready');
          io.on('msg', function(data){
            $('#msg').text(data.msg);
          });
        </script>
        <div id="msg"></div>
      </body>
</html>

到此为止，一切都运行有问题。数据以间隔正确显示。但在另一个页面中，我想用角度控制器显示数据。我在 socket.io 中做了同样的例子。对于控制器，代码是

var apps = angular.module('stocksample', []);

apps.controller('StockListCtrl', function($scope, socket) { 
  $scope.stocks = [];
  socket.on('msg', function(data) {
        $scope.stocks = JSON.parse(data.msg);           
    });
});

apps.factory('socket', function($rootScope) {
    var socket = io.connect();
    return {
        on: function(eventName, callback) {
            socket.on(eventName, function() {
                var args = arguments;
                $rootScope.$apply(function() {
                    callback.apply(socket, args);
                });
            });
        },
    };
});

并且对于 socket.io 运行良好，只要 io.emit for 'msg' 发生并显示在其他页面中，它就会绑定股票数据。我需要使用 express.io 为同一个控制器编写代码。请提供任何建议。帮助将不胜感激。

4

1 回答 1

2

终于解决了。我忘了提供socket.emit('ready'); 在我的角工厂

所以工厂的代码现在是

apps.factory('socket', function($rootScope) {
    var socket = io.connect();
    socket.emit('ready');
    return {
        on: function(eventName, callback) {
            socket.on(eventName, function() {
                var args = arguments;
                $rootScope.$apply(function() {
                    callback.apply(socket, args);

                });
            });
        }
    };
});
于 2015-04-18T07:50:12.773 回答