socket.chatting.app.js

// 모듈을 추출한다. - http://localhost:52273
var http = require("http");
var fs = require("fs");
var socketio = require("socket.io");

// 웹 서버를 생성한다.
var server = http.createServer(function(request, response) {

    // HTMLPage.html 파일을 읽는다.
    fs.readFile("node_chatting.html", function(error, data) {

        response.writeHead(200, {"Content-Type" : "text/html"});
        response.end(data);
    });
}).listen(52273, function() {

    console.log("Server Running at http://127.0.0.1:52273");
});

// 소켓 서버를 만든다.
var io = socketio.listen(server);

// 접속한 사용자의 방이름, 사용자명, socket.id값을 저장할 전역변수
const loginIds = new Array();

io.sockets.on("connection", function(socket) {

    // 채팅방 입시 실행
    socket.on("access", function(data) {

        // console.log(io.sockets.adapter.rooms);

        socket.leave(socket.id);
        socket.join(data.room);

        loginIds.push({
              socket : socket.id  // 생성된 socket.id
            , room : data.room  // 접속한 채팅방의 이름
            , user : data.name   // 접속자의 유저의 이름
        });

        // 사용자가 페이지 새로고침시 loginIds 변수에 값이 누적되지 않게 동일한 사용자의 socket.id 값을 삭제한다.
        for(var num in loginIds) {

            // 사용자 이름이 같으면서, 기존소켓아이디와 현재 소켓아이디가 다른 값이 있는지 찾아낸다.
            if(loginIds[num]['user'] == data.name && loginIds[num]['socket'] != socket.id) {
               
                // loginIds의 해당 순서의 값을 삭제한다.
                loginIds.splice(num, 1);
            }
        }

        // 클라이언트의 Contact 이벤트를 실행하여 입장한 사용자의 정보를 출력한다.
        io.sockets.in(data.room).emit("contact", {
              count : io.sockets.adapter.rooms[data.room].length
            , name : data.name
            , message : data.name + "님이 채팅방에 들어왔습니다."
        });
    });

    // 채팅방 퇴장시 실행(Node.js에서 사용자의 Disconnect 이벤트는 사용자가 방을 나감과 동시에 이루어진다.)
    socket.on("disconnect", function() {

        var room = "";
        var name = "";
        var socket = "";
        var count = 0;
       
        // disconnect 이벤트중 socket.io의 정보를 꺼내는데는 에러가 발생하고,
        // 실행중인 node.js Application이 종료된다.
        // 이에따라 try ~ catch ~ finally 로 예외처리해준다.
        try {
           
            // 생성된 방의 수만큼 반복문을 돌린다.
            for(var key in io.sockets.adapter.rooms) {

                // loginIds 배열의 값만큼 반복문을 돌린다.
                var members = loginIds.filter(function(chat) {
                    return chat.room === key;
                });
   
                // 현재 소켓 방의 length와 members 배열의 갯수가 일치하지 않는경우
                if(io.sockets.adapter.rooms[key].length != members.length) {
               
                    // 반복문으로 loginIds에 해당 socket.id값의 존재 여부를 확인한다.
                    for(var num in loginIds) {

                        // 일치하는 socket.id의 정보가 없을경우 그 사용자가 방에서 퇴장한것을 알 수 있다.
                        if(io.sockets.adapter.rooms[key].sockets.hasOwnProperty(loginIds[num]['socket']) == false) {

                            // 퇴장한 사용자의 정보를 변수에 담는다.
                            room = key;
                            name = loginIds[num]['user'];

                            // loginIds 배열에서 퇴장한 사용자의 정보를 삭제한다.
                            loginIds.splice(num, 1);
                        }
                    }
                   
                    // 해당 방의 인원수를 다시 구한다.
                    count = io.sockets.adapter.rooms[key].length;
                }
            }

        } catch(exception) {

            console.log(exception);

        } finally {

            // 클라이언트의 Contact 이벤트를 실행하여 이탈한 사용자가 누군지 알린다.
            io.sockets.in(room).emit("contact", {
                  count : count
                , name : name
                , message : name + "님이 채팅방에서 나갔습니다."
            });
           
        }
      });

    // 메세지 전송 이벤트
    socket.on("message", function(data) {

        // 클라이언트의 Message 이벤트를 발생시킨다.
        io.sockets.in(data.room).emit("message", data);
    });
});

 node_chatting.html

 $ npm install --global pm2

 $ pm2 version

 pm2_test.js( 예제노드.js )

const http = require("http");

http.createServer(function(request, response) {

    response.writeHead(200, {"Content-Type":"text/html"});

    response.end("Hello World\n");

}).listen(52275, function() {

    console.log("Server Running at localhost:52273");

});

 $ pm2 start 예제파일.js

 $ pm2 start 예제노드.js --name "APP이름"

 $ pm2 list

 $ pm2 stop 인덱스번호

 $ pm2 stop APP이름

 $ pm2 start 인덱스번호

 $ pm2 start APP이름

 $ pm2 delete 인덱스번호

 $ pm2 delete APP이름

 $ pm2 show 인덱스번호
 $ pm2 show APP이름

정보

경로

 error log path

 기본경로$home .. /logs/프로세스명-error.log

 out log path

 기본경로$home .. /logs/프로세스명-out.log

 pid path

 기본경로$home .. /logs/프로세스명-0.log

 $ pm2 start 예제노드.js --name "APP이름" --ouput ./로그파일.log

 $ cat 로그파일.log

 $ pm2 start 예제노드.js --name "APP이름" --ouput ./로그파일.log --error ./로그파일.log --merge-logs

 $ cat 로그파일.log

명령 옵션

설명

 --log | -l

 · 출력 및 오류 로그를 모두 출력할 파일의 경로 지정

 --outer | -o

 · 출력 로그 파일 지정 

 --error | -e

 · 오류 로그 파일 지정

 --time

 · 표준 형식 타임스탬프를 포함한 로그 출력

 --log-data-format

 · 사용자 지정 형식 지정 타임스탬프로 있는 로그 출력

 --merge-logs

 · 동일한 앱 이름( name )으로 여러 프로세스를 실행할 때 ID로 파일을 분할하지 않게 지정

 $ pm2 logs 인덱스번호

 $ pm2 logs APP이름

 $ pm2 monit

 $ sudo apt-get install -y build-essential

 $ curl -sl https://deb.nodesource.com/setup_버전 숫자.x | sudo -E bash -

 $ sudo apt-get install -y nodejs

  $ node

 > console.log('Hello Wicked Miso .. !');

 $ cd /usr/lib/node_modules/npm/node_modules

 :/usr/lib/node_modules/npm/node_modules$ ls -al