The Pursuit of Happyness

반응형

MongoDB는 고성능, 고가용성 그리고 오토스케일링을 지원하는 오픈소스 Document DB 입니다.


MongoDB에서의 Document는 Object 형식의 데이터를 이야기하며 입출력은 json 포맷입니다.


실제 데이터는 BSON 형태로 저장되며, 각 Document Object 는 유니크한 ID를 가지게 됩니다.



--------



Mac에서의 설치는 homebrew를 이용해서 할 수 있습니다. homebrew 설치는 http://brew.sh/ 사이트를 참고하세요.


MongoDB 설치를 위해 터미널을 열고 다음과 같이 입력합니다.


$ brew install mongodb



/usr/local/Cellar/mongodb/[version] 에 설치가 됩니다.


설치된 버전 확인은 다음 명령어를 이용하면 됩니다.



$ mongo --version 



MongoDB 서버 실행은 다음의 명령어로 합니다. (MongoDB 서버가 실행이 되면 종료되기 전까지는 Mac을 재부팅해도 계속 돌아갑니다.)


 $ brew services start mongodb



데이터는 설정을 변경하지 않았다면 /usr/local/var/mongodb 에 저장됩니다.


종료는 다음과 같이 합니다.



$ brew services stop mongodb 



데이터 저장 위치를 변경하고자 하면 아래 파일에서 dbPath를 수정하면 됩니다.


/usr/local/etc/mongod.conf


반응형

반응형

실행환경 Ubuntu 14.04 LTS / node v0.10.25


이번에는 events 모듈을 이용한 채팅서버 코드이다.

events 모듈을 이용하여 원하는 명령어에 대한 동작을 다음과 같이 구현하면 된다.

event를 전송하는 channel 객체를 생성하고, 채널 객체에 clients 에는 소켓들을, subscriptions 에는 각 클라이언트에 전달하는 메써드를 지정한다.

클라이언트 연결시에는 'join' 이벤트가, 연결 종료시에는 'leave' 이벤트가 처리된다.


var events = require('events');
var net = require('net');

var channel = new events.EventEmitter();
channel.clients = {};
channel.subscriptions = {};

channel.on('join',
        function(id, client) {
                this.clients[id] = client;
                this.subscriptions[id] = function(senderId, message) {
                        if (id != senderId) {
                                this.clients[id].write(message);
                        }
                }
                this.on('broadcast', this.subscriptions[id]);
        }
);

channel.on('leave',
        function(id) {
                channel.removeListener('broadcast', this.subscriptions[id]);
                channel.emit('broadcast', id, id + " has left the chat.\n");
        }
);

var server = net.createServer(
        function(client) {
                var id = client.remoteAddress + ':' + client.remotePort;
                channel.emit('join', id, client);
                client.on('data',
                        function(data) {
                                channel.emit('broadcast', id, data.toString());
                        }
                );
                client.on('close',
                        function() {
                                channel.emit('leave', id);
                        }
                );
        }
);
server.listen(3000);


반응형

반응형

실행환경 Ubuntu 14.04 LTS / node v0.10.25


다음은 node.js 로 작성한 채팅 서버 코드.

chat.js라는 파일에 다음과 같이 코드를 작성해서 저장.

var net = require('net');
var sockets = [];

var server = net.createServer(
                function(socket) {
                        socket.name = socket.remoteAddress + ":" + socket.remotePort;
                        sockets.push(socket);
                        socket.write("Welcome " + socket.name + "\n");
                        broadcast(socket.name + " joined the chat\n", socket);

                        socket.on('data',
                                function(data) {
                                        broadcast(socket.name + "> " + data, socket);
                                }
                        );

                        socket.on('end',
                                function(data) {
                                        sockets.splice(sockets.indexOf(socket), 1);
                                        broadcast(socket.name + " left the chat.\n");
                                }
                        );
                }
);

function broadcast(message, sender) {
        sockets.forEach(
                function (socket) {
                        if (socket === sender) return;
                        socket.write(message);
                }
        );
}
server.listen(3000);

실행은 nodejs chat 이라고 입력하면 된다.

코드를 살펴보면, 이 채팅 서버는 3000번 포트로 작동한다.

클라이언트에서 접속하면 소켓 IP와 Port를 아이디로 할당하여 sockets 에 저장.

그리고 새로 접속한 클라이언트에게는 서버 Welcome 메시지를 전송하고, 기존의 클라이언트에게는 새로운 유저가 들어왔다는 메시지를 broadcast로  전송.

클라이언트가 끊고 나가는 경우 sockets에서 해당 소켓 정보를 삭제하고 남은 클라이언트 들에게 유저가 나갔다는 메시지를 전달.

 

테스트를 위해서 telnet 을 이용해서 접속을 한다.

telnet [서버IP] 3000

 

텔넷 창을 여러개 띄워서 상대방이 보낸 메시지가 제대로 오는지 확인한다.

반응형

반응형

실행환경 Ubuntu 14.04 LTS / node v0.10.25


다음은 클라이언트가 입력한 값을 그대로 돌려주는 Echo Server를 Node.js 스타일로 작성해 보겠다.

이번 예제에서는 소켓 연결을 위해서 net 모듈을 사용했으며, 3000번 포트로 동작하도록 하였다.

echo.js 라는 파일을 생성하여 아래와 같이 작성한다.

var net = require('net');
var server = net.createServer(
                function(socket) {
                        socket.on('data',
                                function(data) {
                                        socket.write(data);
                                }
                        );
                }
);
server.listen(3000);

실행은 nodejs echo 로 하면 되고, 확인을 위해서 telnet 등을 이용해서 서버에 3000 포트로 접속하면 입력한 값을 되돌려 주는 것을 확인 할 수 있다. 

여기서 socket.on 대신 socket.once 를 사용하면 한번 응답후에 연결을 종료시키도록 할 수 있다.

반응형