java接受安卓及ios App上传的图片，并保存到阿里OSS

做后台的时候，写了两个方法，分别用来获取安卓和苹果IOS端上传的头像，保存到阿里云OSS图片存储服务器上。（SMM框架）

安卓及H5版本：

 /**
     * 上传用户头像
     */
    @RequestMapping("/uploadPhoto")
    public R uploadPhoto(@RequestParam("imgFile") MultipartFile imgFile, HttpServletRequest req) throws Exception {
        if (imgFile.isEmpty()) {
            throw new RRException("上传文件不能为空");
        }
        
        Integer uid = WebUtils.getUid(req);
        WfMemberEntity member = memberService.queryObject(uid);
        
        String newsUrl = "";
        if (!((MultipartFile) imgFile).isEmpty()) {
            try {
                newsUrl = OSSUtil.addFile(imgFile, "head", Constants.IGM_BUCKET);
                
            } catch (IOException e) {
                e.printStackTrace();
            }
        }else {
            return R.error("上传图片不可为空");
        }
        if(member.getHeadimage() == null) {
             member.setHeadimage(newsUrl);
             member.setThumbimg(newsUrl);
             memberService.update(member);
        }else {
            // 删除原来图片
            OSSUtil.delete(member.getHeadimage(), Constants.IGM_BUCKET);
            member.setHeadimage(newsUrl);
            member.setThumbimg(newsUrl);
            memberService.update(member);
        }
        System.out.println("*************************************头像路径： "+newsUrl+"***************************************");
        return R.ok().put("url", newsUrl);
    }

对应的苹果图片上传版本：

 @RequestMapping("/iosUpload")  
   public R iosUpload(HttpServletRequest req){  
        
        Integer uid = WebUtils.getUid(req);
        WfMemberEntity member = memberService.queryObject(uid);
        
        String image = req.getParameter("image");
          // 将base64 转 字节数组
        Base64 base = new Base64();
        byte[] decode = base.decode(image);

        // 定义图片输入流
        InputStream fin = new ByteArrayInputStream(decode);
        
        String newsUrl = "";
        try {
            newsUrl = OSSUtil.putFile(fin, "head", Constants.IGM_BUCKET);
        } catch (IOException e) {
            e.printStackTrace();
        }
        if(member.getHeadimage() == null) {
             member.setHeadimage(newsUrl);
             member.setThumbimg(newsUrl);
             memberService.update(member);
        }else {
            // 删除原来图片
            OSSUtil.delete(member.getHeadimage(), Constants.IGM_BUCKET);
            member.setHeadimage(newsUrl);
            member.setThumbimg(newsUrl);
            memberService.update(member);
        }
        System.out.println("*************************************头像路径： "+newsUrl+"***************************************");
        return R.ok().put("url", newsUrl);
    }

对应的OSS上传工具：

package com.wfcm.utils;

import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.io.InputStream;
import java.util.ArrayList;
import java.util.List;

import org.springframework.web.multipart.MultipartFile;
import org.springframework.web.multipart.commons.CommonsMultipartFile;

import com.aliyun.oss.OSSClient;
import com.aliyun.oss.model.ListObjectsRequest;
import com.aliyun.oss.model.OSSObject;
import com.aliyun.oss.model.OSSObjectSummary;
import com.aliyun.oss.model.ObjectListing;
import com.aliyun.oss.model.ObjectMetadata;
import com.wfcm.utils.UUIDGenerator;


/**
 * 阿里云分布式存储工具类
 * @author lyinlong
 *
 */
public class OSSUtil {

    //初始化client
    static OSSClient client = new OSSClient(Constants.OSS_ENDPOINT,Constants.OSS_ACCESS_ID, Constants.OSS_ACCESS_KEY);

    /**
     * 获取指定文件夹下的文件列表
     * @param folderName 文件夹名称(如果获取当前所有, 空字符串)
     * @return 文件的所有key
     * @throws IOException
     */
    public static List<String> listBybucket(String bucketName ,String folderName) throws IOException{
        // 构造ListObjectsRequest请求
        ListObjectsRequest listObjectsRequest = new ListObjectsRequest(bucketName);

        // 递归列出fun目录下的所有文件
        listObjectsRequest.setPrefix(folderName);

        ObjectListing listing = client.listObjects(listObjectsRequest);

        List<String> keys = new ArrayList<>();

        // 遍历所有Object
        for (OSSObjectSummary objectSummary : listing.getObjectSummaries()) {
            keys.add(objectSummary.getKey());
        }
        return keys;
    }

