socketio 本地聊天室 ing

Author: topshadow

.bowerrc

@@ -0,0 +1,3 @@
+{
+  "directory": "www/lib/"
+}

app/app.js

@@ -9,7 +9,7 @@ process.env.NODE_ENV = process.env.NODE_ENV || 'developement';
     var app = express();
     var server = require('http').Server(app);
     //socket.io
-// require('../config/socket-io')(server);
+require('../config/socket-io')(server);
 
     var port = 3000;
     server.listen(process.env.PORT || port, function (err) {

config/express.js

@@ -14,11 +14,12 @@ module.exports = function() {
 
 //跨域问题
     app.all('*', function(req, res, next) {
-        res.header("Access-Control-Allow-Origin", "*");
+        res.header("Access-Control-Allow-Origin", "http://localhost:3000");
         res.header("Access-Control-Allow-Headers", "X-Requested-With");
         res.header("Access-Control-Allow-Methods","PUT,POST,GET,DELETE,OPTIONS");
+        res.header("Access-Control-Allow-Credentials",true);
         res.header("X-Powered-By",' 3.2.1');
-        res.header("Content-Type", "application/json;charset=utf-8");
+        // res.header("Content-Type", "application/json;charset=utf-8");
         next();
     });
 

config/socket-io.js

@@ -2,18 +2,15 @@
 
 module.exports=async function (server){
     var io = require('socket.io')(server);
-    var connect =async function(server) {
-        return  new Promise(function(resolve,reject){
-            io.on('connection', function (socket) {
-
-                socket.emit('login', '登陆成功');
-                resolve(socket);
-            });
+    io.on('connection', function (socket){
+        console.log('一位用户已经登录');
+        socket.emit('new connect', '新的用户已经登录');
+        socket.on('send message',function(msg){
+            socket.broadcast.emit('receive message',msg);
         });
-    };
-    //聊天应用程序逻辑
-    var socket = await  connect(server);
-    socket.emit('login','登录成功');
-
-    return socket;
+        socket.on('login',function(msg){
+            console.log(msg);
+        });
+        //聊天应用程序逻辑
+    });
 };

www/js/app/controller.js

@@ -1,3 +1,5 @@
+
+var socket;
 angular.module('app.controller',[])
 .controller('SignInCtrl', function($http,$scope, $state,$ionicPopup,$timeout,popup,$ionicNavBarDelegate,userService) {
     $scope.user = {};
@@ -38,9 +40,12 @@ angular.module('app.controller',[])
         };
     })
 
-    .controller('menuCtrl',function($scope,camera,$ionicActionSheet,$ionicSlideBoxDelegate,userService){
-        var socket = io(config.serverUrl);
-
+    .controller('menuCtrl',function($scope,camera,$ionicActionSheet,config,$ionicSlideBoxDelegate,userService){
+        socket = io('http://localhost:3000');
+        socket.on('connect', function (data) {
+            console.log(data);
+            socket.emit('login', '一个用户已经登录');
+        });
 
     $scope.changeHeader = function(){
 
@@ -55,7 +60,7 @@ angular.module('app.controller',[])
         // Called each time the slide changes
         $scope.slideChanged = function(index) {
             $scope.slideIndex = index;
-        }
+        };
             // .controller('tabMessageCtrl', function($scope, $stateParams, Chats) {
             //     $scope.chat = Chats.get($stateParams.chatId);
             // })

www/js/app/tool.js

@@ -27,8 +27,6 @@ factory('config',function(){
             alert(err);
              });
         }
-
-    
 }).factory('popup',function($ionicPopup,$timeout){
     return{
         show:function(title,subTitle){

www/js/chat/controllers.js

@@ -10,62 +10,19 @@ angular.module('chat.controllers', [])
 })
 
 .controller('messageCtrl', function($scope, $state, $ionicPopup, localStorageService, messageService) {
-    
-    // $scope.messages = messageService.getAllMessages();
-    // console.log($scope.messages);
+    socket = io.connect('http://localhost:3000');
+    socket.emit('send message','杨杰');
     $scope.onSwipeLeft = function() {
         $state.go("tab.friends");
     };
-    $scope.popupMessageOpthins = function(message) {
-        $scope.popup.index = $scope.messages.indexOf(message);
-        $scope.popup.optionsPopup = $ionicPopup.show({
-            templateUrl: "templates/popup.html",
-            scope: $scope,
-        });
-        $scope.popup.isPopup = true;
-    };
-    $scope.markMessage = function() {
-        var index = $scope.popup.index;
-        var message = $scope.messages[index];
-        if (message.showHints) {
-            message.showHints = false;
-            message.noReadMessages = 0;
-        } else {
-            message.showHints = true;
-            message.noReadMessages = 1;
-        }
-        $scope.popup.optionsPopup.close();
-        $scope.popup.isPopup = false;
-        messageService.updateMessage(message);
-    };
-    $scope.deleteMessage = function() {
-        var index = $scope.popup.index;
-        var message = $scope.messages[index];
-        $scope.messages.splice(index, 1);
-        $scope.popup.optionsPopup.close();
-        $scope.popup.isPopup = false;
-        messageService.deleteMessageId(message.id);
-        messageService.clearMessage(message);
-    };
-    $scope.topMessage = function() {
-        var index = $scope.popup.index;
-        var message = $scope.messages[index];
-        if (message.isTop) {
-            message.isTop = 0;
-        } else {
-            message.isTop = new Date().getTime();
-        }
-        $scope.popup.optionsPopup.close();
-        $scope.popup.isPopup = false;
-        messageService.updateMessage(message);
-    };
     $scope.messageDetils = function(message) {
         $state.go("messageDetail", {
             "messageId": message.id
         });
     };
+
     $scope.$on("$ionicView.beforeEnter", function(){
-        // console.log($scope.messages);
+        console.log($scope.messages);
         $scope.messages = messageService.getAllMessages();
         $scope.popup = {
             isPopup: false,
@@ -99,7 +56,6 @@ angular.module('chat.controllers', [])
         var viewScroll = $ionicScrollDelegate.$getByHandle('messageDetailsScroll');
         // console.log("enter");
         $scope.doRefresh = function() {
-            // console.log("ok");
             $scope.messageNum += 5;
             $timeout(function() {
                 $scope.messageDetils = messageService.getAmountMessageById($scope.messageNum,
@@ -109,13 +65,7 @@ angular.module('chat.controllers', [])
         };
         var id=31;
         $scope.sendMessage = function(){
-            id++;
-            $scope.messageDetils.push({
-                $$hashKey: "object:"+id,
-                content: $scope.send_content,
-                isFromeMe: false,
-                time: "2015-11-27 06:34:55"
-            });
+            socket.emit('send message',$scope.send_content);
             viewScroll.scrollBottom();
         };