websocketphp推送消息

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

<?php
use Workerman\Worker;
require_once './Workerman/Autoloader.php';
// 初始化一個worker容器，監聽1234埠
$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

以上代碼親測可以直接使用

② php 怎麼使用websocket推送消息

刪除文件可以使用unlink，沒有必要將目錄轉換成絕對路徑，如果想刪除images中的文件，可以直接unlink("/image/文件名")即可~!

我剛剛在後盾人看到的，樓主覺得不錯也可以去學習哦.

③ 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: http://example.com

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怎麼實現主動向客戶端發送信息

實現消息推送首先需要瀏覽器支持 websocket 協議，這是前提，然後再通過瀏覽器發起websocket 請求到伺服器，建立一條連接，這是伺服器端就可以通過這條連接向瀏覽器推送消息了。

伺服器端對websocket的支持可以通過一些第三方庫來實現，供參考

1. hoa/websocket網頁鏈接

2. swoole 庫
   

⑤ php 怎麼使用websocket推送消息

我使用的工具是基於wokman的web-msg-sender是一款web長連接推送框架，採用PHPSocket.IO開發，基於WebSocket長連接通訊，如果瀏覽器不支持WebSocket則自動轉用comet推送。 通過後台推送消息，消息可以即時推送到客戶端，非輪詢，實時性非常好，性能很高。

下載和demo地址http://www.workerman.net/web-sender

這裡面區分服務端和客戶端，去上面地址下載源代碼，放到你服務端。使用相關命令開啟服務。

其中有一個文件是start_io.php，這個文件算是核心，裡面有怎麼發送socket消息的代碼，也會有監控用戶上下線的介面，在這個地方可以根據業務需要拓展自己的代碼需求。類似：用戶在socket檢測用戶上下線的是時候，可以http請求到自己的api層

下面我貼一下我的代碼

這個地方明確表明了監聽埠，websocket跟api在同一個伺服器上面，所以用了0.0.0.0，所以你在http服務端如果想發消息給客戶端，只需要發送到這個埠上面，socket自動會監聽到發送給客戶端。

⑥ php 怎麼使用websocket推送消息

自己寫個socket服務端文件或者用workerman框架 。架設一個socket
然後h5 鏈接socket 寫邏輯

具體可以參考workerman的演示