Java對接樂橙攝像頭詳細步驟(綁定設(shè)備/直播/控制)

更新時間：2025年12月21日 10:20:20 作者：苡檸苡茉

大華樂橙SDK（LechangeSDK）是一套由大華科技推出的智能安防領(lǐng)域?qū)Ｓ密浖_發(fā)工具包,下面這篇文章主要介紹了Java對接樂橙攝像頭(綁定設(shè)備/直播/控制)的相關(guān)資料,文中通過代碼介紹的非常詳細,需要的朋友可以參考下

接入前準備

開發(fā)前需要去官網(wǎng)注冊，獲取開發(fā)需要的appId 和 appSecret
樂橙官網(wǎng)
樂橙開發(fā)文檔

開始接入

話不多說，直接上代碼。按照這個流程走的話，半天就能完全接入!

常量類

/**
* 我們把這些固定的參數(shù)單獨配置，后續(xù)有變動改這里就可以了
*/
public class MonitorConstants {

    /**
     * 監(jiān)控 redis key
     */
    public static final String MONITOR_CODE_KEY = "monitor_code_key";

    /**
     * appId
     */
    public static final String APP_ID = "xxx";

    /**
     * appSecret
     */
    public static final String APP_SECRET = "xxx";
}

實體類

/**
* 這里給的案例是一個設(shè)備組綁定一個監(jiān)控。大家根據(jù)自己的業(yè)務(wù)情況去修改
*/
@Data
public class DeviceGroup implements Serializable {

    private static final long serialVersionUID = xxx;

    /**
     * 設(shè)備組id
     */
    private Long id;

    /**
     * 用戶id
     */
    private Long userId;

    /**
     * 設(shè)備組名稱
     */
    private String groupName;

    /**
     * 創(chuàng)建時間
     */
    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
    private Date createTime;

    /**
     * 監(jiān)控編碼
     */
    private String monitorCode;

    /**
     * 監(jiān)控鏈接
     */
    private String monitorUrl;

    /**
     * 0-上，1-下，2-左，3-右
     */
    private String operation;

    /**
     * 設(shè)備驗證碼或密碼
     */
    private String code;
}

接口

	/**
     * 監(jiān)控綁定
     *
     * @param deviceGroup
     * @return
     */
    @PutMapping("/monitorBind")
    public AjaxResult monitorBind(@RequestBody DeviceGroup deviceGroup) {

        //判斷設(shè)備組是否已經(jīng)綁定監(jiān)控
        int countGroup = monitorService.getGroupMonitorCount(deviceGroup.getId());
        if (countGroup > 0) {
            return error("設(shè)備組只能綁定一個監(jiān)控!");
        }

        //根據(jù)監(jiān)控編碼判斷監(jiān)控是否被綁定
        int count = monitorService.getMonitorIsBinding(deviceGroup.getMonitorCode());
        if (count > 0) {
            return error("監(jiān)控已被綁定,請檢查!");
        }

        return toAjax(monitorService.monitorBind(deviceGroup));
    }

    /**
     * 監(jiān)控操作
     *
     * @param deviceGroup
     * @return
     */
    @PostMapping("/controlMovePTZ")
    public AjaxResult controlMovePTZ(@RequestBody DeviceGroup deviceGroup) {
        monitorService.controlMovePTZ(deviceGroup);
        return success();
    }

綁定設(shè)備和獲取直播流地址

業(yè)務(wù)層

/**
     * 監(jiān)控綁定
     *
     * @param deviceGroup
     * @return
     */
    @Transactional(rollbackFor = Exception.class)
    @Override
    public int monitorBind(DeviceGroup deviceGroup) {

        //獲取token
        String token = getToken();

        //綁定設(shè)備
        bindDevice(deviceGroup, token);

        //創(chuàng)建設(shè)備源直播地址
        String monitorUrl = bindDeviceLive(deviceGroup, token);
        if (monitorUrl == null) {
            throw new RuntimeException("創(chuàng)建設(shè)備源直播地址失敗!");
        }

        deviceGroup.setMonitorUrl(monitorUrl);

        return monitorMapper.monitorBind(deviceGroup);
    }

獲取token（關(guān)鍵）

/**
     * 獲取token
     *
     * @return
     */
    private String getToken() {

        try {
            //從redis獲取token
            Object cacheObject = redisCache.getCacheObject(MonitorConstants.MONITOR_CODE_KEY);
            if (cacheObject != null) {
                return cacheObject.toString();
            }
            Map<String, Object> requestParams = paramsInit(Collections.emptyMap());
            String requestData = JSONObject.toJSONString(requestParams);

            String result = HttpClientUtil.getToken("https://openapi.lechange.cn/openapi/accessToken", requestData);
            JSONObject jsonObject = JSONObject.parseObject(result);
            if ("0".equals(JSONObject.from(jsonObject.get("result")).get("code"))) {
                String token = JSONObject.from(JSONObject.from(jsonObject.get("result")).get("data")).get("accessToken").toString();
                redisCache.setCacheObject(MonitorConstants.MONITOR_CODE_KEY, token, 2, TimeUnit.DAYS);
                return token;
            }
        } catch (Exception e) {
            e.printStackTrace();
        }

        return null;
    }

