图片等文件信息上传阿里云

时间 2019-11-07

原文原文链接

最近公司要保存用户的图片信息到阿里云，通过学习已经掌握了阿里云基本上传的开发步骤。过程仍是比较顺利的，查看了不少博客，代码都不是很全，本身为了方便之后使用和回忆，因此我写篇博客记录一下当时的过程。由于api里面有详细的步骤，这里我不在详细描述，只写代码实现和大抵的步骤。html

①上传阿里云maven须要配置的jar包java

<dependency>
    <groupId>com.aliyun.oss</groupId>
    <artifactId>aliyun-sdk-oss</artifactId>
    <version>2.2.3</version>
</dependency>

<dependency>
    <groupId>org.apache.httpcomponents</groupId>
    <artifactId>httpclient</artifactId>
    <version>4.4</version>
</dependency>

注：org.apache.httpcomponents必须为4.4版本。web

若是mven里面有4.3版本的httpclient 会形成版本冲突，配置以前先检查mven里面的配置。spring

若是有低版本，应先删除再配置高版本的httpclient。（我由于这个半天都在报错，切记）apache

②阅读apiapi

地址：https://help.aliyun.com/document_detail/32010.html?spm=5176.doc32009.6.211.OeN2Uw安全

必须阅读几遍api，这样流程会大抵熟悉服务器

③就是代码部分（上传接口）app

package com.zhongqi.ChessMember.client.web.controller.xaingqi;

import com.aliyun.oss.OSSClient;
import com.aliyun.oss.model.ObjectMetadata;
import com.aliyun.oss.model.PutObjectResult;
import com.zhongqi.ChessMember.dto.UploadAddInfo;
import com.zhongqi.ChessMember.entity.UploadFile;
import com.zhongqi.ChessMember.service.xiangqi.UploadService;
import com.zhongqi.common.controller.BaseController;
import com.zhongqi.common.dto.JsonResponseResult;
import com.zhongqi.common.util.BaseUtils;
import org.apache.commons.codec.digest.DigestUtils;
import org.apache.commons.io.IOUtils;
import org.apache.log4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.multipart.MultipartFile;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.InputStream;
import java.text.SimpleDateFormat;
import java.util.Date;

/**
 * Created by jordan on 16/10/24.
 * @author 宁春笋
 */
@Controller
@RequestMapping("/clientUpload")
public class UploadController extends BaseController {
    Logger logger = Logger.getLogger(UploadController.class);

    @Autowired
    private UploadService uploadService;

    @RequestMapping("/upload")
    public void upload(@RequestParam(value = "file", required = false) MultipartFile uploadFile,
                       HttpServletRequest request, HttpServletResponse response)throws Exception {
        JsonResponseResult result = new JsonResponseResult();

        result.setCode(1);
        result.setMsg("导入文件失败");

        if (!uploadFile.isEmpty()) {
            try {
                // 文件保存路径
                String strPath = request.getSession().getServletContext().getRealPath("/uploadImgs");
                System.out.println(" strPath"+ strPath);

                //得到上传文件的名字
                String fileName = uploadFile.getOriginalFilename();
                System.out.print("fileName"+fileName);

                //拿到文件的流进行加密
                FileInputStream fis = new FileInputStream(strPath + "/"+fileName);
                String fileMD5= DigestUtils.md5Hex(IOUtils.toByteArray(fis));
                UploadFile uploadFile1=uploadService.checkUploadFileInfo(fileMD5);
                if (uploadFile1==null){
                File file = new File(strPath + "/"+fileName);
                // 转存文件到服务器
                uploadFile.transferTo(file);

                /**
                 * 从服务器读取存储阿里云
                 * 上传文件的名字:file.getName()
                 *
                 * 当前时间:getCurrentDate()
                 *
                 * 文件(bucketName里面建立的)Constant.filePath
                 *
                 */
                String key =Constant.filePath+ "/" +getCurrentDate()+"/"+fileName;
                System.out.println("key"+key);
                String  filePath =strPath+ "/" +fileName;

                //  存储阿里云
                putObject(Constant.bucketName, key,filePath);
                UploadAddInfo uploadAddInfo =new UploadAddInfo();
                uploadAddInfo.setFileMD5(fileMD5);
                uploadAddInfo.setFilePath(key);
                uploadAddInfo.setUploadDate(new Date());
                Integer uploadId= uploadService.addUploadinfo(uploadAddInfo);
                    if (uploadId!=null){
                        result.setCode(0);
                        result.setMsg("导入成功");
                        result.setResponse(uploadAddInfo);
                    }

                }
            } catch (FileNotFoundException f) {
                logger.error(f);
                throw f;
            }
        }

        response(BaseUtils.toJsonFromObject(result), response,logger);
    }

