Java中使用RestFul接口上传图片到阿里云OSS服务器

import java.io.IOException;

import javax.servlet.http.HttpServletRequest;

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 com.alibaba.fastjson.JSONObject;
import com.voyage.client.util.ApiResponse;
import com.voyage.client.util.OSSUtil;
import com.voyage.client.util.StringUtil;

@RestController
@RequestMapping("/resource")
public class BasicController {

    /*
     * 图片上传
     */
    @PostMapping("/imgUpload")
    public ApiResponse imgUpload(HttpServletRequest request, @RequestParam("file") MultipartFile file) {

        String url = "";
        if (file != null) {

            String fileName = file.getOriginalFilename();//获取上传原图片名称
            String newFileName = StringUtil.guid() + fileName.substring(fileName.lastIndexOf("."));//生成保存在服务器的图片名称，延用原后缀名
            try {
                OSSUtil.upload(newFileName, file.getInputStream());
                url = newFileName;
            } catch (IOException e) {

                e.printStackTrace();
            }
        }
        JSONObject r = new JSONObject();
        r.put("url", OSSUtil.getUrl(url, ""));
        //r.put("snapshotUrl", OSSUtil.getUrl(url, "?x-oss-process=image/resize,m_fixed,h_200,w_200"));
        return new ApiResponse(r);
    
    }
    
    
}

import com.aliyun.oss.OSSClient;
import com.aliyun.oss.model.ObjectMetadata;
import com.aliyun.oss.model.PutObjectResult;

import java.io.IOException;
import java.io.InputStream;
import java.net.URL;

public class OSSUtil {

    private static String endpoint = "oss-cn-shenzhen.aliyuncs.com";

    private static String accessKeyId = "LT*******3";

    private static String accessKeySecret = "U**************Y4A";

    private static String bucketName = "bucketName";

    private static OSSClient ossClientStatic;

    static {
        ossClientStatic = new OSSClient(endpoint, accessKeyId, accessKeySecret);
    }

    /**
     * 上传到OSS服务器 如果同名文件会覆盖服务器上的
     * 
     * @param fileName 文件名称 包括后缀名
     * @param instream 文件流
     * @return 出错返回"" ,唯一MD5数字签名
     */
    public static String upload(String fileName, InputStream instream) {
        String resultStr = "";
        try {

            // 创建上传Object的Metadata
            ObjectMetadata objectMetadata = new ObjectMetadata();
//            objectMetadata.setContentLength(instream.available());
//            objectMetadata.setCacheControl("no-cache");
//            objectMetadata.setHeader("Pragma", "no-cache");
//            objectMetadata.setContentType(getContentType(fileName.substring(fileName.lastIndexOf("."))));
//            objectMetadata.setContentDisposition("inline;filename=" + fileName);

            // 上传文件 (上传文件流的形式)
            PutObjectResult putResult = ossClientStatic.putObject(bucketName, fileName, instream, objectMetadata);
            // 解析结果
            resultStr = putResult.getETag();
        } catch (Exception e) {
            e.printStackTrace();

        } finally {
            try {
                if (instream != null) {
                    instream.close();
                }
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
        return resultStr;

    }

    /**
     * 上传图片
     *
     * @param url
     */
    public static void uploadUrl(String fileName, String url) {

        try {
            InputStream instream = new URL(url).openStream();
            upload(fileName, instream);
        } catch (Exception e) {
            e.printStackTrace();

        } finally {

        }
    }

    /**
     * 获得url链接
     *
     * @param key
     * @return
     */
    public static String getUrl(String key, String option) {
        if (StringUtil.isBlank(key))
            return "";
        return "http://" + bucketName + "." + endpoint + "/" + key + option;

    }

    public static String getBaseUrl() {

        return "http://" + bucketName + "." + endpoint + "/";
    }
}