參考了您的"如何在php后端及時推送消息給客戶端",幾乎與您的案例一致。
在本地能正常運行,在阿里云服務器上不行。前端代碼顯示連接成功。
在后端推動代碼那里沒有反應。
以下是相關代碼截圖,如果你有時間看到,麻煩幫我看看,萬分感謝。
后端代碼:
<?php
use Workerman\Worker;
require_once 'Autoloader.php';
$clients = []; //保存客戶端信息
// 初始化一個worker容器,監(jiān)聽8081端口
$worker = new Worker('websocket://0.0.0.0:8088');
// 這里進程數必須設置為1
$worker->count = 1;
// 新增加一個屬性,用來保存uid到connection的映射
$worker->uidConnections = array();
// worker進程啟動后建立一個內部通訊端口
$worker->onWorkerStart = function($worker)
{
var_dump('onWorkerStart--11:'.time());
// 開啟一個內部端口,方便內部系統推送數據,Text協議格式 文本+換行符
$inner_text_worker = new Worker('text://0.0.0.0:8089');
$inner_text_worker->onMessage = function($connection, $buffer)
{
var_dump('onWorkerStart-onMessage:'.time());
global $worker;
$data = json_decode($buffer, true);
if(isset($data['uid'])){
$uid = $data['uid'];
// 通過workerman,向uid的頁面推送數據
$ret = sendMessageByUid($uid, $buffer);
}else{
$ret = broadcast($buffer);
}
// 返回推送結果
$connection->send($ret ? 'ok' : 'fail');
};
$inner_text_worker->listen();
};
// 當有客戶端發(fā)來消息時執(zhí)行的回調函數
$worker->onMessage = function($connection, $data)use ($worker)
{
global $worker;
var_dump('onMessage--1');
// 判斷當前客戶端是否已經驗證,既是否設置了uid
if(!isset($connection->uid)) {
$connection->send('hello world--'.$data);
// 沒驗證的話把第一個包當做uid
if($data != 0){
$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);
}
return true;
}
// 針對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();
前端代碼:
<script>
$(function () {
FastClick.attach(document.body);
cal_guess_data('init');
});
/*----------WebSocket----------*/
//創(chuàng)建socket,注意URL的格式:ws://ip:端口
var ws = new WebSocket("ws://127.0.0.1:8088");
if(typeof(ws) == 'undefined'){
alert('你的瀏覽器不支持 WebSocket ,推薦使用Google Chrome 或者 Mozilla Firefox');
}
//握手監(jiān)聽函數
ws.onopen = function(){
//狀態(tài)為1證明握手成功
if(ws.readyState == 1){
console.log('connect success');
var bind_id = parseInt({$user_id});
if(bind_id == 0){
//未登錄使用隨機uid
bind_id = "{:uniqid()}";
}
console.log('bind_id'+bind_id);
//綁定user_id
ws.send(bind_id);
}
};
//數據接收監(jiān)聽,接收服務器推送過來的信息,返回的數據給msg,然后進行顯示
ws.onmessage = function (msg){
console.log('onmessage');
console.log(msg);
var jsons = JSON.parse(msg.data);
updateData(jsons);
};
ws.onclose = function(){
console.log('connect close');
ws.close();
};
ws.onerror = function(event){
console.log("connect error" + event.data);
};
</script>
/**
* webSocket即時推送
* @param int $uid 被推送用戶的user_id
* @param array $singleData 單獨推送的數據
* @param array $allData 全用戶推送的數據
* @Author Faramita
*/
function push_webSocket($uid,$singleData,$allData = []){
// 建立socket連接到內部推送端口
$client = stream_socket_client('tcp://127.0.0.1:8089', $errno, $errmsg, 1);
if($uid && $singleData){
// 推送的數據,包含uid字段,表示是給這個uid的用戶推送的
$singleData['uid'] = $uid;
// 發(fā)送數據,注意8089端口是Text協議的端口,Text協議需要在數據末尾加上換行符
fwrite($client, json_encode($singleData)."\n");
}
if($allData){
fwrite($client, json_encode($allData)."\n");
}
// 讀取推送結果
//echo fread($client, 8192);
}