#### 问题描述
在gateway中使用AsyncTcpConnection把任务发给task_worker去处理,参考了异步任务文档https://www.workerman.net/doc/workermanbusinessWorker)
{
if ($businessWorker->id == 0) {
Timer::add($msgInterval, function () {
// 与远程task服务建立异步连接,ip为远程task服务的ip,如果是本机就是127.0.0.1,如果是集群就是lvs的ip
$task_connection = new AsyncTcpConnection('Text://127.0.0.1"\n";
};
// 设置业务处理函数
$task_worker->onMessage = function($connection, $task_data)
{
// 假设发来的是json数据json_decode($task_data, true);
trace([$task_data,'msg'=>'发送后'],'crontab');
// 根据task_data处理相应的任务逻辑