KS3 SDK For C#使用指南

static String accessKey = "YOUR ACCESS KEY";
static String secretKey = "YOUR SECRET KEY";
static String bucketName = "YOUR BUCKET NAME";
static String objKeyName = "YOUR OBJECT KEY";
static KS3Client ks3Client = new KS3Client(accessKey, secretKey);

private static bool listBuckets()
	{
        // List Buckets
		try
		{
			IList<Bucket> bucketsList = ks3Client.listBuckets();
			foreach (Bucket b in bucketsList)
			{
				Console.WriteLine(b.ToString());
			}
		}
		catch (System.Exception e)
		{
			return false;
		}
		return true;
	}

private static bool deleteBucket()
	{
        // Delete Bucket
        try
        {
            ks3Client.deleteBucket(bucketName);
		}
        catch (System.Exception e)
        {
			return false;
        }
		return true;
    }

private static bool listObjects()
	{
		try
		{
			// List Objects
			Console.WriteLine("--- List Objects: ---");

			ObjectListing objects = ks3Client.listObjects(bucketName);

			Console.WriteLine(objects.ToString());
			Console.WriteLine("---------------------\n");

			// Get Object Metadata
			Console.WriteLine("--- Get Object Metadata ---");

			ObjectMetadata objMeta = ks3Client.getObjectMetadata(bucketName, objKeyName); 
			Console.WriteLine(objMeta.ToString());
			
			Console.WriteLine("---------------------------\n");
		}
		catch (System.Exception e)
		{
			Console.WriteLine(e.ToString());		
			return false;
		}

		return true;
	}

private static bool getBucketACL()
	{
        // Get Bucket ACL
        try 
		{
			Console.WriteLine("--- Get Bucket ACL: ---");
        
		    AccessControlList acl = ks3Client.getBucketAcl(bucketName);
            Console.WriteLine("Bucket Name: " + bucketName);
            Console.WriteLine(acl.ToString());

			Console.WriteLine("-----------------------\n");
		}
		catch (System.Exception e)
		{
			Console.WriteLine(e.ToString());
			return false;
		}

		return true;
	}

 private static ListMultipartUploadsResult listMultipartUploads(string bucket,string objKey,string uploadId) {
        ListMultipartUploadsRequest request = new ListMultipartUploadsRequest(bucket,objKey,uploadId);
        ListMultipartUploadsResult result =ks3Client.getListMultipartUploads(request);
        return result;
    }

private static bool createBucket()
	{
        // Create Bucket
		try
		{
            Console.WriteLine("--- Create Bucket: ---");
            Console.WriteLine("Bucket Name: " + bucketName);

			Bucket bucket = ks3Client.createBucket(bucketName);

			Console.WriteLine("Success.");
			Console.WriteLine("----------------------\n");
		}
		catch (System.Exception e)
		{
			Console.WriteLine("Create Bucket Fail! " + e.ToString());				
			return false;
		}

		return true;
	}

private static bool setBucketACL()
	{
        // Set Bucket ACL
		try 
		{
			Console.WriteLine("--- Set Bucket ACL: ---");

			CannedAccessControlList cannedAcl = new CannedAccessControlList(CannedAccessControlList.PUBLICK_READ_WRITE);
			ks3Client.setBucketAcl(bucketName, cannedAcl);

            Console.WriteLine("Bucket Name: " + bucketName);
			Console.WriteLine("Success, now the ACL is:\n" + ks3Client.getBucketAcl(bucketName));
			Console.WriteLine("-----------------------\n");
		}
		catch (System.Exception e)
		{
			Console.WriteLine(e.ToString());
			return false;
		}

		return true;
	}

private static bool deleteObject()
	{
		// Delete Object
		try
		{
			Console.WriteLine("--- Delete Object: ---");

			ks3Client.deleteObject(bucketName, objKeyName);

			Console.WriteLine("Delete Object completed.");
			Console.WriteLine("---------------------\n");
		}
		catch (Exception e)
		{
			Console.WriteLine(e.ToString());
			return false;
		}
		
		return true;
	}

