后端推送消息

function globalPushMessage($uid, $data, $type)
    {
        try{
            $tcp = 'tcp://'.config('websocket.host').':'.config('websocket.port_backend');
            // if(config("database")['database']=='dhf_dkapp_dev'){
            //     $tcp = 'tcp://172.31.97.162:39301';
            // }
            $client = stream_socket_client($tcp, $errno, $errmsg, 1);  
            $result = [ 'type'=>$type, 'uid'=>$uid, 'data'=> $data ];
            fwrite($client, json_encode($result)."\n"); 
            fclose($client);
        }catch(\Exception $ex){  }  
    }