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

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

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

<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版本。

如果mven里面有4.3版本的httpclient 会造成版本冲突，配置之前先检查mven里面的配置。

如果有低版本，应先删除再配置高版本的httpclient。（我因为这个半天都在报错，切记）

②阅读api

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

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

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

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;
}
}

④用到的配置工具类

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