devbox
盐析白兔
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

Java SDK调用 海康网络摄像头 多摄像头同时预览 并取流_java对接海康摄像头

作者：盐析白兔 | 2024-02-18 00:37:11

赞

踩

java对接海康摄像头

(修改前言:最近公司需求又对接海康的人脸设备，也就刚刚好有时间重新整理写的这篇博客，看评论也有很多人说有问题 demo无法跑通 小编在这呢 也重新测一遍 也会将一些细节更详细的列出来吗 同时呢  除了之前写的这套方案，小编在这也会再提供一个方案)

写在前面：

最近也遇到了调用海康多个摄像头实现同时预览的需求，不`过官方demo里并没详细的案例，上网查了下资料，也找不到对应的解决方案 ，电话咨询海康技术，没接过，信息没回过。这里就不对海康技术支持多作评价了，废话不多说。上方案！

小编首先整理了文档和获取流程（如图）

然后小编根据这个思路将SDK的Demo流程整个看了一遍，终于发现了问题的所在，接下来直接上代码（个人是根据海康提供的demo进行简单的修改,将部分公共代码给抽了出来,另外小编只用到了预览录制和停止录制功能，解码和其他功能小编没用到，所以小编在这里都干掉了。尽量能简洁易懂就简介易懂，大佬勿喷！仅供参考和提供思路！！！！！！）

1 首先去官网下载海康的demo和文档，地址不知道？没关系 我给你啦！

https://open.hikvision.com/download/5cda567cf47ae80dd41a54b3?type=10

选择立即下载

2  选择java开发示例，然后选择预览回放和下载

 官网的demo示例就在这啦 不过 要注意官方的提示文件 根据上面的注意事项 导入文件到你的项目中

（然后就可以开始进行Demo调试啦）

具体流程如下：

1 初始化设备 并定义一个list集合存储用户句柄 

  1.    
  2.    public static List<Integer> lUserIDList = new ArrayList<>();//用户句柄集合
  3.          //初始化
  4.     private static   void init() {
  5.  
  6.         //SDK初始化，一个程序只需要调用一次
  7.         boolean initSuc = hCNetSDK.NET_DVR_Init();
  8.  
  9.         if (initSuc != true) {
  10.             System.out.println("初始化失败");
  11.         }
  12.  
  13.         //异常消息回调
  14.         if (fExceptionCallBack == null) {
  15.             fExceptionCallBack = new FExceptionCallBack_Imp();
  16.         }
  17.  
  18.         Pointer pUser = null;
  19.         if (!hCNetSDK.NET_DVR_SetExceptionCallBack_V30(0, 0, fExceptionCallBack, pUser)) {
  20.             return;
  21.         }
  22.         System.out.println("设置异常消息回调成功");
  23.  
  24.         //启动SDK写日志
  25.         hCNetSDK.NET_DVR_SetLogToFile(3, "..\\sdkLog\\", false);
  26.  
  27.     }

 2 登陆设备（只是演示和提供思路 具体实现请各位大佬根据实际业务）

登陆一台设备就会返回一个用户句柄也可称登陆句柄，后续调用预览是根据用户句柄来区分和管理的。

唯一注意的是，设备登陆后的返回值需要保存！登陆完后创建保存回调函数的音频数据文件

(注意：你的设备要和你自己的网络在同一个网段！！！！！！！查看电脑的网段 win+R 输入cmd  你的电脑是192.16.0段的 把摄像头的ip地址和网关也改成同段的 不然会报错误码7或错误码8等）

  1.       //登陆
  2.     private static void login(){
  3.  
  4.         //存储登陆设备集合
  5.         List<Device> list = new ArrayList<>();
  6.         Device device = new Device();
  7.         device.setIp("192.168.1.16"); //改成自己设备的ip 用户名和密码
  8.         device.setUserName("admin");
  9.         device.setPassWord("Admin123");
  10.         Device devic1 = new Device();
  11.         device.setIp("192.168.1.17");
  12.         device.setUserName("admin");
  13.         device.setPassWord("Admin123");
  14.         list.add(device);
  15.         list.add(devic1);
  16.  
  17.         //登录设备，每一台设备分别登录; 登录句柄是唯一的，可以区分设备
  18.         HCNetSDK.NET_DVR_USER_LOGIN_INFO m_strLoginInfo;//设备登录信息
  19.         HCNetSDK.NET_DVR_DEVICEINFO_V40 m_strDeviceInfo;//设备信息
  20.  
  21.         for (Device d : list) {
  22.             m_strLoginInfo = new HCNetSDK.NET_DVR_USER_LOGIN_INFO();//设备登录信息
  23.             m_strDeviceInfo = new HCNetSDK.NET_DVR_DEVICEINFO_V40();//设备信息
  24.             String m_sDeviceIP = d.getIp();//设备ip地址
  25.             m_strLoginInfo.sDeviceAddress = new byte[HCNetSDK.NET_DVR_DEV_ADDRESS_MAX_LEN];
  26.             System.arraycopy(m_sDeviceIP.getBytes(), 0, m_strLoginInfo.sDeviceAddress, 0, m_sDeviceIP.length());
  27.  
  28.             String m_sUsername = d.getUserName();//设备用户名
  29.             m_strLoginInfo.sUserName = new byte[HCNetSDK.NET_DVR_LOGIN_USERNAME_MAX_LEN];
  30.             System.arraycopy(m_sUsername.getBytes(), 0, m_strLoginInfo.sUserName, 0, m_sUsername.length());
  31.  
  32.             String m_sPassword = d.getPassWord();//设备密码
  33.             m_strLoginInfo.sPassword = new byte[HCNetSDK.NET_DVR_LOGIN_PASSWD_MAX_LEN];
  34.             System.arraycopy(m_sPassword.getBytes(), 0, m_strLoginInfo.sPassword, 0, m_sPassword.length());
  35.  
  36.             m_strLoginInfo.wPort = 8000; //SDK端口
  37.             m_strLoginInfo.bUseAsynLogin = false; //是否异步登录：0- 否，1- 是
  38.             m_strLoginInfo.write();
  39.             lUserID = hCNetSDK.NET_DVR_Login_V40(m_strLoginInfo, m_strDeviceInfo);
  40.  
  41.             //将登陆返回的用户句柄保存！（这里很重要 是原先官网没有的，这里保存句柄是为了预览使用）
  42.             lUserIDList.add(lUserID);
  43.  
  44.             if (lUserID==-1) {
  45.                 System.out.println("登录失败，错误码为" + hCNetSDK.NET_DVR_GetLastError());
  46.             } else {
  47.                 System.out.println("设备登录成功! " + "设备序列号:" + new String(m_strDeviceInfo.struDeviceV30.sSerialNumber).trim());
  48.                 m_strDeviceInfo.read();
  49.             }
  50.             //保存回调函数的音频数据
  51.             VideoDemo.setFile(lUserID);
  52.  
  53.         }
  54.     }

3 创建保存回调函数的音频数据文件  同时创建一个map集合 保存对应的文件输出流 键为登陆后返回的用户句柄

  1.   //定义流的map集合 键为用户句柄（也就是你登陆返回的句柄）
  2.  static Map<Integer, FileOutputStream> outputStreamMap = new HashMap();
  3.  public static void setFile(int userId) {
  4.         file = new File("/Download/" + new Date().getTime() + "(" + userId + ")" + ".mp4");  //保存回调函数的音频数据
  5.  
  6.         if (!file.exists()) {
  7.             try {
  8.                 file.createNewFile();
  9.             } catch (Exception e) {
  10.                 e.printStackTrace();
  11.             }
  12.         }
  13. //            FileOutputStream outputStream=new FileOutputStream(file);
  14.         try {
  15.  
  16.             outputStreamMap.put(userId, new FileOutputStream(file));
  17.         } catch (FileNotFoundException e) {
  18.             e.printStackTrace();
  19.         }
  20.     }

4 线程run中执行预览代码 通过调用NET_DVR_RealPlay_V40实现预览

  1.    @Override
  2.     public void run() {
  3.         fRealDataCallBack = null;
  4.         if (userId == -1) {
  5.             System.out.println("请先注册");
  6.             return;
  7.         }
  8.     HCNetSDK.NET_DVR_PREVIEWINFO strClientInfo = new HCNetSDK.NET_DVR_PREVIEWINFO();
  9.         strClientInfo.read();
  10.         strClientInfo.hPlayWnd =null;  //窗口句柄，从回调取流不显示一般设置为空
  11.         strClientInfo.lChannel = 1;  //通道号
  12.         strClientInfo.dwStreamType = 0; //0-主码流，1-子码流，2-三码流，3-虚拟码流，以此类推
  13.         strClientInfo.dwLinkMode = 0; //连接方式：0- TCP方式，1- UDP方式，2- 多播方式，3- RTP方式，4- RTP/RTSP，5- RTP/HTTP，6- HRUDP（可靠传输） ，7- RTSP/HTTPS，8- NPQ
  14.         strClientInfo.bBlocked = 1;
  15.         strClientInfo.write();
  16.  
  17.         if (fRealDataCallBack == null) {
  18.             fRealDataCallBack = new FRealDataCallBack();
  19.         }
  20.         //开启预览
  21.         lPlay = hCNetSDK.NET_DVR_RealPlay_V40(userId, strClientInfo, fRealDataCallBack, null);
  22.         if (lPlay == -1) {
  23.             int iErr = hCNetSDK.NET_DVR_GetLastError();
  24.             System.out.println("取流失败" + iErr);
  25.             return;
  26.         }
  27.         System.out.println("取流成功");
  28.     }

5 修改回调函数 这里的回调函数参数都是sdk规定好的 在回调中取出集合中对应的流进行文件输出

  1.     static class FRealDataCallBack implements HCNetSDK.FRealDataCallBack_V30 {
  2.  
  3.         //预览回调
  4.         public void invoke(int lRealHandle, int dwDataType, ByteByReference pBuffer, int dwBufSize, Pointer pUser) {
  5.  
  6. //            System.out.println(lRealHandle + "码流数据回调" + pBuffer + ", 数据类型: " + dwDataType + ", 数据长度:" + dwBufSize + "puser:" + pUser);
  7.             long offset = 0;
  8.  
  9.             ByteBuffer buffers = pBuffer.getPointer().getByteBuffer(offset, dwBufSize);
  10.  
  11.             byte[] bytes = new byte[dwBufSize];
  12.             buffers.rewind();
  13.             buffers.get(bytes);
  14.             try {
  15.                 //根据lRealHandle从map中取出对应的流读取数据
  16.                 outputStreamMap.get(lRealHandle).write(bytes);
  17.             } catch (Exception e) {
  18.                 e.printStackTrace();
  19.             }
  20.         }
  21.  
  22.  
  23.     }

6 开启线程 

  1.    public static void main(String[] args) throws InterruptedException {
  2.  
  3.         if (hCNetSDK == null && playControl == null) {
  4.             if (!CreateSDKInstance()) {
  5.                 System.out.println("Load SDK fail");
  6.                 return;
  7.             }
  8.             if (!CreatePlayInstance()) {
  9.                 System.out.println("Load PlayCtrl fail");
  10.                 return;
  11.             }
  12.         }
  13.         //linux系统建议调用以下接口加载组件库
  14.         if (osSelect.isLinux()) {
  15.             HCNetSDK.BYTE_ARRAY ptrByteArray1 = new HCNetSDK.BYTE_ARRAY(256);
  16.             HCNetSDK.BYTE_ARRAY ptrByteArray2 = new HCNetSDK.BYTE_ARRAY(256);
  17.             //这里是库的绝对路径，请根据实际情况修改，注意改路径必须有访问权限
  18.             String strPath1 = System.getProperty("user.dir") + "/lib/libcrypto.so.1.1";
  19.             String strPath2 = System.getProperty("user.dir") + "/lib/libssl.so.1.1";
  20.  
  21.             System.arraycopy(strPath1.getBytes(), 0, ptrByteArray1.byValue, 0, strPath1.length());
  22.             ptrByteArray1.write();
  23.             hCNetSDK.NET_DVR_SetSDKInitCfg(3, ptrByteArray1.getPointer());
  24.  
  25.             System.arraycopy(strPath2.getBytes(), 0, ptrByteArray2.byValue, 0, strPath2.length());
  26.             ptrByteArray2.write();
  27.             hCNetSDK.NET_DVR_SetSDKInitCfg(4, ptrByteArray2.getPointer());
  28.  
  29.             String strPathCom = System.getProperty("user.dir") + "/lib";
  30.             HCNetSDK.NET_DVR_LOCAL_SDK_PATH struComPath = new HCNetSDK.NET_DVR_LOCAL_SDK_PATH();
  31.             System.arraycopy(strPathCom.getBytes(), 0, struComPath.sPath, 0, strPathCom.length());
  32.             struComPath.write();
  33.             hCNetSDK.NET_DVR_SetSDKInitCfg(2, struComPath.getPointer());
  34.         }
  35.  
  36.         //初始化
  37.         init();
  38.  
  39.         //登陆
  40.         login();
  41.  
  42.  
  43.         // 创建线程池对象指定线程数量
  44.         ExecutorService tp = Executors.newFixedThreadPool(2);
  45.  
  46.         VideoDemo video1=new VideoDemo(lUserIDList.get(0), 1);
  47.         VideoDemo video2=new VideoDemo(lUserIDList.get(1),1) ;
  48.  
  49.         tp.submit(video1);
  50.         tp.submit(video2);
  51.     }

以上代码生成的视频在你盘符+Download 文件夹里面去找(如图所示） 

 注意：你现在生成的视频是无法直接查看的 需要用到海康的播放软件解码查看！ 啥软件？ 我把链接给你啦

https://www.hikvision.com/cn/support/Downloads/Desktop-Application/Hikvision-Player/

插件打开效果如图:

方案一 完整代码:

  1. package com.NetSDKDemo;
  2.  
  3. import Common.osSelect;
  4. import com.Device;
  5. import com.sun.jna.Native;
  6. import com.sun.jna.Pointer;
  7.  
  8. import java.util.ArrayList;
  9. import java.util.List;
  10. import java.util.Timer;
  11. import java.util.concurrent.ExecutorService;
  12. import java.util.concurrent.Executors;
  13.  
  14. /**
  15.  * @create 2020-12-24-17:55
  16.  */
  17. public class ClinetDemo {
  18.  
  19.  
  20.     static HCNetSDK hCNetSDK = null;
  21.     static PlayCtrl playControl = null;
  22.     static int lUserID = 0;//用户句柄
  23.     public static List<Integer> lUserIDList = new ArrayList<>();//用户句柄
  24.  
  25.     static FExceptionCallBack_Imp fExceptionCallBack;
  26.  
  27.  
  28.     static class FExceptionCallBack_Imp implements HCNetSDK.FExceptionCallBack {
  29.         public void invoke(int dwType, int lUserID, int lHandle, Pointer pUser) {
  30.             System.out.println("异常事件类型:" + dwType);
  31.             return;
  32.         }
  33.     }
  34.  
  35.     public static void main(String[] args) throws InterruptedException {
  36.  
  37.         if (hCNetSDK == null && playControl == null) {
  38.             if (!CreateSDKInstance()) {
  39.                 System.out.println("Load SDK fail");
  40.                 return;
  41.             }
  42.             if (!CreatePlayInstance()) {
  43.                 System.out.println("Load PlayCtrl fail");
  44.                 return;
  45.             }
  46.         }
  47.         //linux系统建议调用以下接口加载组件库
  48.         if (osSelect.isLinux()) {
  49.             HCNetSDK.BYTE_ARRAY ptrByteArray1 = new HCNetSDK.BYTE_ARRAY(256);
  50.             HCNetSDK.BYTE_ARRAY ptrByteArray2 = new HCNetSDK.BYTE_ARRAY(256);
  51.             //这里是库的绝对路径，请根据实际情况修改，注意改路径必须有访问权限
  52.             String strPath1 = System.getProperty("user.dir") + "/lib/libcrypto.so.1.1";
  53.             String strPath2 = System.getProperty("user.dir") + "/lib/libssl.so.1.1";
  54.  
  55.             System.arraycopy(strPath1.getBytes(), 0, ptrByteArray1.byValue, 0, strPath1.length());
  56.             ptrByteArray1.write();
  57.             hCNetSDK.NET_DVR_SetSDKInitCfg(3, ptrByteArray1.getPointer());
  58.  
  59.             System.arraycopy(strPath2.getBytes(), 0, ptrByteArray2.byValue, 0, strPath2.length());
  60.             ptrByteArray2.write();
  61.             hCNetSDK.NET_DVR_SetSDKInitCfg(4, ptrByteArray2.getPointer());
  62.  
  63.             String strPathCom = System.getProperty("user.dir") + "/lib";
  64.             HCNetSDK.NET_DVR_LOCAL_SDK_PATH struComPath = new HCNetSDK.NET_DVR_LOCAL_SDK_PATH();
  65.             System.arraycopy(strPathCom.getBytes(), 0, struComPath.sPath, 0, strPathCom.length());
  66.             struComPath.write();
  67.             hCNetSDK.NET_DVR_SetSDKInitCfg(2, struComPath.getPointer());
  68.         }
  69.  
  70.         //初始化
  71.         init();
  72.  
  73.         //登陆
  74.         login();
  75.  
  76.  
  77.         // 创建线程池对象指定线程数量
  78.         ExecutorService tp = Executors.newFixedThreadPool(2);
  79.  
  80.         VideoDemo video1=new VideoDemo(lUserIDList.get(0), 1);
  81.         VideoDemo video2=new VideoDemo(lUserIDList.get(1),1) ;
  82.  
  83.         tp.submit(video1);
  84.         tp.submit(video2);
  85.     }
  86.  
  87.  
  88.  
  89.     //登陆
  90.     private static void login(){
  91.  
  92.         //存储登陆设备集合
  93.         List<Device> list = new ArrayList<>();
  94.         Device device = new Device();
  95.         device.setIp("192.168.1.11");
  96.         device.setPassWord("admin");
  97.         device.setPassWord("123456");
  98.         Device device1 = new Device();
  99.         device1.setIp("192.168.1.12");
  100.         device1.setPassWord("admin");
  101.         device1.setPassWord("123456");
  102.  
  103.         list.add(device);
  104.         list.add(device1);
  105.  
  106.         //登录设备，每一台设备分别登录; 登录句柄是唯一的，可以区分设备
  107.         HCNetSDK.NET_DVR_USER_LOGIN_INFO m_strLoginInfo;//设备登录信息
  108.         HCNetSDK.NET_DVR_DEVICEINFO_V40 m_strDeviceInfo;//设备信息
  109.  
  110.         for (Device d : list) {
  111.             m_strLoginInfo = new HCNetSDK.NET_DVR_USER_LOGIN_INFO();//设备登录信息
  112.             m_strDeviceInfo = new HCNetSDK.NET_DVR_DEVICEINFO_V40();//设备信息
  113.             String m_sDeviceIP = d.getIp();//设备ip地址
  114.             m_strLoginInfo.sDeviceAddress = new byte[HCNetSDK.NET_DVR_DEV_ADDRESS_MAX_LEN];
  115.             System.arraycopy(m_sDeviceIP.getBytes(), 0, m_strLoginInfo.sDeviceAddress, 0, m_sDeviceIP.length());
  116.  
  117.             String m_sUsername = d.getUserName();//设备用户名
  118.             m_strLoginInfo.sUserName = new byte[HCNetSDK.NET_DVR_LOGIN_USERNAME_MAX_LEN];
  119.             System.arraycopy(m_sUsername.getBytes(), 0, m_strLoginInfo.sUserName, 0, m_sUsername.length());
  120.  
  121.             String m_sPassword = d.getPassWord();//设备密码
  122.             m_strLoginInfo.sPassword = new byte[HCNetSDK.NET_DVR_LOGIN_PASSWD_MAX_LEN];
  123.             System.arraycopy(m_sPassword.getBytes(), 0, m_strLoginInfo.sPassword, 0, m_sPassword.length());
  124.  
  125.             m_strLoginInfo.wPort = 8000; //SDK端口
  126.             m_strLoginInfo.bUseAsynLogin = false; //是否异步登录：0- 否，1- 是
  127.             m_strLoginInfo.write();
  128.             lUserID = hCNetSDK.NET_DVR_Login_V40(m_strLoginInfo, m_strDeviceInfo);
  129.  
  130.             //将登陆返回的用户句柄保存！（这里很重要 是原先官网没有的，这里保存句柄是为了预览使用）
  131.             lUserIDList.add(lUserID);
  132.  
  133.             if (lUserID==-1) {
  134.                 System.out.println("登录失败，错误码为" + hCNetSDK.NET_DVR_GetLastError());
  135.             } else {
  136.                 System.out.println("设备登录成功! " + "设备序列号:" + new String(m_strDeviceInfo.struDeviceV30.sSerialNumber).trim());
  137.                 m_strDeviceInfo.read();
  138.             }
  139.             //保存回调函数的音频数据
  140.             VideoDemo.setFile(lUserID);
  141.  
  142.         }
  143.     }
  144.  
  145.  
  146.     //初始化
  147.     private static   void init() {
  148.  
  149.         //SDK初始化，一个程序只需要调用一次
  150.         boolean initSuc = hCNetSDK.NET_DVR_Init();
  151.  
  152.         if (initSuc != true) {
  153.             System.out.println("初始化失败");
  154.         }
  155.  
  156.         //异常消息回调
  157.         if (fExceptionCallBack == null) {
  158.             fExceptionCallBack = new FExceptionCallBack_Imp();
  159.         }
  160.  
  161.         Pointer pUser = null;
  162.         if (!hCNetSDK.NET_DVR_SetExceptionCallBack_V30(0, 0, fExceptionCallBack, pUser)) {
  163.             return;
  164.         }
  165.         System.out.println("设置异常消息回调成功");
  166.  
  167.         //启动SDK写日志
  168.         hCNetSDK.NET_DVR_SetLogToFile(3, "..\\sdkLog\\", false);
  169.  
  170.     }
  171.  
  172.     /**
  173.      * 动态库加载
  174.      *
  175.      * @return
  176.      */
  177.     private static boolean CreateSDKInstance() {
  178.         if (hCNetSDK == null) {
  179.             synchronized (HCNetSDK.class) {
  180.                 String strDllPath = "";
  181.                 try {
  182.                     if (osSelect.isWindows())
  183.                         //win系统加载库路径
  184.                         //strDllPath = System.getProperty("user.dir") + "\\lib\\HCNetSDK.dll";
  185.                         strDllPath = "E:\\eclipse2019work\\ClientDemo-NetBeansPro\\HCNetSDK.dll";
  186.  
  187.                     else if (osSelect.isLinux())
  188.                         //Linux系统加载库路径
  189.                         //  strDllPath = System.getProperty("user.dir") + "/lib/libhcnetsdk.so";
  190.                         strDllPath = "/usr/local/lib/libhcnetsdk.so";
  191.                     hCNetSDK = (HCNetSDK) Native.loadLibrary(strDllPath, HCNetSDK.class);
  192.                 } catch (Exception ex) {
  193.                     System.out.println("loadLibrary: " + strDllPath + " Error: " + ex.getMessage());
  194.                     return false;
  195.                 }
  196.             }
  197.         }
  198.         return true;
  199.     }
  200.  
  201.     /**
  202.      * 播放库加载
  203.      *
  204.      * @return
  205.      */
  206.     private static boolean CreatePlayInstance() {
  207.         if (playControl == null) {
  208.             synchronized (PlayCtrl.class) {
  209.                 String strPlayPath = "";
  210.                 try {
  211.                     if (osSelect.isWindows())
  212.                         //win系统加载库路径
  213.                         strPlayPath = System.getProperty("user.dir") + "\\lib\\PlayCtrl.dll";
  214.                     else if (osSelect.isLinux())
  215.                         //Linux系统加载库路径
  216.                         strPlayPath = System.getProperty("user.dir") + "/lib/libPlayCtrl.so";
  217.                     playControl = (PlayCtrl) Native.loadLibrary("E:\\eclipse2019work\\ClientDemo-NetBeansPro\\PlayCtrl.dll", PlayCtrl.class);
  218.  
  219.                 } catch (Exception ex) {
  220.                     System.out.println("loadLibrary: " + strPlayPath + " Error: " + ex.getMessage());
  221.                     return false;
  222.                 }
  223.             }
  224.         }
  225.         return true;
  226.     }
  227.  
  228.    //注销设备
  229.     public void videoWrite() {
  230.  
  231.  
  232.  
  233.         //退出程序时调用，每一台设备分别注销
  234.  
  235.         for (int id : lUserIDList) {
  236.             if (hCNetSDK.NET_DVR_Logout(id)) {
  237.                 System.out.println("注销成功");
  238.             }
  239.         }
  240.  
  241.  
  242.         lUserIDList.clear();
  243.  
  244.  
  245.         //SDK反初始化，释放资源，只需要退出时调用一次
  246.         hCNetSDK.NET_DVR_Cleanup();
  247.  
  248.  
  249.         VideoDemo.outputStreamMap.clear();
  250.     }
  251.  
  252. }
  253.  
  254.  
  255.  
  1. package com.NetSDKDemo;
  2.  
  3. import com.sun.jna.Pointer;
  4. import com.sun.jna.ptr.ByteByReference;
  5. import com.sun.jna.ptr.IntByReference;
  6.  
  7. import java.io.*;
  8. import java.lang.reflect.Parameter;
  9. import java.nio.ByteBuffer;
  10. import java.text.SimpleDateFormat;
  11. import java.util.Date;
  12. import java.util.HashMap;
  13. import java.util.Map;
  14. import java.util.Timer;
  15.  
  16. import static com.NetSDKDemo.ClinetDemo.hCNetSDK;
  17. import static com.NetSDKDemo.ClinetDemo.playControl;
  18.  
  19. /**
  20.  * 视频取流预览，下载，抓图
  21.  *
  22.  * @create 2022-03-30-9:48
  23.  */
  24. public class VideoDemo implements Runnable{
  25.     Timer Downloadtimer;//下载用定时器
  26.     Timer Playbacktimer;//回放用定时器
  27.     static FRealDataCallBack fRealDataCallBack;//预览回调函数实现
  28.     //定义流的map集合
  29.     static Map<Integer, FileOutputStream> outputStreamMap = new HashMap();
  30.     static int lPlay = -1;  //预览句柄
  31.     static File file;
  32.  
  33.  
  34.  
  35.     private Integer userId;
  36.  
  37.     private Integer iChannelNo;
  38.  
  39.     public VideoDemo(Integer userId, Integer iChannelNo) {
  40.         this.userId = userId;
  41.         this.iChannelNo = iChannelNo;
  42.     }
  43.  
  44.     @Override
  45.     public void run() {
  46.         fRealDataCallBack = null;
  47.         if (userId == -1) {
  48.             System.out.println("请先注册");
  49.             return;
  50.         }
  51.         HCNetSDK.NET_DVR_PREVIEWINFO strClientInfo = new HCNetSDK.NET_DVR_PREVIEWINFO();
  52.         strClientInfo.read();
  53.         strClientInfo.hPlayWnd = null;  //窗口句柄，从回调取流不显示一般设置为空
  54.         strClientInfo.lChannel = iChannelNo;  //通道号
  55.         strClientInfo.dwStreamType = 0; //0-主码流，1-子码流，2-三码流，3-虚拟码流，以此类推
  56.         strClientInfo.dwLinkMode = 0; //连接方式：0- TCP方式，1- UDP方式，2- 多播方式，3- RTP方式，4- RTP/RTSP，5- RTP/HTTP，6- HRUDP（可靠传输） ，7- RTSP/HTTPS，8- NPQ
  57.         strClientInfo.bBlocked = 1;
  58.         strClientInfo.write();
  59.  
  60.         if (fRealDataCallBack == null) {
  61.             fRealDataCallBack = new FRealDataCallBack();
  62.         }
  63.         //开启预览
  64.         lPlay = hCNetSDK.NET_DVR_RealPlay_V40(userId, strClientInfo, fRealDataCallBack, null);
  65.         if (lPlay == -1) {
  66.             int iErr = hCNetSDK.NET_DVR_GetLastError();
  67.             System.out.println("取流失败" + iErr);
  68.             return;
  69.         }
  70.         System.out.println("取流成功");
  71.     }
  72.  
  73.  
  74.  
  75.     //创建文件
  76.     /**
  77.      *
  78.      *
  79.      * @date 2022/8/31 23:37
  80.      * @param userId：登陆返回的用户句柄
  81.      */
  82.     public static void setFile(int userId) {
  83.         file = new File("/Download/" + new Date().getTime() + "(" + userId + ")" + ".mp4");  //保存回调函数的音频数据
  84.  
  85.         if (!file.exists()) {
  86.             try {
  87.                 file.createNewFile();
  88.             } catch (Exception e) {
  89.                 e.printStackTrace();
  90.             }
  91.         }
  92. //            FileOutputStream outputStream=new FileOutputStream(file);
  93.         try {
  94.  
  95.             outputStreamMap.put(userId, new FileOutputStream(file));
  96.         } catch (FileNotFoundException e) {
  97.             e.printStackTrace();
  98.         }
  99.     }
  100.  
  101.  
  102.  
  103.  
  104.  
  105.     static class FRealDataCallBack implements HCNetSDK.FRealDataCallBack_V30 {
  106.         //预览回调
  107.         public void invoke(int lRealHandle, int dwDataType, ByteByReference pBuffer, int dwBufSize, Pointer pUser) {
  108.             long offset = 0;
  109.             ByteBuffer buffers = pBuffer.getPointer().getByteBuffer(offset, dwBufSize);
  110.             byte[] bytes = new byte[dwBufSize];
  111.             buffers.rewind();
  112.             buffers.get(bytes);
  113.             try {
  114.                 //从map中取出对应的流读取数据
  115.                 outputStreamMap.get(lRealHandle).write(bytes);
  116.             } catch (Exception e) {
  117.                 e.printStackTrace();
  118.             }
  119.  
  120.  
  121.         }
  122.     }
  123.  
  124.  
  125. }

实体类

  1. package com;
  2.  
  3. /**
  4.  * @author lws
  5.  * @date 2022/8/31 23:07
  6.  */
  7. public class Device {
  8.     private String ip;
  9.  
  10.     private String userName;
  11.  
  12.     private String passWord;
  13.  
  14.     public String getIp() {
  15.         return ip;
  16.     }
  17.  
  18.     public void setIp(String ip) {
  19.         this.ip = ip;
  20.     }
  21.  
  22.     public String getUserName() {
  23.         return userName;
  24.     }
  25.  
  26.     public void setUserName(String userName) {
  27.         this.userName = userName;
  28.     }
  29.  
  30.     public String getPassWord() {
  31.         return passWord;
  32.     }
  33.  
  34.     public void setPassWord(String passWord) {
  35.         this.passWord = passWord;
  36.     }
  37. }

小编的代码目录结构

简单总结：

1 初始化

2 登陆设备 并保存登陆设备的用户句柄

3 创建保存回调函数的音频文件

4 创建map集合 存储对应的文件输出流，键为用户句柄

5 对回调函数进行修改 

（啊啊啊 博主给的代码有时候录制不同步！！！！ 博主给的代码没有视频转码代码！！！ 别急啦，往下个方案看看啦。注释就都在代码里了，这里就懒得写了哈）

改造后的代码（名字就叫TwoClientDemo)

  1.  
  2.  
  3. public class TwoClientDemo {
  4.  
  5.     public static void main(String[] args) throws ExecutionException, InterruptedException {
  6.         List<Device> devices = addDevice();
  7.         TwoVideoDemo video;
  8.         CameraInfo cameraInfo;
  9.         FutureTask<Result> ft;
  10.         for (int i = 0; i < devices.size(); i++) {
  11.             cameraInfo = new CameraInfo();
  12.             cameraInfo.setAddress(devices.get(i).getIp());
  13.             cameraInfo.setPort((short) 8000);
  14.             cameraInfo.setUserName(devices.get(i).getUserName());
  15.             cameraInfo.setPwd(devices.get(i).getPassWord());
  16.  
  17.             video = new TwoVideoDemo(cameraInfo);
  18.  
  19.             ft = new FutureTask<>(video);
  20.             new Thread(ft).start();
  21.             //模拟录制过程
  22.             Thread.sleep(5000);
  23.             ft.get();
  24.  
  25.             System.out.println("取流成功");
  26.         }
  27. //                renderSuccess(result);
  28.  
  29.  
  30. }
  31.  
  32.  
  33.     //存储登陆设备集合
  34.     public static List<Device> addDevice() {
  35.         List<Device> list = new ArrayList<>();
  36.         Device device = new Device();
  37.         device.setIp("192.168.1.16"); //改成自己设备的ip 用户名和密码
  38.         device.setUserName("admin");
  39.         device.setPassWord("Admin123");
  40.         list.add(device);
  41. //        Device devic1 = new Device();
  42. //        device.setIp("192.168.1.17");
  43. //        device.setUserName("admin");
  44. //        device.setPassWord("Admin123");
  45. //        list.add(devic1);
  46.  
  47.         return list;
  48.     }
  49.  
  50. }

(值得注意的一点哈！！！ 方案二自己改下这里的路径） 

然后线程实现类 改改 回调函数啥也别写了 直接调海康sdk接口取流即可 

线程实现类

  1. public class TwoVideoDemo implements Callable<Result> {
  2.  
  3.     //初始化
  4.     public static final HCNetSDK INSTANCE = HCNetSDK.INSTANCE;
  5.     static HCNetSDK sdk;
  6.  
  7.  
  8.     private CameraInfo cameraInfo;
  9.  
  10.  
  11.     public TwoVideoDemo(CameraInfo cameraInfo) {
  12.         this.cameraInfo = cameraInfo;
  13.     }
  14.   @Override
  15.     public Result call() throws Exception {
  16.         sdk = INSTANCE;
  17.         if (!sdk.NET_DVR_Init()) {
  18.  
  19.             System.out.println("初始化失败..................");
  20.         }
  21.  
  22.         //创建设备
  23.         HCNetSDK.NET_DVR_DEVICEINFO_V30 deInfo = new HCNetSDK.NET_DVR_DEVICEINFO_V30();
  24.  
  25.         //注册用户设备
  26.         Integer id = sdk.NET_DVR_Login_V30(cameraInfo.getAddress(), cameraInfo.getPort(),
  27.                 cameraInfo.getUserName(), cameraInfo.getPwd(), deInfo);
  28.         cameraInfo.setUserId(id);
  29.  
  30.         //判断是否注册成功
  31.         if (cameraInfo.getUserId().intValue() < 0) {
  32.             System.out.println("注册设备失败 错误码为:"+sdk.NET_DVR_GetLastError());
  33.         } else {
  34.  
  35.             System.out.println("注册成功  Id为:      " + cameraInfo.getUserId().intValue());
  36.         }
  37.  
  38.         //判断是否获取到设备能力
  39.         HCNetSDK.NET_DVR_WORKSTATE_V30 devWork = new HCNetSDK.NET_DVR_WORKSTATE_V30();
  40.         if (!sdk.NET_DVR_GetDVRWorkState_V30(cameraInfo.getUserId(), devWork)) {
  41.  
  42.             System.out.println("获取设备能力集失败,返回设备状态失败..............." + "错误码为:" + sdk.NET_DVR_GetLastError());
  43.         }
  44.  
  45.         //启动实时预览功能  创建clientInfo对象赋值预览参数
  46.  
  47.         HCNetSDK.NET_DVR_CLIENTINFO clientInfo = new HCNetSDK.NET_DVR_CLIENTINFO();
  48.  
  49.         clientInfo.lChannel = 1;   //设置通道号
  50.         clientInfo.lLinkMode = 0;  //TCP取流
  51.         clientInfo.sMultiCastIP = null;                   //不启动多播模式
  52.  
  53.         //创建窗口句柄
  54.         clientInfo.hPlayWnd = null;
  55.  
  56.         FRealDataCallBack fRealDataCallBack = new FRealDataCallBack();//预览回调函数实现
  57.  
  58.         while (true){
  59.  
  60.             //开启实时预览
  61.             Integer key = sdk.NET_DVR_RealPlay_V30(cameraInfo.getUserId(), clientInfo, fRealDataCallBack, null, true);
  62.  
  63.             //判断是否预览成功
  64.             if (key.intValue() == -1) {
  65.                 sdk.NET_DVR_Logout(cameraInfo.getUserId());
  66.                 sdk.NET_DVR_Cleanup();
  67.             System.out.println("预览失败   错误代码为:  " + sdk.NET_DVR_GetLastError());
  68.             }
  69.  
  70.             System.out.println("开始预览成功");
  71.  
  72.  
  73. //            预览成功后 调用接口使视频资源保存到文件中
  74.             if (!sdk.NET_DVR_SaveRealData(key, "/Download/" + new Date().getTime()  + ".mp4")) {
  75.                 sdk.NET_DVR_StopRealPlay(key);
  76.                 sdk.NET_DVR_Logout(cameraInfo.getUserId());
  77.                 sdk.NET_DVR_Cleanup();
  78.             System.out.println("保存到文件失败 错误码为:  " + sdk.NET_DVR_GetLastError());
  79.             }
  80.             return Result.success("录制成功",null);
  81.         }
  82.     }
  83.  
  84.  
  85.     /**
  86.      * @param预览回调接口实现类
  87.      */
  88.     class FRealDataCallBack implements HCNetSDK.FRealDataCallBack_V30 {
  89.  
  90.  
  91.         @Override
  92.         public void invoke(int lRealHandle, int dwDataType, ByteByReference pBuffer, int dwBufSize, Pointer pUser) {
  93.  
  94.         }
  95.     }
  96.  
  97.  
  98.  
  99.     //停止录制
  100.     static void stopRecord(Integer i) {
  101.  
  102.  
  103.         sdk.NET_DVR_Logout(i);
  104.         sdk.NET_DVR_StopRealPlay(i);
  105.         sdk.NET_DVR_Cleanup();
  106.  
  107.  
  108.     }
  109.  
  110. }

Result(公共返回数据类)

  1. package com.NetSDKDemo.comm;
  2.  
  3. public class Result {
  4.  
  5.  
  6.     private boolean flag;
  7.     private Integer code;
  8.     private String message;
  9.     private Object data;
  10.  
  11.     public Result() {
  12.     }
  13.  
  14.     public Result(boolean flag, Integer code, String message, Object data) {
  15.         super();
  16.         this.flag = flag;
  17.         this.code = code;
  18.         this.message = message;
  19.         this.data = data;
  20.     }
  21.  
  22.     public Result(boolean flag, Integer code, String message) {
  23.         super();
  24.         this.flag = flag;
  25.         this.code = code;
  26.         this.message = message;
  27.     }
  28.  
  29.     public boolean isFlag() {
  30.         return flag;
  31.     }
  32.  
  33.     public void setFlag(boolean flag) {
  34.         this.flag = flag;
  35.     }
  36.  
  37.     public Integer getCode() {
  38.         return code;
  39.     }
  40.  
  41.     public void setCode(Integer code) {
  42.         this.code = code;
  43.     }
  44.  
  45.     public String getMessage() {
  46.         return message;
  47.     }
  48.  
  49.     public void setMessage(String message) {
  50.         this.message = message;
  51.     }
  52.  
  53.     public Object getData() {
  54.         return data;
  55.     }
  56.  
  57.     public void setData(Object data) {
  58.         this.data = data;
  59.     }
  60.  
  61.     public static Result success(String msg, Object data) {
  62.         return new Result(true, 200, msg, data);
  63.     }
  64.  
  65.     public static Result error(String msg) {
  66.         return new Result(false, 500, msg, null);
  67.     }
  68.  
  69.     public static Result error(String msg, Object data,Integer code) {
  70.         return new Result(true, code, msg, data);
  71.     }
  72. }
  73.  
CameraInfo实体类
  1. public class CameraInfo {
  2.     private String address;
  3.     private String userName;
  4.     private String pwd;
  5.     private short port;
  6.     private Integer userId;
  7.     private Integer channel;
  8.     private Integer key;
  9.  
  10.  
  11.     public String getAddress() {
  12.         return address;
  13.     }
  14.  
  15.     public void setAddress(String address) {
  16.         this.address = address;
  17.     }
  18.  
  19.     public String getUserName() {
  20.         return userName;
  21.     }
  22.  
  23.     public void setUserName(String userName) {
  24.         this.userName = userName;
  25.     }
  26.  
  27.     public String getPwd() {
  28.         return pwd;
  29.     }
  30.  
  31.     public void setPwd(String pwd) {
  32.         this.pwd = pwd;
  33.     }
  34.  
  35.     public short getPort() {
  36.         return port;
  37.     }
  38.  
  39.     public void setPort(short port) {
  40.         this.port = port;
  41.     }
  42.  
  43.     public Integer getUserId() {
  44.         return userId;
  45.     }
  46.  
  47.     public void setUserId(Integer userId) {
  48.         this.userId = userId;
  49.     }
  50.  
  51.     public Integer getChannel() {
  52.         return channel;
  53.     }
  54.  
  55.     public void setChannel(Integer channel) {
  56.         this.channel = channel;
  57.     }
  58.  
  59.     public Integer getKey() {
  60.         return key;
  61.     }
  62.  
  63.     public void setKey(Integer key) {
  64.         this.key = key;
  65.     }
  66. }

结果

解码工具类

  1. public class FormatConverterUtils {
  2.  
  3.     /**
  4.      * FFmpeg程序执行路径
  5.      * 当前系统安装好ffmpeg程序并配置好相应的环境变量后，值为ffmpeg.exe可执行程序文件在实际系统中的绝对路径
  6.      */
  7.     //视频解码配置
  8.     //linux下，路径肯定不是这样，是/root/xx这样子
  9. //    public String outputPath = "/usr/local/tobaccocasedoc/Download/";
  10. //    public String FFMPEG_PATH = "D:ffmpeg-master-latest-win64-gpl\\bin\\"; //linux中，路径为 /root/moch/ffmpeg-4.4-amd64-static/ 你自己在linux服务器上安装的路径
  11.     public static String FFMPEG_PATH = "/usr/local/ffmpeg/ffmpeg-git-20220910-amd64-static/"; //linux中，路径为 /root/moch/ffmpeg-4.4-amd64-static/ 你自己在linux服务器上安装的路径
  12.  
  13.  
  14.  
  15.  
  16.     /**
  17.      * 音频转换器
  18.      * @param resourcePath 需要被转换的音频文件全路径带文件名
  19.      * @param targetPath 转换之后的音频文件全路径带文件名
  20.      */
  21.     public static void audioConverter(String resourcePath, String targetPath) {
  22.         formatConverter(new File(resourcePath), new File(targetPath), false);
  23.     }
  24.  
  25.     /**
  26.      * 视频转换器
  27.      * @param resourcePath 需要被转换的视频文件全路径带文件名
  28.      * @param targetPath 转换之后的视频文件全路径带文件名
  29.      */
  30.     public static void videoConverter(String resourcePath, String targetPath) {
  31.  
  32.         formatConverter(new File(resourcePath), new File(targetPath), true);
  33.     }
  34.  
  35.     /**
  36.      * 文件格式转换器
  37.      * 注意！此方法为按照需求进行拼接命令来完成音频视频文件的处理 命令拼接需要根据自己需求进行更改
  38.      * 视频 或 音频
  39.      * @param fileInput 源文件路径
  40.      * @param fileOutPut 转换后的文件路径
  41.      * @param isVideo 源文件是视频文件
  42.      *
  43.      */
  44.     public static void formatConverter(File fileInput, File fileOutPut, boolean isVideo) {
  45.         fileInput.setExecutable(true);//设置可执行权限
  46.         fileInput.setReadable(true);//设置可读权限
  47.         fileInput.setWritable(true);//设置可写权限
  48.  
  49.  
  50.         fileOutPut.setExecutable(true);//设置可执行权限
  51.         fileOutPut.setReadable(true);//设置可读权限
  52.         fileOutPut.setWritable(true);//设置可写权限
  53.         if (null == fileInput || !fileInput.exists()) {
  54.             throw new RuntimeException("源文件不存在，请检查源路径");
  55.         }
  56.         if (null == fileOutPut) {
  57.             throw new RuntimeException("转换后的路径为空，请检查转换后的存放路径是否正确");
  58.         }
  59.  
  60.         if (!fileOutPut.exists()) {
  61.             try {
  62.                 fileOutPut.createNewFile();
  63.             } catch (IOException e) {
  64.                 System.out.println("转换时新建输出文件失败");
  65.             }
  66.         }
  67.         List<String> commond = new ArrayList<String>();
  68.         //输出直接覆盖文件
  69.         commond.add("-y");
  70.         commond.add("-i");
  71.         commond.add(fileInput.getAbsolutePath());
  72.         if (isVideo) {
  73.             commond.add("-vcodec");
  74.             commond.add("libx264");
  75.             commond.add("-mbd");
  76.             commond.add("0");
  77.             commond.add("-c:a");
  78.             commond.add("aac");
  79.             commond.add("-s");
  80.             commond.add("720*720");
  81.             commond.add("-threads");  //指定同时启动线程执行数, 经测试到10再大速度几无变化
  82.             commond.add("25");
  83.             commond.add("-preset");
  84.             commond.add("ultrafast");
  85.             commond.add("-strict");
  86.             commond.add("-2");
  87.             commond.add("-pix_fmt");
  88.             commond.add("yuv420p");
  89.             commond.add("-movflags");
  90.             commond.add("faststart");
  91.         }
  92.         commond.add(fileOutPut.getAbsolutePath());
  93.         //执行命令
  94.         executeCommand(commond);
  95.     }
  96.  
  97.     /**
  98.      * 执行FFmpeg命令
  99.      * @param commonds 要执行的FFmpeg命令
  100.      * @return FFmpeg程序在执行命令过程中产生的各信息，执行出错时返回null
  101.      */
  102.     public static String executeCommand(List<String> commonds) {
  103.         if (CollectionUtils.isEmpty(commonds)) {
  104.             System.out.println("--- 指令执行失败，因为要执行的FFmpeg指令为空！ ---");
  105.             return null;
  106.         }
  107.         LinkedList<String> ffmpegCmds = new LinkedList<>(commonds);
  108.         ffmpegCmds.addFirst(FFMPEG_PATH); // 设置ffmpeg程序所在路径
  109.         System.out.println("--- 待执行的FFmpeg指令为：---" + ffmpegCmds);
  110.  
  111.         Runtime runtime = Runtime.getRuntime();
  112.         Process ffmpeg = null;
  113.         try {
  114.             // 执行ffmpeg指令
  115.             ProcessBuilder builder = new ProcessBuilder("/bin/sh", "-c");
  116.             builder.command(ffmpegCmds);
  117.             ffmpeg = builder.start();
  118.             System.out.println("--- 开始执行FFmpeg指令：--- 执行线程名：" + builder.toString());
  119.  
  120.             // 取出输出流和错误流的信息
  121.             // 注意：必须要取出ffmpeg在执行命令过程中产生的输出信息，如果不取的话当输出流信息填满jvm存储输出留信息的缓冲区时，线程就回阻塞住
  122.             PrintStream errorStream = new PrintStream(ffmpeg.getErrorStream());
  123.             PrintStream inputStream = new PrintStream(ffmpeg.getInputStream());
  124.             errorStream.start();
  125.             inputStream.start();
  126.             // 等待ffmpeg命令执行完
  127.             ffmpeg.waitFor();
  128.  
  129.             // 获取执行结果字符串
  130.             String result = errorStream.stringBuffer.append(inputStream.stringBuffer).toString();
  131.  
  132.             // 输出执行的命令信息
  133.             String cmdStr = Arrays.toString(ffmpegCmds.toArray()).replace(",", "");
  134.             String resultStr = StringUtils.isBlank(result) ? "【异常】" : "正常";
  135.             System.out.println("--- 已执行的FFmepg命令： ---" + cmdStr + " 已执行完毕,执行结果： " + resultStr);
  136.             return result;
  137.  
  138.         } catch (Exception e) {
  139.             System.out.println("--- FFmpeg命令执行出错！ --- 出错信息： " + e.getMessage());
  140.             return null;
  141.  
  142.         } finally {
  143.             if (null != ffmpeg) {
  144.                 ProcessKiller ffmpegKiller = new ProcessKiller(ffmpeg);
  145.                 // JVM退出时，先通过钩子关闭FFmepg进程
  146.                 runtime.addShutdownHook(ffmpegKiller);
  147.             }
  148.         }
  149.     }
  150.  
  151.     /**
  152.      * 用于取出ffmpeg线程执行过程中产生的各种输出和错误流的信息
  153.      */
  154.     static class PrintStream extends Thread {
  155.  
  156.         InputStream inputStream = null;
  157.         BufferedReader bufferedReader = null;
  158.         StringBuffer stringBuffer = new StringBuffer();
  159.  
  160.         public PrintStream(InputStream inputStream) {
  161.             this.inputStream = inputStream;
  162.         }
  163.  
  164.         @Override
  165.         public void run() {
  166.             try {
  167.                 if (null == inputStream) {
  168.                     System.out.println("--- 读取输出流出错！因为当前输出流为空！---");
  169.                 }
  170.                 bufferedReader = new BufferedReader(new InputStreamReader(inputStream));
  171.                 String line = null;
  172.                 while ((line = bufferedReader.readLine()) != null) {
  173.                     System.out.println(line);
  174.                     stringBuffer.append(line);
  175.                 }
  176.             } catch (Exception e) {
  177.                 System.out.println("--- 读取输入流出错了！--- 错误信息：" + e.getMessage());
  178.             } finally {
  179.                 try {
  180.                     if (null != bufferedReader) {
  181.                         bufferedReader.close();
  182.                     }
  183.                     if (null != inputStream) {
  184.                         inputStream.close();
  185.                     }
  186.                 } catch (IOException e) {
  187.                     System.out.println("--- 调用PrintStream读取输出流后，关闭流时出错！---");
  188.                 }
  189.             }
  190.         }
  191.     }
  192.  
  193.     /**
  194.      * 在程序退出前结束已有的FFmpeg进程
  195.      */
  196.     private static class ProcessKiller extends Thread {
  197.  
  198.         private Process process;
  199.  
  200.         public ProcessKiller(Process process) {
  201.             this.process = process;
  202.         }
  203.  
  204.         @Override
  205.         public void run() {
  206.             this.process.destroy();
  207.             System.out.println("--- 已销毁FFmpeg进程 --- 进程名： " + process.toString());
  208.         }
  209.     }
  210.  
  211.  
  212.  
  213.     /**
  214.      * 获取音频基本信息
  215.      *
  216.      * @param path 文件路径|URL
  217.      * @throws EncoderException
  218.      */
  219.     public static MultimediaInfo testMediaInfo(String path) throws EncoderException, MalformedURLException {
  220.         MultimediaObject instance;
  221.         if (path.startsWith("http")) {
  222.             instance = new MultimediaObject(new URL(path));
  223.         } else {
  224.             instance = new MultimediaObject(new File(path));
  225.         }
  226.         return instance.getInfo();
  227.     }
  228.     /**
  229.      * 原生调用ffmpeg获取音频基本信息
  230.      *
  231.      * @param urlPath
  232.      */
  233.     public static void testFFmpeg(String urlPath) {
  234.         ProcessLocator processLocator = new DefaultFFMPEGLocator();
  235.         ProcessWrapper ffmpeg = processLocator.createExecutor();
  236.         ffmpeg.addArgument("-i");
  237.         ffmpeg.addArgument(urlPath);
  238.         try {
  239.             ffmpeg.execute();
  240.             String res = IOUtils.toString(ffmpeg.getErrorStream(), "UTF-8");
  241.         } catch (Exception e) {
  242.             e.printStackTrace();
  243.         } finally {
  244.             ffmpeg.destroy();
  245.         }
  246.     }
  247.  
  248.     /**
  249.      * 转成Mp4
  250.      *
  251.      * @param sourceFile
  252.      * @param distFile
  253.      * @param pListener
  254.      * @throws EncoderException
  255.      */
  256.     public static void codecToMp4(String sourceFile, String distFile, EncoderProgressListener pListener) throws EncoderException {
  257.         File source = new File(sourceFile);
  258.         File target = new File(distFile);
  259.         if (target.exists()) {
  260.             target.delete();
  261.         }
  262.         AudioAttributes audioAttr = new AudioAttributes();
  263.         VideoAttributes videoAttr = new VideoAttributes();
  264.         EncodingAttributes encodingAttr = new EncodingAttributes();
  265.         audioAttr.setChannels(2);
  266.         audioAttr.setCodec("aac");
  267.         audioAttr.setBitRate(128000);
  268.         audioAttr.setSamplingRate(44100);
  269.         videoAttr.setCodec("libx264");
  270.         videoAttr.setBitRate(2 * 1024 * 1024);
  271.         videoAttr.setSize(new VideoSize(1080, 720));
  272.         videoAttr.setFaststart(true);
  273.         videoAttr.setFrameRate(29);
  274.         encodingAttr.setAudioAttributes(audioAttr);
  275.         encodingAttr.setVideoAttributes(videoAttr);
  276.         encodingAttr.setOutputFormat("mp4");
  277.         Encoder encoder = new Encoder();
  278.         encoder.encode(new MultimediaObject(source), target, encodingAttr, pListener);
  279.     }
  280.  
  281.  
  282.     /**
  283.      * 添加文字水印
  284.      *
  285.      * @param sourceFile
  286.      * @param distFile
  287.      * @param textWaterMark
  288.      * @param pListener
  289.      * @throws EncoderException
  290.      */
  291.     public static void codecToMp4WithText(String sourceFile, String distFile, String textWaterMark, EncoderProgressListener pListener) throws EncoderException {
  292.         File sourceVideo = new File(sourceFile);
  293.         File target = new File(distFile);
  294.         if (target.exists()) {
  295.             target.delete();
  296.         }
  297.         DrawtextFilter vf = new DrawtextFilter(textWaterMark, "(w-text_w)/2", "(h-text_h)/2", "宋体", 30.0, new Color("ffffff", "44"));
  298.         vf.setShadow(new Color("000000", "44"), 2, 2);
  299.         VideoAttributes videoAttributes = new VideoAttributes();
  300.         videoAttributes.addFilter(vf);
  301.         EncodingAttributes attrs = new EncodingAttributes();
  302.         attrs.setVideoAttributes(videoAttributes);
  303.         Encoder encoder = new Encoder();
  304.         encoder.encode(new MultimediaObject(sourceVideo), target, attrs, pListener);
  305.     }
  306.  
  307. //
  308.     public static void main(String[] args) throws EncoderException, MalformedURLException {
  309.         String videoPath = "D:\\usr\\local\\tobaccocasedoc\\Download\\test(0).mp4";
  310.         String wavPath = "D:\\usr\\local\\tobaccocasedoc\\Download\\test(0).mp4";
  311.         String mp3Path = "D:\\usr\\local\\tobaccocasedoc\\Download\\result.mp4";
  312.         //测试获取视频信息
  313.         MultimediaInfo info = testMediaInfo(videoPath);
  314.         System.out.println(JSON.toJSONString(info));
  315.         //测试音频转码
  316.         codecToMp4(wavPath, mp3Path, new EncoderProgressListener() {
  317.             @Override
  318.             public void sourceInfo(MultimediaInfo info) {
  319.                 System.out.println(JSON.toJSONString(info));
  320.             }
  321.             @Override
  322.             public void progress(int permil) {
  323.                 System.out.println(permil);
  324.             }
  325.             @Override
  326.             public void message(String message) {
  327.                 System.out.println(message);
  328.             }
  329.         });
  330.  
  331.     }

（注： 因为官方的sdk不定时更新，一些接口参数也可能发生改变 大家可以根据返回的错误码判断错误信息 这篇文章仅供大家参考，如需要和我版本一致的sdk，源码下载类替换就好啦）

源码地址:（晚点上传）

对应的jar和maven需要大佬们自己去找找了

大佬勿喷！！！！！！！！！！！！！！！！！！！！！ 写这个博客只是希望可以帮到大家

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/盐析白兔/article/detail/102872
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号