node.js 채팅 프로그램은 Ajax 롱 폴링 롱 링크 새로 고침 mode_javascript 기술을 어떻게 구현합니까?

더 이상 고민하지 말고 오늘의 주제를 시작하겠습니다. 이 프로그램을 보면서 가장 가치 있는 점은 nodejs를 사용하여 롱링크 모드의 새로 고침 기술을 구현하는 방법을 보여준다는 점이라고 생각합니다.
　(이 프로그램은 자세히 소개하지 않으나 이 기능에 집중하겠습니다)
Client.js　

코드는 다음과 같습니다.

function longPoll (data) { //....여기서 **** 행은 생략됩니다 $.ajax({ 캐시: false , type: "GET" , url: "/recv "

, dataType: "json"

, data: { 이후: CONFIG.last_message_time, id: CONFIG.id }
, error: function () {
addMessage("", "long poll error. 다시 시도 중...", new Date(), "error");
transmission_errors = 1;
//오류 발생 시 서버가 넘치지 않도록 10초 후에 다시 시도하세요.
setTimeout( longPoll, 10*1000);
}
, 성공: function (data) {
transmission_errors = 0;
//모든 것이 잘 되었다면 즉시 다른 요청을 시작하세요.
//서버 응답하는 데 오랜 시간이 걸립니다
//얼마나 걸리나요? 다른 메시지가 올 때까지 기다렸다가
//그 다음에는 해당 메시지를 반환하고
//그 이후로 연결을 종료합니다. 데이터를 받으면 연결이 닫힙니다.
longPoll(data);
}
})
}


이것은 클라이언트의 코드 조각입니다. .js. 이 코드를 보면 즉시 "재귀"라는 두 단어가 떠오를 것입니다. longPoll 메서드에서 일반적인 재귀 호출인 longPoll 메서드를 다시 호출합니다.
이 코드의 의미에 따르면 처음 로드할 때 longPoll 메서드가 호출되어 "/resv"에서 값을 비동기적으로 가져오는 것을 알 수 있습니다. 성공하면 성공 메서드가 실행됩니다. longPoll 메소드는 즉시 다시 호출됩니다. 실패하면 error 함수를 실행하고 10초마다 longPoll 메서드를 다시 호출합니다. 물론, 오류 메소드가 실행될 수 있는 횟수에는 일정한 제한이 있으며, 이는 Transmission_errorsx 변수에 의해 제어됩니다.
서버가 데이터를 얻기 위해 재귀적으로 루핑해야 하는 부담이 있습니까?라는 질문이 있을 수 있습니다. 얻을 데이터가 없을 때 이 주기가 계속됩니까? 물론 대답은 '아니오'입니다! 게다가 nodejs는 자신의 특성을 활용하여 이 문제를 매우 잘 해결합니다. 그런 다음 아래를 살펴보세요.
Server.js
이제 서버가 위 클라이언트 호출에 어떻게 응답하는지 살펴보세요. 핵심 코드는

코드 복사
입니다.

코드는 다음과 같습니다.

fu.get("/recv", function (req, res) { //세션 확인 및 업데이트... channel.query(since, function (messages) { if (session) session.poke(); res.simpleJSON(200, { message: message, rss: mem.rss });

});

});


fu.get()이 무엇을 의미하는지 걱정하지 마세요. 이 튜토리얼과는 아무 관련이 없습니다. 간단히 말해서 클라이언트의 호출에 응답할 수 있다는 점만 알아두십시오. 위의 코드는 세션에 대한 일부 작업 외에도 채널의 쿼리 메서드를 호출합니다. 전달된 매개변수에 주의하세요.
시간을 기록하는
메시지 매개변수와 두 가지 작업을 허용하는 익명 메서드: 1. 세션 시간 업데이트, 2. json 반환, 즉 메시지 반환 클라이언트에게.
어떤 사람들은 질문을 할 수 있습니다: 여기에서 메시지를 직접 반환하는 것이 가능하지 않습니까? 왜 채널을 운영하기 위해 메소드를 정의해야 합니까? 답변: 그렇다면 무한 루프가 됩니다. 반환할 정보가 없더라도 서버와 클라이언트는 항상 데이터와 상호 작용합니다.
계속 읽어보세요!
채널 정의 방법 보기:

코드 복사


코드는 다음과 같습니다.

