import com.aliyun.openservices.oss.model.ObjectMetadata; //导入依赖的package包/类
@Override
public String add(InputStream input, String dir, String filename, long lenght, String contentType) throws IOException {
	if (input == null) {
		throw new NullPointerException("input不能为空.");
	}
	
	OSSClient client = new OSSClient(endpoint, accessKeyId, secretAccessKey);
	// System.err.println("endpoint:" + endpoint);
	ObjectMetadata meta = new ObjectMetadata();
	meta.setContentLength(lenght);
	if (contentType != null) {
		meta.setContentType(contentType);
	}
	filename = toUuidFileName(filename);
	String uri;
	if (dir == null || dir.length() == 0) {
		uri = filename;
	}
	else {
		uri = dir + "/" + filename;
	}
	System.out.println("uri:" + uri + " lenght:" + lenght);
	PutObjectResult result = client.putObject(bucketName, uri, input, meta);
	System.out.println(result.getETag());
	return "/" + uri;
}
 

import com.aliyun.openservices.oss.model.ObjectMetadata; //导入依赖的package包/类
@Override
public void upload(String path, File file, String contentType) {
	PluginConfig pluginConfig = getPluginConfig();
	if (pluginConfig != null) {
		String accessId = pluginConfig.getAttribute("accessId");
		String accessKey = pluginConfig.getAttribute("accessKey");
		String bucketName = pluginConfig.getAttribute("bucketName");
		InputStream inputStream = null;
		try {
			inputStream = new FileInputStream(file);
			OSSClient ossClient = new OSSClient(accessId, accessKey);
			ObjectMetadata objectMetadata = new ObjectMetadata();
			objectMetadata.setContentType(contentType);
			objectMetadata.setContentLength(file.length());
			ossClient.putObject(bucketName, StringUtils.removeStart(path, "/"), inputStream, objectMetadata);
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			IOUtils.closeQuietly(inputStream);
		}
	}
}
 

import com.aliyun.openservices.oss.model.ObjectMetadata; //导入依赖的package包/类
@SuppressWarnings("deprecation")
@Override
public String save(GenericFile genericFile){
	OSSClient client = new OSSClient(accessKeyId, accessKeySecret);
	if(!client.doesBucketExist(bucketName)){
		client.createBucket(bucketName);
	}
	ObjectMetadata metadata = new ObjectMetadata();
	metadata.setContentLength(genericFile.getLength());
	if(fileNameGenerator == null){
		throw new RuntimeException("no file name generator configed");
	}
	String path = fileNameGenerator.gen() + genericFile.getExtend();
	client.putObject(bucketName, path, genericFile.getIs(), metadata);
	return path;
}
 

import com.aliyun.openservices.oss.model.ObjectMetadata; //导入依赖的package包/类
@Override
@Nullable
public FileMetadata retrieveMetadata(String key) throws IOException {
  checkNotNull(key);

  try {
    ObjectMetadata metadata = client.getObjectMetadata(bucket, key);
    return new FileMetadata(key, metadata.getContentLength(), metadata.getLastModified().getTime());
  } catch (OSSException e) {
    try {
      throw handleException(e, key);
    } catch (FileNotFoundException e2) {
      LOG.debug("{} does not exist", key);
      return null; // degrade gracefully
    }
  }
}
 

import com.aliyun.openservices.oss.model.ObjectMetadata; //导入依赖的package包/类
/**
 * Breaks up {@code file} into multiple parts and uploads it.
 *
 * @param key     destination key
 * @param file    local file
 * @param md5Hash checksum
 * @throws com.aliyun.openservices.ServiceException from OSSClient.
 */
void upload(String key, File file, Optional<byte[]> md5Hash) throws IOException {
  checkNotNull(key);
  checkNotNull(file);
  checkNotNull(md5Hash);

  // initiate upload
  ObjectMetadata metadata = metadata(file, md5Hash);
  String uploadId = initiateMultiPartUpload(key, metadata);

  // count number of parts
  int parts = (int) calculateNumParts(file.length());
  LOG.info("Initiating multipart upload request for key {} with {} parts", key, parts);

  List<PartETag> eTags = uploadParts(key, file, uploadId, parts);
  completeMultipartUpload(key, uploadId, eTags);
}
 

import com.aliyun.openservices.oss.model.ObjectMetadata; //导入依赖的package包/类
@Override
public void storeEmptyFile(String key) throws IOException {
  checkNotNull(key);

  try (InputStream input = new ByteArrayInputStream(new byte[0])) {
    ObjectMetadata metadata = new ObjectMetadata();
    metadata.setContentType("binary/octet-stream");
    metadata.setContentLength(0);
    client.putObject(bucket, key, input, metadata);
  } catch (ServiceException e) {
    throw handleException(e, key);
  }
}
 

import com.aliyun.openservices.oss.model.ObjectMetadata; //导入依赖的package包/类
private void doSimpleUpload(String key, File file, Optional<byte[]> md5Hash) throws IOException {
  try (BufferedInputStream input = new BufferedInputStream(new FileInputStream(file))) {
    ObjectMetadata metadata = new ObjectMetadata();
    metadata.setContentLength(file.length());
    metadata.setLastModified(new Date(file.lastModified()));
    // add MD5, if provided
    if (md5Hash.isPresent()) {
      String contentMd5 = Base64.encodeBase64String(md5Hash.get());
      metadata.setHeader("Content-MD5", contentMd5.trim());
    }
    client.putObject(bucket, key, input, metadata);
  } catch (ServiceException e) {
    throw handleException(e, key);
  }
}
 

import com.aliyun.openservices.oss.model.ObjectMetadata; //导入依赖的package包/类
@Override
public String upload(InputStream is, String filename, String contentType, long length) throws IOException {
    ObjectMetadata meta = new ObjectMetadata();
    meta.setContentLength(length);
    meta.setContentType(contentType);
    meta.setCacheControl("max-age=" + 3600 * 1000 * 48);
    meta.setLastModified(new Date());
    client.putObject(name, "images/" + filename, is, meta);
    return filename;
}
 

import com.aliyun.openservices.oss.model.ObjectMetadata; //导入依赖的package包/类
private String initiateMultiPartUpload(String key, ObjectMetadata metadata) {
  InitiateMultipartUploadRequest request = new InitiateMultipartUploadRequest(bucket, key);
  request.setObjectMetadata(metadata);
  InitiateMultipartUploadResult result = client.initiateMultipartUpload(request);
  return result.getUploadId();
}