发表新帖

客户端如何发送给swoole框架的控制器执行异步操作？

swoole框架是以AppServer方式运行的，也看到底层代码支持分发路由执行
{{{php
 /**
     * 接收到数据
     * @param $serv \swoole_server
     * @param $client_id
     * @param $from_id
     * @param $data
     * @return null
     */
    function onReceive($serv, $client_id, $from_id, $data)
    {
        //检测request data完整性
        $ret = $this->checkData($client_id, $data);
        switch($ret)
        {
            //错误的请求
            case self::ST_ERROR;
                $this->server->close($client_id);
                return;
            //请求不完整，继续等待
            case self::ST_WAIT:
                return;
            default:
                break;
        }
        //完整的请求
        //开始处理

/**
         * @var $request Swoole\Request
         */
        $request = $this->requests[$client_id];
	    $info = $serv->connection_info($client_id);
        $request->remote_ip = $info['remote_ip'];
        $request->remote_port = $info['remote_port'];
	    $_SERVER['SWOOLE_CONNECTION_INFO'] = $info;
        $this->parseRequest($request);
        $request->fd = $client_id;
        $this->currentRequest = $request;

//处理请求，产生response对象
        $response = $this->onRequest($request);
        if ($response and $response instanceof Swoole\Response)
        {
            //发送response
            $this->response($request, $response);
        }
    }
}}}

哪么客户端如何发送到某个路由执行呢？
{{{php
$client = new swoole_client(SWOOLE_SOCK_TCP);
$client ->connect('127.0.0.1', 8888, 1);
$client->send($data)           //这里如何发送到路由由控制器执行？
}}}

发布于6年前 · 1 次浏览 · 来自提问

绝食伤心

swoole框架是以AppServer方式运行的，也看到底层代码支持分发路由执行
{{{php
 /**
     * 接收到数据
     * @param $serv \swoole_server
     * @param $client_id
     * @param $from_id
     * @param $data
     * @return null
     */
    function onReceive($serv, $client_id, $from_id, $data)
    {
        //检测request data完整性
        $ret = $this->checkData($client_id, $data);
        switch($ret)
        {
            //错误的请求
            case self::ST_ERROR;
                $this->server->close($client_id);
                return;
            //请求不完整，继续等待
            case self::ST_WAIT:
                return;
            default:
                break;
        }
        //完整的请求
        //开始处理

/**
         * @var $request Swoole\Request
         */
        $request = $this->requests[$client_id];
	    $info = $serv->connection_info($client_id);
        $request->remote_ip = $info['remote_ip'];
        $request->remote_port = $info['remote_port'];
	    $_SERVER['SWOOLE_CONNECTION_INFO'] = $info;
        $this->parseRequest($request);
        $request->fd = $client_id;
        $this->currentRequest = $request;

//处理请求，产生response对象
        $response = $this->onRequest($request);
        if ($response and $response instanceof Swoole\Response)
        {
            //发送response
            $this->response($request, $response);
        }
    }
}}}

哪么客户端如何发送到某个路由执行呢？
{{{php
$client = new swoole_client(SWOOLE_SOCK_TCP);
$client ->connect('127.0.0.1', 8888, 1);
$client->send($data)           //这里如何发送到路由由控制器执行？
}}}

评论

2017-08-19

keheng

2017-08-20

翱翔

微信公众号

Swoole官方公众号

暂无回复的问答

- CodeGalaxy K3s 轻量集群节点之间如何实现负载均衡

- 关于openssl CURL WARNING swSSL_connect: SSL_connect(fd=69) failed. Error: error:141A318A:SSL routines:tls_process_ske_dhe:dh key too small[1|394]

- 多个模型如何进行事务异常回退？

- websocket开启wss报错

- 协程tcp服务器如何使用多进程？recv()方法接收信息，打印出来的pid一直是同一个。没用使用到多进程啊。