[comet] 페이스 북, gmail은 실시간 알림을 어떻게 보내나요?

페이스 북이하는 방식은 꽤 흥미 롭습니다.

이러한 알림을 수행하는 일반적인 방법은 주어진 간격 (아마도 몇 초마다)마다 서버에서 스크립트 (AJAX 사용)를 폴링하여 문제가 발생했는지 확인하는 것입니다. 그러나 이것은 네트워크 집약적 일 수 있으며 아무 일도 일어나지 않기 때문에 종종 무의미한 요청을합니다.

페이스 북이하는 방식은 한 폴링이 완료 되 자마자 다른 폴링을 발행하자마자 간격으로 폴링하는 대신 혜성 접근법을 사용하는 것입니다. 그러나 서버의 스크립트에 대한 각 요청은 시간이 매우 길며, 서버는 요청이 발생한 후에 만 ​​요청에 응답합니다. Facebook에있는 동안 Firebug의 콘솔 탭을 표시하고 스크립트에 대한 요청이 몇 분 정도 걸릴 수 있습니다. 이 방법은 요청 수와 전송 빈도를 즉시 줄이므로 매우 독창적입니다. 이제 서버가 이벤트를 ‘실행’할 수있는 이벤트 프레임 워크를 갖게되었습니다.

그 뒤에는 해당 설문 조사에서 반환 된 실제 내용과 관련하여 JSON 목록이며 이벤트 목록으로 보이는 내용과 관련 정보가 있습니다. 그래도 축소되었으므로 읽기가 약간 어렵습니다.

실제 기술 측면에서 AJAX는 요청 시간 초과 및 기타 여러 가지를 제어 할 수 있기 때문에 여기로가는 방법입니다. jQuery를 사용하여 AJAX를 수행하는 것이 좋습니다 (Stack overflow cliche here), 많은 호환성 문제가 사라질 것입니다. PHP와 관련하여 PHP 스크립트에서 이벤트 로그 데이터베이스 테이블을 간단히 폴링하고 어떤 일이 발생했을 때만 클라이언트로 돌아갈 수 있습니까? 나는 이것을 구현하는 많은 방법이 있다고 생각합니다.

구현 :

서버 측:

PHP에는 혜성 라이브러리가 몇 가지 구현되어 있지만 솔직히 말하면 다음과 같은 의사 코드와 같이 매우 간단합니다.

while(!has_event_happened()) {
   sleep(5);
}

echo json_encode(get_events());

• has_event_happened 함수는 이벤트 테이블이나 무언가에 무슨 일이 있었는지 확인한 다음 get_events 함수는 테이블의 새 행 목록을 반환합니까? 실제로 문제의 상황에 따라 다릅니다.

• PHP 최대 실행 시간을 변경하는 것을 잊지 마십시오. 그렇지 않으면 조기 시간 초과됩니다!

고객 입장에서:

Comet 상호 작용을 수행하기위한 jQuery 플러그인을 살펴보십시오.

• 프로젝트 홈페이지 : http://plugins.jquery.com/project/Comet
• Google 코드 : https://code.google.com/archive/p/jquerycomet/- 서브 버전 저장소에서 일종의 사용 예가 나타납니다.

즉, 플러그인은 약간의 복잡성을 추가하는 것처럼 보이며 클라이언트에서 매우 간단합니다 (jQuery 사용).

function doPoll() {
   $.get("events.php", {}, function(result) {
      $.each(result.events, function(event) { //iterate over the events
          //do something with your event
      });
      doPoll();
      //this effectively causes the poll to run again as
      //soon as the response comes back
   }, 'json');
}

$(document).ready(function() {
    $.ajaxSetup({
       timeout: 1000*60//set a global AJAX timeout of a minute
    });
    doPoll(); // do the first poll
});

모든 것은 기존 아키텍처가 어떻게 구성되는지에 달려 있습니다.

답변

function pollTask() {

    $.ajax({

        url: '/api/Polling',
        async: true,            // by default, it's async, but...
        dataType: 'json',       // or the dataType you are working with
        timeout: 10000,          // IMPORTANT! this is a 10 seconds timeout
        cache: false

    }).done(function (eventList) {

       // Handle your data here
       var data;
       for (var eventName in eventList) {

            data = eventList[eventName];
            dispatcher.handle(eventName, data); // handle the `eventName` with `data`

       }

    }).always(pollTask);

}

function handleRequest () {

     while (!anythingHappened() || hasTimedOut()) { sleep(2); }

     return events();

}

var comet = new iComet({
    sign_url: 'http://' + app_host + '/sign?obj=' + obj,
    sub_url: 'http://' + icomet_host + '/sub',
    callback: function(msg){
        // on server push
        alert(msg.content);
    }
});

function longPoll() {
        var shouldDelay = false;

        $.ajax({
            url: 'poll.php',
            async: true,            // by default, it's async, but...
            dataType: 'json',       // or the dataType you are working with
            timeout: 10000,          // IMPORTANT! this is a 10 seconds timeout
            cache: false

        }).done(function (data, textStatus, jqXHR) {
             // do something with data...

        }).fail(function (jqXHR, textStatus, errorThrown ) {
            shouldDelay = textStatus !== "timeout";

        }).always(function() {
            // in case of network error. throttle otherwise we DOS ourselves. If it was a timeout, its normal operation. go again.
            var delay = shouldDelay ? 10000: 0;
            window.setTimeout(longPoll, delay);
        });
}
longPoll(); //fire first handler