    //  存储阿里云
    private  void putObject(String bucketName, String key, String filePath) throws FileNotFoundException {

        // 初始化OSSClient
        OSSClient client = DefaultOSSClient.getDefaultOSSClient();
        // 获取指定文件的输入流
        File file = new File(filePath);
        InputStream content = new FileInputStream(file);

        // 建立上传Object的Metadata
        ObjectMetadata meta = new ObjectMetadata();

        // 必须设置ContentLength
        meta.setContentLength(file.length());
        Date expire = new Date(new Date().getTime() + 30 * 1000);
        meta.setExpirationTime(expire);

        // 上传Object.
        PutObjectResult result = client.putObject(Constant.bucketName, key, content, meta);
        // 打印ETag
        System.out.println("etag--------------->" + result.getETag());
    }
    //时间处理
    private static String  getCurrentDate(){
        Date date =new Date();
        SimpleDateFormat simpleDateFormat =new SimpleDateFormat("yyyyMMddHHmmss");
        String timeDate =simpleDateFormat.format(date);
        return timeDate;
    }
}

④用到的配置工具类maven

DefaultOSSClient类

package com.zhongqi.ChessMember.client.web.controller.xaingqi;

import com.aliyun.oss.OSSClient;
import com.zhongqi.ChessMember.client.config.DefaultClientConfiguration;

/**
 * Created by jordan on 16/10/21.
 * @author 宁春笋
 */
public class DefaultOSSClient {

    /*
     * Constructs a client instance with your account for accessing OSS
     */
    private static OSSClient client = new OSSClient(Constant.endpoint, Constant.accessKeyId, Constant.accessKeySecret, DefaultClientConfiguration.getDefalutClientConfig());

    private DefaultOSSClient() {

    }

    public static OSSClient getDefaultOSSClient(){
        if(client == null){
            client = new OSSClient(Constant.endpoint,Constant.accessKeyId, Constant.accessKeySecret,DefaultClientConfiguration.getDefalutClientConfig());
        }
        return client;
    }

    public static void shutdownOSSClient(){
        client.shutdown();
        client = null;
    }




}

Constant类

Constant类

package com.zhongqi.ChessMember.client.web.controller.xaingqi;

/**
 * Created by jordan on 16/10/21.
 * @author 宁春笋
 */
public  class Constant {
    public static String endpoint = "http://oss-cn-hangzhou.aliyuncs.com";
    public static  String accessKeyId = "你的accessKeyId";
    public static String accessKeySecret = "你的accessKeySecret";
    public static  String bucketName = "本身建立的bucket";
    public static  String filePath="本身建立的上传位置";
}

默认配置能够查询api本身定义

package com.zhongqi.ChessMember.client.config;

import com.aliyun.oss.ClientConfiguration;

/**
 * Created by jordan on 16/10/21.
 * 宁春笋
 */
public class DefaultClientConfiguration {
    // 建立ClientConfiguration实例
    private static final ClientConfiguration conf = new ClientConfiguration();

    private DefaultClientConfiguration() {
        // 设置OSSClient使用的最大链接数，默认1024
        conf.setMaxConnections(100);
        // 设置请求超时时间，默认50秒
        conf.setConnectionTimeout(5000);
        // 设置失败请求重试次数，默认3次
        conf.setMaxErrorRetry(3);
        //Socket层传输数据的超时时间（单位：毫秒）。默认为50000毫秒
        conf.setSocketTimeout(2000);
    }

    public static ClientConfiguration getDefalutClientConfig(){
        return conf;
    }
}

⑤service实现

package com.zhongqi.ChessMember.service.xiangqi.impl;

import com.zhongqi.ChessMember.dao.xiangqi.UploadDao;
import com.zhongqi.ChessMember.dto.UploadAddInfo;
import com.zhongqi.ChessMember.entity.UploadFile;
import com.zhongqi.ChessMember.service.xiangqi.UploadService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

/**
 * Created by jordan on 16/10/24.
 */
@Service("uploadService")
public class UploadServiceImpl implements UploadService{