private static bool getObject()
	{
		try
		{
            // GET Object为用户提供了object的下载，用户可以通过控制Range实现分块多线程下载
			Console.WriteLine("--- Download and Store in Memory ---");
			
			GetObjectRequest getShortContent = new GetObjectRequest(bucketName, objKeyName);
			getShortContent.setRange(0, 24);
			KS3Object ks3Object = ks3Client.getObject(getShortContent);
			
			StreamReader sr = new StreamReader(ks3Object.getObjectContent());
			Console.WriteLine("Content:\n" + sr.ReadToEnd());
			sr.Close();
			ks3Object.getObjectContent().Close();
			
			Console.WriteLine("------------------------------------\n");
		}
		catch (System.Exception e)
		{
			Console.WriteLine(e.ToString());
			return false;
		}


		try
		{
            // 直接下载并存储成文件
			Console.WriteLine("--- Download a File ---");

			// I need to get the Content-Length to set the listener.
			ObjectMetadata objectMetadata = ks3Client.getObjectMetadata(bucketName, objKeyName); 
			
			SampleListener downloadListener = new SampleListener(objectMetadata.getContentLength());
			GetObjectRequest getObjectRequest = new GetObjectRequest(bucketName, objKeyName, new FileInfo(outFilePath));
			getObjectRequest.setProgressListener(downloadListener);
			KS3Object obj = ks3Client.getObject(getObjectRequest);
			obj.getObjectContent().Close(); // The file was opened in [KS3ObjectResponseHandler], so I close it first. 
			
			Console.WriteLine("Success. See the file downloaded at {0}", outFilePath);
			Console.WriteLine("-----------------------\n");
		}
		catch (System.Exception e)
		{
			Console.WriteLine(e.ToString());
			return false;
		}

		return true;
	}

private static bool getObjectACL()
    {
        // Get Object ACL
        try
        {
            Console.WriteLine("--- Get Object ACL: ---");

            AccessControlList acl = ks3Client.getObjectAcl(bucketName ,objKeyName);
            Console.WriteLine("Object Key: " + objKeyName);
            Console.WriteLine(acl.ToString());

            Console.WriteLine("-----------------------\n");
        }
        catch (System.Exception e)
        {
            Console.WriteLine(e.ToString());
            return false;

        }

        return true;
    }

private static bool putObject()
	{
		try
        {
             //Put Object(upload a short content)
	 //以流方式上传文件到KS3，Content-Type 默认为 application/octet-stream
            Console.WriteLine("--- Upload a Short Content: ---");

            String sampleContent = "This is a sample content.(25 characters before, included the 4 spaces)";
            Stream stream = new MemoryStream(Encoding.UTF8.GetBytes(sampleContent));
            PutObjectResult shortContentResult = ks3Client.putObject(bucketName, objKeyName, stream, null);

            Console.WriteLine("Upload Completed. eTag=" + shortContentResult.getETag() + ", MD5=" + shortContentResult.getContentMD5());
            Console.WriteLine("-------------------------------\n");

             //Put Object(upload a file)
	 //以文件方式上传到KS3时，Content-Type 会默认匹配上传文件的后缀名
			Console.WriteLine("--- Upload a File ---");

			FileInfo file = new FileInfo("E:\\tool\\eclipse.rar");
			PutObjectRequest putObjectRequest = new PutObjectRequest(bucketName, objKeyName, file);
			SampleListener sampleListener = new SampleListener(file.Length);
			putObjectRequest.setProgressListener(sampleListener);
			PutObjectResult putObjectResult = ks3Client.putObject(putObjectRequest);
			
			Console.WriteLine("Upload Completed. eTag=" + putObjectResult.getETag() + ", MD5=" + putObjectResult.getContentMD5());
			Console.WriteLine("---------------------\n");
		}
		catch (System.Exception e) 
		{
			Console.WriteLine(e.ToString());
			return false;
		}

		return true;
	}

 private static bool setObjectACL()
    {
        // Set Object ACL
        try
        {
            Console.WriteLine("--- Set Object ACL: ---");

            CannedAccessControlList cannedAcl = new CannedAccessControlList(CannedAccessControlList.PUBLICK_READ_WRITE);
            Console.WriteLine("Object Key: " + objKeyName);
            ks3Client.setObjectAcl(bucketName, objKeyName, cannedAcl);

            Console.WriteLine("Success, now the ACL is:\n" + ks3Client.getObjectAcl(bucketName, objKeyName));
            Console.WriteLine("-----------------------\n");
        }
        catch (System.Exception e)
        {
            Console.WriteLine(e.ToString());
            return false;
        }

        return true;
    }

