【第11篇】Windows Azure兰州拉面馆-日志与队列的使用

2023-10-21 16:59

本文主要是介绍【第11篇】Windows Azure兰州拉面馆-日志与队列的使用,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

第9篇里,为了便于大家理解,我把Windows Azure的环境比喻成了"Azure兰州拉面馆"。本篇我们继续沿用这个比喻,讲讲Windows Azure中的队列(Queue Storage)与日志的使用。

 

Queue Storage【Azure Services Platform. Step by Step-第9篇】Windows Azure Storage概览里介绍过,这里就不再重复了。顾名思义,Queue就是队列,按照先进先出的顺序来处理数据。在上图的“Azure兰州拉面馆”中,Queue就充当了记录点菜情况的小本子,前台服务员将顾客点的菜记录在Queue中,后台厨房的厨师则按照Queue中的顺序,一个一个地做菜(处理数据)。

Windows Azure Log是整个Azure平台运行情况的日志。微软官方把Windows Azure比喻成“云平台的操作系统”,既然是操作系统,当然会维护日志了!Windows Azure里提供了非常简单记录日志的办法,但很遗憾地是没有提供同样简单地查看日志的办法——换句话说,通过程序记录日志容易,查看日志繁琐。为了不偏题,本篇只展示如何在Development Fabric里查看日志。对于如何编程读取日志,感兴趣的读者可以参考WPF应用程序AzureLogViewer的源代码(见篇末附件)。

 

实验步骤:

 

第一步:

在VS2008中新建Web And Worker Cloud Service。这也是本系列文章中第一次用到Worker Role。

第9篇一样,添加对StorageClient的引用。

image

image

 

第二步:

运行Azure SDK里的imageimage ,并启动Development Storage里的Queue服务。

image

 

第三步:

配置好ServiceConfiguration.cscfg和ServiceDefinition.csdef。如有疑问,请参考【Azure Services Platform. Step by Step-第8篇】开发部署Azure留言板或本文篇末附件内的示例代码。

image

 

 

第四步:

打开Web Role项目的Default.aspx,拖入以下控件:

TextBox txtMessage
Button btnSend
TextBox txtLog

image

