发表新帖

swoole_client 绑定事件问题

我在构造方法里面绑定了事件，但是没有起效，我一样的语法在swoole_server里面是没有问题的！

<?php

// +----------------------------------------------------------------------
// | date: 2015-06-28
// +----------------------------------------------------------------------
// | SwooleController.php: swoole客户端控制器
// +----------------------------------------------------------------------
// | Author: yangyifan <yangyifanphp@gmail.com>
// +----------------------------------------------------------------------

class SwooleController extends Controller {

private $swoole_client;//swoole_clent客户端

/**
     * 构造方法
     *
     * @auther yangyifan <yangyifanphp@gmail.com>
     */
    public function __construct(){
        $this->swoole_client = new \swoole_client(SWOOLE_SOCK_TCP);

//设置客户端参数
        $this->set();

//绑定事件
        $this->swoole_client->on('connect', [$this, 'onConnect']);
        $this->swoole_client->on('receive', [$this, 'onReceive']);
        $this->swoole_client->on('close', [$this, 'onClose']);

//链接swoole_server
        $this->swoole_client->connect(config('swoole.swoole_host'), config('swoole.swoole_port'), config('swoole.swoole_timeout'));

//判断是否连接
        if($this->swoole_client->isConnected() == false){
            echo ("connect failed. Error: {$this->swoole_client->errCode}".config('swoole.package_eof'));
        }

}

/**
     * 设置客户端参数
     *
     * @auther yangyifan <yangyifanphp@gmail.com>
     */
    private function set(){
        $this->swoole_client->set([
            'open_length_check' => config('swoole.open_eof_check'),
            'package_eof'       => config('swoole.package_eof'),
        ]);
    }

/**
     * 发送请求
     *
     * @auther yangyifan <yangyifanphp@gmail.com>
     */
    public function getIndex(){
        $this->swoole_client->send("hello world212121".config('swoole.package_eof'));
    }

/**
     * 客户端连接
     *
     * @param \swoole_client $client
     * @auther yangyifan <yangyifanphp@gmail.com>
     */
    public function onConnect($client){
        echo 'Clent connect'.config('swoole.package_eof');
        $client->send("hello world212121".config('swoole.package_eof'));
    }

/**
     * 接受数据
     *
     * @param \swoole_client $client
     * @param string $data
     * @auther yangyifan <yangyifanphp@gmail.com>
     */
    public function onReceive($client, $data = ''){
        echo $data;
    }

/**
     * 客户端关闭
     *
     * @param \swoole_client $client
     * @auther yangyifan <yangyifanphp@gmail.com>
     */
    public function onClose($client){
        echo 'Client close';
    }
}

发布于8年前 · 0 次浏览 · 来自提问

十

十年不散

我在构造方法里面绑定了事件，但是没有起效，我一样的语法在swoole_server里面是没有问题的！

<?php

class SwooleController extends Controller {

private $swoole_client;//swoole_clent客户端

/**
     * 构造方法
     *
     * @auther yangyifan <yangyifanphp@gmail.com>
     */
    public function __construct(){
        $this->swoole_client = new \swoole_client(SWOOLE_SOCK_TCP);

//设置客户端参数
        $this->set();

//链接swoole_server
        $this->swoole_client->connect(config('swoole.swoole_host'), config('swoole.swoole_port'), config('swoole.swoole_timeout'));

//判断是否连接
        if($this->swoole_client->isConnected() == false){
            echo ("connect failed. Error: {$this->swoole_client->errCode}".config('swoole.package_eof'));
        }

}

2016-10-29

qzuser

微信公众号

热门内容

暂无回复的问答

- 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一直是同一个。没用使用到多进程啊。