在根目錄下新建Worker目錄
進入新建的Worker資料夾
執行
LINUX下執行 composer require workerman/workerman
win 下執行 composer require workerman/workerman-for-win

Worker資料夾 下新建檔案push.php

<?php
//require_once DIR .'/vendor/autoload.php';
require_once DIR .'/vendor/workerman/workerman/Autoloader.php';
// require_once DIR .'/vendor/workerman/workerman-for-win/Autoloader.php'; WIN下的引用
use Workerman\Worker;
//
// 初始化一個worker容器，監聽1234埠
$worker = new Worker('websocket://192.168.85.128:1234');
// 這裡程序數必須設定為1
$worker->count = 1;
// worker程序啟動後建立一個內部通訊埠
$worker->onWorkerStart = function($worker)
{

// 開啟一個內部埠，方便內部系統推送資料，Text協議格式 文字+換行符
$inner_text_worker = new Worker('Text://192.168.85.128: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();

http://www.yiichina.com/extension/1206