     @Autowired
     private UploadDao uploadDao;

    //存储上传信息
    @Override
    @Transactional
    public Integer addUploadinfo(UploadAddInfo uploadAddInfo) {
        return uploadDao.addUploadinfo(uploadAddInfo);
    }

    @Override
    public UploadFile checkUploadFileInfo(String fileMD5) {
        return uploadDao.checkUploadFileInfo(fileMD5);
    }
}

⑥dao实现

package com.zhongqi.ChessMember.dao.xiangqi.impl;

import com.zhongqi.ChessMember.dao.xiangqi.UploadDao;
import com.zhongqi.ChessMember.dto.UploadAddInfo;
import com.zhongqi.ChessMember.entity.UploadFile;
import com.zhongqi.common.dao.impl.BaseDaoImpl;
import org.apache.log4j.Logger;
import org.springframework.stereotype.Repository;

/**
 * Created by jordan on 16/10/24.
 * @author 宁春笋
 */
@Repository("uploadDao")
public class UploadImpl extends BaseDaoImpl implements UploadDao {
    Logger logger = Logger.getLogger(UploadImpl.class);

    //存储上传信息
    @Override
    public Integer addUploadinfo(UploadAddInfo uploadAddInfo) {
        Integer result =0;

        UploadFile uploadFile =new UploadFile();
        uploadFile.setFileMD5(uploadAddInfo.getFileMD5());
        uploadFile.setFilePath(uploadAddInfo.getFilePath());
        uploadFile.setUploadDate(uploadAddInfo.getUploadDate());

        try {
            save(uploadFile);
            result=uploadFile.getId();
        }catch (Exception e){
            logger.error(e);
        }
        return result;
    }
    //效验图片MD5值
    @Override
    public UploadFile checkUploadFileInfo(String fileMD5) {
        String hql = "from UploadFile where fileMD5=?";
        Object[] params ={fileMD5};
        UploadFile uploadFile =(UploadFile)get(hql,params);
        return uploadFile;
    }
}

⑦实体和工具

package com.zhongqi.ChessMember.entity;

import javax.persistence.*;
import java.util.Date;

/**
 * Created by jordan on 16/10/24.
 * @author 宁春笋
 */
@Entity
@Table(name="uploadFile")
public class UploadFile {


    //主键
    private Integer id;

    // 文件MD5值
    private String fileMD5;

    // 存储路径
    private String filePath;

    //上传日期
    private Date uploadDate;

    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    @Column(name="id", unique = true, nullable = false)
    public Integer getId() {
        return id;
    }

    public void setId(Integer id) {
        this.id = id;
    }
    @Column(name="fileMD5",nullable=true)
    public String getFileMD5() {
        return fileMD5;
    }

    public void setFileMD5(String fileMD5) {
        this.fileMD5 = fileMD5;
    }
    @Column(name="filePath",nullable=true)
    public String getFilePath() {
        return filePath;
    }

    public void setFilePath(String filePath) {
        this.filePath = filePath;
    }

    @Column(name="uploadDate",nullable=true)
    public Date getUploadDate() {
        return uploadDate;
    }

    public void setUploadDate(Date uploadDate) {
        this.uploadDate = uploadDate;
    }
}

UploadAddInfo类

package com.zhongqi.ChessMember.dto;

import java.util.Date;

/**
 * Created by jordan on 16/10/24.
 */
public class UploadAddInfo {
    //主键
    private Integer id;

    // 文件MD5值
    private String fileMD5;

    // 存储路径
    private String filePath;

    //上传日期
    private Date uploadDate;

    public Integer getId() {
        return id;
    }

    public void setId(Integer id) {
        this.id = id;
    }

    public String getFileMD5() {
        return fileMD5;
    }

    public void setFileMD5(String fileMD5) {
        this.fileMD5 = fileMD5;
    }

    public String getFilePath() {
        return filePath;
    }

    public void setFilePath(String filePath) {
        this.filePath = filePath;
    }

    public Date getUploadDate() {
        return uploadDate;
    }

    public void setUploadDate(Date uploadDate) {
        this.uploadDate = uploadDate;
    }
}

以上是上传涉及的全部代码，上传是一个比较经常使用的模块，彻底能够单拉一个站点出来。以便之后服用，阿里云存储安全性也比较高，避免用户数据的丢失。做为一个菜鸟，但愿你们多多支持。2016/11/1