Microsoft Azure上的Storage服务看起来非常牛逼,它是用来在云端存储数据和文件的服务,比如Azure里的虚拟机就是保存在Storage中的。当然我们可以用Storage做更多的事,比如有些数据并不适合存放在关系型数据库中,就像图片和附件,我们就可以使用Storage服务。
今天介绍的是Storage里的一种,Blob Storage。Windows Azure Storage还有其他两种存储:Table和Queue,但是我只开荒过Blob Storage,所以其他两个就只能以后介绍了。
使用Blob存储首先得建立一个Storage Account,Account中包含的是Container,这类似于文件夹,最后你的文件会存放在Container下,也就是Blob。
它们的关系就像这样(可耻的盗用了一张Azure官网的图片):
一、在Azure管理页面中建立Storage Account
1. 在Windows Azure管理页面中点击工具栏上的New按钮,如图,新建一个Storage Account。Geo-Replication可以不选,它是用来做异地备份的,但会要你掏额外的钱。
2. 创建好之后,我们可以直接在Azure管理页面里创建Container,当然,也可以通过编程方式来实现,不过不是这次介绍的范围。
ACCESS的意思是这个Container的访问权限,根据自己需要设置。创建完成之后就像这样:
URL是我们访问这个Container的地址,非常重要。
二、通过编程方式访问Blob Storage
首先要说明的是,你并不需要安装Azure SDK,也并不需要建立Cloud Service的项目。任何一个普通的.NET项目,比如Console Application,都可以通过安装NuGet包的方式得到Windows Azure的API。
这个例子里我用的就是Console Application。
1. 通过NuGet安装“Windows Azure Storage”,安装时候会把其他几个包自动带上,我们仅需要这些就可以了。
2. 配置Storage Account的连接字符串。
在App.config中加一个新的appSettings,名为diaospublicblob,稍候代码里会读这个连接字符串。
<appSettings> <add key="diaospublicblob" value="DefaultEndpointsProtocol=https;AccountName=eas01;AccountKey=×××××××××;BlobEndpoint=http://eas01.blob.core.windows.net/" /> </appSettings>
AccountKey可以在Azure管理界面上找到. 在你的Storage Account的页面下方的工具栏上,点击Manage Keys就有了。这里我们只需要Primary Access Key。
BlobEndPoint的地址同样在Azure的管理页面中可以找到:
3. 对Blob的任何操作都必须先获得Container的实例,代码如下:
// connect to azure storage
var storageAccount = CloudStorageAccount.Parse(CloudConfigurationManager.GetSetting("diaospublicblob"));
var blobClient = storageAccount.CreateCloudBlobClient();
var container = blobClient.GetContainerReference("diaostainer");
CloudConfigurationManager.GetSetting(string)的作用就是从刚才的App.config中读取Blob Storage的连接字符串。
必要的API都在这些命名空间里:
using Microsoft.WindowsAzure;
using Microsoft.WindowsAzure.Storage;
using Microsoft.WindowsAzure.Storage.Blob;
4. 向Container中上传本地文件:
private static void UploadFileToContainer(CloudBlobContainer container, string filePath, string uplodedFileName)
{
var blockBlob = container.GetBlockBlobReference(uplodedFileName);
using (var fileStream = System.IO.File.OpenRead(filePath))
{
blockBlob.UploadFromStream(fileStream);
}
}
// upload file
UploadFileToContainer(container, @"E:\Fuck.txt", "Fuck.txt");
上传之后可以直接在Azure的管理界面里看到这个文件。也可以直接下载。
如果碰到重名的话,本地文件将会替换Azure上的文件。
5. 显示Container中的文件列表
private static void ListBlobsInContainer(CloudBlobContainer container)
{
foreach (var item in container.ListBlobs(null, false))
{
if (item is CloudBlockBlob)
{
var blob = (CloudBlockBlob) item;
Console.WriteLine("Block blob of length {0}: {1}", blob.Properties.Length, blob.Uri);
}
else if (item is CloudPageBlob)
{
var pageBlob = (CloudPageBlob) item;
Console.WriteLine("Page blob of length {0}: {1}", pageBlob.Properties.Length, pageBlob.Uri);
}
else if (item is CloudBlobDirectory)
{
var directory = (CloudBlobDirectory) item;
Console.WriteLine("Directory: {0}", directory.Uri);
}
}
}
结果如图
6. 下载文件到本地硬盘
private static void DownloadBlobFromContainer(CloudBlobContainer container, string blobName, string downloadFilePath)
{
var blockBlob = container.GetBlockBlobReference(blobName);
using (var fileStream = System.IO.File.OpenWrite(downloadFilePath))
{
blockBlob.DownloadToStream(fileStream);
}
}
// download file
DownloadBlobFromContainer(container, "Fuck.txt", @"E:\Fucked.txt");
7. 删除文件
private static void DeleteBlobFromContainer(CloudBlobContainer container, string blobName)
{
CloudBlockBlob blockBlob = container.GetBlockBlobReference(blobName);
blockBlob.Delete();
}
// delete file
DeleteBlobFromContainer(container, "Fuck.txt");