标签：
Consolidate multiple tasks or operations into a single computational unit. This pattern can increase compute resource utilization, and reduce the costs and management overhead associated with performing compute processing in cloud-hosted applications.
合并多个任务或操作成一个单一的计算单元。这种模式可以提高计算资源的利用率，并降低与云托管的应用程序进行计算处理相关的成本和管理开销。
A cloud application frequently implements a variety of operations. In some solutions it may make sense initially to follow the design principle of separation of concerns, and divide these operations into discrete computational units that are hosted and deployed individually (for example, as separate roles in a Microsoft Azure Cloud Service, separate Azure Web Sites, or separate Virtual Machines). However, although this strategy can help to simplify the logical design of the solution, deploying a large number of computational units as part of the same application can increase runtime hosting costs and make management of the system more complex.
云应用程序频繁地实现各种操作。在一些解决方案可能是有意义最初遵循的关注点分离的设计原则，并划分这些操作成离散的计算单位并进行托管和独立部署（例如，如在微软Azure云服务，独立Azure网站，独立角色离散计算单元，或单独的虚拟机）。然而，尽管这种策略可以帮助简化解决方案的逻辑设计，可部署大量计算单元在同一应用下提高运行时的托管费用，使系统的管理更加复杂的一部分。
As an example, Figure 1 shows the simplified structure of a cloud-hosted solution that is implemented using more than one computational unit. Each computational unit runs in its own virtual environment. Each function has been implemented as a separate task (labeled Task A through Task E) running in its own computational unit.
作为一个例子，图1示出了使用多个计算单元实施了云托管解决方案的简化的结构。每个计算单元在自己的虚拟环境中运行。每个功能已被实现为自己的计算单元上运行一个单独的任务（通过任务?标记任务A）。
Figure 1 - Running tasks in a cloud environment by using a set of dedicated computational units
图1 - 通过使用一组专用的计算单元运行在云环境中的任务
Each computational unit consumes chargeable resources, even when it is idle or lightly used. Therefore, this approach may not always be the most cost-effective solution.
每个计算单元消耗的资源收费，即使是空闲或轻易使用。因此，这种方法可能不总是最有成本效益的解决方案。
To help reduce costs, increase utilization, improve communication speed, and ease the management effort it may be possible to consolidate multiple tasks or operations into a single computational unit.
为了帮助降低成本，提高利用率，提高通信速度，减轻管理工作有可能将多个任务或操作固定成一个单一的计算单元。
Tasks can be grouped according to a variety of criteria based on the features provided by the environment, and the costs associated with these features. A common approach is to look for tasks that have a similar profile concerning their scalability, lifetime, and processing requirements. Grouping these items together allows them to scale as a unit. The elasticity provided by many cloud environments enables additional instances of a computational unit to be started and stopped according to the workload. For example, Azure provides autoscaling that you can apply to roles in a Cloud Service, Web Sites, and Virtual Machines. For more information, see Autoscaling Guidance.
任务可以根据各种基于由环境提供的功能，以及与这些功能相关的成本标准进行分组。一种常见的方法是寻找有关于他们的可扩展性，寿命和加工要求具有相似的任务。分组这些产品一起使它们能够扩展为一个单元。由许多云环境所提供的弹性使一计算单元的其他实例，以根据业务负载来启动和停止。例如，Azure提供了自动缩放，可以适用于云服务的角色，网站和虚拟机。欲了解更多信息，请参阅自动缩放指导。
As a counter example to show how scalability can be used to determine which operations should probably not be grouped together, consider the following two tasks:
作为抗衡例子来说明的可扩展性可以如何被用来确定哪些操作可能不应该被分组在一起，考虑以下两个任务：
?任务1轮询发送到一个队列频繁，时间不敏感的消息。
?任务2处理网络流量的高容量阵阵。
The second task requires elasticity that may involve starting and stopping a large number of instances of the computational unit. Applying the same scaling to the first task would simply result in more tasks listening for infrequent messages on the same queue, and is a waste of resources.
第二任务要求的弹性可能涉及在启动和停止的大量的计算单元的实例。应用相同的缩放到第一任务只会导致更多的任务上监听同一队列不频繁的消息，并且是对资源的浪费。
In many cloud environments it is possible to specify the resources available to a computational unit in terms of the number of CPU cores, memory, disk space, and so on. Generally, the more resources specified, the greater the cost. For financial efficiency, it is important to maximize the amount of work an expensive computational unit performs, and not let it become inactive for an extended period.
在许多云环境中，它有可能在CPU内核，存储器，磁盘空间等的数量方面来指定一个计算单元的可用资源。一般地，指定的更多的资源，成本越大。对于金融效率，最大限度地工作的一个昂贵的计算单元执行的数量，并且不让它在较长时间内成为不活动是比较重要的。
If there are tasks that require a great deal of CPU power in short bursts, consider consolidating these into a single computational unit that provides the necessary power. However, it is important to balance this need to keep expensive resources busy against the contention that could occur if they are over-stressed. Long-running, compute-intensive tasks should probably not share the same computational unit, for example.
如果任务需要的强大的CPU处理能力在短时间内，考虑合并这些到单一的计算单元以提供必需的动力。然而，为了平衡这需要保持昂贵资源繁忙针对它们是否过度强调，可能发生争用是重要的。例如，长时间运行的，计算密集型任务可能不应该共享相同的计算单元。
Consider the following points when implementing this pattern:
实施这一模式时，请考虑以下几点：
你应该考虑巩固只对已经生产了一段时间以便运营商和开发者可以监视系统和创建标识每个任务如何利用不同资源的热图系统的计算资源。这张地图可以用于确定哪些任务很适合于共享计算资源。
Use this pattern for tasks that are not cost effective if they run in their own computational units. If a task spends much of its time idle, running this task in a dedicated unit can be expensive.
使用这种模式不是成本有效如果他们运行在自己计算单位的任务。如果一项任务花了很多空闲时间，运行此任务在一个专门的单位是昂贵的。
This pattern might not be suitable for tasks that perform critical fault-tolerant operations, or tasks that process highly-sensitive or private data and require their own security context. These tasks should run in their own isolated environment, in a separate computational unit.
这种模式可能不适合于执行关键容错操作该处理高度敏感的或私人数据，并要求他们自己的安全上下文的任务。这些任务应该在他们自己的分离的环境中运行，在一个单独的计算单元。
When building a cloud service on Azure, it’s possible to consolidate the processing performed by multiple tasks into a single role. Typically this is a worker role that performs background or asynchronous processing tasks.
当在Azure上构建一个云服务，它可能合并多任务的处理成一个单一的角色。通常，这是执行的背景或异步处理任务的辅助角色。
Note:
In some cases it may be possible to include background or asynchronous processing tasks in the web role. This technique can help to reduce costs and simplify deployment, although it can impact the scalability and responsiveness of the public-facing interface provided by the web role. The article Combining Multiple Azure Worker Roles into an Azure Web Role contains a detailed description of implementing background or asynchronous processing tasks in a web role.
在某些情况下，它可能在 web 角色中包括背景或异步处理任务。这种技术可以帮助降低成本和简化部署，虽然它可以影响的可伸缩性和响应能力提供 web 角色的面向公众的界面。文章《结合多个 Azure 工作者角色到 Azure Web 角色》包含 web 角色实施背景或异步处理任务的详细的说明。
The role is responsible for starting and stopping the tasks. When the Azure fabric controller loads a role, it raises the Start event for the role. You can override the OnStart method of the WebRole or WorkerRole class to handle this event, perhaps to initialize the data and other resources on which the tasks in this method depend.
角色是负责启动和停止的任务。当Azure结构控制器加载一个角色，它提出了该角色的Start事件。您可以覆盖WebRole或WorkerRole类的OnStart方法来处理这个事件，也许是初始化数据和其他资源，在这种方法的任务依赖。
When the OnStart method completes, the role can start responding to requests. You can find more information and guidance about using the OnStart and Run methods in a role in theApplication Startup Processes section in the patterns & practices guide Moving Applications to the Cloud.
当OnStart方法完成后，角色就可以开始响应请求。你可以找到更多的信息和有关使用在应用程序启动一个角色的OnStart和Run方法指导流程的模式与实践指南移动应用程序到云部分。
Note:注意：
Keep the code in the OnStart method as concise as possible. Azure does not impose any limit on the time taken for this method to complete, but the role will not be able to start responding to network requests sent to it until this method completes.
请尽可能简洁OnStart方法的代码。 Azure不征收采取这种方法来完成任何时间限制，但角色将不能启动响应，直到这个方法完成发送给它的网络请求。
When the OnStart method has finished, the role executes the Run method. At this point, the fabric controller can start sending requests to the role.
当OnStart方法完成后，执行任务的运行方式。在这一点上，结构控制器可以开始将请求发送到角色。
Place the code that actually creates the tasks in the Run method. Note that the Run method effectively defines the lifetime of the role instance. When this method completes, the fabric controller will arrange for the role to be shut down.
在Run方法中设置实际创建任务的代码。注意，Run方法有效地定义角色实例的生命周期。当该方法完成后，结构控制器将安排的作用被关闭。
When a role shuts down or is recycled, the fabric controller prevents any more incoming requests being received from the load balancer and raises the Stop event. You can capture this event by overriding the OnStop method of the role and perform any tidying up required before the role terminates.
当一个角色关闭或回收，结构控制器可以防止从负载平衡器接收任何更多的传入请求并引发停止事件。您可以通过覆盖角色的OnStop方法捕获这个事件，并执行任何清理行动中的作用终止前必需的。
Note:
Any actions performed in the OnStop method must be completed within five minutes (or 30 seconds if you are using the Azure emulator on a local computer); otherwise the Azure fabric controller assumes that the role has stalled and will force it to stop.
在调用OnStop方法执行的任何动作必须在五分钟（或30秒，如果您使用的是本地计算机上的Azure仿真器）内完成;否则Azure结构控制器假设角色已经停止，并迫使它停下来。
Figure 2 illustrates the lifecycle of a role, and the tasks and resources that it hosts. The tasks are started by the Run method, which then waits for the tasks to complete. The tasks themselves, which implement the business logic of the cloud service, can respond to messages posted to the role through the Azure load balancer.
图2示出了作用的生命周期，并且它承载的任务和资源。该任务由Run方法，该方法然后等待任务来完成启动。这实现了云服务的业务逻辑的任务本身，可以通过Azure的负载均衡器发布到角色的消息作出回应。
Figure 2 - The lifecycle of tasks and resources in a role in a Azure cloud service
Note:
The ComputeResourceConsolidation.Worker project is part of the ComputeResourceConsolidation solution that is available for download with this guidance.
In the worker role, code that runs when the role is initialized creates the required cancellation token and a list of tasks to run.
在工作角色代码运行时被初始化辊创建所需的CancellationToken和任务运行的列表。
public class WorkerRole: RoleEntryPoint { // The cancellation token source used to cooperatively cancel running tasks. private readonly CancellationTokenSource cts = new CancellationTokenSource (); // List of tasks running on the role instance. private readonly List<Task> tasks = new List<Task>(); // List of worker tasks to run on this role. private readonly List<Func<CancellationToken, Task>> workerTasks = new List<Func<CancellationToken, Task>> { MyWorkerTask1, MyWorkerTask2 }; ... }
The MyWorkerTask1 and the MyWorkerTask2 methods are provided to illustrate how to perform different tasks within the same worker role. The following code shows MyWorkerTask1. This is a simple task that sleeps for 30 seconds and then outputs a trace message. It repeats this process indefinitely until the task is cancelled. The code in MyWorkerTask2 is very similar.
提供的MyWorkerTask1和工人任务2的方法来说明如何在同一工作者角色内执行不同的任务。下面的代码显示MyWorkerTask1。这是一个简单的任务，休眠30秒，然后输出一个跟踪消息。直到任务被取消它无限期地重复这个过程。在MyWorkerTask2代码非常相似。
// A sample worker role task. private static async Task MyWorkerTask1(CancellationToken ct) { // Fixed interval to wake up and check for work and/or do work. var interval = TimeSpan.FromSeconds(30); try { while (!ct.IsCancellationRequested) { // Wake up and do some background processing if not canceled. // TASK PROCESSING CODE HERE Trace.TraceInformation("Doing Worker Task 1 Work"); // Go back to sleep for a period of time unless asked to cancel. // Task.Delay will throw an OperationCanceledException when canceled. await Task.Delay(interval, ct); } } catch (OperationCanceledException) { // Expect this exception to be thrown in normal circumstances or check // the cancellation token. If the role instances are shutting down, a // cancellation request will be signaled. Trace.TraceInformation("Stopping service, cancellation requested"); // Re-throw the exception. throw; } }
Note:注意：
The approach shown by the sample code is a common implementation of a background process. In a real world application you can follow this same structure, except that you should place your own processing logic in the body of the loop that waits for the cancellation request.
通过示例代码中显示的方法是一个后台进程的共同实现。在实际应用中，你可以按照同样的结构，但你应该把你自己的处理逻辑在等待取消请求的循环体。
After the worker role has initialized the resources it uses, the Run method starts the two tasks concurrently, as shown here.
随后辅助角色被初始化当它使用资源时，Run方法同时启动两个任务，如下图所示。
... // RoleEntry Run() is called after OnStart(). // Returning from Run() will cause a role instance to recycle. public override void Run() { // Start worker tasks and add them to the task list. foreach (var worker in workerTasks) tasks.Add(worker(cts.Token)); Trace.TraceInformation("Worker host tasks started"); // The assumption is that all tasks should remain running and not return, // similar to role entry Run() behavior. try { Task.WaitAny(tasks.ToArray()); } catch (AggregateException ex) { Trace.TraceError(ex.Message); // If any of the inner exceptions in the aggregate exception // are not cancellation exceptions then re-throw the exception. ex.Handle(innerEx => (innerEx is OperationCanceledException)); } // If there was not a cancellation request, stop all tasks and return from Run() // An alternative to cancelling and returning when a task exits would be to // restart the task. if (!cts.IsCancellationRequested) { Trace.TraceInformation("Task returned without cancellation request"); Stop(TimeSpan.FromMinutes(5)); } } ...
In this example, the Run method waits for tasks to be completed. If a task is canceled, the Run method assumes that the role is being shut down and waits for the remaining tasks to be canceled before finishing (it waits for a maximum of five minutes before terminating). If a task fails due to an expected exception, the Run method cancels the task.
在这个例子中，Run方法等待要完成的任务。如果任务被取消，Run方法假定作用正在关闭，并等待剩余的任务完成（它等待超过五分钟结束之前）之前被取消。如果任务失败，因为预期异常，Run方法取消任务。
Note:
Note that you could implement more comprehensive monitoring and exception handling strategies in the Run method such as restarting tasks that have failed, or including code that enables the role to stop and start individual tasks.
请注意，你可以实现在Run方法更全面的监测和异常处理策略，如重新启动已失败的任务，或者包括代码使角色停止和启动单个任务。
The Stop method shown in the following code is called when the fabric controller shuts down the role instance (it is invoked from the OnStop method). The code stops each task gracefully by cancelling it. If any task takes more than five minutes to complete, the cancellation processing in the Stop method ceases waiting and the role is terminated.
在下面的代码所示的Stop方法当结构控制器关闭角色实例（它是从调用OnStop方法调用）被调用。该代码通过取消其正常停止每项任务。如果任何任务的时间超过五分钟就能完成，在Stop方法取消处理不再等待和角色被终止。
// Stop running tasks and wait for tasks to complete before returning // unless the timeout expires. private void Stop(TimeSpan timeout) { Trace.TraceInformation("Stop called. Canceling tasks."); // Cancel running tasks. cts.Cancel(); Trace.TraceInformation("Waiting for canceled tasks to finish and return"); // Wait for all the tasks to complete before returning. Note that the // emulator currently allows 30 seconds and Azure allows five // minutes for processing to complete. try { Task.WaitAll(tasks.ToArray(), timeout); } catch (AggregateException ex) { Trace.TraceError(ex.Message); // If any of the inner exceptions in the aggregate exception // are not cancellation exceptions then re-throw the exception. ex.Handle(innerEx => (innerEx is OperationCanceledException)); } }
The following patterns and guidance may also be relevant when implementing this pattern:
实施这一模式时，以下模式和指导也可能是相关的：
计算分区指引。该指导说明如何分配在云服务的服务和组件的方式，有助于最小化运行成本，同时保持了可扩展性，性能，可用性，和服务的安全性。
Compute Resource Consolidation Pattern 计算资源整合模式
标签：
原文地址：http://www.cnblogs.com/zsy/p/5222867.html
