如何使用angular-socket-io庫設置socket.io服務器？

Question

答案中重複並不是指的是在我的代碼中使用了angularjs庫，因爲路上的角度設置的角度插座-IO是不相似的重複提供的答案！

剛開始工作在socket.io第一次我發現angular-socket-io圖書館工作在客戶端但它看起來有點複雜，我只是想發送消息從服務器到客戶端使用角度套接字庫，但它沒有發生任何想法在下面的代碼中實現了什麼錯誤？

的index.html

<script src="bower_components/socket.io-client/socket.io.js"></script> 
<script src="bower_components/angular-socket-io/socket.js"></script> 

server.js

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

    io.on('connection', function(client) { 
     console.log('Client connected...'); 
     io.emit('message', message); 
    }); 


server.listen(3000); 

angularSOcketFactory.js

angular.module('loggingApp').factory('mySocket', function (socketFactory) { 
    'use strict'; 
    return socketFactory(); 
}); 

angularCtrl.js

$scope.$on('socket:someEvent', function (ev, data) { 
     $scope.theData = data; 
    }); 

Answer 1

有一個關於如何創建角自己socket.io提供商excellent tutorial。

我已經在我的AngularJS應用程序中成功地使用了它，我在該要點中也有一個completed version的源代碼。這是設置爲Browserify，但你可以通過只擺脫兩個require('');聲明該文件在頂部的撤消。

以下是Socket.io提供程序的源代碼，您只需將其掛接到控制器即可。所有的功勞都屬於Maciej Sopylo，因爲這個方法使用了教程。

(function() { 
    'use strict'; 

    var angular = require('angular'); 
    var io = require('socket.io-client'); 

    angular 
    .module('socket.io', []) 
    .provider('$socket', $socketProvider); 

    /* @ngInject */ 
    function $socketProvider() { 
    var ioUrl = ''; 
    var ioConfig = {}; 

    // Private Function to assign properties to ioConfig 
    function setOption(name, value, type) { 
     if (typeof value !== type) 
     throw new TypeError('\'' + name + '\' must be of type \'' + type + '\''); 
     else 
     ioConfig[name] = value; 
    } 

    this.$get = function $socketFactory($rootScope) { 
     var socket = io(ioUrl, ioConfig); 

     return { 
     on: function on(event, callback) { 
      socket.on(event, function() { 
      var resData = arguments; 

      $rootScope.$apply(function() { 
       callback.apply(socket, resData); 
      }); 
      }); 
     }, 
     off: function off(event, callback) { 
      if (typeof callback === 'function') 
      socket.removeListener(event, callback); 
      else 
      socket.removeAllListeners(event); 
     }, 
     emit: function emit(event, data, callback) { 
      if (typeof callback === 'function') { 
      socket.emit(event, data, function() { 
       callback.apply(socket, arguments); 
      }); 
      } 
      else 
      socket.emit(event, data); 
     } 
     }; 
    }; 

    this.setConnectionUrl = function setConnectionUrl(url) { 
     if (typeof url === 'string') 
     ioUrl = url; 
     else 
     throw new TypeError('url must be of type string'); 
    }; 

    this.setPath = function setPath(value) { 
     setOption('path', value, 'string'); 
    }; 

    this.setConnectTimeout = function setConnectTimeout(value) { 
     setOption('connect timeout', value, 'number'); 
    }; 

    this.setTryMultipleTransports = function setTryMultipleTransports(value) { 
     setOption('try multiple transports', value, 'boolean'); 
    }; 

    this.setReconnect = function setReconnect(value) { 
     setOption('reconnect', value, 'boolean'); 
    }; 

    this.setReconnectionDelay = function setReconnectionDelay(value) { 
     setOptions('reconnection delay', value, 'number'); 
    }; 

    this.setReconnectionLimit = function setReconnectionLimit(value) { 
     setOptions('max reconnection attempts', value, 'number'); 
    }; 

    this.setSyncDisconnectOnUnload = function setSyncDisconnectOnUnload(value) { 
     setOptions('sync disconnect on unload', value, 'boolean'); 
    }; 

    this.setAutoConnect = function setAutoConnect(value) { 
     setOptions('auto connect', value, 'boolean'); 
    }; 

    this.setFlashPolicyPort = function setFlashPolicyPort(value) { 
     setOptions('flash policy port', value, 'number'); 
    }; 

    this.setForceNewConnection = function setForceNewConnection(value) { 
     setOptions('force new connection', value, 'boolean'); 
    }; 
    } 

})();