import com.aliyun.oss.model.ObjectMetadata; //导入依赖的package包/类
/**
 * 上传Object
 *
 * @param client
 * @param bucketName
 * @param key
 * @param filePath
 * @return
 * @throws FileNotFoundException
 */
public static PutObjectResult putObject(OSSClient client, String bucketName, String key, String filePath) throws FileNotFoundException {

	// 获取指定文件的输入流
	File file = new File(filePath);
	InputStream content = new FileInputStream(file);

	// 创建上传Object的Metadata
	ObjectMetadata meta = new ObjectMetadata();

	// 必须设置ContentLength
	meta.setContentLength(file.length());
	// 用户自定义文件名称
	meta.addUserMetadata("filename", key);

	// 上传Object.
	PutObjectResult result = client.putObject(bucketName, key, content, meta);

	return result;
}
 

import com.aliyun.oss.model.ObjectMetadata; //导入依赖的package包/类
public static void putObject(String bucketName, File file, String fileName)
		throws IOException {

	// 初始化OSSClient
	OSSClient client = getOSSClient();

	// 获取指定文件的输入流
	// File file = new File(fileRealPath + fileName);
	InputStream content = new FileInputStream(file);

	// 创建上传Object的Metadata
	ObjectMetadata meta = new ObjectMetadata();

	// 必须设置ContentLength
	// meta.setContentLength(file.length());
	meta.setContentEncoding("UTF-8");
	// 上传Object.
	String key = fileName;
	PutObjectResult result = client.putObject(bucketName, key, content,
			meta);
	content.close();
}
 

import com.aliyun.oss.model.ObjectMetadata; //导入依赖的package包/类
/**
 * Create empty object with content length is 0L
 *
 * @param bucketName
 * @param objectName
 * @throws ClientException
 * @throws OSSException
 */
private void createEmptyObject(final String bucketName, final String objectName)
        throws ClientException, OSSException {

  final InputStream nullStream = new InputStream() {
    @Override
    public int read() throws IOException {
      return -1;
    }
  };

  final ObjectMetadata om = new ObjectMetadata();
  om.setContentLength(0L);

  PutObjectRequest putObjectRequest = new PutObjectRequest(bucketName, objectName, nullStream, om);
  client.putObject(putObjectRequest);
  statistics.incrementWriteOps(1);
}
 

import com.aliyun.oss.model.ObjectMetadata; //导入依赖的package包/类
public static String uploadFile(String fileName, String path, boolean img, String contentType) throws OSSException,
		ClientException, FileNotFoundException {
	if (client == null) throw new OSSException("OssKit must init before use");

	File file = new File(path);

	ObjectMetadata objectMeta = new ObjectMetadata();
	objectMeta.setContentLength(file.length());
	if (contentType != null) objectMeta.setContentType(contentType);

	InputStream input = new FileInputStream(file);

	client.putObject(buketName, fileName, input, objectMeta);

	if (img) return getImgUrl(fileName);
	else return getUrl(fileName);
}
 

import com.aliyun.oss.model.ObjectMetadata; //导入依赖的package包/类
@Override
protected UploadResult putObject(MultipartFile file, String path,
		String originalName, String resultName) throws IOException,
		UploadException {
	
	if(ossClient==null){
		throw new UploadException("OSS Client is null.");
	}
	
	ObjectMetadata objectMeta = new ObjectMetadata();
	objectMeta.setContentType(file.getContentType());
	
	InputStream is = file.getInputStream();
	objectMeta.setContentLength(is.available());
	
	UploadResult result = new UploadResult(path, originalName, resultName);
	ossClient.putObject(bucket, result.getFullPath(), is, objectMeta);
	//PutObjectResult ossResult = 
	return result;
}
 

import com.aliyun.oss.model.ObjectMetadata; //导入依赖的package包/类
/**
 * 上传文件
 *
 * @param path 文件路径
 * @param file 文件对象
 * @param meta 媒体类型
 */
public static void putObject(String path, File file, ObjectMetadata meta) {
    OSSClient ossClient = newOSSClient();
    try {
        ossClient.putObject(bucketName, path, file, meta);
    } finally {
        ossClient.shutdown();
    }
}
 

