技术标签: 文件存储 工具 青云Cloud文件存储-OSS
package com.hswg.jstxb.issued.api.controller;/**
* Created by TongGuoBo on 2019/6/14.
*/
import com.google.gson.Gson;
import com.qingstor.sdk.constants.QSConstant;
import com.qingstor.sdk.exception.QSException;
import com.qingstor.sdk.model.OutputModel;
import com.qingstor.sdk.service.Bucket;
import com.qingstor.sdk.service.QingStor;
import com.qingstor.sdk.service.Types;
import com.qingstor.sdk.upload.UploadManager;
import com.qingstor.sdk.upload.UploadManagerCallback;
import java.io.*;
import java.nio.file.Files;
import java.nio.file.Paths;
import java.util.ArrayList;
import java.util.List;
/**
* @ClassName Examples
* @Description TODO
* @Author TongGuoBo
* @Date 2019/6/14 8:55
**/
public class Examples {
private static final String ACCESS_KEY = "your_access_key";
private static final String ACCESS_SECRET = "your_access_secret";
public static final String PROTOCOL = "https";
public static final String HOST = "qingstor.com";
public static void main(String... args) {
Examples examples = new Examples();
EnvContext context = new EnvContext(ACCESS_KEY, ACCESS_SECRET);
context.setProtocol(PROTOCOL);
context.setHost(HOST);
context.setRequestUrlStyle(QSConstant.PATH_STYLE);
String zoneKey = "pek3b";
String bucketName = "test-in-2018-08-08-by-chengww";
Bucket bucket = new Bucket(context, zoneKey, bucketName);
examples.testAll(bucket, bucketName);
}
public void testAll(Bucket bucket, String bucketName) {
long start = System.currentTimeMillis();
try {
// Create a new Bucket
Bucket.PutBucketOutput output = bucket.put();
if (output.getStatueCode() == 201) {
System.out.println("Put Bucket OK");
headBucket(bucket);
putBucketACL(bucket);
getBucketACL(bucket);
putBucketPolicy(bucket, bucketName);
getBucketPolicy(bucket);
deleteBucketPolicy(bucket);
putBucketCORS(bucket);
getBucketCORS(bucket);
deleteBucketCORS(bucket);
putBucketExternalMirror(bucket);
getBucketExternalMirror(bucket);
deleteBucketExternalMirror(bucket);
putBucketNotification(bucket);
getBucketNotification(bucket);
deleteBucketNotification(bucket);
putBucketLifecycle(bucket);
getBucketLifecycle(bucket);
deleteBucketLifecycle(bucket);
String uploadFileName = "pek1.zip";
try {
putObject(bucket, "folder/" + uploadFileName, "/Users/chengww/Downloads/vpn/" + uploadFileName);
} catch (FileNotFoundException e) {
e.printStackTrace();
}
String multiPartUploadFileName = "pub-qingstor-sdk-java.zip";
String filePath = "/Users/chengww/Downloads/backup/pub-qingstor-sdk-java.zip";
putObjectAuto(bucket, filePath);
getObject(bucket, "folder/" + uploadFileName, "/Users/chengww/Desktop/test.zip");
putObjectCopy(bucket, "/" + bucketName + "/folder/" + uploadFileName, "folder-copied/" + uploadFileName);
putObjectMove(bucket, "/" + bucketName + "/folder/" + uploadFileName, "folder-moved/" + uploadFileName);
putObjectFetch(bucket, "https://www.qingcloud.com/static/assets/images/icons/common/footer_logo.svg", "folder-fetched/qingcloud_footer_logo.svg");
headObject(bucket, "folder-copied/" + uploadFileName);
optionsObject(bucket, "folder-copied/" + uploadFileName);
listObjects(bucket, null, null);
listMultipartUploads(bucket);
getBucketStatistics(bucket);
deleteObject(bucket, "folder-copied/" + uploadFileName);
List<String> objectKeys = new ArrayList<>();
objectKeys.add(multiPartUploadFileName);
objectKeys.add("folder-moved/" + uploadFileName);
objectKeys.add("folder-fetched/qingcloud_footer_logo.svg");
deleteMultpieObjects(bucket, objectKeys);
deleteBucket(bucket);
} else {
handleError(output);
}
} catch (QSException e) {
e.printStackTrace();
}
System.out.println("End: Time = " + (System.currentTimeMillis() - start) + " ms");
}
/**
* Delete Multpie Objects once
*
* @param bucket bucket
* @param objectKeys a string list of the objectKey
* objectKey looks like this: "folder/fileName".<br/>
* If objectKey = "fileName", means the object is in the bucket's root folder.
* @throws QSException exception will be thrown if (objectKeys == null || objectKeys.size() < 1)
*/
public void deleteMultpieObjects(Bucket bucket, List<String> objectKeys) throws QSException {
if (objectKeys == null || objectKeys.size() < 1) {
throw new QSException("ObjectKeys list must contains at least one key.");
}
Bucket.DeleteMultipleObjectsInput deleteInput = new Bucket.DeleteMultipleObjectsInput();
List<Types.KeyModel> keyList = new ArrayList<>();
for (String key : objectKeys) {
Types.KeyModel keyModel = new Types.KeyModel();
keyModel.setKey(key);
keyList.add(keyModel);
}
deleteInput.setObjects(keyList);
Bucket.DeleteMultipleObjectsOutput output = bucket.deleteMultipleObjects(deleteInput);
if (output.getStatueCode() == 200 || output.getStatueCode() == 204) {
// Deleted
System.out.println("Delete Multpie Objects: Deleted.");
System.out.println("Delete Multpie Objects: Keys = \n" + new Gson().toJson(keyList));
} else {
// Failed
System.out.println("Failed to delete multpie objects.");
handleError(output);
}
}
/**
* Delete Object
*
* @param bucket bucket
* @param objectKey looks like this: "folder/fileName".<br/>
* If objectKey = "fileName", means the object is in the bucket's root folder.
*/
public void deleteObject(Bucket bucket, String objectKey) {
try {
Bucket.DeleteObjectOutput output = bucket.deleteObject(objectKey);
if (output.getStatueCode() == 204) {
// Deleted
System.out.println("Delete Object: Deleted. ");
System.out.println("Delete Object: Object key = " + objectKey);
} else {
// Failed
System.out.println("Failed to delete " + objectKey);
System.out.println("StatueCode = " + output.getStatueCode());
System.out.println("Message = " + output.getMessage());
System.out.println("RequestId = " + output.getRequestId());
System.out.println("Code = " + output.getCode());
System.out.println("Url = " + output.getUrl());
}
} catch (QSException e) {
e.printStackTrace();
}
}
/**
* Head Object
*
* @param bucket bucket
* @param objectKey looks like this: "folder/fileName".<br/>
* If objectKey = "fileName", means the object is in the bucket's root folder.
*/
public void headObject(Bucket bucket, String objectKey) {
try {
Bucket.HeadObjectInput input = new Bucket.HeadObjectInput();
Bucket.HeadObjectOutput output = bucket.headObject(objectKey, input);
if (output.getStatueCode() == 200) {
System.out.println("Head Object success.");
System.out.println("ObjectKey = " + objectKey);
System.out.println("ContentLength = " + output.getContentLength());
System.out.println("ContentType = " + output.getContentType());
System.out.println("ETag = " + output.getETag());
System.out.println("LastModified = " + output.getLastModified());
System.out.println("XQSEncryptionCustomerAlgorithm = " + output.getXQSEncryptionCustomerAlgorithm());
System.out.println("XQSStorageClass = " + output.getXQSStorageClass());
} else {
// Failed
System.out.println("Head Object failed.");
System.out.println("ObjectKey = " + objectKey);
handleError(output);
}
} catch (QSException e) {
e.printStackTrace();
}
}
/**
* Get(Download) an object from the bucket.
*
* @param bucket bucket
* @param objectKey looks like this: "folder/fileName".<br/>
* If objectKey = "fileName", means the object is in the bucket's root folder.
* @param localKeptPath the object will be kept in this path.
*/
public void getObject(Bucket bucket, String objectKey, String localKeptPath) {
try {
Bucket.GetObjectInput input = new Bucket.GetObjectInput();
Bucket.GetObjectOutput output = bucket.getObject(objectKey, input);
InputStream inputStream = output.getBodyInputStream();
if (output.getStatueCode() == 200) {
if (inputStream != null) {
FileOutputStream fos = new FileOutputStream(localKeptPath);
int len;
byte[] bytes = new byte[4096];
while ((len = inputStream.read(bytes)) != -1) {
fos.write(bytes, 0, len);
}
fos.flush();
fos.close();
System.out.println("Get object success.");
System.out.println("ObjectKey = " + objectKey);
System.out.println("LocalKeptPath = " + localKeptPath);
} else {
System.out.println("Get object status code == 200, but inputStream is null, skipped.");
}
} else {
// Failed
System.out.println("Failed to get object.");
handleError(output);
}
if (inputStream != null) inputStream.close();
} catch (QSException | IOException e) {
e.printStackTrace();
}
}
public void putObjectMove(Bucket bucket, String moveSource, String newObjectKey) {
try {
Bucket.PutObjectInput input = new Bucket.PutObjectInput();
input.setXQSMoveSource(moveSource); // MoveSource looks like this: "/bucketName/folder/fileName"
Bucket.PutObjectOutput output = bucket.putObject(newObjectKey, input); // NewObjectKey looks like this: "folder-moved/fileName"
if (output.getStatueCode() == 201) {
// Created
System.out.println("Put Object Move: Moved.");
System.out.println("From " + moveSource + " to " + newObjectKey);
} else {
// Failed
System.out.println("Put Object Move: Failed to move.");
System.out.println("From " + moveSource + " to " + newObjectKey);
handleError(output);
}
} catch (QSException e) {
e.printStackTrace();
}
}
public void putObjectCopy(Bucket bucket, String copySource, String newObjectKey) {
try {
Bucket.PutObjectInput input = new Bucket.PutObjectInput();
input.setXQSCopySource(copySource); // CopySource looks like this: "/bucketName/folder/fileName"
Bucket.PutObjectOutput output = bucket.putObject(newObjectKey, input); // NewObjectKey looks like this: "folder-copied/fileName"
if (output.getStatueCode() == 201) {
// Created
System.out.println("Put Object Copy: Copied.");
System.out.println("From " + copySource + " to " + newObjectKey);
} else {
// Failed
System.out.println("Put Object Copy: Failed to copy.");
System.out.println("From " + copySource + " to " + newObjectKey);
handleError(output);
}
} catch (QSException e) {
e.printStackTrace();
}
}
public void putObjectFetch(Bucket bucket, String fetchSource, String newObjectKey) {
try {
Bucket.PutObjectInput input = new Bucket.PutObjectInput();
input.setXQSFetchSource(fetchSource); // Fetch source looks like this: "protocol://host[:port]/[path]"
Bucket.PutObjectOutput output = bucket.putObject(newObjectKey, input); // NewObjectKey looks like this: "folder-fetched/fileName"
if (output.getStatueCode() == 201) {
// Success
System.out.println("Put Object - Fetch success.");
System.out.println("From " + fetchSource + " to " + newObjectKey);
} else {
// Failed
System.out.println("Put Object - Fetch failed.");
System.out.println("From " + fetchSource + " to " + newObjectKey);
handleError(output);
}
} catch (QSException e) {
e.printStackTrace();
}
}
/**
* Put a file to the bucket.
*
* @param bucket bucket
* @param objectKey looks like this: "folder/fileName".<br/>
* If objectKey = "fileName", we will put the object into the bucket's root.
* @param filePath local file path
* @throws FileNotFoundException if file does not exist, the exception will occurred.
*/
public void putObject(Bucket bucket, String objectKey, String filePath) throws FileNotFoundException {
File file = new File(filePath);
if (!file.exists() || file.isDirectory())
throw new FileNotFoundException("File does not exist or it is a directory.");
Bucket.PutObjectInput input = new Bucket.PutObjectInput();
// Using the JDK1.7 self-bringing method to get content type(Requires JDK 1.7+, linux requires GLib.)
try {
String contentType = Files.probeContentType(Paths.get(filePath));
input.setContentType(contentType);
System.out.println("Put Object: ContentType = " + contentType);
} catch (IOException e) {
e.printStackTrace();
System.out.println("Put Object: Get file's content type error.");
}
input.setContentLength(file.length());
input.setBodyInputFile(file);
try {
Bucket.PutObjectOutput output = bucket.putObject(objectKey, input);
if (output.getStatueCode() == 201) {
System.out.println("PUT Object OK.");
System.out.println("key = " + objectKey);
System.out.println("path = " + filePath);
} else {
// Failed
System.out.println("Failed to PUT object.");
System.out.println("key = " + objectKey);
handleError(output);
}
} catch (QSException e) {
e.printStackTrace();
}
}
public void putObjectAuto(Bucket bucket, String filePath) {
UploadManager uploadManager = new UploadManager(bucket, null, new UploadProgressListener() {
@Override
public void onProgress(String objectKey, long currentSize, long totalSize) {
float progress = (float) currentSize * 100 / totalSize;
System.out.println(objectKey + ": uploading = " + String.format("%.2f", progress) + " %");
}
}, null, new UploadManagerCallback() {
@Override
public void onAPIResponse(String objectKey, OutputModel output) {
if (output.getStatueCode() == 200 || output.getStatueCode() == 201) {
System.out.println("Upload success.");
} else if (output.getStatueCode() == QSConstant.REQUEST_ERROR_CANCELLED) {
System.out.println("Stopped.");
} else {
handleError(output);
}
}
});
try {
uploadManager.put(new File(filePath));
} catch (QSException e) {
e.printStackTrace();
}
}
public void putBucketACL(Bucket bucket) {
try {
Bucket.PutBucketACLInput input = new Bucket.PutBucketACLInput();
Types.ACLModel acl = new Types.ACLModel();
acl.setPermission("FULL_CONTROL");
Types.GranteeModel gm = new Types.GranteeModel();
gm.setName("QS_ALL_USERS");
gm.setType("group");
acl.setGrantee(gm);
List<Types.ACLModel> lstACL = new ArrayList<>();
lstACL.add(acl);
input.setACL(lstACL);
Bucket.PutBucketACLOutput output = bucket.putACL(input);
if (output.getStatueCode() == 200) {
System.out.println("Put bucket ACL OK.");
} else {
// Failed
System.out.println("Failed to put bucket ACL.");
handleError(output);
}
} catch (QSException e) {
e.printStackTrace();
}
}
/**
* List objects start with prefix(folderName), after a object named marker. Limit up to 100 data.
* 列取所有前缀为 prefix(folderName) ,在 marker 之后的对象。每次最多 100 条数据。
* @param bucket bucket
* @param prefix prefix(folderName)
* @param marker View the data on the next page. The marker is the value of next_marker returned by the last Response
* 查看下一页的数据。marker 为上一次 Response 返回的 next_marker 的值
* @return next_marker
*/
public String listObjects(Bucket bucket, String prefix, String marker) {
Bucket.ListObjectsInput input = new Bucket.ListObjectsInput();
if (null != prefix && !"".equals(prefix)) {
// Only show objects name start with 'prefix'
input.setPrefix(prefix);
}
if (null != marker && !"".equals(marker)) {
// Sort by name after a object named marker
input.setMarker(marker);
}
input.setDelimiter("/");
input.setLimit(100); // Default 200, max 1000
try {
Bucket.ListObjectsOutput output = bucket.listObjects(input);
if (output.getStatueCode() == 200) {
// Success
System.out.println("List Objects success.");
System.out.println("=======List Objects:Folders======");
List<String> commonPrefixes = output.getCommonPrefixes();
for (String folderName : commonPrefixes) {
System.out.println("folderName = " + folderName);
}
System.out.println("=======List Objects:Files======");
List<Types.KeyModel> keys = output.getKeys();
if (keys != null && keys.size() > 0) {
System.out.println("keys = " + new Gson().toJson(keys));
}
System.out.println("=============");
return output.getNextMarker();
} else {
// Failed
System.out.println("List Objects failed.");
handleError(output);
}
} catch (QSException e) {
// NetWork exception
e.printStackTrace();
}
return null;
}
public void getBucketACL(Bucket bucket) {
try {
Bucket.GetBucketACLOutput output = bucket.getACL();
if (output.getStatueCode() == 200) {
// Success
Types.OwnerModel owner = output.getOwner();
if (owner != null) {
System.out.println("owner = {'name': " + owner.getName() + ", 'ID': " + owner.getID() + "}");
} else {
System.out.println("owner = null");
}
System.out.println("=======Get Bucket ACL======");
List<Types.ACLModel> acls = output.getACL();
if (acls != null && acls.size() > 0) {
System.out.println("ACLs = " + new Gson().toJson(acls));
} else {
System.out.println("ACLs is empty.");
}
System.out.println("=============");
} else {
// Failed
System.out.println("Failed to Get Bucket ACL.");
handleError(output);
}
} catch (QSException e) {
e.printStackTrace();
}
}
public void listMultipartUploads(Bucket bucket) {
try {
Bucket.ListMultipartUploadsInput input = new Bucket.ListMultipartUploadsInput();
// See Request Parameters to set input
Bucket.ListMultipartUploadsOutput output = bucket.listMultipartUploads(input);
if (output.getStatueCode() == 200) {
// Success
System.out.println("=======List Multipart Uploads======");
System.out.println("Name = " + output.getName());
List<Types.UploadsModel> uploads = output.getUploads();
if (uploads != null && uploads.size() > 0) {
System.out.println("Uploads = " + new Gson().toJson(uploads));
} else {
System.out.println("Uploads is empty.");
}
System.out.println("=============");
} else {
// Failed
System.out.println("Failed to List Multipart Uploads.");
handleError(output);
}
} catch (QSException e) {
e.printStackTrace();
}
}
public void getBucketStatistics(Bucket bucket) {
try {
Bucket.GetBucketStatisticsOutput output = bucket.getStatistics();
if (output.getStatueCode() == 200) {
// Success
System.out.println("Get Bucket Statistics success.");
System.out.println("Name = " + output.getName());
System.out.println("Created = " + output.getCreated());
System.out.println("Location = " + output.getLocation());
System.out.println("Status = " + output.getStatus());
System.out.println("URL = " + output.getURL()); // The method is different of output.getUrl().
System.out.println("Count = " + output.getCount());
System.out.println("Size = " + output.getSize());
} else {
// Failed
System.out.println("Failed to Get Bucket Statistics.");
handleError(output);
}
} catch (QSException e) {
e.printStackTrace();
}
}
public void headBucket(Bucket bucket) {
try {
Bucket.HeadBucketOutput output = bucket.head();
if (output.getStatueCode() == 200) {
System.out.println("Head Bucket success.");
// You can print http headers/parameters you defined here.
// See [Get/Set HTTP Headers/Parameters Of A Request](./get_set_http_headers.md)
System.out.println("You can access the Bucket.");
System.out.println("You can print http headers/parameters you defined here.");
} else {
// Failed
System.out.println("Head Bucket: You cannot access the Bucket or it does not exist.");
handleError(output);
}
} catch (QSException e) {
e.printStackTrace();
}
}
public void deleteBucket(Bucket bucket) {
try {
Bucket.DeleteBucketOutput output = bucket.delete();
if (output.getStatueCode() == 204) {
// Deleted
System.out.println("Delete Bucket: Deleted.");
} else {
// Failed
System.out.println("Failed to Delete Bucket.");
handleError(output);
}
} catch (QSException e) {
e.printStackTrace();
}
}
public void putBucket(Bucket bucket) {
try {
Bucket.PutBucketOutput output = bucket.put();
if (output.getStatueCode() == 201) {
// Created
System.out.println("Put Bucket: Created.");
} else {
// Failed
System.out.println("Failed to Put Bucket.");
handleError(output);
}
} catch (QSException e) {
e.printStackTrace();
}
}
public void deleteBucketPolicy(Bucket bucket) {
try {
Bucket.DeleteBucketPolicyOutput output = bucket.deletePolicy();
if (output.getStatueCode() == 204) {
System.out.println("The policy of bucket deleted.");
} else {
// Failed
System.out.println("Failed to delete bucket policy.");
handleError(output);
}
} catch (QSException e) {
e.printStackTrace();
}
}
public void getBucketPolicy(Bucket bucket) {
try {
Bucket.GetBucketPolicyOutput output = bucket.getPolicy();
if (output.getStatueCode() == 200) {
System.out.println("====Get Bucket Policy====");
List<Types.StatementModel> statements = output.getStatement();
if (statements != null && statements.size() > 0) {
System.out.println("Statements = " + new Gson().toJson(statements));
} else {
System.out.println("Statement list is empty, Policy is empty.");
}
System.out.println("========");
} else {
// Failed
System.out.println("Failed to Get Bucket Policy.");
handleError(output);
}
} catch (QSException e) {
e.printStackTrace();
}
}
public void putBucketPolicy(Bucket bucket, String bucketName) {
try {
Bucket.PutBucketPolicyInput input = new Bucket.PutBucketPolicyInput();
List<Types.StatementModel> statement = new ArrayList<>();
Types.StatementModel statementModel = new Types.StatementModel();
// ID
statementModel.setID("allow certain site to get objects");
// User
List<String> user = new ArrayList<>();
user.add("*");
statementModel.setUser(user);
// Action
List<String> action = new ArrayList<>();
action.add("get_object");
statementModel.setAction(action);
// Effect
statementModel.setEffect("allow");
// Resource
List<String> resource = new ArrayList<>();
resource.add(bucketName + "/*");
statementModel.setResource(resource);
// Condition
Types.ConditionModel conditionModel = new Types.ConditionModel();
Types.StringLikeModel stringLikeModel = new Types.StringLikeModel();
List<String> referer = new ArrayList<>();
referer.add("*.example1.com");
referer.add("*.example2.com");
stringLikeModel.setReferer(referer);
conditionModel.setStringLike(stringLikeModel);
statementModel.setCondition(conditionModel);
statement.add(statementModel);
input.setStatement(statement);
Bucket.PutBucketPolicyOutput output = bucket.putPolicy(input);
if (output.getStatueCode() == 200) {
System.out.println("PUT Bucket Policy OK.");
} else {
// Failed
System.out.println("PUT Bucket Policy failed.");
handleError(output);
}
} catch (QSException e) {
e.printStackTrace();
}
}
public void deleteBucketCORS(Bucket bucket) {
try {
Bucket.DeleteBucketCORSOutput output = bucket.deleteCORS();
if (output.getStatueCode() == 204) {
System.out.println("Delete bucket CORS OK.");
} else {
// Failed
System.out.println("Failed to delete bucket CORS.");
handleError(output);
}
} catch (QSException e) {
e.printStackTrace();
}
}
public void getBucketCORS(Bucket bucket) {
try {
Bucket.GetBucketCORSOutput output = bucket.getCORS();
if (output.getStatueCode() == 200) {
System.out.println("====Get Bucket CORS====");
List<Types.CORSRuleModel> corsRules = output.getCORSRules();
if (corsRules != null && corsRules.size() > 0) {
System.out.println("CorsRules = " + new Gson().toJson(corsRules));
} else {
System.out.println("CorsRules list is empty, CORS is empty.");
}
System.out.println("========");
} else {
// Failed
System.out.println("Failed to GET Bucket CORS.");
handleError(output);
}
} catch (QSException e) {
e.printStackTrace();
}
}
public void putBucketCORS(Bucket bucket) {
Bucket.PutBucketCORSInput input = new Bucket.PutBucketCORSInput();
List<Types.CORSRuleModel> corsRuleModels = new ArrayList<>();
Types.CORSRuleModel corsRuleModel = new Types.CORSRuleModel();
// Allowed_origin
corsRuleModel.setAllowedOrigin("http://*.qingcloud.com");
// Allowed_methods
List<String> allowed_methods = new ArrayList<>();
allowed_methods.add("PUT");
allowed_methods.add("GET");
allowed_methods.add("DELETE");
allowed_methods.add("POST");
corsRuleModel.setAllowedMethods(allowed_methods);
// Allowed_headers
List<String> allowed_headers = new ArrayList<>();
allowed_headers.add("x-qs-date");
allowed_headers.add("Content-Type");
allowed_headers.add("Content-MD5");
allowed_headers.add("Authorization");
corsRuleModel.setAllowedHeaders(allowed_headers);
// Max_age_seconds
corsRuleModel.setMaxAgeSeconds(200);
// Expose_headers
List<String> expose_headers = new ArrayList<>();
expose_headers.add("x-qs-date");
corsRuleModel.setExposeHeaders(expose_headers);
corsRuleModels.add(corsRuleModel);
input.setCORSRules(corsRuleModels);
try {
Bucket.PutBucketCORSOutput output = bucket.putCORS(input);
if (output.getStatueCode() == 200) {
System.out.println("PUT Bucket CORS OK.");
} else {
// Failed
System.out.println("PUT Bucket CORS failed.");
handleError(output);
}
} catch (QSException e) {
e.printStackTrace();
}
}
public void deleteBucketLifecycle(Bucket bucket) {
try {
Bucket.DeleteBucketLifecycleOutput output = bucket.deleteLifecycle();
if (output.getStatueCode() == 204) {
System.out.println("Delete bucket lifecycle OK.");
} else {
// Failed
System.out.println("Failed to delete bucket lifecycle.");
handleError(output);
}
} catch (QSException e) {
e.printStackTrace();
}
}
public void getBucketLifecycle(Bucket bucket) {
try {
Bucket.GetBucketLifecycleOutput output = bucket.getLifecycle();
if (output.getStatueCode() == 200) {
System.out.println("======GET Bucket Lifecycle=======");
List<Types.RuleModel> rules = output.getRule();
if (rules != null && rules.size() > 0) {
System.out.println("Rules = " + new Gson().toJson(rules));
} else {
System.out.println("GET Bucket Lifecycle: Rules is empty.");
}
System.out.println("=============");
} else {
// Failed
System.out.println("Failed to GET Bucket Lifecycle.");
handleError(output);
}
} catch (QSException e) {
e.printStackTrace();
}
}
public void putBucketLifecycle(Bucket bucket) {
Bucket.PutBucketLifecycleInput input = new Bucket.PutBucketLifecycleInput();
List<Types.RuleModel> rules = new ArrayList<>();
Types.RuleModel rule = new Types.RuleModel();
// ID
rule.setID("delete-logs");
// Status
rule.setStatus("enabled");
// Filter
Types.FilterModel filter = new Types.FilterModel();
filter.setPrefix("logs/");
rule.setFilter(filter);
// Expiration
Types.ExpirationModel expiration = new Types.ExpirationModel();
expiration.setDays(180);
rule.setExpiration(expiration);
rules.add(rule);
input.setRule(rules);
try {
Bucket.PutBucketLifecycleOutput output = bucket.putLifecycle(input);
if (output.getStatueCode() == 200) {
System.out.println("Put bucket lifecycle OK.");
} else {
// Failed
System.out.println("Failed to put bucket lifecycle.");
handleError(output);
}
} catch (QSException e) {
e.printStackTrace();
}
}
public void deleteBucketNotification(Bucket bucket) {
try {
Bucket.DeleteBucketNotificationOutput output = bucket.deleteNotification();
if (output.getStatueCode() == 204) {
System.out.println("The notification of bucket deleted.");
} else {
// Failed
System.out.println("Failed to delete bucket notification.");
handleError(output);
}
} catch (QSException e) {
e.printStackTrace();
}
}
public void getBucketNotification(Bucket bucket) {
try {
Bucket.GetBucketNotificationOutput output = bucket.getNotification();
if (output.getStatueCode() == 200) {
System.out.println("=======GET Bucket Notification======");
List<Types.NotificationModel> notifications = output.getNotifications();
if (notifications != null && notifications.size() > 0) {
System.out.println("Notifications = " + new Gson().toJson(notifications));
} else {
System.out.println("GET Bucket Notification: Notifications is empty.");
}
System.out.println("=============");
} else {
// Failed
System.out.println("Failed to GET Bucket Notification.");
handleError(output);
}
} catch (QSException e) {
e.printStackTrace();
}
}
public void putBucketNotification(Bucket bucket) {
Bucket.PutBucketNotificationInput input = new Bucket.PutBucketNotificationInput();
List<Types.NotificationModel> notifications = new ArrayList<>();
Types.NotificationModel notification = new Types.NotificationModel();
// Cloudfunc
notification.setCloudfunc("tupu-porn");
// EventTypes
List<String> eventTypes = new ArrayList<>();
eventTypes.add("create_object");
notification.setEventTypes(eventTypes);
// ID
notification.setID("notification-1");
// ObjectFilters: List or String
List<String> objectFilters = new ArrayList<>();
objectFilters.add("*");
objectFilters.add("test_classes");
notification.setObjectFilters(objectFilters);
// NotifyURL
notification.setNotifyURL("http://user_notify_url");
notifications.add(notification);
input.setNotifications(notifications);
try {
Bucket.PutBucketNotificationOutput output = bucket.putNotification(input);
if (output.getStatueCode() == 200 || output.getStatueCode() == 201) {
System.out.println("Put bucket notification OK.");
} else {
// Failed
System.out.println("Failed to put bucket notification.");
handleError(output);
}
} catch (QSException e) {
e.printStackTrace();
}
}
public void deleteBucketExternalMirror(Bucket bucket) {
try {
Bucket.DeleteBucketExternalMirrorOutput output = bucket.deleteExternalMirror();
if (output.getStatueCode() == 204) {
System.out.println("Delete bucket external mirror OK.");
} else {
// Failed
System.out.println("Failed to delete bucket external mirror.");
handleError(output);
}
} catch (QSException e) {
e.printStackTrace();
}
}
public void getBucketExternalMirror(Bucket bucket) {
try {
Bucket.GetBucketExternalMirrorOutput output = bucket.getExternalMirror();
if (output.getStatueCode() == 200) {
String sourceSite = output.getSourceSite();
System.out.println("GET Bucket External Mirror: SourceSite = " + sourceSite);
} else {
// Failed
System.out.println("Failed to GET Bucket External Mirror.");
handleError(output);
}
} catch (QSException e) {
e.printStackTrace();
}
}
public void putBucketExternalMirror(Bucket bucket) {
Bucket.PutBucketExternalMirrorInput input = new Bucket.PutBucketExternalMirrorInput();
input.setSourceSite("http://example.com:80/image/");
try {
Bucket.PutBucketExternalMirrorOutput output = bucket.putExternalMirror(input);
if (output.getStatueCode() == 200) {
System.out.println("PUT Bucket External Mirror OK.");
} else {
// Failed
System.out.println("Failed to PUT Bucket External Mirror.");
handleError(output);
}
} catch (QSException e) {
e.printStackTrace();
}
}
/**
* Options Object
*
* @param bucket bucket
* @param objectKey looks like this: "folder/fileName".<br/>
* If objectKey = "fileName", means the object is in the bucket's root folder.
*/
public void optionsObject(Bucket bucket, String objectKey) {
try {
Bucket.OptionsObjectInput input = new Bucket.OptionsObjectInput();
input.setOrigin("Origin");
input.setAccessControlRequestMethod("<http-method>");
input.setAccessControlRequestHeaders("<request-header>");
Bucket.OptionsObjectOutput output = bucket.optionsObject(objectKey, input);
if (output.getStatueCode() == 200) {
// Success
System.out.println("Options Object success.");
System.out.println("AccessControlAllowOrigin = " + output.getAccessControlAllowOrigin());
System.out.println("AccessControlMaxAge = " + output.getAccessControlMaxAge());
System.out.println("AccessControlAllowMethods = " + output.getAccessControlAllowMethods());
System.out.println("AccessControlAllowHeaders = " + output.getAccessControlAllowHeaders());
System.out.println("AccessControlExposeHeaders = " + output.getAccessControlExposeHeaders());
} else {
// Failed
System.out.println("Failed to Options Object.");
handleError(output);
}
} catch (QSException e) {
e.printStackTrace();
}
}
public void handleError(OutputModel output) {
if (output == null) return;
System.out.println("StatusCode = " + output.getStatueCode());
System.out.println("Message = " + output.getMessage());
System.out.println("RequestId = " + output.getRequestId());
System.out.println("Code = " + output.getCode());
System.out.println("Url = " + output.getUrl());
}
private void listBuckets(EnvContext context) {
QingStor stor = new QingStor(context);
try {
QingStor.ListBucketsOutput output = stor.listBuckets(null);
if (output.getStatueCode() == 200) {
System.out.println("Count = " + output.getCount());
List<Types.BucketModel> buckets = output.getBuckets();
System.out.println("buckets = " + new Gson().toJson(buckets));
} else {
handleError(output);
}
} catch (QSException e) {
e.printStackTrace();
}
}
}
文章浏览阅读645次。这个肯定是末尾的IDAT了,因为IDAT必须要满了才会开始一下个IDAT,这个明显就是末尾的IDAT了。,对应下面的create_head()代码。,对应下面的create_tail()代码。不要考虑爆破,我已经试了一下,太多情况了。题目来源:UNCTF。_攻防世界困难模式攻略图文
文章浏览阅读2.9k次,点赞3次,收藏10次。偶尔会用到,记录、分享。1. 数据库导出1.1 切换到dmdba用户su - dmdba1.2 进入达梦数据库安装路径的bin目录,执行导库操作 导出语句:./dexp cwy_init/[email protected]:5236 file=cwy_init.dmp log=cwy_init_exp.log 注释: cwy_init/init_123..._达梦数据库导入导出
文章浏览阅读1.9k次。1. 在官网上下载KindEditor文件,可以删掉不需要要到的jsp,asp,asp.net和php文件夹。接着把文件夹放到项目文件目录下。2. 修改html文件,在页面引入js文件:<script type="text/javascript" src="./kindeditor/kindeditor-all.js"></script><script type="text/javascript" src="./kindeditor/lang/zh-CN.js"_kindeditor.js
文章浏览阅读2.3k次,点赞6次,收藏14次。SPI的详情简介不必赘述。假设我们通过SPI发送0xAA,我们的数据线就会变为10101010,通过修改不同的内容,即可修改SPI中0和1的持续时间。比如0xF0即为前半周期为高电平,后半周期为低电平的状态。在SPI的通信模式中,CPHA配置会影响该实验,下图展示了不同采样位置的SPI时序图[1]。CPOL = 0,CPHA = 1:CLK空闲状态 = 低电平,数据在下降沿采样,并在上升沿移出CPOL = 0,CPHA = 0:CLK空闲状态 = 低电平,数据在上升沿采样,并在下降沿移出。_stm32g431cbu6
文章浏览阅读1.2k次,点赞2次,收藏8次。数据链路层习题自测问题1.数据链路(即逻辑链路)与链路(即物理链路)有何区别?“电路接通了”与”数据链路接通了”的区别何在?2.数据链路层中的链路控制包括哪些功能?试讨论数据链路层做成可靠的链路层有哪些优点和缺点。3.网络适配器的作用是什么?网络适配器工作在哪一层?4.数据链路层的三个基本问题(帧定界、透明传输和差错检测)为什么都必须加以解决?5.如果在数据链路层不进行帧定界,会发生什么问题?6.PPP协议的主要特点是什么?为什么PPP不使用帧的编号?PPP适用于什么情况?为什么PPP协议不_接收方收到链路层数据后,使用crc检验后,余数为0,说明链路层的传输时可靠传输
文章浏览阅读587次。软件测试工程师移民加拿大 无证移民,未受过软件工程师的教育(第1部分) (Undocumented Immigrant With No Education to Software Engineer(Part 1))Before I start, I want you to please bear with me on the way I write, I have very little gen...
文章浏览阅读304次。Thinkpad X250笔记本电脑,装的是FreeBSD,进入BIOS修改虚拟化配置(其后可能是误设置了安全开机),保存退出后系统无法启动,显示:secure boot failed ,把自己惊出一身冷汗,因为这台笔记本刚好还没开始做备份.....根据错误提示,到bios里面去找相关配置,在Security里面找到了Secure Boot选项,发现果然被设置为Enabled,将其修改为Disabled ,再开机,终于正常启动了。_安装完系统提示secureboot failure
文章浏览阅读10w+次,点赞93次,收藏352次。1、用strtok函数进行字符串分割原型: char *strtok(char *str, const char *delim);功能:分解字符串为一组字符串。参数说明:str为要分解的字符串,delim为分隔符字符串。返回值:从str开头开始的一个个被分割的串。当没有被分割的串时则返回NULL。其它:strtok函数线程不安全,可以使用strtok_r替代。示例://借助strtok实现split#include <string.h>#include <stdio.h&_c++ 字符串分割
文章浏览阅读2.3k次。1 .高斯日记 大数学家高斯有个好习惯:无论如何都要记日记。他的日记有个与众不同的地方,他从不注明年月日,而是用一个整数代替,比如:4210后来人们知道,那个整数就是日期,它表示那一天是高斯出生后的第几天。这或许也是个好习惯,它时时刻刻提醒着主人:日子又过去一天,还有多少时光可以用于浪费呢?高斯出生于:1777年4月30日。在高斯发现的一个重要定理的日记_2013年第四届c a组蓝桥杯省赛真题解答
文章浏览阅读851次,点赞17次,收藏22次。摘要:本文利用供需算法对核极限学习机(KELM)进行优化,并用于分类。
文章浏览阅读1.1k次。一、系统弱密码登录1、在kali上执行命令行telnet 192.168.26.1292、Login和password都输入msfadmin3、登录成功,进入系统4、测试如下:二、MySQL弱密码登录:1、在kali上执行mysql –h 192.168.26.129 –u root2、登录成功,进入MySQL系统3、测试效果:三、PostgreSQL弱密码登录1、在Kali上执行psql -h 192.168.26.129 –U post..._metasploitable2怎么进入
文章浏览阅读257次。本文将为初学者提供Python学习的详细指南,从Python的历史、基础语法和数据类型到面向对象编程、模块和库的使用。通过本文,您将能够掌握Python编程的核心概念,为今后的编程学习和实践打下坚实基础。_python人工智能开发从入门到精通pdf