phpはsocketとゲームサーバ間の小さなデータ量通信を利用する

2525 ワード

php利用のフレームワークはlaravel
せいぎょそうち
25198:ユーザid,type:ゲームサーバと約束したタイプ,value:数値
public function testtcp(){
    $aa = (new Tcp())->sendNoti(25198, [['type'=>0, 'value'=>10000]]);
}

モデル:Tcp.php
3, "usec"=>10 ));  //     
        socket_set_option($socket,SOL_SOCKET,SO_SNDTIMEO,array("sec"=>2, "usec"=>10 ));  //     2 
		
        if ($socket === false) {
            return false;
        }
		
        $result = socket_connect($socket, $ip, $port);
        
        if($result === false) {
            return false;
        }
        
        $r = socket_write($socket, $send_data, strlen($send_data));

        $buffer = socket_read($socket,1024,PHP_BINARY_READ);
        if($buffer){
            socket_close($socket);
            return true;
        }

        if($r){
            socket_close($socket);
            return true;
        }else{
            socket_close($socket);
            return false;
        }
        socket_close($socket);
        return false;
    }

    static function packData($data, $msgId){
        $len = strlen($data);
        $send_data = pack("l",strlen($data) + 4, $msgId, $data);
        return $send_data;
    }

    static function unpackData($data){
        $r = unpack("lhead/lmsgId/a*body", $data);
        return $r;
    }

    public function sendNoti($userId, $notiData = array()){
        if(empty($notiData)) return true;
        $noti = new RECHARGE_NOTI();
        $noti->set_UserID($userId);
        foreach ($notiData as $k => $v) {
            $atti = new Modify_Atti();
            $atti->set_Type(intval($v['type']));
            $atti->set_Value(strval($v['value']));
            $noti->set_attrList($k, $atti);
        }
        $str = $noti->SerializeToString();
        $pdata = Tcp::packData($str, protoID::RECHARGE_NOTI_ID);
        return Tcp::send($pdata);
    }

}




モデル内のsendNoti関数からパッケージ化されたパッケージがあることが分かった
パッケージの場所はApplibsにあります
ダウンロード:https://github.com/yangshengquan87/socket.git