import com.aliyun.oss.model.ObjectMetadata; //导入依赖的package包/类
public String uploadCode(LanguageEnum lang, String code) {
    InputStream is = new ByteArrayInputStream(code.getBytes());
    StringBuilder fileName = new StringBuilder(UUID.randomUUID().toString());
    switch (lang) {
        case JAVA8:
            fileName.append(".java");
            break;
        case C:
            fileName.append(".c");
            break;
        case CPP:
            fileName.append(".cpp");
            break;
        default:
            fileName.append(".py");
            break;
    }
    ObjectMetadata metadata = new ObjectMetadata();
    metadata.setContentType("text/plain");
    String filePath = generateFilePath(fileName.toString());
    try {
        ossClient.putObject(BUCKET, filePath, is, metadata);
        return "/"+filePath;
    } catch (Exception e) {
        return null;
    }
}
 

import com.aliyun.oss.model.ObjectMetadata; //导入依赖的package包/类
/**
 * OSSObjectMetadata到CCSObjectMetadata
 */
public static CCSObjectMetadata parseToCCSObjectMetadata(ObjectMetadata ossObjectMetadata) {
	CCSObjectMetadata ccsObjectMetadata = new CCSObjectMetadata();
	ccsObjectMetadata.setContentEncoding(ossObjectMetadata.getContentEncoding());
	ccsObjectMetadata.setContentLength(ossObjectMetadata.getContentLength());
	ccsObjectMetadata.setContentMD5(ossObjectMetadata.getContentMD5());
	ccsObjectMetadata.setContentType(ossObjectMetadata.getContentType());
	ccsObjectMetadata.setETag(ossObjectMetadata.getETag());
	ccsObjectMetadata.setLastModified(ossObjectMetadata.getLastModified());
	ccsObjectMetadata.setObjectType(ossObjectMetadata.getObjectType());
	ccsObjectMetadata.setStorgeClass(ossObjectMetadata.getObjectStorageClass().name());
	ccsObjectMetadata.setUserMetaData(ossObjectMetadata.getUserMetadata());
	return ccsObjectMetadata;
}
 

import com.aliyun.oss.model.ObjectMetadata; //导入依赖的package包/类
/**
 * CCSObjectMetadata 到 OSS ObjectMetadata
 */
public static ObjectMetadata parseToObjectMetadata(CCSObjectMetadata ccsObjectMetadata) {
	ObjectMetadata objectMetadata = new ObjectMetadata();
	if (ccsObjectMetadata!=null) {
		objectMetadata.setUserMetadata(ccsObjectMetadata.getUserMetaData());
		objectMetadata.setLastModified(ccsObjectMetadata.getLastModified());
		objectMetadata.setContentType(ccsObjectMetadata.getContentType());
		objectMetadata.setContentMD5(ccsObjectMetadata.getContentMD5());
		objectMetadata.setContentLength(ccsObjectMetadata.getContentLength());
		objectMetadata.setContentEncoding(ccsObjectMetadata.getContentEncoding());
	}
	return objectMetadata;
}
 

import com.aliyun.oss.model.ObjectMetadata; //导入依赖的package包/类
/**
 * Copy an existing file to another place.
 *
 * @param srcKey source object key
 * @param dstKey destination object key
 * @throws IOException
 */
private void copyFile(String srcKey, String dstKey) throws IOException {
  if (LOG.isDebugEnabled()) {
    LOG.debug("copyFile " + srcKey + " -> " + dstKey);
  }

  ObjectMetadata om = client.getObjectMetadata(bucket, srcKey);
  CopyObjectRequest copyObjectRequest = new CopyObjectRequest(bucket, srcKey, bucket, dstKey);
  copyObjectRequest.setNewObjectMetadata(om);
  copyObjectRequest.setProgressListener(new ProgressListener() {
    public void progressChanged(ProgressEvent progressEvent) {
      switch (progressEvent.getEventType()) {
        case TRANSFER_PART_COMPLETED_EVENT:
          statistics.incrementWriteOps(1);
          break;
        default:
          break;
      }
    }
  });
  try {
    client.copyObject(copyObjectRequest);
    statistics.incrementWriteOps(1);
  } catch (OSSException | ClientException e) {
    throw new IOException("Got interrupted, cancelling");
  }
}
 

import com.aliyun.oss.model.ObjectMetadata; //导入依赖的package包/类
/**
 * Enhanced to auto choose simple or multipart copy via multipart copy threshold.
 *
 * @param copyObjectRequest
 * @return
 * @throws OSSException
 * @throws ClientException
 */
@Override
public CopyObjectResult copyObject(CopyObjectRequest copyObjectRequest)
        throws OSSException, ClientException {

  ObjectMetadata metadata = this.getObjectMetadata(copyObjectRequest.getSourceBucketName(), copyObjectRequest.getSourceKey());
  if (!isMultipartCopy(metadata)) {
    return super.copyObject(copyObjectRequest); //simple copy
  } else {
    return doMultiPartCopy(copyObjectRequest, metadata);  //multi-part copy
  }
}
 

