图片上传

whole-estate/pom.xml

@@ -48,6 +48,11 @@
             <!--<version>2.1.3.RELEASE</version>-->
         <!--</dependency>-->
 
+        <dependency>
+            <groupId>com.aliyun.oss</groupId>
+            <artifactId>aliyun-sdk-oss</artifactId>
+            <version>2.8.3</version>
+        </dependency>
 
         <!-- 测试 -->
         <dependency>

whole-estate/src/main/java/com/example/wholeestate/controller/ImageController.java

@@ -0,0 +1,75 @@
+package com.example.wholeestate.controller;
+
+import com.example.wholeestate.common.base.BaseController;
+import com.example.wholeestate.common.resp.ResponseBean;
+import com.example.wholeestate.service.ImageService;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import io.swagger.annotations.ApiParam;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.multipart.MultipartFile;
+import sun.misc.BASE64Decoder;
+
+import javax.sql.rowset.serial.SerialBlob;
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * @author weichaochao
+ * @Title: ImageController
+ * @Description: 图片上传以及获取url
+ * @date 2018/10/31
+ */
+@RestController
+@RequestMapping("/")
+@Api(value = "图片操作API", description = "图片操作API")
+public class ImageController extends BaseController {
+
+    @Autowired
+    private ImageService imageService;
+
+    @ApiOperation(value = "图片上传以及获取url", notes = "图片上传以及获取url")
+    @PostMapping(value = "/uploadimage", consumes = "multipart/*", headers = "content-type=multipart/form-data")
+    public ResponseBean uploadImgAndGetUrl(@ApiParam(value = "uploadFiles" ,required = true) MultipartFile[] uploadFiles) throws Exception {
+        ResponseBean responseBean = new ResponseBean();
+        List<String> urls = new ArrayList<String>();
+        for (MultipartFile uploadFile : uploadFiles){
+            String url = imageService.getImageUrl(uploadFile);
+            urls.add(url);
+        }
+        responseBean.addSuccess(urls);
+        return responseBean;
+    }
+
+    @ApiOperation(value = "图片上传以及获取url", notes = "图片上传以及获取url")
+    @PostMapping(value = "/uploadimageBase64")
+    public ResponseBean uploadImgBase64AndGetUrl(@ApiParam(value = "uploadFiles" ,required = true) String uploadFiles) throws Exception {
+        ResponseBean responseBean = new ResponseBean();
+        List<String> urls = new ArrayList<String>();
+        // int index = uploadFiles.indexOf("data:image/jpeg;base64,");
+        //uploadFiles = uploadFiles.substring(23);
+        String[] split = uploadFiles.split("base64,");
+        SerialBlob serialBlob = null;
+        if (split.length > 1) {
+            serialBlob = decodeToImage(split[1]);
+        } else {
+            serialBlob = decodeToImage(split[0]);
+        }
+
+        String url = imageService.getImageUrl(serialBlob.getBinaryStream());
+        urls.add(url);
+        responseBean.addSuccess(urls);
+        return responseBean;
+    }
+
+    public static SerialBlob decodeToImage(String imageString) throws Exception {
+        BASE64Decoder decoder = new BASE64Decoder();
+        byte[] imageByte = decoder.decodeBuffer(imageString);
+        return new SerialBlob(imageByte);
+    }
+
+
+}

whole-estate/src/main/java/com/example/wholeestate/service/ImageService.java

@@ -0,0 +1,24 @@
+package com.example.wholeestate.service;
+
+import org.springframework.web.multipart.MultipartFile;
+
+import java.io.IOException;
+import java.io.InputStream;
+
+/**
+ * @author admin
+ * @Title: ImageService
+ * @Description: TODO
+ * @date 2018/11/5
+ */
+public interface ImageService {
+    String getImageUrl(MultipartFile uploadFile) throws IOException;
+
+    /**
+     * 二进制方式 上传 阿里云
+     * @param uploadFile
+     * @return
+     * @throws IOException
+     */
+    String getImageUrl(InputStream uploadFile) throws IOException;
+}

whole-estate/src/main/java/com/example/wholeestate/service/impl/ImageServiceimpl.java

@@ -0,0 +1,68 @@
+package com.example.wholeestate.service.impl;
+
+import com.aliyun.oss.OSSClient;
+import com.example.wholeestate.service.ImageService;
+import org.springframework.stereotype.Service;
+import org.springframework.web.multipart.MultipartFile;
+
+import java.io.ByteArrayInputStream;
+import java.io.IOException;
+import java.io.InputStream;
+import java.util.Date;
+
+/**
+ * @author weichaochao
+ * @Title: ImageServiceimpl
+ * @Description: 获取图片地址实现类
+ * @date 2018/11/5
+ */
+@Service("ImageService")
+public class ImageServiceimpl implements ImageService {
+
+    private static String endpoint = "http://oss-cn-shanghai.aliyuncs.com";
+    private static String accessKeyId = "LTAIkc75dpkJw8Lb";
+    private static String accessKeySecret = "v4bvXCaix6vSDTCFfwSAdqV53iFEQw";
+    private static String bucketName = "jingcheng-h5temp";
+
+    @Override
+    public String getImageUrl(MultipartFile uploadFile) throws IOException {
+
+        String imgName = System.currentTimeMillis() + ".png";
+        // 创建OSSClient实例
+        OSSClient ossClient = new OSSClient(endpoint, accessKeyId, accessKeySecret);
+        // 上传
+        long time = System.currentTimeMillis();
+
+        ossClient.putObject(bucketName, imgName, new ByteArrayInputStream(uploadFile.getBytes()));
+
+        // 关闭client
+        ossClient.shutdown();
+        Date expiration = new Date(time + 3600 * 1000 * 24 * 365 * 10);
+        String url = ossClient.generatePresignedUrl(bucketName, imgName, expiration).toString();
+
+        // 截取掉签名
+        url = url.substring(0, url.lastIndexOf("&Signature"));
+        return url;
+    }
+
+    @Override
+    public String getImageUrl(InputStream uploadFile) throws IOException {
+
+        String imgName = System.currentTimeMillis() + ".png";
+        // 创建OSSClient实例
+        OSSClient ossClient = new OSSClient(endpoint, accessKeyId, accessKeySecret);
+        // 上传
+        long time = System.currentTimeMillis();
+
+        ossClient.putObject(bucketName, imgName, uploadFile);
+
+        // 关闭client
+        ossClient.shutdown();
+        Date expiration = new Date(time + 3600 * 1000 * 24 * 365 * 10);
+        String url = ossClient.generatePresignedUrl(bucketName, imgName, expiration).toString();
+
+        // 截取掉签名
+        url = url.substring(0, url.lastIndexOf("&Signature"));
+        return url;
+    }
+}