美文网首页
springboot服务端视频压缩和图片压缩

springboot服务端视频压缩和图片压缩

作者: SeekLife0 | 来源:发表于2023-01-28 08:58 被阅读0次

视频压缩:
参考:
(61条消息) JAVA,实现视频压缩(最全)seniorShen的博客-CSDN博客压缩视频实现 博客

引入

        <!--   视频压缩   -->
        <dependency>
            <groupId>ws.schild</groupId>
            <artifactId>jave-core</artifactId>
            <version>3.0.0</version>
        </dependency>
        <!-- 在windows上开发 开发机可实现压缩效果 window64位 -->
        <dependency>
            <groupId>ws.schild</groupId>
            <artifactId>jave-nativebin-win64</artifactId>
            <version>3.0.0</version>
        </dependency>
        <!-- 在linux上部署 linux服务器需要这个才能生效 linux64位 -->
        <dependency>
            <groupId>ws.schild</groupId>
            <artifactId>jave-nativebin-linux64</artifactId>
            <version>3.0.0</version>
        </dependency>
/**
 * Copyright (C) 2018-2021
 * All rights reserved, Designed By www.yixiang.co

 */
package co.gpthome.tools.rest;

import co.gpthome.tools.domain.QiniuContent;
import co.gpthome.tools.service.LocalStorageService;
import co.gpthome.tools.service.QiNiuService;
import co.gpthome.tools.utils.VideoUtils;
import co.gpthome.utils.FileUtil;
import co.gpthome.utils.ImageUtils;
import co.gpthome.utils.RedisUtils;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.multipart.MultipartFile;

import java.io.IOException;
import java.util.HashMap;
import java.util.Map;

/**
 * @author seeklife
 * @date 2023/1/5 16:58
 */
@Api(tags = "前端富文本文件上传")
@RestController
    @RequestMapping("/api/editor/upload")
@Slf4j
@SuppressWarnings("unchecked")
public class UploadVideoController {

    private final LocalStorageService localStorageService;
    private final QiNiuService qiNiuService;
    private final RedisUtils redisUtils;

    public UploadVideoController(LocalStorageService localStorageService, QiNiuService qiNiuService,
                                 RedisUtils redisUtils) {
        this.localStorageService = localStorageService;
        this.qiNiuService = qiNiuService;
        this.redisUtils = redisUtils;
    }


    @ApiOperation("上传文件")
    @PostMapping
    public ResponseEntity<Object> create(@RequestParam(defaultValue = "") String name,
                                         @RequestParam(defaultValue = "") String type,
                                         @RequestParam("file") MultipartFile[] files) throws IOException {
        StringBuilder url = new StringBuilder();
        QiniuContent qiniuContent;
        for (MultipartFile file : files) {
            if(ImageUtils.checkSuffix(file.getOriginalFilename()) &&
                    ImageUtils.checkFileSize(file.getSize(), 10, "M")){
                qiniuContent = qiNiuService.upload(VideoUtils.compressionVideo(file,file.getOriginalFilename()), qiNiuService.find(), true);
            }else {
                qiniuContent = qiNiuService.upload(file, qiNiuService.find(), true);
            }
            if ("".equals(url.toString())) {
                url = url.append(qiniuContent.getUrl());
            }else{
                url = url.append(","+qiniuContent.getUrl());
            }
        }
        Map<String, Object> map = new HashMap<>(2);
        map.put("errno", 0);
        map.put("link", url);
        return new ResponseEntity(map, HttpStatus.CREATED);
    }


}

VideoUtils

package co.gpthome.tools.utils;

import co.gpthome.utils.FileUtil;
import org.apache.http.entity.ContentType;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.mock.web.MockMultipartFile;
import org.springframework.web.multipart.MultipartFile;
import ws.schild.jave.Encoder;
import ws.schild.jave.MultimediaObject;
import ws.schild.jave.encode.AudioAttributes;
import ws.schild.jave.encode.EncodingAttributes;
import ws.schild.jave.encode.VideoAttributes;
import ws.schild.jave.info.AudioInfo;
import ws.schild.jave.info.VideoSize;

