NET module 사용시 'data' event 질문

[arton7278]

문제점

server에 연결 후 데이터 요청시

1. 데이터가 두번 나눠서 받는 경우가 있다.
2. 데이터가 두번 나눠서 받는 경우 JSON.parse가 동작을 하지를 못한다.

코드

client.on('data', function (data) {
    console.log(data.length); 
    console.log(JSON.parse(data.toString())); // error 위치
    client.end();
});

결과

// 데이터를 두번 나눠서 받는 경우
undefined:1
lication_1409186885665_0039", "host_ip": "192.168.10.3", "app_master_id": "con
                                                                              ^
SyntaxError: Unexpected end of input
    at Object.parse (native)
    at Socket. (/workspace/webTest/lavenderTest/a_test.js:27:22)
    at Socket.EventEmitter.emit (events.js:95:17)
    at Socket. (_stream_readable.js:746:14)
    at Socket.EventEmitter.emit (events.js:92:17)
    at emitReadable_ (_stream_readable.js:408:10)
    at emitReadable (_stream_readable.js:404:5)
    at readableAddChunk (_stream_readable.js:165:9)
    at Socket.Readable.push (_stream_readable.js:127:10)
    at TCP.onread (net.js:526:21)

// 정상 처리 경우 
// 한번에 모든 데이터 받는 경우 정상적으로 JSON.parse처리가 된다. 
{ SEQ_NO: 0,
  RESULT:
   [ { status: 'running',
       count: '4',
       container_log: '/Lavender/usr/thirdparty/hadoop-2.4.0/logs/userlogs/application_1409186885665_0038/container_1409186885665_0038_01_000001',
       app_name: 'collector',
       start_time: '20140923023553',
       app_id: 'application_1409186885665_0038',
       host_ip: '192.168.10.3',
       app_master_id: 'container_1409186885665_0038_01_000001',
       host_name: 'slave2',
       _id: '5420dc896d987fb1009e8e66',
       containers: [Object],
       end_time: 'N/A' },
     { status: 'running',
       count: '4',
       container_log: '/Lavender/usr/thirdparty/hadoop-2.4.0/logs/userlogs/application_1409186885665_0039/container_1409186885665_0039_01_000001',
       app_name: 'parser',
       start_time: '20140923023632',
       app_id: 'application_1409186885665_0039',
       host_ip: '192.168.10.3',
       app_master_id: 'container_1409186885665_0039_01_000001',
       host_name: 'slave2',
       _id: '5420dcb06d987fb1009e8e67',
       containers: [Object],
       end_time: 'N/A' } ],
  RESULT_CODE: 0 }

[JoonseokRyu]

나눠져서 받아져서 그렇다면 버퍼를 하나 두고 다 받아서 사용하면 되지 않을까요?
socket.on('data', function(chunk) {
// save into buffer
});
socket.on('end', function() {
// use buffer contents
});

[veldise]

JSON.parse에서 에러가 발생하는 이유는 명백합니다.
함수의 인자로 넣은 문자열이 JSON 형식에 어긋나기 때문입니다.

왜 문자열이 JSON 형식에서 어긋나느냐 하면 데이터를 다 받지 못했기 때문이므로
일단 문제는 데이터를 나눠서 받는 것 하나로 좁혀집니다.

---

서버 개발자라면 항상 네크워크에 장애가 발생할 것을 염두해두고 코드를 짜야 합니다.
또한 장애가 없더라도 socket 내부의 buffer에 담을 수 있는 데이터에는 한계가 있기 때문에
위와같이 이벤트 한 번으로 데이터를 한 번에 받는다고 가정해서는 안됩니다.

패킷 단위 데이터 송수신이라면 패킷의 시작/끝을 나타내는 문자나 패킷의 길이를 받아서
client가 패킷 단위로 데이터를 처리할 수 있도록 도와주는게 보통입니다.

이를 참고하여 문제를 해결해보세요.

[veldise]

https://github.com/veldise/js-utils/blob/master/node/pbsocket.js
PBSocket은 protobuf 로 serialize 된 패킷을 주고받는다는 가정하에 작성된 클래스입니다.
코드를 분석해보세요.