Windows Azure入门教学系列 (七):使用REST API访问Storage Service

简介: 本文是Windows Azure入门教学的第七篇文章。 本文将会介绍如何使用REST API来直接访问Storage Service。 在前三篇教学中,我们已经学习了使用Windows Azure SDK所提供的StorageClient来使用Blob Storage, Queue Storage以及Table Storage的基本方法。

本文是Windows Azure入门教学的第七篇文章。

本文将会介绍如何使用REST API来直接访问Storage Service。

在前三篇教学中,我们已经学习了使用Windows Azure SDK所提供的StorageClient来使用Blob Storage, Queue Storage以及Table Storage的基本方法。我们在前几篇教学中也提及最终StorageClient也是通过发送REST请求来与服务器端通信的。

在这篇教学中,我们会以Blob Storage为例,说明如何使用REST API直接与服务器进行通信。需要说明的是,这篇教学中使用的是C#语言。但是由于REST API实际上是通过HTTP发送的HTTP消息,使用其他语言的工程师同样可以参考代码逻辑了解如何构造HTTP消息以便在其他编程语言中使用。

在开始本教学之前,请确保你从Windows Azure 平台下载下载并安装了最新的Windows Azure开发工具。本教学使用Visual Studio 2010作为开发工具。

步骤一:准备工作

在本教学中我们将使用List Blobs API,欲了解详细信息,请参见List Blobs

该API的作用是返回给定的Container中的Blob信息。为了测试我们的代码我们首先需要有一个已经创建的Container并且向其中添加至少一个Blob。由于如何添加Container和Blob的方法我们已经在Windows Azure入门教学系列 (四):使用Blob Storage中提过,在此不赘述。读者可以按照Windows Azure入门教学系列 (四):使用Blob Storage中的代码创建名为helloworldcontainer的Container和名为myfile的Blob。(只需注释掉删除Blob的代码并运行程序即可)

步骤二:创建解决方案和项目

首先,请确保Storage Emulator已经启动。我们可以找到管理器的进程手动启动或者让Visual Studio 2010帮助我们启动他。

右击工具栏中Windows Azure模拟器的图标,选择”Show Storage Emulator UI”。弹出如下图所示的窗口:

我们要关注的是Service management中Blob所在的一行。要确保Status为Running。

确认完毕后启动Visual Studio 2010,并且新建一个Console项目。

步骤三:添加程序集引用

请在项目属性页里确认项目的Target framework的值是.NET Framework 4或.NET Framework 3.5。然后在Console项目中添加对System.Web程序集的引用。该程序集安装在GAC中。在.NET标签下能够找到该程序集。我们将使用该程序集来发送HTTP请求和接受HTTP消息。

步骤四:添加代码

首先在项目中的Program.cs中引用命名空间:

1
2
3
4
5
6
7
8
9
using System.IO;
 
using System.Collections.Specialized;
 
using System.Collections;
 
using System.Web;
 
using System.Net;

然后在Program.cs中添加如下代码:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
class Program
 
{
 
     internal class CanonicalizedString
 
     {
 
         private StringBuilder canonicalizedString = new StringBuilder();
 
  
 
         internal CanonicalizedString(string initialElement)
 
         {
 
             this.canonicalizedString.Append(initialElement);
 
         }
 
  
 
         internal void AppendCanonicalizedElement(string element)
 
         {
 
             this.canonicalizedString.Append("n");
 
             this.canonicalizedString.Append(element);
 
         }
 
         internal string Value
 
         {
 
             get
 
             {
 
                 return this.canonicalizedString.ToString();
 
             }
 
         }
 
     }
 
  
 
     const string bloburi = @"http://127.0.0.1:10000/devstoreaccount1";
 
     const string accountname = "devstoreaccount1";
 
     const string key = "Eby8vdM02xNOcqFlqUwJPLlmEtlCDXJ1OUzFT50uSRZ6IFsuFq2UVErCz4I6tq/K1SZFPTOtr/KBHBeksoGMGw==";
 
     const string method = "GET";
 
  
 
     static void Main(string[] args)
 