import java.io.*;
import java.math.BigDecimal;
import java.math.RoundingMode;
import java.net.HttpURLConnection;
import java.net.URL;
import java.nio.channels.FileChannel;

/**
 * @author seeklife
 * 视频压缩工具类
 * @date 2023年01月05日 17:17
 */
public class VideoUtils {

    @Value("${file.videoPath}")
    private static String path;

    /**
     * 传视频File对象(这是一个具体的文件),返回压缩后File对象信息
     * @param source
     */
    public static MultipartFile compressionVideo(MultipartFile source, String picName) {
        if(source == null){
            return null;
        }
        File temSource = FileUtil.toFile(source);
        String newPath = path + picName;//temSource.getAbsolutePath().substring(0, temSource.getAbsolutePath().lastIndexOf(File.separator)).concat(File.separator).concat(picName);
        File target = new File(newPath);
        try {
            MultimediaObject object = new MultimediaObject(temSource);
            AudioInfo audioInfo = object.getInfo().getAudio();
            // 根据视频大小来判断是否需要进行压缩,
            int maxSize = 5;
            double mb = Math.ceil(temSource.length()/ 1048576);
            int second = (int)object.getInfo().getDuration()/1000;
            BigDecimal bd = new BigDecimal(String.format("%.4f", mb/second));
            System.out.println("开始压缩视频了--> 视频每秒平均 "+ bd +" MB ");
            // 视频 > 5MB, 或者每秒 > 0.5 MB 才做压缩, 不需要的话可以把判断去掉
            boolean temp = mb > maxSize || bd.compareTo(new BigDecimal(0.5)) > 0;
//            if(temp){
            long time = System.currentTimeMillis();
            //TODO 视频属性设置
            int maxBitRate = 128000;
            int maxSamplingRate = 44100;
            int bitRate = 800000;
            int maxFrameRate = 20;
            int maxWidth = 1280;

            AudioAttributes audio = new AudioAttributes();
            // 设置通用编码格式10                   audio.setCodec("aac");
            // 设置最大值:比特率越高,清晰度/音质越好
            // 设置音频比特率,单位:b (比特率越高,清晰度/音质越好,当然文件也就越大 128000 = 182kb)
            if(audioInfo.getBitRate() > maxBitRate){
                audio.setBitRate(new Integer(maxBitRate));
            }

            // 设置重新编码的音频流中使用的声道数(1 =单声道,2 = 双声道(立体声))。如果未设置任何声道值,则编码器将选择默认值 0。
            audio.setChannels(audioInfo.getChannels());
            // 采样率越高声音的还原度越好,文件越大
            // 设置音频采样率,单位:赫兹 hz
            // 设置编码时候的音量值,未设置为0,如果256,则音量值不会改变
            // audio.setVolume(256);
            if(audioInfo.getSamplingRate() > maxSamplingRate){
                audio.setSamplingRate(maxSamplingRate);
            }

            //TODO 视频编码属性配置
            ws.schild.jave.info.VideoInfo videoInfo = object.getInfo().getVideo();
            VideoAttributes video = new VideoAttributes();
            video.setCodec("h264");
            //设置音频比特率,单位:b (比特率越高,清晰度/音质越好,当然文件也就越大 800000 = 800kb)
            if(videoInfo.getBitRate() > bitRate){
                video.setBitRate(bitRate);
            }

            // 视频帧率:15 f / s  帧率越低,效果越差
            // 设置视频帧率(帧率越低,视频会出现断层,越高让人感觉越连续),视频帧率(Frame rate)是用于测量显示帧数的量度。所谓的测量单位为每秒显示帧数(Frames per Second,简:FPS)或“赫兹”(Hz)。
            if(videoInfo.getFrameRate() > maxFrameRate){
                video.setFrameRate(maxFrameRate);
            }

            // 限制视频宽高
            int width = videoInfo.getSize().getWidth();
            int height = videoInfo.getSize().getHeight();
            if(width > maxWidth){
                float rat = (float) width / maxWidth;
                video.setSize(new VideoSize(maxWidth,(int)(height/rat)));
            }

            EncodingAttributes attr = new EncodingAttributes();
//                attr.setFormat("mp4");
            attr.setAudioAttributes(audio);
            attr.setVideoAttributes(video);

            // 速度最快的压缩方式, 压缩速度 从快到慢: ultrafast, superfast, veryfast, faster, fast, medium,  slow, slower, veryslow and placebo.
//                attr.setPreset(PresetUtil.VERYFAST);
//                attr.setCrf(27);
//                // 设置线程数
//                attr.setEncodingThreads(Runtime.getRuntime().availableProcessors()/2);

            Encoder encoder = new Encoder();
            encoder.encode(new MultimediaObject(temSource), target, attr);
            System.out.println("压缩总耗时:" + (System.currentTimeMillis() - time)/1000);
//            return target;
            FileInputStream inputStream = new FileInputStream(target);
            MultipartFile multipartFile = new MockMultipartFile(picName, picName,
                    ContentType.APPLICATION_OCTET_STREAM.toString(), inputStream);
            return multipartFile;
//            }
        } catch (Exception e) {
            e.printStackTrace();
        }finally {
            if(target.length() > 0){
                temSource.delete();
            }
        }
        return source;
    }

}