第五步:
Button btnSend的Click中加入btnSend_Click。代码如下。
protected void btnSend_Click(object sender, EventArgs e)
{
//读取Queue服务的配置。注意:RoleManager.GetConfigurationSetting获取的是  
//service configuration(即ServiceConfiguration.cscfg文件)里的配置。
Uri baseUri = new Uri(RoleManager.GetConfigurationSetting("QueueEndpoint")); string accountName = RoleManager.GetConfigurationSetting("AccountName"); string accountKey = RoleManager.GetConfigurationSetting("AccountSharedKey"); //初始化StorageAccountInfo实体。 StorageAccountInfo account = new StorageAccountInfo( baseUri, null, accountName, accountKey); //创建一个QueueStorage(即Queue Storage服务)的实体 QueueStorage service = QueueStorage.Create(account); //创建一个MessageQueue(即队列)的实体。 //这个queue就是咱们Azure拉面馆的“记菜本”了 //我们把这个记菜本取名为"message"。 MessageQueue queue = service.GetQueue("messages"); //判断当前Queue Storage服务中是否已经存在"message" if (!queue.DoesQueueExist()) { queue.CreateQueue(); } //把点菜信息记录到记菜本中! Message msg = new Message(txtMessage.Text); queue.PutMessage(msg); txtLog.Text += "\n你在"+DateTime.Now.ToString("HH点mm分ss秒")+"点了一份\"" + txtMessage.Text.Trim()+'\"'; txtMessage.Text = string.Empty; }
最关键的就是一步:queue.PutMessage(msg); 就这样很轻松地把消息存入队列了。
 

第六步:

打开WorkerRole项目里的WorkerRole.cs。我们首先要对Start()进行override 。

Start()函数可以理解为Worker Role的入口函数。一旦Worker Role被部署,就会触发Start()。

我们讨论过,Worker Role的牛X之处就是可以让一段程序一直在运行。如何做到呢?只需把Start()方法写成一个死循环方法就好了。

public override void Start()
{
// 初始化账户信息
Uri baseUri = new Uri(RoleManager.GetConfigurationSetting("QueueEndpoint"));
string accountName = RoleManager.GetConfigurationSetting("AccountName");
string accountKey = RoleManager.GetConfigurationSetting("AccountSharedKey");
StorageAccountInfo account = new StorageAccountInfo(
baseUri,
null,
accountName,
accountKey);
           QueueStorage service = QueueStorage.Create(account);
           // 取得对这个名叫"message"的记菜本Queue的引用
MessageQueue queue = service.GetQueue("messages");
// 构造死循环
           while (true)
{
// 死循环中的程序每一秒执行一次
               Thread.Sleep(10000);
if (queue.DoesQueueExist())
{
                  // 取得记菜本中的当前应该处理的消息
                   Message msg = queue.GetMessage();
if (msg != null)
{
                     // 记录Windows Azure Log              
                      RoleManager.WriteToLog("Critical",
string.Format("大厨已经在{0}把{1} 做好了。",DateTime.Now.ToString("HH点mm分ss秒"), msg.ContentAsString()));
                    // 记录删除刚才已经处理的那条消息
                      queue.DeleteMessage(msg);
}
}
}
}

这段程序中,值得注意的有三处:

  1. 获取当前应该处理的数据:Message msg = queue.GetMessage();  既然是队列,就必须按照先进先出的顺序来操作数据。使用者也只能通过GetMessage方法取得队列中最靠前的那条数据,不能取到其他数据。就像是排队买火车票,售票员只能卖给排到队伍最靠前的那个人。
  2. 删除消息:queue.DeleteMessage(msg);   这又像是排队买火车票,当排在最前面的那位仁兄买到票后,他应该马上从队伍中消失。
  3. RoleManager.WriteToLog(string eventLogName,string message)方法。
    这就是上文提到的,非常简单好用的记录日志的方法。用过log4net的程序员一看就明白,这简直是一个“山寨版”的log4net。它借鉴了log4net记录日志的模式,又阉割了log4net的配置和自定义格式功能。
    Azure Log支持的EventLog类型共有Critical,Error,Warning,Information,Verbose这5种。如果你没用过log4net或不明白EventLog类型的意思,可以尝试这样理解:Azure Log把日志分为5类;分类记录日志更加便于查看。本例中使用的是"Critical”,也只是为了方便查看而已。

第七步:

F5运行程序。此时我们的Azure兰州拉面馆就正式在Development Fabric中开业了!

打开Development Fabric看看。

选择我们刚部署的服务中的Worker Role,点击右键,选择"Clear logs”清屏,再选择Logging Level- Critical 。这就是对日志进行分类查看,我们选择了查看Criticial类别是因为我们在记录点菜信息时使用了Critical 。

image

 

第八步:

测试一下吧 :)

image

看,我们点菜,大厨依次做菜!

随便看一条数据吧,比如“(兰州版)扬州炒饭”这一项,我们在01点29分58秒的时候将它写入Queue。大厨发现Queue中有它后,在00点30分04秒中处理了它。

梳理一下流程:

点菜 - 把菜名写入Queue - 大厨每秒钟查看一次Queue,如果Queue中有需要做的菜,则按照先来后到的顺序做菜 -从记菜本中删除刚做好的菜 - 把做菜信息写入Azure Log中

 

到目前为止,我们掌握了:获取Queue Storage的引用、建立Queue、插入数据到Queue中(入队)、从Queue中取出数据(出队)、记录Azure系统日志、查看Azure系统日志。

 

                             ———患侏儒症的分割线———

【附件】:

传说中的万能StorageClient:StorageClient.rar

WPF应用程序Azure Log Viewer源代码:AzureLogViewer.zip

本文实验全部源代码:QueueStorage.rar

来自 “ ITPUB博客 ” ,链接:http://blog.itpub.net/21507842/viewspace-592062/,如需转载,请注明出处,否则将追究法律责任。