/**
     * 初始化分块上传，服务端会返回一个全局唯一的uploadid
     * **/
    private static InitiateMultipartUploadResult multipartUp()
    {
        InitiateMultipartUploadResult re=ks3Client.initiateMultipartUpload(bucketName, objKeyName);
        Console.WriteLine(re.ToString());
        return re;
    }
    /**
     * 分块上传例子
     * **/
    private static bool uploadPart() {
        string path = @"you file path";//上传文件路径,例如E:\tool\aa.rar
        InitiateMultipartUploadResult result=multipartUp();
        FileInfo file = new FileInfo(path);
        int part = 5 * 1024 * 1024;
        int numBytesToRead = (int)file.Length;
        int i = 0;
        XElement root = new XElement("CompleteMultipartUpload");//初始化一个xml，以备分块上传完成后调用complete方法提交本次上传的文件以通知服务端合并分块
        //开始读取文件
        using (FileStream fs = new FileStream(path, FileMode.Open))
        {
            while (numBytesToRead > 0)
            {
                UploadPartRequest request = new UploadPartRequest(
                        result.getBucket(), result.getKey(), result.getUploadId(),
                        i + 1);
                //每次读取5M文件内容，如果最后一次内容不及5M则按实际大小取值
                int count = Convert.ToInt32((i * part + part) > file.Length ? file.Length - i * part : part);
                byte[] data = new byte[count];
                int n = fs.Read(data, 0, count);
                request.setInputStream(new MemoryStream(data));
                ProgressListener sampleListener = new SampleListener(count);//实例一个更新进度的监听类，实际使用中可自己定义实现
                request.setProgressListener(sampleListener);
                PartETag tag = ks3Client.uploadPart(request);//上传本次分块内容
                Console.WriteLine(tag.ToString());
                if (n == 0)
                    break;
                numBytesToRead -= n;
               
                XElement partE = new XElement("Part");
                partE.Add(new XElement("PartNumber", i + 1));
                partE.Add(new XElement("ETag", tag.geteTag()));
                root.Add(partE);
                i++;
            }
        }
        //所有分块上传完成后发起complete request，通知服务端合并分块
        CompleteMultipartUploadRequest completeRequest = new CompleteMultipartUploadRequest(result.getBucket(), result.getKey(), result.getUploadId());
        completeRequest.setContent(new MemoryStream(System.Text.Encoding.Default.GetBytes(root.ToString())));
        CompleteMultipartUploadResult completeResult = ks3Client.completeMultipartUpload(completeRequest);
        return true;
    }

    /**
     * 放弃本次上传
     * **/
    private static bool AbortMultipartUpload(string bucket, string objKey, string uploadId)
    {
        AbortMultipartUploadRequest request = new AbortMultipartUploadRequest(bucket, objKey, uploadId);
        ks3Client.AbortMultipartUpload(request);
        return true;
    }

/**
    * 多线程分块上传例子开始
    * **/
    static List<ManualResetEvent> manualEvents = new List<ManualResetEvent>();
    static List<Param> paras = new List<Param>();

    private static bool uploadPartMultithread()
    {
        string path = inFilePath;//上传文件路径,例如E:\tool\aa.rar
        InitiateMultipartUploadResult result = multipartUp();
        FileInfo file = new FileInfo(path);
        int part = 5 * 1024 * 1024;
        int numBytesToRead = (int)file.Length;
        int i = 0;
        XElement root = new XElement("CompleteMultipartUpload");//初始化一个xml，以备分块上传完成后调用complete方法提交本次上传的文件以通知服务端合并分块
        //开始读取文件
        using (FileStream fs = new FileStream(path, FileMode.Open))
        {
            while (numBytesToRead > 0)
            {
                UploadPartRequest request = new UploadPartRequest(
                        result.getBucket(), result.getKey(), result.getUploadId(),
                        i + 1);
                //每次读取5M文件内容，如果最后一次内容不及5M则按实际大小取值
                int count = Convert.ToInt32((i * part + part) > file.Length ? file.Length - i * part : part);
                byte[] data = new byte[count];
                int n = fs.Read(data, 0, count);
                request.setInputStream(new MemoryStream(data));

                ManualResetEvent mre = new ManualResetEvent(false);
                manualEvents.Add(mre);

                Param pra = new Param();
                pra.mrEvent = mre;
                pra.praNum = i + 1;
                pra.request = request;
                paras.Add(pra);

                ThreadPool.QueueUserWorkItem(new WaitCallback(uploadPartTask), pra);
                if (n == 0)
                    break;
                numBytesToRead -= n;
                i++;
            }
        }

        WaitHandle.WaitAll(manualEvents.ToArray());

        for (int j = 0; j < paras.Count; j++)
        {
            XElement partE = new XElement("Part");
            partE.Add(new XElement("PartNumber", paras[j].praNum));
            partE.Add(new XElement("ETag", paras[j].etag));
            Console.WriteLine("==" + paras[j].praNum + ", etag=" + paras[j].etag);
            root.Add(partE);
        }

        //所有分块上传完成后发起complete request，通知服务端合并分块
        CompleteMultipartUploadRequest completeRequest = new CompleteMultipartUploadRequest(result.getBucket(), result.getKey(), result.getUploadId());
        completeRequest.setContent(new MemoryStream(System.Text.Encoding.Default.GetBytes(root.ToString())));
        CompleteMultipartUploadResult completeResult = ks3Client.completeMultipartUpload(completeRequest);
        return true;
    }

    private static void uploadPartTask(Object obj) {
        Param pra = (Param)obj;
        UploadPartRequest request = pra.request;
        PartETag tag = ks3Client.uploadPart(request);//上传本次分块内容
        if (tag.geteTag() != null) {
            pra.etag = tag.geteTag();                
            pra.mrEvent.Set();
            Console.WriteLine(tag.ToString());
        }
    }

    public class Param
    {
        public ManualResetEvent mrEvent;
        public UploadPartRequest request;
        public int praNum;
        public string etag;
    }
    /**
    * 多线程分块上传例子结束
    * */