javascript - 在 Angular 工厂上使用 socket

我试图使用角度服务，以便从我的节点js服务器传递到我的视图json对象。
我调试了服务函数，发现它确实在获取对象，但是当我返回objects数组时，im getting on$scope.messages=undefined。
我的服务器代码：

var express = require("express");
var url = require("url");
var app = express(); // express.createServer();
var server = require('http').createServer(app);
var io = require('socket.io').listen(server);
server.listen(8080);
app.use(express.static(__dirname + '/public'));
var MongoClient = require('mongodb').MongoClient
, format = require('util').format;

var insertMsg, Collection;
var socketMap = {};

MongoClient.connect('mongodb://127.0.0.1:27017/EladGuy', function(err, db) {
    if(err)
        throw err;
    Collection = db.collection('messages');
    console.log("connected to DB");
});

app.get("/*", function(request, response) {
    var screen = url.parse(request.url).pathname;
    check = String(screen).split("=");
    check2 = String(screen).split("/");
    if (check[0] != "/screen" && check2[1] != "html") {
        response.sendFile(__dirname + '/public/index.html');
    } else {
        if (check[1]>0 && check[1]<4) {
            saveScreen = check[1];
            response.sendFile(__dirname + '/public/oldIndex.html');
        } else if (check2[1] == "html") {
            response.sendFile(__dirname + screen);
        } else {
            response.sendFile(__dirname + '/public/index.html');
        }
    }
});

io.sockets.on('connection', function(socket) {
    socket.on('sendId', function(stationId) {
        socketMap[parseInt(stationId)] = socket;
    });
    socket.on('getMessages', function(unUsed) {
        res = [];
        Collection.find({"screensId":{'$eq': parseInt(saveScreen)}}).toArray(function(err, docs) {
            docs.forEach(function(doc) {
                res.push(doc);
            });
            socket.emit('sendMessages', res);
        });
    });
    socket.on('getAllMessages',function(unUsed){
        res = [];
        Collection.find().toArray(function(err, docs) {
            docs.forEach(function(doc) {
                res.push(doc);
            });
            console.log("STAM CHECK:" + res[0].name);
            socket.emit('sendAllMessages', res);
        });
    });
});

main.js代码（用于旋转、服务和控制器）：

var myApp = angular.module('myApp', ['ngRoute']);

myApp.config(function($routeProvider) {
    $routeProvider
        .when('/',
            {
                controller: 'HomeController',
                templateUrl: 'menu.html'
            })
        .when('/stations',
            {
                controller: 'StationsController',
                templateUrl: 'messagesView.html'
            })
        .when('/',
            {
                controller: 'HomeController',
                templateUrl: 'menu.html'
            })
        .otherwise({redirectTo: '/'});
});
 var customersService = function ($http, $q) {
        var addsFactory = {};
        var socket = io.connect('http://localhost:8080');
        addsFactory.getMessages = function () {
            socket.emit('getAllMessages',null);
            socket.on('sendAllMessages',function (result) {
                return result;
            });
        };
        return addsFactory;
 };
  myApp.factory('customersService', ['$http', '$q', customersService]);


myApp.controller('StationsController',function($scope,customersService){
    $scope.messages = [];
    $scope.messages = customersService.getMessages();
});

myApp.controller('HomeController',function($scope){
    $scope.message="Loaded Menu!!";
});

有人能帮我知道我有什么问题吗？

最佳答案

将addsFactory.getMessages封装在变量customersService中。然后在外部函数中，尝试用customersService.getMessages();调用它。您所定义的方式是，customersService本身就是一个函数，其中有一个addsFactory对象和一个getMessages函数。你能看到你的函数调用怎么不匹配吗？有各种方法可以补救。您需要在外部作用域中定义此函数：

function getMessages(socket) {
    socket.emit('getAllMessages',null);
    socket.on('sendAllMessages',function (result) {
        return result;
    });
};

这样就可以将getMessages函数公开给控制器，并给它一个socket参数。然后您可以通过getMessages(io.connect('http://localhost:8080');调用它，并将返回的值传递给您想要的任何对象。你应该多读一些有角度的最佳实践。我建议John Papa's style guide。