import com.aliyun.oss.model.ObjectMetadata; //导入依赖的package包/类
/**
 * Test high performance copyFromLocal.
 *
 * @throws Exception
 */
public void testCopyFromLocalFile() throws Exception {
  final File sampleFile = createSampleFile(1100); //48.83 MB
  fileSystem.copyFromLocalFile(false, true, new Path(sampleFile.getAbsolutePath()), path("test/test-copyFromLocalFile"));

  ObjectMetadata metaData = client.getObjectMetadata("hadoop-intg", "user/shawguo/test/test-copyFromLocalFile");
  assertEquals(sampleFile.length(), metaData.getContentLength());
}
 

import com.aliyun.oss.model.ObjectMetadata; //导入依赖的package包/类
public void set(@Nonnull String bucketName, @Nonnull String folder, @Nonnull String name,
                @Nonnull InputStream inputStream, @Nonnull ObjectMetadata objectMetadata) {
    checkNotNull(bucketName);
    checkNotNull(folder);
    checkNotNull(name);
    checkNotNull(inputStream);
    checkNotNull(objectMetadata);

    String key = formatKey(folder, name);

    ossClient.putObject(bucketName, key, inputStream, objectMetadata);
}
 

import com.aliyun.oss.model.ObjectMetadata; //导入依赖的package包/类
public ObjectOperation store(File file, ObjectMetadata meta){
	if(!file.exists()){
		throw new BaseException("file is not exists!");
	}
	putObject(new PutObjectRequest(bucketName, key, file, meta));
	return this;
}
 

import com.aliyun.oss.model.ObjectMetadata; //导入依赖的package包/类
/****
 * 
 * @author wayshall
 * @param object
 * @param contentType example: MediaType.APPLICATION_OCTET_STREAM_VALUE
 * @return
 */
public ObjectOperation storeAsJson(Object object, String contentType){
	String json = JsonMapper.DEFAULT_MAPPER.toJson(object);
	StringReader sr = new StringReader(json);
	ObjectMetadata meta = new ObjectMetadata();
	meta.setContentType(contentType);
	return store(new ReaderInputStream(sr), meta);
}
 

import com.aliyun.oss.model.ObjectMetadata; //导入依赖的package包/类
/**
 * The src file is on the local disk.  Add it to FS at
 * the given dst name.
 * <p/>
 * This version doesn't need to create a temporary file to calculate the md5.
 * Sadly this doesn't seem to be used by the shell cp :(
 * <p/>
 * delSrc indicates if the source should be removed
 *
 * @param delSrc    whether to delete the src
 * @param overwrite whether to overwrite an existing file
 * @param src       path
 * @param dst       path
 */
@Override
public void copyFromLocalFile(boolean delSrc, boolean overwrite, Path src,
                              Path dst) throws IOException {
  String key = pathToKey(dst);

  if (!overwrite && exists(dst)) {
    throw new IOException(dst + " already exists");
  }
  if (LOG.isDebugEnabled()) {
    LOG.debug("Copying local file from " + src + " to " + dst);
  }

  // Since we have a local file, we don't need to stream into a temporary file
  LocalFileSystem local = getLocal(getConf());
  File srcfile = local.pathToFile(src);

  final ObjectMetadata om = new ObjectMetadata();
  PutObjectRequest putObjectRequest = new PutObjectRequest(bucket, key, srcfile);
  putObjectRequest.setMetadata(om);
  putObjectRequest.setProgressListener(new ProgressListener() {
    public void progressChanged(ProgressEvent progressEvent) {
      switch (progressEvent.getEventType()) {
        case TRANSFER_PART_COMPLETED_EVENT:
          statistics.incrementWriteOps(1);
          break;
        default:
          break;
      }
    }
  });

  try {
    client.putObject(putObjectRequest);
    statistics.incrementWriteOps(1);
  } catch (OSSException | ClientException e) {
    throw new IOException("Got interrupted, cancelling");
  }
  // This will delete unnecessary fake parent directories
  finishedWrite(key);
  if (delSrc) {
    local.delete(src, false);
  }
}
 