ImageUtils

package co.gpthome.utils;

import net.coobird.thumbnailator.Thumbnails;
import org.apache.commons.codec.binary.Base64;
import org.apache.http.entity.ContentType;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.mock.web.MockMultipartFile;
import org.springframework.web.multipart.MultipartFile;

import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;

/**
 * 图片压缩工具类
 * @author huanghao
 * @date 2022年03月11日 16:25
 */
public class ImageUtils {

    @Value("${file.path}")
    private static String path;



    /**
     * 图片按比例压缩
     * @author huanghao
     * @date 2022/3/12 8:58
     * @param file
     * @return java.io.File
     */
    public static MultipartFile compressImage(MultipartFile file) throws IOException {
        String imageName = file.getOriginalFilename();
        FileOutputStream outputStream = new FileOutputStream(path+imageName);
        Thumbnails.of(FileUtil.toFile(file))
                .scale(1f) //图片大小(长宽)压缩 从0按照
                .outputQuality(1f) //图片质量压缩比例 从0-1,越接近1质量越好
                .toOutputStream(outputStream);
        outputStream.close();
        //file转MultipartFile
        FileInputStream inputStream = new FileInputStream(new File(path+imageName));
        MultipartFile multipartFile = new MockMultipartFile(imageName, imageName,
                ContentType.APPLICATION_OCTET_STREAM.toString(), inputStream);
        return multipartFile;
    }

    /**
     * 判断文件大小
     *
     * @param len
     *            文件长度
     * @param size
     *            限制大小
     * @param unit
     *            限制单位(B,K,M,G)
     * @return
     */
    public static boolean checkFileSize(Long len, int size, String unit) {
        double fileSize = 0;
        if ("B".equals(unit.toUpperCase())) {
            fileSize = (double) len;
        } else if ("K".equals(unit.toUpperCase())) {
            fileSize = (double) len / 1024;
        } else if ("M".equals(unit.toUpperCase())) {
            fileSize = (double) len / 1048576;
        } else if ("G".equals(unit.toUpperCase())) {
            fileSize = (double) len / 1073741824;
        }
        if (fileSize < size) {
            return false;
        }
        return true;
    }


    /**
     * 验证文件是否是图片
     * @author huanghao
     * @date 2022/3/12 9:42
     * @param imgPath
     * @return boolean
     */
    public static boolean checkSuffix(String imgPath) {
        Boolean flag =false;
        //图片格式
        String[] FILETYPES = new String[]{
                ".jpg", ".jpeg", ".png",
                ".JPG", ".JPEG", ".PNG"
        };
        if(!StringUtils.isBlank(imgPath)){
            for (int i = 0; i < FILETYPES.length; i++) {
                String fileType = FILETYPES[i];
                if (imgPath.endsWith(fileType)) {
                    flag = true;
                    break;
                }
            }
        }

        return flag;
    }

