實時傳感器數據作爲從Python到PHP的服務器發送事件（SSE）？

Question

我正在更新一個呈現實時傳感器數據的Web應用程序，它在當前的第一次迭代中是通過連續的AJAX輪詢實現的。 但是，爲了讓這更像是一個'真正的實時'應用程序，我希望它是基於事件的。

我一直在閱讀基於事件的技術，並且基於實時通信只需要一種方式（服務器 - >客戶端）的事實，我選擇使用Server-Sent Events （SSE），而不是像websockets。 如上所述here on the Mozilla Docs，這是很容易與像在服務器端執行（有點簡化）：

<?php 
// SSEscript.php 
date_default_timezone_set("America/New_York"); 
header("Content-Type: text/event-stream\n\n"); 

while (1) { 
    if ($new_data_available) { 
     echo "data:". $data; 
    } 

    sleep($short_time_to_spare_cpu); 
} 
?> 

，並在客戶端使用：

<script> 
var evtSource = new EventSource("SSEscript.php"); 

evtSource.onmessage = function(e) { 
    var data = e.data; 
    // Do something with data object 
} 
</script> 

上述所有工作正常，我。但是，傳感器數據最初是通過在服務器上連續運行的Python腳本檢索的，因此，如何在檢索時將傳感器數據從Python腳本立即傳輸到PHP腳本，以便可以生成併發送事件？

我可以做類似下面描述的事嗎？ ：

同時所有新數據都存儲在一個MySQL數據庫中，所以我當然可以讓PHP腳本經常查詢數據庫以查找新條目，但必須有一個更智能的方法。那麼我可以讓圖像中的2.1和2.2在同一時間發生嗎？

我在這裏可以找到的所有答案都描述瞭如何通過讓PHP執行Python腳本來傳輸數據，但這不是我想要的，因爲無論用戶是否要求數據，這都會運行。

是一種套路要走的路，如果是這樣，你能指出我該怎麼做的方向嗎？ 我希望你能幫助我！

Answer 1

我使用redis做python和redis之間的信號傳輸。在python完成所有的工作之後，將一個令牌（或最新數據）發送到redis隊列中。在PHP中，我使用一個while（true）循環來保存請求和redis lpop（隊列，超時）等待令牌，併發送數據，如下所示：

<?php 
    require __DIR__.'/predis-1.0/autoload.php'; 
    header("Content-Type: text/event-stream"); 
    header("Cache-Control: no-cache"); 
    header("Connection: keep-alive"); 

    $lastId = isset($_SERVER["HTTP_LAST_EVENT_ID"]) ? 
       $_SERVER["HTTP_LAST_EVENT_ID"] : null; 
    if (isset($lastId) && !empty($lastId) && is_numeric($lastId)) { 
     $lastId = intval($lastId); 
     $lastId++; 
    } 

    $index = isset($_GET['index']) ? $_GET['index'] : null; 

    echo "retry: 2000\n"; 

    $client = new Predis\Client(); 
    while (true) { 
     $data = $client->blpop('queue',5); 
     if ($data) { 
      error_log("$index : " . strlen($data)); 
      sendMessage($lastId, $data); 
      $lastId++; 
     } 
    } 

    function sendMessage($id, $data) { 
     echo "id: $id\n"; 
     echo "data: $data\n\n"; 
     ob_flush(); 
     flush(); 
    }