转载于:http://blog.itpub.net/21507842/viewspace-592062/

这篇关于【第11篇】Windows Azure兰州拉面馆-日志与队列的使用的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/255726

相关文章

Spring IoC 容器的使用详解(最新整理)

《SpringIoC容器的使用详解(最新整理)》文章介绍了Spring框架中的应用分层思想与IoC容器原理,通过分层解耦业务逻辑、数据访问等模块,IoC容器利用@Component注解管理Bean... 目录1. 应用分层2. IoC 的介绍3. IoC 容器的使用3.1. bean 的存储3.2. 方法注

Python内置函数之classmethod函数使用详解

《Python内置函数之classmethod函数使用详解》:本文主要介绍Python内置函数之classmethod函数使用方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地... 目录1. 类方法定义与基本语法2. 类方法 vs 实例方法 vs 静态方法3. 核心特性与用法(1编程客

怎样通过分析GC日志来定位Java进程的内存问题

《怎样通过分析GC日志来定位Java进程的内存问题》:本文主要介绍怎样通过分析GC日志来定位Java进程的内存问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录一、GC 日志基础配置1. 启用详细 GC 日志2. 不同收集器的日志格式二、关键指标与分析维度1.

Linux中压缩、网络传输与系统监控工具的使用完整指南

《Linux中压缩、网络传输与系统监控工具的使用完整指南》在Linux系统管理中,压缩与传输工具是数据备份和远程协作的桥梁,而系统监控工具则是保障服务器稳定运行的眼睛,下面小编就来和大家详细介绍一下它... 目录引言一、压缩与解压:数据存储与传输的优化核心1. zip/unzip:通用压缩格式的便捷操作2.

解读GC日志中的各项指标用法

《解读GC日志中的各项指标用法》:本文主要介绍GC日志中的各项指标用法,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录一、基础 GC 日志格式(以 G1 为例)1. Minor GC 日志2. Full GC 日志二、关键指标解析1. GC 类型与触发原因2. 堆

使用Python实现可恢复式多线程下载器

《使用Python实现可恢复式多线程下载器》在数字时代,大文件下载已成为日常操作,本文将手把手教你用Python打造专业级下载器,实现断点续传,多线程加速,速度限制等功能,感兴趣的小伙伴可以了解下... 目录一、智能续传:从崩溃边缘抢救进度二、多线程加速:榨干网络带宽三、速度控制:做网络的好邻居四、终端交互

Python中注释使用方法举例详解

《Python中注释使用方法举例详解》在Python编程语言中注释是必不可少的一部分,它有助于提高代码的可读性和维护性,:本文主要介绍Python中注释使用方法的相关资料,需要的朋友可以参考下... 目录一、前言二、什么是注释?示例:三、单行注释语法:以 China编程# 开头,后面的内容为注释内容示例:示例:四

Go语言数据库编程GORM 的基本使用详解

《Go语言数据库编程GORM的基本使用详解》GORM是Go语言流行的ORM框架,封装database/sql,支持自动迁移、关联、事务等,提供CRUD、条件查询、钩子函数、日志等功能,简化数据库操作... 目录一、安装与初始化1. 安装 GORM 及数据库驱动2. 建立数据库连接二、定义模型结构体三、自动迁

ModelMapper基本使用和常见场景示例详解

《ModelMapper基本使用和常见场景示例详解》ModelMapper是Java对象映射库,支持自动映射、自定义规则、集合转换及高级配置(如匹配策略、转换器),可集成SpringBoot,减少样板... 目录1. 添加依赖2. 基本用法示例:简单对象映射3. 自定义映射规则4. 集合映射5. 高级配置匹

Spring 框架之Springfox使用详解

《Spring框架之Springfox使用详解》Springfox是Spring框架的API文档工具,集成Swagger规范,自动生成文档并支持多语言/版本,模块化设计便于扩展,但存在版本兼容性、性... 目录核心功能工作原理模块化设计使用示例注意事项优缺点优点缺点总结适用场景建议总结Springfox 是