php助手消息,php消息推送

本文目錄一覽：

• 1、php 定時推送消息怎麼做？
• 2、PHP如何實現消息通知功能
• 3、php實現websocket實時消息推送
• 4、在PHP中如何使用消息列隊
• 5、如何在php後端及時推送消息給客戶端？

php 定時推送消息怎麼做？

這個要用到伺服器系統的計劃任務，如果是linux伺服器 的cron。代碼實現是非常消耗性能的，需要不停的循環執行。

PHP如何實現消息通知功能

這個一般都是發郵件吧 就是用戶有什麼消息發送過去，然後管理員收到什麼郵件之類的

或者在數據設計的時候加一個flag 用戶向後台發送了什麼數據 就有個flag 管理員的頁面就顯示帶有這個flag的消息 點擊之後flag取消。這個比較麻煩吧 對於開發者哈

php實現websocket實時消息推送

一、socket協議的簡介

WebSocket是什麼，有什麼優點

WebSocket是一個持久化的協議，這是相對於http非持久化來說的。應用層協議

舉個簡單的例子，http1.0的生命周期是以request作為界定的，也就是一個request，一個response，對於http來說，本次client與server的會話到此結束；而在http1.1中，稍微有所改進，即添加了keep-alive，也就是在一個http連接中可以進行多個request請求和多個response接受操作。然而在實時通信中，並沒有多大的作用，http只能由client發起請求，server才能返回信息，即server不能主動向client推送信息，無法滿足實時通信的要求。而WebSocket可以進行持久化連接，即client只需進行一次握手，成功後即可持續進行數據通信，值得關注的是WebSocket實現client與server之間全雙工通信，即server端有數據更新時可以主動推送給client端。

二、介紹client與server之間的socket連接原理

1、下面是一個演示client和server之間建立WebSocket連接時握手部分

2、client與server建立socket時握手的會話內容，即request與response

a、client建立WebSocket時向伺服器端請求的信息

GET /chat HTTP/1.1

Host: server.example.com

Upgrade: websocket //告訴伺服器現在發送的是WebSocket協議

Connection: Upgrade

Sec-WebSocket-Key: x3JJHMbDL1EzLkh9GBhXDw== //是一個Base64 encode的值，這個是瀏覽器隨機生成的，用於驗證伺服器端返回數據是否是WebSocket助理

Sec-WebSocket-Protocol: chat, superchat

Sec-WebSocket-Version: 13

Origin:

b、伺服器獲取到client請求的信息後，根據WebSocket協議對數據進行處理並返回，其中要對Sec-WebSocket-Key進行加密等操作

HTTP/1.1 101 Switching Protocols

Upgrade: websocket //依然是固定的，告訴客戶端即將升級的是Websocket協議，而不是mozillasocket，lurnarsocket或者shitsocket

Connection: Upgrade

Sec-WebSocket-Accept: HSmrc0sMlYUkAGmm5OPpG2HaGWk= //這個則是經過伺服器確認，並且加密過後的 Sec-WebSocket-Key,也就是client要求建立WebSocket驗證的憑證

Sec-WebSocket-Protocol: chat

3、socket建立連接原理圖：

三、PHP中建立websocket的過程講解

SocketService.php:

web.html:

在PHP中如何使用消息列隊

在寫入隊列的時候可以規定相應的規則如：

{‘處理腳本’:’test’,’data’:{‘test’:’test’},’分組’:『1′,’處理結果’:’0′}

這樣就可以通過一個消息隊列來處理整個項目的所以消息任務

把data發送給相遇的腳本返回處理結果，而這個分組可以實現分組多進程並發處理來解決效率問題。

效率問題的結局還可以在守護進程上進行增加，守護進程跟進當前的任務量發起適當的處理進程，處理進程再分發給具體的業務處理腳本！

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

使用以下代碼可以更改設置。

後端代碼

push.php

?php

use Workerman\Worker;

require_once ‘./Workerman/Autoloader.php’;

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

// 這裡進程數必須設置為1

$worker-count = 1;

// worker進程啟動後建立一個內部通訊埠

$worker-onWorkerStart = function($worker)

{

// 開啟一個內部埠，方便內部系統推送數據，Text協議格式 文本+換行符    $inner_text_worker = new Worker(‘Text://0.0.0.0:5678’);

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

{

global $worker;

// $data數組格式，裡面有uid，表示向那個uid的頁面推送數據

$data = json_decode($buffer, true);

$uid = $data[‘uid’];

// 通過workerman，向uid的頁面推送數據

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

// 返回推送結果

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

};

$inner_text_worker-listen();

};

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

$worker-uidConnections = array();

// 當有客戶端發來消息時執行的回調函數$worker-onMessage = function($connection, $data)use($worker)

{

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

if(!isset($connection-uid))

{

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

$connection-uid = $data;

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

* 實現針對特定uid推送數據

*/

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

return;

}

};

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

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

{

global $worker;

if(isset($connection-uid))

{

// 連接斷開時刪除映射

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

}

};

// 向所有驗證的用戶推送數據

function broadcast($message)

{

global $worker;

foreach($worker-uidConnections as $connection)

{

$connection-send($message);

}

}

// 針對uid推送數據

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連接到內部推送埠

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

// 推送的數據，包含uid欄位，表示是給這個uid推送

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

// 發送數據，注意5678埠是Text協議的埠，Text協議需要在數據末尾加上換行符

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

// 讀取推送結果

echo fread($client, 8192);這裡的uid不一定是用戶的id，也可以理解為任務id即 taskid