java springboot mqtt控制海康摄像头

GHHKControlService 接口

package org.gh.ghhk.service;public interface GHHKControlService {boolean monitorControl(String payload);}

GHHKControlServiceImpl  实现类

​
package org.gh.ghhk.service.impl;import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.sun.jna.NativeLong;
import lombok.RequiredArgsConstructor;
import org.gh.ghhk.net.HCNetSDK;
import org.gh.ghhk.service.GHHKControlService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Service;@RequiredArgsConstructor
@Service
public class GHHKControlServiceImpl implements GHHKControlService {private static final String MONITORIP = "monitorIp";private static final String MONITORCONTROLPORT = "monitorControlPort";private static final String MONITORUSERNAME = "monitorUserName";private static final String MONITORPASSWORD = "monitorPassWord";private static final String DIR = "dir";private static final String SPEED = "speed";private static final String DATA = "data";private static final String ACTIONS = "actions";private static final Logger log = LoggerFactory.getLogger(GHHKControlServiceImpl.class);@Overridepublic boolean monitorControl(String payload) {try {JSONObject jsonObject = JSONObject.parseObject(payload);JSONObject dastaJsonObject = jsonObject.getJSONObject(DATA);JSONArray actionsJsonArray = dastaJsonObject.getJSONArray(ACTIONS);for (int i = 0; i < actionsJsonArray.size(); i++) {JSONObject actionJsonObject = actionsJsonArray.getJSONObject(i);String monitorIp = actionJsonObject.getString(MONITORIP);Short monitorControlPort = actionJsonObject.getShort(MONITORCONTROLPORT);String monitorUserName = actionJsonObject.getString(MONITORUSERNAME);String monitorPassword = actionJsonObject.getString(MONITORPASSWORD);int dir = actionJsonObject.getInteger(DIR);int speed = actionJsonObject.getInteger(SPEED);boolean result = this.processMonitorControl(monitorIp, monitorControlPort, monitorUserName, monitorPassword, dir, speed);if (!result) {// 如果某个操作失败，可以选择返回false或者继续执行return false;}}return true; // 如果所有操作都成功，返回true} catch (Exception e) {e.printStackTrace();return false;}}public boolean processMonitorControl(String monitorIp, Short monitorControlPort, String monitorUserName, String monitorPassword, Integer dir, int speed) throws InterruptedException {int lUserID;// 用户句柄int lPreviewHandle;// 预览句柄HCNetSDK.NET_DVR_CLIENTINFO m_strClientInfo;// 用户参数HCNetSDK hCNetSDK = HCNetSDK.INSTANCE;log.info("加载完成");boolean bool = hCNetSDK.NET_DVR_Init();log.info("初始化结果：{}", bool);HCNetSDK.NET_DVR_DEVICEINFO_V30 m_strDeviceInfo = new HCNetSDK.NET_DVR_DEVICEINFO_V30();lUserID = hCNetSDK.NET_DVR_Login_V30(monitorIp,monitorControlPort,monitorUserName,monitorPassword,m_strDeviceInfo);log.info("用户登录句柄：{}", lUserID);m_strClientInfo = new HCNetSDK.NET_DVR_CLIENTINFO();m_strClientInfo.lChannel = new NativeLong(1);lPreviewHandle = hCNetSDK.NET_DVR_RealPlay_V30(lUserID,m_strClientInfo, null, null, true);log.info("预览句柄：{}", lPreviewHandle);boolean isOK = hCNetSDK.NET_DVR_PTZControl(lPreviewHandle, dir, speed);log.info("控制结果：{}", isOK);Thread.sleep(1000);isOK = hCNetSDK.NET_DVR_PTZControl(lPreviewHandle, dir, 1);log.info("控制结果：{}", isOK);Thread.sleep(1000);isOK = hCNetSDK.NET_DVR_Logout(lUserID);log.info("控制结果：{}", isOK);isOK = hCNetSDK.NET_DVR_Cleanup();log.info("控制结果：{}", isOK);return true;}}​

订阅mqtt消息

    @Overridepublic void messageArrived(String topic, MqttMessage message) {String payload = new String(message.getPayload());ghhkControlService.monitorControl(payload);log.info("收到消息: {}", payload);}

这里注意 控制摄像头一定要释放 登出 要不然摄像头控制几次不受控制了

        isOK = hCNetSDK.NET_DVR_PTZControl(lPreviewHandle, dir, 1);log.info("控制结果：{}", isOK);Thread.sleep(1000);isOK = hCNetSDK.NET_DVR_Logout(lUserID);log.info("控制结果：{}", isOK);isOK = hCNetSDK.NET_DVR_Cleanup();log.info("控制结果：{}", isOK);