fix image

Author: baiyubin2020

src/main/java/com/aliyun/oss/InconsistentException.java

@@ -0,0 +1,85 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+package com.aliyun.oss;
+
+/**
+ * <p>
+ * 表示OSS端的数据与SDK端的数据不一致。
+ * </p>
+ * 
+ * 
+ * <p>
+ * 通常来讲，调用者需要处理{@link InconsistentException}。因为该异常表明请求被服务处理，
+ * 上传操作已经成功，但是OSS端的数据与SDK端不一致。调用者需要上传上传的文件然后重新删除。
+ * </p>
+ * 
+ * <p>
+ * 抛出该异常的操作包括putObject、appendObject、uploadPart、uploadFile等上传操作，
+ * getObject下载操作的数据一致性，调用者需要在数据流读取结束后校验，即比较OSS端与SDK端的数据校验和。
+ * </p>
+ * 
+ */
+public class InconsistentException extends RuntimeException {
+
+	private static final long serialVersionUID = 2140587868503948665L;
+
+	private Long clientChecksum;
+    private Long serverChecksum;
+    private String requestId;
+
+	public InconsistentException(Long clientChecksum, Long serverChecksum, String requestId) {
+		super();
+		this.clientChecksum = clientChecksum;
+		this.serverChecksum = serverChecksum;
+		this.requestId = requestId;
+	}
+    
+	public Long getClientChecksum() {
+		return clientChecksum;
+	}
+
+	public void setClientChecksum(Long clientChecksum) {
+		this.clientChecksum = clientChecksum;
+	}
+
+	public Long getServerChecksum() {
+		return serverChecksum;
+	}
+
+	public void setServerChecksum(Long serverChecksum) {
+		this.serverChecksum = serverChecksum;
+	}
+
+	public String getRequestId() {
+		return requestId;
+	}
+
+	public void setRequestId(String requestId) {
+		this.requestId = requestId;
+	}
+   
+	@Override
+    public String getMessage() {
+		return "InconsistentException " + "\n[RequestId]: " + getRequestId()
+        + "\n[ClientChecksum]: " + getClientChecksum()
+        + "\n[ServerChecksum]: " + getServerChecksum();
+    }
+	
+}

src/samples/CRCSample.java

@@ -0,0 +1,96 @@
+package samples;
+
+import java.io.File;
+import java.io.IOException;
+
+import com.aliyun.oss.ClientException;
+import com.aliyun.oss.OSSClient;
+import com.aliyun.oss.OSSException;
+import com.aliyun.oss.model.GetObjectRequest;
+
+/**
+ * 断点续传下载用法示例
+ *
+ */
+public class ImageSample {
+    
+    private static String endpoint = "<endpoint, http://oss-cn-hangzhou.aliyuncs.com>";
+    private static String accessKeyId = "<accessKeyId>";
+    private static String accessKeySecret = "<accessKeySecret>";
+    private static String bucketName = "<bucketName>";
+    private static String key = "example.jpg";
+    
+    
+    public static void main(String[] args) throws IOException {        
+
+        OSSClient ossClient = new OSSClient(endpoint, accessKeyId, accessKeySecret);
+        
+        try {
+            // 缩放
+            String style = "image/resize,m_fixed,w_100,h_100";  
+            GetObjectRequest request = new GetObjectRequest(bucketName, key);
+            request.setProcess(style);
+            
+            ossClient.getObject(request, new File("example-resize.jpg"));
+            
+            // 裁剪
+            style = "image/crop,w_100,h_100,x_100,y_100,r_1"; 
+            request = new GetObjectRequest(bucketName, key);
+            request.setProcess(style);
+            
+            ossClient.getObject(request, new File("example-crop.jpg"));
+            
+            // 旋转
+            style = "image/rotate,90"; 
+            request = new GetObjectRequest(bucketName, key);
+            request.setProcess(style);
+            
+            ossClient.getObject(request, new File("example-rotate.jpg"));
+            
+            // 锐化
+            style = "image/sharpen,100"; 
+            request = new GetObjectRequest(bucketName, key);
+            request.setProcess(style);
+            
+            ossClient.getObject(request, new File("example-sharpen.jpg"));
+            
+            // 水印
+            style = "image/watermark,text_SGVsbG8g5Zu-54mH5pyN5YqhIQ"; 
+            request = new GetObjectRequest(bucketName, key);
+            request.setProcess(style);
+            
+            ossClient.getObject(request, new File("example-watermark.jpg"));
+            
+            // 格式转换
+            style = "image/format,png"; 
+            request = new GetObjectRequest(bucketName, key);
+            request.setProcess(style);
+            
+            ossClient.getObject(request, new File("example-format.png"));
+            
+            // 图片信息
+            style = "image/info"; 
+            request = new GetObjectRequest(bucketName, key);
+            request.setProcess(style);
+            
+            ossClient.getObject(request, new File("example-info.txt"));
+            
+        } catch (OSSException oe) {
+            System.out.println("Caught an OSSException, which means your request made it to OSS, "
+                    + "but was rejected with an error response for some reason.");
+            System.out.println("Error Message: " + oe.getErrorCode());
+            System.out.println("Error Code:       " + oe.getErrorCode());
+            System.out.println("Request ID:      " + oe.getRequestId());
+            System.out.println("Host ID:           " + oe.getHostId());
+        } catch (ClientException ce) {
+            System.out.println("Caught an ClientException, which means the client encountered "
+                    + "a serious internal problem while trying to communicate with OSS, "
+                    + "such as not being able to access the network.");
+            System.out.println("Error Message: " + ce.getMessage());
+        } catch (Throwable e) {
+            e.printStackTrace();
+        } finally {
+            ossClient.shutdown();
+        }
+    }
+}