import com.aliyun.oss.model.ObjectMetadata; //导入依赖的package包/类
@Override
public synchronized void close() throws IOException {
  if (closed) {
    return;
  }

  backupStream.close();
  if (LOG.isDebugEnabled()) {
    LOG.debug("OutputStream for key '" + key + "' closed. Now beginning upload");
  }
  try {
    final ObjectMetadata om = new ObjectMetadata();
    PutObjectRequest putObjectRequest = new PutObjectRequest(bucket, key, backupFile);
    putObjectRequest.setMetadata(om);
    putObjectRequest.setProgressListener(new ProgressListener() {
      public void progressChanged(ProgressEvent progressEvent) {
        switch (progressEvent.getEventType()) {
          case TRANSFER_PART_COMPLETED_EVENT:
            statistics.incrementWriteOps(1);
            break;
          default:
            break;
        }
      }
    });

    fs.getOSSClient().putObject(putObjectRequest);

    // This will delete unnecessary fake parent directories
    fs.finishedWrite(key);
  } catch (OSSException | ClientException e) {
    throw new IOException(e);
  } finally {
    if (!backupFile.delete()) {
      LOG.warn("Could not delete temporary oss file: {}", backupFile);
    }
    super.close();
    closed = true;
  }
  if (LOG.isDebugEnabled()) {
    LOG.debug("OutputStream for key '" + key + "' upload complete");
  }
}
 

import com.aliyun.oss.model.ObjectMetadata; //导入依赖的package包/类
private CopyObjectResult doMultiPartCopy(CopyObjectRequest copyObjectRequest, ObjectMetadata metadata) {

    //Claim a new upload id for your target bucket
    InitiateMultipartUploadRequest initiateMultipartUploadRequest =
            new InitiateMultipartUploadRequest(copyObjectRequest.getDestinationBucketName(), copyObjectRequest.getDestinationKey());
    InitiateMultipartUploadResult initiateMultipartUploadResult = this.initiateMultipartUpload(initiateMultipartUploadRequest);
    String uploadId = initiateMultipartUploadResult.getUploadId();

    //Calculate how many parts to be divided
    long optimalPartSize = calculateOptimalPartSizeForCopy(configuration, metadata.getContentLength());
    long objectSize = metadata.getContentLength();
    int totalParts = (int) Math.ceil((double) objectSize / optimalPartSize);

    //Upload multi-parts by copy mode
    System.out.println("Begin to upload multiparts by copy mode to OSS\n");
    List<Future<PartETag>> futures = new ArrayList<Future<PartETag>>();
    for (int i = 0; i < totalParts; i++) {
      long startPos = i * optimalPartSize;
      long curPartSize = (i + 1 == totalParts) ? (objectSize - startPos) : optimalPartSize;

      //Construct UploadPartCopyRequest
      UploadPartCopyRequest uploadPartCopyRequest = new UploadPartCopyRequest(
              copyObjectRequest.getSourceBucketName(), copyObjectRequest.getSourceKey(), copyObjectRequest.getDestinationBucketName(), copyObjectRequest.getDestinationKey());
      uploadPartCopyRequest.setUploadId(uploadId);
      uploadPartCopyRequest.setPartSize(curPartSize);
      uploadPartCopyRequest.setBeginIndex(startPos);
      uploadPartCopyRequest.setPartNumber(i + 1);
      futures.add(threadPoolExecutor.submit(new PartCopyCallable(uploadPartCopyRequest)));
    }

    List<PartETag> partETags = collectPartETags(futures);
    //Verify whether all parts are finished
    if (partETags.size() != totalParts) {
      throw new IllegalStateException("Upload multi-parts fail due to some parts are not finished yet");
    } else {
      LOG.info("Succeed to complete multi-parts copy from object named {} to {}", copyObjectRequest.getSourceKey(), copyObjectRequest.getDestinationKey());
    }

    //Complete to upload multi-parts
    System.out.println("Completing to upload multiparts\n");
    CompleteMultipartUploadRequest completeMultipartUploadRequest = new CompleteMultipartUploadRequest(
            copyObjectRequest.getDestinationBucketName(), copyObjectRequest.getDestinationKey(), uploadId, partETags);
    CompleteMultipartUploadResult completeMultipartUploadResult = this.completeMultipartUpload(completeMultipartUploadRequest);
    CopyObjectResult result = new CopyObjectResult();
    result.setEtag(completeMultipartUploadResult.getETag());
    return result;
  }
 

import com.aliyun.oss.model.ObjectMetadata; //导入依赖的package包/类
private boolean isMultipartCopy(ObjectMetadata metadata) {
  return (metadata.getContentLength() > configuration.getMultipartCopyThreshold());
}
 

import com.aliyun.oss.model.ObjectMetadata; //导入依赖的package包/类
public String storeWithFileName(String bucketName, File file, ObjectMetadata meta){
	String key = FileUtils.getFileName(file.getPath());
	objectOperation(bucketName, key).store(file, meta);
	return getUrl(true, bucketName, key);
}