如何在php后端及時推送消息給客戶端

后端代碼

在阿壩州等地區(qū)，都構建了全面的區(qū)域性戰(zhàn)略布局，加強發(fā)展的系統(tǒng)性、市場前瞻性、產(chǎn)品創(chuàng)新能力，以專注、極致的服務理念，為客戶提供網(wǎng)站設計、網(wǎng)站建設 網(wǎng)站設計制作定制開發(fā),公司網(wǎng)站建設,企業(yè)網(wǎng)站建設,成都品牌網(wǎng)站建設,營銷型網(wǎng)站建設,外貿(mào)網(wǎng)站建設,阿壩州網(wǎng)站建設費用合理。

push.php

?php

use Workerman\Worker;

require_once './Workerman/Autoloader.php';

// 初始化一個worker容器，監(jiān)聽1234端口

$worker = new Worker('websocket://0.0.0.0:1234');

// 這里進程數(shù)必須設置為1

$worker-count = 1;

// worker進程啟動后建立一個內(nèi)部通訊端口

$worker-onWorkerStart = function($worker)

{

// 開啟一個內(nèi)部端口，方便內(nèi)部系統(tǒng)推送數(shù)據(jù)，Text協(xié)議格式 文本+換行符

$inner_text_worker = new Worker('Text://0.0.0.0:5678');

$inner_text_worker-onMessage = function($connection, $buffer)

{

global $worker;

// $data數(shù)組格式，里面有uid，表示向那個uid的頁面推送數(shù)據(jù)

$data = json_decode($buffer, true);

$uid = $data['uid'];

// 通過workerman，向uid的頁面推送數(shù)據(jù)

$ret = sendMessageByUid($uid, $buffer);

// 返回推送結果

$connection-send($ret ? 'ok' : 'fail');

};

$inner_text_worker-listen();

};

// 新增加一個屬性，用來保存uid到connection的映射

$worker-uidConnections = array();

// 當有客戶端發(fā)來消息時執(zhí)行的回調(diào)函數(shù)

$worker-onMessage = function($connection, $data)use($worker)

{

// 判斷當前客戶端是否已經(jīng)驗證,既是否設置了uid

if(!isset($connection-uid))

{

// 沒驗證的話把第一個包當做uid（這里為了方便演示，沒做真正的驗證）

$connection-uid = $data;

/* 保存uid到connection的映射，這樣可以方便的通過uid查找connection，

* 實現(xiàn)針對特定uid推送數(shù)據(jù)

*/

$worker-uidConnections[$connection-uid] = $connection;

return;

}

};

// 當有客戶端連接斷開時

$worker-onClose = function($connection)use($worker)

{

global $worker;

if(isset($connection-uid))

{

// 連接斷開時刪除映射

unset($worker-uidConnections[$connection-uid]);

}

};

// 向所有驗證的用戶推送數(shù)據(jù)

function broadcast($message)

{

global $worker;

foreach($worker-uidConnections as $connection)

{

$connection-send($message);

}

}

// 針對uid推送數(shù)據(jù)

function sendMessageByUid($uid, $message)

{

global $worker;

if(isset($worker-uidConnections[$uid]))

{

$connection = $worker-uidConnections[$uid];

$connection-send($message);

return true;

}

return false;

}

// 運行所有的worker（其實當前只定義了一個）

Worker::runAll();

啟動后端服務

php push.php start -d

前端接收推送的js代碼

var ws = new WebSocket('ws://127.0.0.1:1234');

ws.onopen = function(){

var uid = 'uid1';

ws.send(uid);

};

ws.onmessage = function(e){

alert(e.data);

};

后端推送消息的代碼

// 建立socket連接到內(nèi)部推送端口

$client = stream_socket_client('tcp://127.0.0.1:5678', $errno, $errmsg, 1, STREAM_CLIENT_CONNECT|STREAM_CLIENT_PERSISTENT);

// 推送的數(shù)據(jù)，包含uid字段，表示是給這個uid推送

$data = array('uid'='uid1', 'percent'='88%');

// 發(fā)送數(shù)據(jù)，注意5678端口是Text協(xié)議的端口，Text協(xié)議需要在數(shù)據(jù)末尾加上換行符

fwrite($client, json_encode($data)."\n");

// 讀取推送結果

echo fread($client, 8192);

這里的uid不一定是用戶的id，也可以理解為任務id即 taskid

如何用php程序主動向html頁面發(fā)送信息？

你說的應該是服務端主動向客戶端推送消息， 這個只能使用Socket建立長連接來實現(xiàn)。

客戶端實現(xiàn)比較簡單， 大多數(shù)瀏覽器提供的應該都有接口， 幾個方法就可以建立一個連接，然后進行消息監(jiān)聽就可以了，服務端實現(xiàn)稍微復雜點， 不過你根本不用自己寫那些底層代碼， php平臺上有一個庫叫 "Workerman", 里面所有功能已經(jīng)幫你實現(xiàn)好了， 你看看文檔就能直接調(diào)用了， 很簡單的。

PHP怎么從后端及時向前段發(fā)出提示

使用http協(xié)議的話只能是前端主動向后端發(fā)請求。后端不能主動向前端發(fā)送提示。要及時得到后臺的狀態(tài)，只能用長輪詢，就是前端定時向后臺請求數(shù)據(jù)……或者HTML5有個websocket可以雙向通信，題主可以查查。。。

PHP 如何向前端主動發(fā)起操作

可以在你覺得可以滿足條件的時候，在前端用ajax連接php，php 主動訪問是不行的，因為php的條件決定了，是先運行php代碼，在渲染html代碼