使用start_worker的onMessage无法执行内部函数方法

@walkor大神，非常感谢大神这么晚还这么快速的回复，谢谢了！也特别感谢大神们开发出workerman这么优秀的框架，给我们广大开发者带来的极大便利，是码农们的福音！

我对问题重新做了下编辑，同时也把代码demo直接发上来，还请大神能给予指导，问题还是onmessage回调里去实现服务端给客户端发送消息时候，无法触达，代码如下：

use \Workerman\Worker;
use \Workerman\Timer;
use \Workerman\Connection\UdpConnection;

// 自动加载类
require_once __DIR__ . '/../../vendor/autoload.php';

$worker = new Worker('udp://0.0.0.0:6000');
// worker名称
$worker->name = 'XMC-UDP-Worker';
// Worker进程数量
/*
 * 注意这里进程数必须设置为1，否则会报端口占用错误
 * (php 7可以设置进程数大于1，前提是$inner_text_worker->reusePort=true)
 */
$worker->count = 1;
$worker->uids = [];

//启动内部通讯
$worker->onWorkerStart = function ($worker) {
    // 开启一个内部端口，方便内部系统推送数据，Text协议格式 文本+换行符
    $inner_text_worker = new Worker('text://0.0.0.0:5678');
    $inner_text_worker->onMessage = function ($connection, $buffer) {
        // $data数组格式，里面有uid，表示向那个uid的页面推送数据
        $data = json_decode($buffer, true);
        $uid = intval($data['uid']);
        // 通过workerman，向uid的页面推送数据
        $ret = sendMessageByUid($uid, $data['msg']);
        // 返回推送结果
        $connection->send($ret ? 'ok' : 'fail');
    };
    // ## 执行监听 ##
    $inner_text_worker->listen();
};

//监听接收消息
$worker->onMessage = function ($connection, $message) {
    global $worker;
    if (!isset($connection->uid)) {
        $ip_arr = explode('.', $connection->getRemoteIp());
        ///$port = $connection->getRemotePort();
        $ip = intval(end($ip_arr));
        $connection->uid = $ip;
        $worker->uids[$connection->uid] = $connection;
    }
    //$client_id这里为了测试直接写死为一个客户端IP
    $client_id=109；
    $client = stream_socket_client('tcp://0.0.0.0:5678', $errno, $errmsg, 1);
    // 推送的数据，包含uid字段，表示是给这个uid推送
    $data = json_encode(['uid' => $client_id, 'msg' => 'test']);
    // 发送数据，注意5678端口是Text协议的端口，Text协议需要在数据末尾加上换行符
    fwrite($client, $data . "\n");
    //echo fread($client, 8192);
};

// 向所有验证的用户推送数据
function broadcast($message)
{
    global $worker;
    foreach ($worker->uids as $connection) {
        $connection->send($message);
    }
};

// 针对uid推送数据
function sendMessageByUid($uid, $message)
{
    global $worker;
    if (isset($worker->uids[$uid])) {
        $connection = $worker->uids[$uid];
        $connection->send($message);
    }
};

// 如果不是在根目录启动，则运行runAll方法
if (!defined('GLOBAL_START')) {
    Worker::runAll();
}