我要评论接入前准备
开发前需要去官网注册，获取开发需要的appid 和 appsecret
乐橙官网
乐橙开发文档
开始接入
话不多说，直接上代码。按照这个流程走的话，半天就能完全接入!
常量类
/**
* 我们把这些固定的参数单独配置，后续有变动改这里就可以了
*/
public class monitorconstants {
/**
* 监控 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";
}
实体类
/**
* 这里给的案例是一个设备组绑定一个监控。大家根据自己的业务情况去修改
*/
@data
public class devicegroup implements serializable {
private static final long serialversionuid = xxx;
/**
* 设备组id
*/
private long id;
/**
* 用户id
*/
private long userid;
/**
* 设备组名称
*/
private string groupname;
/**
* 创建时间
*/
@jsonformat(pattern = "yyyy-mm-dd hh:mm:ss")
private date createtime;
/**
* 监控编码
*/
private string monitorcode;
/**
* 监控链接
*/
private string monitorurl;
/**
* 0-上，1-下，2-左，3-右
*/
private string operation;
/**
* 设备验证码或密码
*/
private string code;
}
接口
/**
* 监控绑定
*
* @param devicegroup
* @return
*/
@putmapping("/monitorbind")
public ajaxresult monitorbind(@requestbody devicegroup devicegroup) {
//判断设备组是否已经绑定监控
int countgroup = monitorservice.getgroupmonitorcount(devicegroup.getid());
if (countgroup > 0) {
return error("设备组只能绑定一个监控!");
}
//根据监控编码判断监控是否被绑定
int count = monitorservice.getmonitorisbinding(devicegroup.getmonitorcode());
if (count > 0) {
return error("监控已被绑定,请检查!");
}
return toajax(monitorservice.monitorbind(devicegroup));
}
/**
* 监控操作
*
* @param devicegroup
* @return
*/
@postmapping("/controlmoveptz")
public ajaxresult controlmoveptz(@requestbody devicegroup devicegroup) {
monitorservice.controlmoveptz(devicegroup);
return success();
}
绑定设备和获取直播流地址
业务层
/**
* 监控绑定
*
* @param devicegroup
* @return
*/
@transactional(rollbackfor = exception.class)
@override
public int monitorbind(devicegroup devicegroup) {
//获取token
string token = gettoken();
//绑定设备
binddevice(devicegroup, token);
//创建设备源直播地址
string monitorurl = binddevicelive(devicegroup, token);
if (monitorurl == null) {
throw new runtimeexception("创建设备源直播地址失败!");
}
devicegroup.setmonitorurl(monitorurl);
return monitormapper.monitorbind(devicegroup);
}
获取token（关键）
/**
* 获取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;
}
绑定设备（关键）
/**
* 绑定设备
*
* @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("绑定设备失败!");
}
}
创建设备源直播地址（关键）
/**
* 创建设备源直播地址
*
* @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;
}
统一封装请求参数（关键）
/**
* 封装请求参数
*
* @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;
}
设备控制
业务层
/**
* 监控操作
*
* @param devicegroup
*/
@override
public void controlmoveptz(devicegroup devicegroup) {
//获取token
string token = gettoken();
//监控操作
control(devicegroup, token);
}
获取token（关键）
同上
发送指令（关键）
/**
* 云台移动控制
*
* @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("监控移动控制失败!");
}
}
总结
1.这里是把生成的直播地址存到数据库，只需要生成一次。后续除非是设备解绑，不然这个链接是长期有效的。
2.设备控制是给的默认1秒，每次上下左右移动的持续时长可以自定义。
3.这里只是给出代码案例，彦祖亦菲们根据自己的实际业务场景来修改。
到此这篇关于java对接乐橙摄像头(绑定设备/直播/控制)的文章就介绍到这了,更多相关java对接乐橙摄像头内容请搜索代码网以前的文章或继续浏览下面的相关文章希望大家以后多多支持代码网！
发表评论