fdkk_meta/src/main/java/com/fdkk/fdkkmeta/test/test.java

//package com.fdkk.fdkkmeta.test;
//
//import cn.hutool.core.date.DateUtil;
//import cn.hutool.core.io.BufferUtil;
//import cn.hutool.core.io.FileUtil;
//import cn.hutool.core.io.IORuntimeException;
//import cn.hutool.core.io.IoUtil;
//import cn.hutool.core.io.file.FileWriter;
//import cn.hutool.core.lang.Console;
//import cn.hutool.core.util.StrUtil;
//import cn.hutool.core.util.URLUtil;
//import cn.hutool.log.StaticLog;
//import cn.hutool.socket.aio.AioServer;
//import cn.hutool.socket.aio.AioSession;
//import cn.hutool.socket.aio.SimpleIoAction;
//import cn.hutool.socket.nio.NioServer;
//import com.alibaba.fastjson.JSON;
//import com.alibaba.fastjson.JSONArray;
//import com.alibaba.fastjson.JSONObject;
//import com.fdkk.fdkkmeta.po.RoutePO;
//import com.fdkk.fdkkmeta.util.FileUtils;
//import org.bytedeco.ffmpeg.global.avcodec;
//import org.bytedeco.javacv.FFmpegFrameGrabber;
//import org.bytedeco.javacv.FFmpegFrameRecorder;
//import org.bytedeco.javacv.Frame;
//
//import java.io.*;
//import java.nio.ByteBuffer;
//import java.nio.charset.Charset;
//import java.text.SimpleDateFormat;
//import java.util.*;
//import java.util.stream.Collectors;
//
///**
// * @author Xiewj
// * @date 2022/3/29
// */
//public class test {
////    public static void main(String[] args) throws IOException {
////        int d=6;
////        int fps=2 % d;
////        if (fps!=0){
////            fps=2/d+1;
////        }
////
////        System.out.println(fps);
////
////    }
//    public static void main(String[] args) throws IOException {
//
//        NioServer server = new NioServer(9099);
//        server.setChannelHandler((sc)->{
//            ByteBuffer readBuffer = ByteBuffer.allocate(1024);
//            try{
//                //从channel读数据到缓冲区
//                int readBytes = sc.read(readBuffer);
//                if (readBytes > 0) {
//                    //Flips this buffer.  The limit is set to the current position and then
//                    // the position is set to zero，就是表示要从起始位置开始读取数据
//                    readBuffer.flip();
//                    //eturns the number of elements between the current position and the  limit.
//                    // 要读取的字节长度
//                    byte[] bytes = new byte[readBuffer.remaining()];
//                    //将缓冲区的数据读到bytes数组
//                    readBuffer.get(bytes);
//                    String body = StrUtil.utf8Str(bytes);
//                    Console.log("[{}]: {}", sc.getRemoteAddress(), body);
//                    String outputFile = "rtmp://demo-kms.4dage.com/live/test12";
//                    try {
//                        frameRecord(sc.socket().getInputStream(), outputFile, 1);
//                    } catch (Exception e) {
//                        e.printStackTrace();
//                    }
//                } else if (readBytes < 0) {
//                    IoUtil.close(sc);
//                }
//            } catch (IOException e){
//                throw new IORuntimeException(e);
//            }
//        });
//        server.listen();
//    }
//    /**
//     * 按帧录制视频
//     *
//     * @param inputFile-该地址可以是网络直播/录播地址，也可以是远程/本地文件路径
//     * @param outputFile
//     *            -该地址只能是文件地址，如果使用该方法推送流媒体服务器会报错，原因是没有设置编码格式
//     * @throws org.bytedeco.javacv.FrameRecorder.Exception
//     */
//    public static void frameRecord(InputStream inputFile, String outputFile, int audioChannel)
//            throws Exception, org.bytedeco.javacv.FrameRecorder.Exception {
//        boolean isStart=true;//该变量建议设置为全局控制变量，用于控制录制结束
//        // 获取视频源
//        FFmpegFrameGrabber grabber = new FFmpegFrameGrabber(inputFile);
//        grabber.setOption("rtsp_transport", "tcp");
//        // 流媒体输出地址，分辨率（长，高），是否录制音频（0:不录制/1:录制）
//        FFmpegFrameRecorder recorder = new FFmpegFrameRecorder(outputFile, 1280, 720, audioChannel);
//        recorder.setVideoCodec(avcodec.AV_CODEC_ID_H264);
//        recorder.setFormat("flv");
//        // 开始取视频源
//        recordByFrame(grabber, recorder, isStart);
//    }
//    private static void recordByFrame(FFmpegFrameGrabber grabber, FFmpegFrameRecorder recorder, Boolean status)
//            throws Exception, org.bytedeco.javacv.FrameRecorder.Exception {
//        try {//建议在线程中使用该方法
//            grabber.start();
//            recorder.start();
//            Frame frame =null ;
//            while (status&& (frame = grabber.grabFrame()) != null) {
//                recorder.record(frame);
//            }
//            recorder.stop();
//            grabber.stop();
//        } finally {
//            if (grabber != null) {
//                grabber.stop();
//            }
//        }
//    }
//
//
//    private static void createdPointsJson(String path) {
//        List<String> list = FileUtils.readFileByLines2(path);
//        JSONArray array=new JSONArray();
//        FileWriter writer=new FileWriter("D:\\video\\points.json");
//        for (int i = 0; i < list.size(); i++) {
//            JSONObject jsonObject=new JSONObject();
//            String[] s = list.get(i).split(" ");
//            jsonObject.put("id",i );
//            JSONObject position=new JSONObject();
//            position.put("x",Double.valueOf(s[0]));
//            position.put("y",Double.valueOf(s[1]));
//            position.put("z",Double.valueOf(s[2]));
//            jsonObject.put("position",position);
//            JSONObject rotation=new JSONObject();
//            rotation.put("x",0.0);
//            rotation.put("y",0.0);
//            rotation.put("z",0.0);
//            rotation.put("w",1.0);
//            jsonObject.put("rotation",rotation);
//            List<String> strings = Arrays.asList(s[4], s[5], s[6], s[7], s[8], s[9], s[10], s[11]);
//            List<Integer> contact = strings.stream().filter(a -> !a.equals("-1")).map(a->{
//                return Integer.parseInt(a)-1;
//            }).collect(Collectors.toList());
//            jsonObject.put("contact",contact);
//            array.add(jsonObject);
//        }
//        writer.write(array.toJSONString());
//    }
//
//    private static void creatTargetJson(String path) {
//        List<String> list = FileUtils.readFileByLines2(path);
//        List<String> collect = new ArrayList<>();
//        FileWriter writer=new FileWriter("D:\\video\\target_freespace.json");
//        for (int i = 0; i < list.size(); i++) {
//            RoutePO po = new RoutePO();
//            String[] s = list.get(i).split(" ");
//            po.setId(i );
//            if (s.length == 12) {
//                double[] oldPoint = {Double.valueOf(s[0]), Double.valueOf(s[1]), Double.valueOf(s[2])};
//                po.setX(oldPoint[0]);
//                po.setY(oldPoint[1]);
//                po.setZ(oldPoint[2]);
//                po.setWeight(Double.parseDouble(s[3]));
//                List<String> strings = Arrays.asList(s[4], s[5], s[6], s[7], s[8], s[9], s[10], s[11]);
//                List<Integer> contact = strings.stream().map(a->{
//                    if (Integer.parseInt(a)!=-1){
//                        return Integer.parseInt(a)-1;
//                    }
//                    return Integer.parseInt(a);
//                }).collect(Collectors.toList());
//                po.setIds(contact);
//            }
//            collect.add(JSON.toJSONString(po));
//        }
//        writer.writeLines(collect);
//    }
//}