下面把TP5官方给出的示例代码：

<?php

namespace app\index\controller;

use think\worker\Server;

use Workerman\Lib\Timer; // 引入WM框架的类库，

class Worker extends Server

{

//     protected $socket = 'http://0.0.0.0:2348';

    protected $socket = 'tcp://0.0.0.0:2349';

    /**

     * 收到信息

     * @param $connection

     * @param $data

     */

    public function onMessage($connection, $data)

    {

        // 给connection临时设置一个lastMessageTime属性，用来记录上次收到消息的时间

        $connection->lastMessageTime = time();

        $connection->send(json_encode($data));

        $connection->send('我收到你的信息了');

    }

    /**

     * 当连接建立时触发的回调函数

     * @param $connection

     */

    public function onConnect($connection)

    {

        echo $connection->getRemoteIP();

    }

    /**

     * 当连接断开时触发的回调函数

     * @param $connection

     */

    public function onClose($connection)

    {

        echo $connection->id . 'disconnect \r\n';

    }

    /**

     * 当客户端的连接上发生错误时触发

     * @param $connection

     * @param $code

     * @param $msg

     */

    public function onError($connection, $code, $msg)

    {

        echo "error $code $msg\n";

    }

    /**

     * 每个进程启动

     * @param $worker

     */

    public function onWorkerStart($worker)

    {

        // 进程启动后设置一个每秒运行一次的定时器

        Timer::add(1, function ()use($worker){

            $time_now = time();

            foreach ($worker->connections as $connection) {

                // 有可能该connection还没收到过消息，则lastMessageTime设置为当前时间

                if (empty($connection->lastMessageTime)) {

                    $connection->lastMessageTime = $time_now;

                    continue;

                }

                // 上次通讯时间间隔大于心跳间隔，则认为客户端已经下线，关闭连接

                if ($time_now - $connection->lastMessageTime > 10) {

                    $connection->close();

                }

            }

        });

        echo $worker->id . "\r\n";

    }

}

这个示例是用来作为TCP协议开发的，看onMessage、onWorkerStart两个函数，是增加一个定时器，
因为是做TCP服务端，必须要使用心跳来检测客户端是否因极端情况（断电、异常关机）
而导致断开（这种状况服务端是无法立即得知客户端的断开状态的）。
实现的逻辑是Worker类继承Server类，Worker类中给参数赋值，
然后由父类的Server构造函数来实例化Worker对象，

------------------------------------------------------------

Server.php

<?php

// +----------------------------------------------------------------------

// | ThinkPHP [ WE CAN DO IT JUST THINK IT ]

// +----------------------------------------------------------------------

// | Copyright (c) 2006-2014 http://thinkphp.cn All rights reserved.

// +----------------------------------------------------------------------

// | Licensed ( http://www.apache.org/licenses/LICENSE-2.0 )

// +----------------------------------------------------------------------

// | Author: liu21st <liu21st@gmail.com>

// +----------------------------------------------------------------------

namespace think\worker;

use Workerman\Worker;

use Workerman\Lib\Timer;

/**

 * Worker控制器扩展类

 */

abstract class Server

{

    protected $worker;

    protected $worker2;

    protected $socket    = '';

    protected $protocol  = 'http';

    protected $host      = '0.0.0.0';

    protected $port      = '2346';

    protected $processes = 1;

    /**

     * 架构函数

     * @access public

     */

    public function __construct()

    {

        // 实例化 Websocket 服务

        $this->worker = new Worker($this->socket ?: $this->protocol . '://' . $this->host . ':' . $this->port);

//         $this->worker2 = new Worker('tcp://0.0.0.0:2349');

        // 设置进程数

        $this->worker->count = $this->processes;

        // 设置进程名称

        $this->worker->name = "bluetooth";

        // 初始化

        $this->init();

        // 设置回调

        foreach (['onWorkerStart', 'onConnect', 'onMessage', 'onClose', 'onError', 'onBufferFull', 'onBufferDrain', 'onWorkerStop', 'onWorkerReload'] as $event) {

            if (method_exists($this, $event)) {

                $this->worker->$event = [$this, $event];

            }

        }

        // Run worker

        Worker::runAll();

    }

    protected function init()

    {

    }

}

虽然是集成进来，但依旧很灵活，可以在Server.php里面自定义你所需要的任意WM功能。