    /**
     * 通过key获取指定的Object
     * @param key
     * @return
     */
    public static InputStream getObject(String bucketName, String key){
        OSSObject object = client.getObject(bucketName, key);
        InputStream objectContent = object.getObjectContent();

        return objectContent;
    }

    /**
     * 添加一个文件到指定文件夹
     * @param file
     * @param folder
     * @return 该文件的Key(文件的唯一标识)
     * @throws FileNotFoundException
     */
    public static String putObject(File file , String folder , String bucketName) throws FileNotFoundException{
         // 获取指定文件的输入流
        InputStream content = new FileInputStream(file);

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

        // 必须设置ContentLength
        meta.setContentLength(file.length());

        String uuid = UUIDGenerator.getUUID(false);

        client.putObject(bucketName, folder+"/"+uuid, content, meta);

        return uuid;
    }

    public static String putFile(InputStream content  , String folder , String bucketName) throws FileNotFoundException{
         // 获取指定文件的输入流
        //InputStream content = new FileInputStream(file);

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

        // 必须设置ContentLength
        try {
            meta.setContentLength(content.available());
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }

        String uuid = UUIDGenerator.getUUID(false);
        client.putObject(bucketName, folder+"/"+uuid+".jpg", content, meta);

        return folder+"/"+uuid+".jpg";
    }
    
    public static String addFile(Object file , String folder , String bucketName) throws IOException{
         InputStream content  = null;
         ObjectMetadata meta = null;
         String  extension = "";
        if(file!=null){
            if(file instanceof CommonsMultipartFile){
                CommonsMultipartFile file1  = (CommonsMultipartFile)file;
                //文件扩展名
                 String fileName = file1.getOriginalFilename();
                 if(fileName.lastIndexOf(".")!=-1){
                     extension = fileName.substring(fileName.lastIndexOf("."),fileName.length());
                 }
                 
                // 获取指定文件的输入流
                  content =file1.getInputStream();
                    // 创建上传Object的Metadata
                   meta = new ObjectMetadata();
                    // 必须设置ContentLength
                    meta.setContentLength(file1.getSize());
                  // 设置content type  
                    String strContentType = file1.getContentType();  
                    meta.setContentType(strContentType);  
            }
            else if(file instanceof MultipartFile){
                MultipartFile    file2 = (MultipartFile)file;
                 String fileName = file2.getOriginalFilename();
                 if(fileName.lastIndexOf(".")!=-1){
                     extension = fileName.substring(fileName.lastIndexOf("."),fileName.length());
                 }
                // 获取指定文件的输入流
                  content =file2.getInputStream();
                    // 创建上传Object的Metadata
                   meta = new ObjectMetadata();
                    // 必须设置ContentLength
                    meta.setContentLength(file2.getSize());
            }
            else if(file instanceof File){
                File file3 = (File)file;
                //文件扩展名
                 String fileName = file3.getName();
                 if(fileName.lastIndexOf(".")!=-1){
                     extension = fileName.substring(fileName.lastIndexOf("."),fileName.length());
                 }
                
                // 获取指定文件的输入流
                  content =new FileInputStream(file3);
                    // 创建上传Object的Metadata
                  meta = new ObjectMetadata();
                    // 必须设置ContentLength
                  meta.setContentLength(file3.length());
            }
            else {
                return null;
            }
        }
        String uuid = UUIDGenerator.getUUID(false);

        client.putObject(bucketName, folder+"/"+uuid+extension, content, meta);

        return folder+"/"+uuid+extension;
    }
    
    /**
     * 删除指定的文件
     * @param key
     */
    public static void delete(String key,String bucketName){

        client.deleteObject(bucketName, key);
    }

    /**
     * 新建文件桶
     * @param bucketName
     */
    public static void createBucket(String bucketName){
        client.createBucket(bucketName);
    }

}