綁定設(shè)備（關(guān)鍵）

/**
     * 綁定設(shè)備
     *
     * @param deviceGroup
     * @param token
     */
    private void bindDevice(DeviceGroup deviceGroup, String token) {

        try {

            Map<String, Object> paramsMap = new HashMap<>();
            paramsMap.put("token", token);
            paramsMap.put("deviceId", deviceGroup.getMonitorCode());
            paramsMap.put("code", deviceGroup.getCode());

            Map<String, Object> requestParams = paramsInit(paramsMap);
            String requestData = JSONObject.toJSONString(requestParams);

            String result = HttpClientUtil.getToken("https://openapi.lechange.cn/openapi/bindDevice", requestData);
            JSONObject jsonObject = JSONObject.parseObject(result);
            if (!"0".equals(JSONObject.from(jsonObject.get("result")).get("code"))) {
                throw new RuntimeException();
            }
        } catch (Exception e) {
            e.printStackTrace();
            throw new RuntimeException("綁定設(shè)備失敗!");
        }
    }

創(chuàng)建設(shè)備源直播地址（關(guān)鍵）

 /**
     * 創(chuàng)建設(shè)備源直播地址
     *
     * @param deviceGroup
     * @param token
     * @return
     */
    private String bindDeviceLive(DeviceGroup deviceGroup, String token) {

        try {

            Map<String, Object> paramsMap = new HashMap<>();
            paramsMap.put("token", token);
            paramsMap.put("deviceId", deviceGroup.getMonitorCode());
            paramsMap.put("channelId", "0");
            paramsMap.put("streamId", 0);

            Map<String, Object> requestParams = paramsInit(paramsMap);
            String requestData = JSONObject.toJSONString(requestParams);

            String result = HttpClientUtil.getToken("https://openapi.lechange.cn/openapi/bindDeviceLive", requestData);
            JSONObject jsonObject = JSONObject.parseObject(result);
            if ("0".equals(JSONObject.from(jsonObject.get("result")).get("code"))) {
                JSONObject jo = JSONObject.from(JSONObject.from(jsonObject.get("result")).get("data"));
                JSONArray streams = JSONArray.parseArray(jo.get("streams").toString());
                return JSONObject.from(streams.get(2)).get("hls").toString();
            }
        } catch (Exception e) {
            e.printStackTrace();
        }

        return null;
    }

統(tǒng)一封裝請求參數(shù)（關(guān)鍵）

/**
     * 封裝請求參數(shù)
     *
     * @param paramsMap
     * @return
     */
    protected static Map<String, Object> paramsInit(Map<String, Object> paramsMap) {
        long time = System.currentTimeMillis() / 1000;
        String nonce = UUID.randomUUID().toString();
        String id = UUID.randomUUID().toString();

        StringBuilder paramString = new StringBuilder();
        paramString.append("time:").append(time).append(",");
        paramString.append("nonce:").append(nonce).append(",");
        paramString.append("appSecret:").append(MonitorConstants.APP_SECRET);

        String sign = "";
        // 計算MD5得值
        try {
            sign = DigestUtils.md5Hex(paramString.toString().trim().getBytes("UTF-8"));
        } catch (Exception e) {
            e.printStackTrace();
        }

        Map<String, Object> systemMap = new HashMap<String, Object>();
        systemMap.put("ver", "1.0");
        systemMap.put("sign", sign);
        systemMap.put("appId", MonitorConstants.APP_ID);
        systemMap.put("nonce", nonce);
        systemMap.put("time", time);

        Map<String, Object> map = new HashMap<String, Object>();
        map.put("system", systemMap);
        map.put("params", paramsMap);
        map.put("id", id);
        return map;
    }

設(shè)備控制

業(yè)務(wù)層

/**
     * 監(jiān)控操作
     *
     * @param deviceGroup
     */
    @Override
    public void controlMovePTZ(DeviceGroup deviceGroup) {

        //獲取token
        String token = getToken();

        //監(jiān)控操作
        control(deviceGroup, token);
    }

獲取token（關(guān)鍵）

同上

發(fā)送指令（關(guān)鍵）

 /**
     * 云臺移動控制
     *
     * @param deviceGroup
     * @param token
     * @return
     */
    private void control(DeviceGroup deviceGroup, String token) {

        try {

            Map<String, Object> paramsMap = new HashMap<>();
            paramsMap.put("token", token);
            paramsMap.put("deviceId", deviceGroup.getMonitorCode());
            paramsMap.put("channelId", "0");
            paramsMap.put("operation", deviceGroup.getOperation());
            paramsMap.put("duration", "1000");

            Map<String, Object> requestParams = paramsInit(paramsMap);
            String requestData = JSONObject.toJSONString(requestParams);

            String result = HttpClientUtil.getToken("https://openapi.lechange.cn/openapi/controlMovePTZ", requestData);
            JSONObject jsonObject = JSONObject.parseObject(result);
            if (!"0".equals(JSONObject.from(jsonObject.get("result")).get("code"))) {
                throw new RuntimeException();
            }
        } catch (Exception e) {
            e.printStackTrace();
            throw new RuntimeException("監(jiān)控移動控制失敗!");
        }
    }