     {
 
         string AccountName = accountname;
 
         string AccountSharedKey = key;
 
         string Address = bloburi;
 
         string container = "helloworldcontainer";
 
  
 
         // 创建请求字符串
 
         string QueryString = "?restype=container&comp=list";
 
         Uri requesturi = new Uri(Address + "/" + container + QueryString);
 
         string MessageSignature = "";
 
  
 
         // 创建HttpWebRequest类
 
         HttpWebRequest Request = (HttpWebRequest)HttpWebRequest.Create(requesturi.AbsoluteUri);
 
         Request.Method = method;
 
         Request.ContentLength = 0;
 
         Request.Headers.Add("x-ms-date", DateTime.UtcNow.ToString("R"));
 
         Request.Headers.Add("x-ms-version", "2009-09-19");
 
  
 
         // 开始创建签名
 
         MessageSignature += "GETn"; // Verb
 
         MessageSignature += "n"; // Content-Encoding
 
         MessageSignature += "n"; // Content-Language
 
         MessageSignature += "n"; // Content-Length
 
         MessageSignature += "n"; // Content-MD5
 
         MessageSignature += "n"; // Content-Type
 
         MessageSignature += "n"; // Date
 
         MessageSignature += "n"; // If-Modified-Since
 
         MessageSignature += "n"; // If-Match
 
         MessageSignature += "n"; // If-None-Match
 
         MessageSignature += "n"; // If-Unmodified-Since
 
         MessageSignature += "n"; // Range
 
  
 
         // CanonicalizedHeaders
 
         ArrayList list = new ArrayList();
 
         foreach (string str in Request.Headers.Keys)
 
         {
 
             if (str.ToLowerInvariant().StartsWith("x-ms-", StringComparison.Ordinal))
 
             {
 
                 list.Add(str.ToLowerInvariant());
 
             }
 
         }
 
         list.Sort();
 
         foreach (string str2 in list)
 
         {
 
             StringBuilder builder = new StringBuilder(str2);
 
             string str3 = ":";
 
             foreach (string str4 in GetHeaderValues(Request.Headers, str2))
 
             {
 
                 string str5 = str4.Replace("rn", string.Empty);
 
                 builder.Append(str3);
 
                 builder.Append(str5);
 
                 str3 = ",";
 
             }
 
             MessageSignature += builder.ToString() + "n";
 
         }
 
         MessageSignature += GetCanonicalizedResourceVersion2(requesturi, AccountName);
 
  
 
         // 开始创建签名
 
         byte[] SignatureBytes = System.Text.Encoding.UTF8.GetBytes(MessageSignature);
 
         System.Security.Cryptography.HMACSHA256 SHA256 = newSystem.Security.Cryptography.HMACSHA256(Convert.FromBase64String(AccountSharedKey));
 
  
 
         // 创建Authorization HTTP消息头的值
 
         String AuthorizationHeader = "SharedKey " + AccountName + ":" + Convert.ToBase64String(SHA256.ComputeHash(SignatureBytes));
 
  
 
         // 把编码后的签名加入到Authorization HTTP消息头中
 
         Request.Headers.Add("Authorization", AuthorizationHeader);
 
  
 
         // 获取返回消息
 
         using (HttpWebResponse response = (HttpWebResponse)Request.GetResponse())
 
         {
 
             if (response.StatusCode == HttpStatusCode.OK)
 
             {
 
                 // 服务器返回成功消息
 
                 using (Stream stream = response.GetResponseStream())
 
                 {
 
                     using (StreamReader sr = new StreamReader(stream))
 
                     {
 
  
 
                         var s = sr.ReadToEnd();
 
                         // 输出返回消息
 
                         Console.WriteLine(s);
 
                     }
 
  
 
                 }
 
             }
 
             else
 
             {
 
                 // 这里可以抛出异常信息
 
             }
 
         }
 
         Console.ReadLine();
 
  
 
     }
 
  
 
     static ArrayList GetHeaderValues(NameValueCollection headers, string headerName)
 
     {
 
         ArrayList list = new ArrayList();
 
         string[] values = headers.GetValues(headerName);
 
         if (values != null)
 
         {
 
             foreach (string str in values)
 
             {
 
                 list.Add(str.TrimStart(new char[0]));
 
             }
 
         }
 
         return list;
 
     }
 
  
 
     static string GetCanonicalizedResourceVersion2(Uri address, string accountName)
 
     {
 
         StringBuilder builder = new StringBuilder("/");
 
         builder.Append(accountName);
 
         builder.Append(address.AbsolutePath);
 
         CanonicalizedString str = new CanonicalizedString(builder.ToString());
 
         NameValueCollection values = HttpUtility.ParseQueryString(address.Query);
 
         NameValueCollection values2 = new NameValueCollection();
 
         foreach (string str2 in values.Keys)
 
         {
 
             ArrayList list = new ArrayList(values.GetValues(str2));
 
             list.Sort();
 
             StringBuilder builder2 = new StringBuilder();
 
             foreach (object obj2 in list)
 
             {
 
                 if (builder2.Length > 0)
 
                 {
 
                     builder2.Append(",");
 
                 }
 
                 builder2.Append(obj2.ToString());
 
             }
 
             values2.Add((str2 == null) ? str2 : str2.ToLowerInvariant(), builder2.ToString());
 
         }
 
         ArrayList list2 = new ArrayList(values2.AllKeys);
 
         list2.Sort();
 
         foreach (string str3 in list2)
 
         {
 
             StringBuilder builder3 = new StringBuilder(string.Empty);
 
             builder3.Append(str3);
 
             builder3.Append(":");
 
             builder3.Append(values2[str3]);
 
             str.AppendCanonicalizedElement(builder3.ToString());
 
         }
 
         return str.Value;
 
     }
 
}

步骤五:观察并分析代码

我们首先观察下面三行代码:

1
2
3
4
5
const string bloburi = @"http://127.0.0.1:10000/devstoreaccount1";
 
const string accountname = "devstoreaccount1";
 