    public static void delImage(String imageName) {
        File file = new File("/usr/local/src/image/"+imageName);
        //判断文件是否存在
        if (file.exists() == true){
            Boolean flag = false;
            flag = file.delete();
            if (flag){
                System.out.println("成功删除图片"+file.getName());
            }else {
                System.out.println("删除失败");
            }
        }
    }

    /**
     * Base64图片字符串转换成MultipartFile
     * @author huanghao
     * @date 2022/5/18 14:19
     * @param base64
     * @return org.springframework.web.multipart.MultipartFile
     */
    public static MultipartFile base64ToMultipartFile(String base64) {
        //base64编码后的图片有头信息所以要分离出来 [0]data:image/png;base64, 图片内容为索引[1]
        String[] baseStrs = base64.split(",");

        //取索引为1的元素进行处理
        byte[] b = Base64.decodeBase64(baseStrs[1]);
        for (int i = 0; i < b.length; ++i) {
            if (b[i] < 0) {
                b[i] += 256;
            }
        }
        //处理过后的数据通过Base64DecodeMultipartFile转换为MultipartFile对象
        return new Base64DecodeMultipartFile(b, baseStrs[0]);
    }


    public static void main(String[] args) {
        System.out.println(checkSuffix("20220312101054521663.jpg"));
    }



}

图片压缩
就是使用前边提供的ImageUtils的compressImage方法

/**
 * Copyright (C) 2018-2021
 * All rights reserved, Designed By www.yixiang.co

 */
package co.gpthome.tools.rest;

import co.gpthome.tools.domain.QiniuContent;
import co.gpthome.tools.service.LocalStorageService;
import co.gpthome.tools.service.QiNiuService;
import co.gpthome.utils.ImageUtils;
import co.gpthome.utils.RedisUtils;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.multipart.MultipartFile;

import java.io.IOException;
import java.util.HashMap;
import java.util.Map;

/**
 * @author huanghao
 * @date 2020-01-09
 */
@Api(tags = "上传统一管理")
@RestController
@RequestMapping("/api/upload")
@Slf4j
@SuppressWarnings("unchecked")
public class UploadPicController {

    private final LocalStorageService localStorageService;
    private final QiNiuService qiNiuService;
    private final RedisUtils redisUtils;

    public UploadPicController(LocalStorageService localStorageService, QiNiuService qiNiuService,
                               RedisUtils redisUtils) {
        this.localStorageService = localStorageService;
        this.qiNiuService = qiNiuService;
        this.redisUtils = redisUtils;
    }


    @ApiOperation("上传文件")
    @PostMapping
    public ResponseEntity<Object> create(@RequestParam(defaultValue = "") String name,
                                         @RequestParam(defaultValue = "") String type,
                                         @RequestParam("file") MultipartFile[] files) throws IOException {
        StringBuilder url = new StringBuilder();
        QiniuContent qiniuContent;
        for (MultipartFile file : files) {
            if(ImageUtils.checkSuffix(file.getOriginalFilename()) &&
                    ImageUtils.checkFileSize(file.getSize(), 4, "M")){
                qiniuContent = qiNiuService.upload(ImageUtils.compressImage(file), qiNiuService.find(), true);
                //清除服务器上被压缩后的图片
                ImageUtils.delImage(file.getName());
            }else {
                qiniuContent = qiNiuService.upload(file, qiNiuService.find(), true);
            }
            if ("".equals(url.toString())) {
                url = url.append(qiniuContent.getUrl());
            }else{
                url = url.append(","+qiniuContent.getUrl());
            }
        }
        Map<String, Object> map = new HashMap<>(2);
        map.put("errno", 0);
        map.put("link", url);
        return new ResponseEntity(map, HttpStatus.CREATED);
    }


}

相关文章

网友评论

      本文标题:springboot服务端视频压缩和图片压缩

      本文链接:https://www.haomeiwen.com/subject/ruphhdtx.html