內(nèi)有demo http://blog.majiameng.com/workerman_socket.html

可以查看我寫(xiě)的即時(shí)通訊案例 http://www.majiameng.com

完美解決在 event 里面 ，onmessage 里面如何 嵌入 thinkphp,使用框架實(shí)現(xiàn)回調(diào)方法

1.安裝[code]composer require tinymeng/worker-socket dev-master[/code]
2.業(yè)務(wù)邏輯
在項(xiàng)目 /application/index/controller 下創(chuàng)建文件Events.php
首先創(chuàng)建控制器類并繼承 tinymeng\worker\Server，然后設(shè)置屬性和添加回調(diào)方法

2.1 ThinkPhp框架示例如下：

<?php
/**
* Name: Events.php.
* Author: JiaMeng <666@majiameng.com>
* Description: websocket callback
*/
namespace app\index\controller;

use tinymeng\worker\Server;
use GatewayWorker\Lib\Gateway;

class Events extends Server{
    /**
    * @var string Socket connect address
    */
    protected $socket = 'websocket://0.0.0.0:1314';
    /**
    * @var string The current class of namespace
    */
    protected $eventHandler = 'app\index\controller\Events';

    /**
    * Description: 當(dāng)客戶端連接時(shí)時(shí)觸發(fā)
    * Author: JiaMeng <666@majiameng.com>
    * @param $client_id
    */
    public static function onConnect($client_id){
        echo 'client_id : '.$client_id. ', connect ' .PHP_EOL;
    }

    /**
    * Description: 當(dāng)客戶端發(fā)來(lái)消息時(shí)觸發(fā)
    * Author: JiaMeng <666@majiameng.com>
    * @param int $client_id 連接id
    * @param string $data 具體消息
    */
    public static function onMessage($client_id, $data) {
        echo 'client : '.$client_id. ',message data :'.$data .PHP_EOL;
    }

    /**
    * Description: 當(dāng)客戶端斷開(kāi)連接時(shí)觸發(fā)
    * Author: JiaMeng <666@majiameng.com>
    * @param int $client_id 連接id
    */
    public static function onClose($client_id) {
        echo 'client_id : '.$client_id .' close '.PHP_EOL;
    }

}

3.配置thinkphp的啟動(dòng)文件然后來(lái)啟動(dòng) workman 這樣回調(diào)就會(huì)主動(dòng)回調(diào)回寫(xiě)的控制中了,可以試一試哦
4.支持workerman所有的回調(diào)方法定義（回調(diào)方法必須是public static類型）