從swoole過來，今天在評估是否可以用webman開發(fā)下一個項目，發(fā)現(xiàn)基本都滿足需求，但是有一個問題沒搞明白：請問webman的控制器如何與自定義進程通信？

比如這是我的自定義進程，基本目的是本地緩存多個小數(shù)據(jù)，組成batch然后發(fā)送到sqs

class Sqs
{
    private $queueData = [];

    public function onWorkerStart()
    {
        // 每隔5秒 flush 到 sqs
        Timer::add(5, function(){
            $currentData = array_splice($this->queueData, 0);
            file_put_contents('/tmp/sqs,txt', var_export($currentData, true), FILE_APPEND);
        });
    }

    public function onMessage(TcpConnection $connection, $data)
    {
        echo "onMessage\n";
        echo "$data\n";

        $this->queueData[] = $data;
    }
}

目前看文檔好像有兩種方式：

1. process配置listen，然后用tcpconnection連接，比如：

   // config/process.php
   'sqs'=>[
   'handler' => process\Sqs::class,
   'listen'  => 'text://0.0.0.0:9090',
   ]

// IndexController.php
function index(){
    if(!$process){
        $process = new TcpConnection('text://0.0.0.0:9090');
    }

    $process->send("some data...");
}

2 用Channel分布式通訊組件，感覺走了彎路

有沒有在控制器里面直接往這個自定義進程發(fā)送數(shù)據(jù)的方法？類似
process('Sqs')->write("some data.....")