var MESSAGE_BACKLOG = 200,
SESSION_TIMEOUT = 60 * 1000;
var 채널 = 새 함수() {
var message = [],
callbacks = []; >this.appendMessage = function (nick, type, text) {
var m = { nick: nick
, type: type // "msg", "join", "part"
, text: text
, 타임스탬프: (new Date()).getTime()
}
switch (type) {
case "msg":
sys.puts(" " text);
break
case "join":
sys.puts(nick " Join")
case "part":
sys .puts(nick " part");
break;
}
messages.push(m )
while (callbacks.length > 0) {
//shift() 메서드 배열의 첫 번째 요소를 삭제하고 첫 번째 요소의 값을 반환하는 데 사용됩니다.
callbacks.shift().callback([m])
}
while (messages.length > ; MESSAGE_BACKLOG )
messages.shift();
};
this.query = 함수(이후, 콜백) {
var match = []
for (var i = 0; i < ; message.length; i ) {
var message = message[i];
if (message.timestamp > 이후)
matching.push(message)
}
if (일치 .length != 0) {
callback(매칭);
} else {
callbacks.push({ timestamp: new Date(), callback: callback }); ;
// 기존 콜백 지우기
// 최대 30초 동안 대기할 수 있습니다.
setInterval(function () {
var now = new Date();
while(콜백 .length > 0 && 현재 - callbacks[0].timestamp > 30*1000) {
callbacks.shift().callback([]);
}
};


채널에는 3초마다 실행되는 변수 2개, 메소드 2개, setInterval 함수가 정의되어 있습니다.
먼저 쿼리 메서드를 살펴보세요.
쿼리 메서드는 두 개의 매개변수를 받습니다.
since: 시간을 기록합니다.

callback: 위에서 언급한 Channel.query 메서드를 호출할 때 전달되는 익명 함수(JS에서) , 함수를 매개변수로 전달할 수도 있고, 받은 후 바로 호출할 수도 있습니다.)
현재 채팅 기록 대기열은 메시지에 저장되며, 쿼리 메소드는 조건에 맞는 채팅 기록을 찾아서 넣습니다. 일치합니다. match.length>0이면 콜백이 수신한 함수가 호출됩니다. 즉, 일치하는 내용이 json 형식으로 클라이언트에 반환됩니다. 하지만. . . 다음은 핵심 포인트입니다! ! !




코드 복사

코드는 다음과 같습니다. if (matching.length != 0) { callback(일치) } else {

callbacks.push({ timestamp: new Date(), callback: callback })

if match.length 그러면 이대로 영원히 보관할 수는 없겠죠. 누군가가 1초마다 채팅 메시지를 보낸다면 어떨까요?
그런 다음 appendMessage(채팅 메시지 추가) 메소드를 살펴보십시오.
이 메소드에서 첫 번째 부분은 들어오는 매개변수를 수신하여 이를 m 세트로 결합한 다음 사용하는 것에 지나지 않습니다. sys.puts를 사용하여 터미널에 표시한 다음 메시지 채팅 메시지 대기열에 m을 삽입합니다. 다음은 핵심입니다.

코드 복사

코드는 다음과 같습니다. while(callbacks .length > 0) { //shift() 메서드는 배열의 첫 번째 요소를 삭제하고 첫 번째 요소의 값을 반환하는 데 사용됩니다. callbacks.shift().callback([m]); }

이제 콜백이 저장되어 있는지 확인해야 합니다. 그렇다면 하나를 실행하고 실행이 완료될 때까지 하나를 삭제하세요. 반환할 채팅 메시지가 없기 전에 누군가 요청을 했는데 시스템이 이러한 요청을 실행하지 않고 콜백 목록에 넣지 않았기 때문입니다.
이제 누군가 채팅 메시지를 보냈으므로 add 메소드를 실행할 때 실행되지 않은 모든 요청을 다시 실행해야 합니다.
일반적인 이해는 다음과 같습니다. 요청을 보냈지만 아직 답장할 새 메시지가 없습니다. 누군가 새 메시지를 보내면 즉시 답장해 드리겠습니다.
이해가 되셨는지 모르겠습니다. . .
마지막 단계는 만료된 콜백을 3초마다 삭제하는 것입니다. 이해하기 어렵지 않습니다.

요약
Nodejs는 자체 이벤트 기반 언어 기능을 사용하여 눈을 뜨게 하는 긴 링크 새로 고침 기능을 구현합니다. 많은 혜택을 받은 것 같아요. 저는 시간을 내어 여러분과 공유하고 제 자신의 이해를 심화하기 위한 튜토리얼을 작성하고 싶습니다.