回调接口

public boolean KY_registerSDKListener(InterfaceCtrl.KY_SDKListener listener);

// 实现SDK回调监听器 InterfaceCtrl.KY_SDKListener sdkListener = new InterfaceCtrl.KY_SDKListener() {    @Override    public void KY_receiveBindInfo(String uid, String credential, int KYDeviceState, int errorCode) {        // 处理绑定结果回调    }        @Override    public void KY_DeviceStatus(String uid, int channel, int state) {        // 处理设备状态回调    }        // 实现其他回调方法... }; // 注册SDK回调 boolean isRegistered = InterfaceCtrl.KY_registerSDKListener(sdkListener); if (isRegistered) {    Log.d("TUTK", "SDK回调注册成功"); } else {    Log.d("TUTK", "SDK回调注册失败"); }

public boolean KY_unRegisterSDKListener(InterfaceCtrl.KY_SDKListener listener);

// 注销SDK回调 boolean isUnregistered = InterfaceCtrl.KY_unRegisterSDKListener(sdkListener); if (isUnregistered) {    Log.d("TUTK", "SDK回调注销成功"); } else {    Log.d("TUTK", "SDK回调注销失败"); }

void KY_receiveBindInfo(String uid, String credential, int KYDeviceState, int errorCode);

@Override public void KY_receiveBindInfo(String uid, String credential, int KYDeviceState, int errorCode) {    if (errorCode == 0) {        Log.d("TUTK", "设备绑定成功，UID: " + uid + ", credential: " + credential);        // 保存绑定凭证，用于后续设备连接        saveCredential(uid, credential);    } else {        Log.e("TUTK", "设备绑定失败，错误码: " + errorCode);        // 处理绑定失败逻辑        handleBindError(errorCode);    } }

void KY_DeviceStatus(String uid, int channel, int state);

@Override public void KY_DeviceStatus(String uid, int channel, int state) {    switch (state) {        case 1: // KY_STATE_CONNECTING            Log.d("TUTK", "设备" + uid + "正在连接中...");            break;        case 2: // KY_STATE_CONNECTED            Log.d("TUTK", "设备" + uid + "连接成功");            // 连接成功，开始出图或其他操作            startPreview(uid);            break;        case 3: // KY_STATE_DISCONNECTED            Log.d("TUTK", "设备" + uid + "连接已断开");            // 处理断开连接逻辑            stopPreview(uid);            break;        default:            Log.e("TUTK", "设备" + uid + "连接失败，状态码: " + state);            // 处理连接失败逻辑            showConnectError(state);            break;    } }

void KY_UpdateDecodedImage(String uid, int channel, long timestamp);

@Override public void KY_UpdateDecodedImage(String uid, int channel, long timestamp) {    Log.d("TUTK", "设备" + uid + "视频帧更新，时间戳: " + timestamp);    // 更新视频显示画面    updateVideoView(uid, channel);        // 统计帧率    calculateFps(uid, timestamp); }

void KY_DecodeVideoFramInfo(String uid, int channel, int connectMode, int videoWidth, int videoHeight, int videoFPS, int bps, int onlineNm, int frameCount, int incompleteFrameCount, boolean isHwDecode, int sessionID, int avChannelIndex, int cmdNum, int cmdReturn);

@Override public void KY_DecodeVideoFramInfo(String uid, int channel, int connectMode,                                 int videoWidth, int videoHeight, int videoFPS,                                 int bps, int onlineNm, int frameCount,                                 int incompleteFrameCount, boolean isHwDecode,                                 int sessionID, int avChannelIndex, int cmdNum, int cmdReturn) {        // 打印视频流信息    Log.d("TUTK", String.format(        "设备%s视频信息：分辨率%dx%d，帧率%dfps，码率%dbps，解码方式：%s",        uid, videoWidth, videoHeight, videoFPS, bps,        isHwDecode ? "硬件解码" : "软件解码"    ));        // 计算丢帧率    float lossRate = frameCount > 0 ? (float)incompleteFrameCount / frameCount * 100 : 0;    Log.d("TUTK", "丢帧率: " + String.format("%.2f", lossRate) + "%");        // 根据连线模式做特殊处理    String connectModeStr = getConnectModeString(connectMode);    Log.d("TUTK", "连线模式: " + connectModeStr); } // 转换连线模式为字符串 private String getConnectModeString(int mode) {    switch (mode) {        case -1: return "NONE";        case 0: return "P2P";        case 1: return "RELAY";        case 2: return "LAN";        default: return "UNKNOWN";    } }

void KY_ReceiveFrameData(String uid, int channel, AVFrame avFrame);

@Override public void KY_ReceiveFrameData(String uid, int channel, AVFrame avFrame) {    if (avFrame == null) {        return;    }        // 获取YUV数据    byte[] yData = avFrame.y;    byte[] uData = avFrame.u;    byte[] vData = avFrame.v;        // 获取帧信息    int width = avFrame.width;    int height = avFrame.height;    long timestamp = avFrame.timestamp;        // 自定义渲染YUV数据到SurfaceView    renderYUVData(yData, uData, vData, width, height);        // 可选：保存视频帧为图片    if (needCaptureFrame) {        saveFrameToImage(avFrame, uid);        needCaptureFrame = false;    } }

void KY_ReceiveAudioData(String uid, int channel, AVFrame avFrame);

// 音频播放器初始化 private AudioTrack audioTrack; @Override public void KY_ReceiveAudioData(String uid, int channel, AVFrame avFrame) {    if (avFrame == null || avFrame.data == null) {        return;    }        // 获取PCM音频数据    byte[] pcmData = avFrame.data;    int sampleRate = avFrame.sampleRate; // 采样率，如8000, 16000等    int channels = avFrame.channels; // 声道数，1:单声道，2:立体声    int bitDepth = avFrame.bitDepth; // 位深，通常为16        // 初始化音频播放器    if (audioTrack == null || !audioTrack.isPlaying()) {        initAudioTrack(sampleRate, channels, bitDepth);    }        // 播放PCM音频数据    if (audioTrack != null && audioTrack.getState() == AudioTrack.STATE_INITIALIZED) {        audioTrack.write(pcmData, 0, pcmData.length);    } } // 初始化AudioTrack private void initAudioTrack(int sampleRate, int channels, int bitDepth) {    int channelConfig = channels == 1 ? AudioFormat.CHANNEL_OUT_MONO : AudioFormat.CHANNEL_OUT_STEREO;    int audioFormat = bitDepth == 16 ? AudioFormat.ENCODING_PCM_16BIT : AudioFormat.ENCODING_PCM_8BIT;    int bufferSize = AudioTrack.getMinBufferSize(sampleRate, channelConfig, audioFormat);        audioTrack = new AudioTrack(        AudioManager.STREAM_MUSIC,        sampleRate,        channelConfig,        audioFormat,        bufferSize * 2,        AudioTrack.MODE_STREAM    );        audioTrack.play(); }

void KY_DidReceiveIOCtrlWithUid(String uid, int channel, int type, byte[] data, int dataSize);

@Override public void KY_DidReceiveIOCtrlWithUid(String uid, int channel, int type, byte[] data, int dataSize) {    Log.d("TUTK", "收到设备" + uid + "的Command回复，指令类型: " + type);        // 根据指令类型解析数据    switch (type) {        case CMD_GET_DEVICE_INFO: // 假设这是获取设备信息的指令类型            // 解析设备信息结构体            DeviceInfo info = parseDeviceInfo(data, dataSize);            Log.d("TUTK", "设备名称: " + info.deviceName + ", 固件版本: " + info.firmwareVersion);            break;                    case CMD_GET_SD_CARD_INFO: // 获取SD卡信息            SDCardInfo sdInfo = parseSDCardInfo(data, dataSize);            Log.d("TUTK", "SD卡容量: " + sdInfo.totalSize + "MB, 可用: " + sdInfo.freeSize + "MB");            break;                    default:            // 其他指令类型解析            Log.d("TUTK", "未处理的指令类型: " + type);            break;    } } // 示例：解析设备信息 private DeviceInfo parseDeviceInfo(byte[] data, int dataSize) {    DeviceInfo info = new DeviceInfo();    if (data != null && dataSize > 0) {        // 按结构体格式解析二进制数据        // 示例：假设前32字节是设备名称，接下来4字节是固件版本号        ByteBuffer buffer = ByteBuffer.wrap(data);        buffer.order(ByteOrder.LITTLE_ENDIAN);                byte[] nameBytes = new byte[32];        buffer.get(nameBytes);        info.deviceName = new String(nameBytes).trim();                info.firmwareVersion = buffer.getInt();    }    return info; }

void KY_DidReceiveNebulaCtrlWithUid(String uid, int channel, String jsonRequest, String jsonResponse);

@Override public void KY_DidReceiveNebulaCtrlWithUid(String uid, int channel, String jsonRequest, String jsonResponse) {    Log.d("TUTK", "设备" + uid + "Nebula指令回复：");    Log.d("TUTK", "请求: " + jsonRequest);    Log.d("TUTK", "响应: " + jsonResponse);        try {        // 解析JSON响应        JSONObject response = new JSONObject(jsonResponse);                // 获取响应状态        int code = response.optInt("code", -1);        String msg = response.optString("msg", "");                if (code == 0) {            // 指令执行成功            Log.d("TUTK", "Nebula指令执行成功");                        // 根据不同指令解析数据            JSONObject request = new JSONObject(jsonRequest);            String cmd = request.optString("cmd");                        if ("device_info".equals(cmd)) {                // 解析设备信息                JSONObject data = response.optJSONObject("data");                String deviceModel = data.optString("model");                String firmwareVer = data.optString("firmware_version");                Log.d("TUTK", "设备型号: " + deviceModel + ", 固件版本: " + firmwareVer);            } else if ("wifi_config".equals(cmd)) {                // 解析WiFi配置结果                boolean success = response.optBoolean("success");                Log.d("TUTK", "WiFi配置" + (success ? "成功" : "失败"));            }        } else {            // 指令执行失败            Log.e("TUTK", "Nebula指令执行失败：" + msg + " (错误码: " + code + ")");        }    } catch (JSONException e) {        Log.e("TUTK", "JSON解析失败", e);    } }

void KY_DownloadUploadOutput(Camera camera, int channel, String filePath, int progress, int loadType, int p2pCode);

// 进度条控件 private ProgressDialog progressDialog; @Override public void KY_DownloadUploadOutput(Camera camera, int channel, String filePath, int progress, int loadType, int p2pCode) {    String fileName = new File(filePath).getName();    String transferType = loadType == AVIOCTRLDEFs.FILETransferType_Download ? "下载" : "上传";        Log.d("TUTK", String.format("%s文件%s，进度：%d%%，状态码：%d",        fileName, transferType, progress, p2pCode));        // 初始化进度对话框    if (progressDialog == null) {        progressDialog = new ProgressDialog(context);        progressDialog.setTitle(transferType + "文件");        progressDialog.setMessage("正在" + transferType + "：" + fileName);        progressDialog.setProgressStyle(ProgressDialog.STYLE_HORIZONTAL);        progressDialog.setCancelable(false);        progressDialog.show();    }        // 更新进度    progressDialog.setProgress(progress);        // 传输完成或失败    if (progress >= 100 || p2pCode != 0) {        progressDialog.dismiss();        progressDialog = null;                if (p2pCode == 0) {            Toast.makeText(context, fileName + transferType + "完成", Toast.LENGTH_SHORT).show();        } else {            Toast.makeText(context, fileName + transferType + "失败，错误码：" + p2pCode, Toast.LENGTH_SHORT).show();        }    } }