const string key = "Eby8vdM02xNOcqFlqUwJPLlmEtlCDXJ1OUzFT50uSRZ6IFsuFq2UVErCz4I6tq/K1SZFPTOtr/KBHBeksoGMGw==";

这三行代码定义了Blob Storage服务端口,我们使用的账户名和密码。由于使用的是本地模拟的Storage,所以必须使用固定的端口地址,用户名以及密码。可以参考Development Storage与Windows Azure Storage Services的不同之处获取更多信息。

在代码中,我们使用HttpWebRequest 构造并发送HTTP请求。由于我们的例子中使用的是List Blobs API我们需要查阅List Blobs对该API的规定构造符合规定的HTTP请求。

在规定中说明了如果该container没有被设置为允许匿名访问,那么必须由于账户拥有者调用该API才能返回结果。要这样做必须添加Authorization HTTP消息头。我们必须严格按照Authentication Schemes规定的格式来生成该HTTP消息头。

步骤六:运行程序

如果一切正常,你将会看到Console程序输出如下信息,内容为名为helloworld的Container中所有Blob的信息:

目录
相关文章
|
22天前
|
Java API Maven
使用Java Libvirt API 访问虚拟机信息
使用Java Libvirt API 访问虚拟机信息
13 1
|
1月前
|
Kubernetes 安全 Cloud Native
云上攻防-云原生篇&Kubernetes&K8s安全&API&Kubelet未授权访问&容器执行
云上攻防-云原生篇&Kubernetes&K8s安全&API&Kubelet未授权访问&容器执行
|
1月前
|
人工智能 自然语言处理 搜索推荐
Elasticsearch 开放 inference API 增加了对 Azure OpenAI 嵌入的支持
【6月更文挑战第8天】Elasticsearch 推出开放 inference API,支持 Azure OpenAI 嵌入,强化搜索和数据分析能力。此更新使用户能灵活集成 AI 技术,实现智能精准搜索。Azure OpenAI 的语言理解能力优化了用户查询处理,提升搜索相关性。示例代码显示了如何结合两者处理查询。该创新提升数据检索效率,适用于智能客服和推荐系统,但也带来数据安全和模型准确性等挑战。这标志着搜索和数据分析领域的智能化新阶段,期待更多创新应用。未来,我们需要持续探索和完善,以发挥技术的最大潜力。
32 3
|
18天前
|
JavaScript 前端开发 定位技术
vue 使用 vue-jsonp 解决跨域请求问题(访问百度地图API)
vue 使用 vue-jsonp 解决跨域请求问题(访问百度地图API)
22 0
|
1月前
|
机器学习/深度学习 数据采集 文字识别
印刷文字识别产品使用合集之需要对子用户加什么权限,才能通过API访问
印刷文字识别产品,通常称为OCR(Optical Character Recognition)技术,是一种将图像中的印刷或手写文字转换为机器编码文本的过程。这项技术广泛应用于多个行业和场景中,显著提升文档处理、信息提取和数据录入的效率。以下是印刷文字识别产品的一些典型使用合集。
|
2月前
|
XML API 网络架构
Web Service和Web API理解和使用场景
**Web Service**是一种基于网络、使用SOAP协议和XML的数据封装的重服务,适用于跨平台、跨语言的企业系统集成,尤其在安全性和事务处理严格的场景,如银行系统。而**Web API**是轻量级的HTTP接口,常遵循REST原则,使用JSON格式,适合移动应用、开放平台和微服务间的通信,因其简洁高效。选择哪种取决于项目需求,Web Service适合复杂交互,Web API则流行于现代Web应用。
|
1月前
|
运维 Serverless API
Serverless 应用引擎产品使用合集之SD API模式可以通过什么方式进行访问
阿里云Serverless 应用引擎(SAE)提供了完整的微服务应用生命周期管理能力,包括应用部署、服务治理、开发运维、资源管理等功能,并通过扩展功能支持多环境管理、API Gateway、事件驱动等高级应用场景,帮助企业快速构建、部署、运维和扩展微服务架构,实现Serverless化的应用部署与运维模式。以下是对SAE产品使用合集的概述,包括应用管理、服务治理、开发运维、资源管理等方面。
|
2月前
|
前端开发 Java 应用服务中间件
在虚拟机的Windows操作系统中:通过Jar方式若依项目,以及在外部的访问!
在虚拟机的Windows操作系统中:通过Jar方式若依项目,以及在外部的访问!
|
2月前
|
JSON 自然语言处理 Dart
私有化部署 Llama3 大模型, 支持 API 访问
通过 ollama 本地运行 Llama3 大模型其实对我们开发来说很有意义,你可以私有化放服务上了。 然后通过 api 访问,来处理我们的业务,比如翻译多语言、总结文章、提取关键字等等。 你也可以安装 enchanted 客户端去直接访问这个服务 api 使用。
655 0
私有化部署 Llama3 大模型, 支持 API 访问
|
2月前
|
Apache 项目管理 数据安全/隐私保护
Windows如何安装使用TortoiseSVN客户端并实现公网访问本地SVN Server
Windows如何安装使用TortoiseSVN客户端并实现公网访问本地SVN Server
48 0