|
|
Запуск первого приложения в Microsoft Azure. Миграция веб-сайта в Cloud Services
using System.Collections.Generic; using System.Linq; using System.Web; namespace MVC4Gallery.Models { public class Image { public string Title{ get; set; } public string Link{ get; set; } }}
<div class="content-wrapper"> <div class="float-left"> <p class="site-title"> Наш первый сайт-галерея </div> </div> </header> <div id="body"> <section class="featured"> <div class="content-wrapper"> <form action="/Home/Upload" method="post" enctype="multipart/form-data"> <label for="title"> <label for="FileData"> Файл</label> <input type="file" id="FileData" name="FileData" /><br /> <input type="submit" value="Сохранить" /> </form> Ваши изображения после "обработки": @foreach (var image in ViewData.Model) { @image.Title <br /> <img width="100" height="100" src="@image.Link" /><br /> } </div> </section> </div>
using System.Collections.Generic; using System.Collections.Specialized; using System.Web; using System.Web.Mvc; using Microsoft.ServiceBus.Messaging; using Microsoft.WindowsAzure; using Microsoft.WindowsAzure.StorageClient; using MVC4Gallery.Models; namespace MvcApplication1.Controllers { public class HomeController : Controller { public ActionResult Index() { List<Image> images = getBlobs("ourgallery"); return View(images); } [HttpPost] [ActionName("Upload")] public ActionResult Upload(string author, string title) { this.SendBlobToStorage(author); return RedirectToAction("Index"); } public void SendBlobToStorage(string author) { try { HttpPostedFileBase file = Request.Files[0]; CloudBlob blob = getBlobContainer("ourgallery"). GetBlobReference(file.FileName); NameValueCollection metadata = new NameValueCollection(); metadata["title"] = file.FileName; blob.UploadFromStream(file.InputStream); BrokeredMessage msg = new BrokeredMessage(blob.Uri.AbsoluteUri); SendBrokeredMessageToServiceBusQueue(msg); } catch (StorageClientException e) { Console.WriteLine ("Возникла ошибка во время работы с хранилищем: " + e.Message); System.Environment.Exit(1); }} public List<Image> getBlobs(string author){ CloudBlobContainer container = getBlobContainer(author); List<Image> images = new List<Image>(); foreach (CloudBlob blob in container.ListBlobs()) { blob.FetchAttributes(); Image image = new Image(); image.Link = blob.Uri.AbsoluteUri; image.Title = blob.Metadata["title"]; images.Add(image); } return images; } public static CloudBlobContainer getBlobContainer(string userId) { var account = CloudStorageAccount. FromConfigurationSetting("storageaccount"); CloudBlobContainer container = account.CreateCloudBlobClient(). GetContainerReference(userId); container.CreateIfNotExist(); var permissions = container.GetPermissions(); permissions.PublicAccess = BlobContainerPublicAccessType.Container; container.SetPermissions(permissions); return container; } public static void SendBrokered MessageToServiceBusQueue(BrokeredMessage msg) { QueueDescription qd = new QueueDescription("servicebustest"); qd.MaxSizeInMegabytes = 5120; qd.DefaultMessageTimeToLive = new TimeSpan(0, 1, 0); string connectionString = CloudConfigurationManager.GetSetting ("Microsoft.ServiceBus.ConnectionString"); QueueClient Client = QueueClient.CreateFromConnectionString (connectionString, "servicebustest"); Client.Send(msg); }}}
SetConfigurationSetting Publisher((configName, configSettingPublisher) => { var connectionString = RoleEnvironment. GetConfigurationSettingValue(configName); configSettingPublisher(connectionString); });
using System.Collections.Specialized; using System.Diagnostics; using System.Net; using System.Threading; using Microsoft.ServiceBus; using Microsoft.ServiceBus.Messaging; using Microsoft.WindowsAzure; using Microsoft.WindowsAzure.ServiceRuntime; using Microsoft.WindowsAzure.StorageClient; namespace WorkerRoleWithSBQueue1 { public class WorkerRole : RoleEntryPoint { // The name of your queue const string QueueName = "servicebustest"; // QueueClient is thread-safe. Recommended that you cache // rather than recreating it on every request QueueClient Client; bool IsStopped; public override void Run() { while (!IsStopped) { try { // Получение сообщения BrokeredMessage receivedMessage = null; receivedMessage = Client.Receive(); if (receivedMessage != null) { // Обработка сообщения. В данном случае изображение получается из блоба, затем возвращается в том же виде, но с другим именем файла. GetBlobFromStorage("ourgallery", receivedMessage.GetBody<string>()); receivedMessage.Complete(); }} catch (MessagingException e) { if (!e.IsTransient) { Trace.WriteLine(e.Message); throw; } Thread.Sleep(10000); } catch (OperationCanceledException e) { if (!IsStopped) { Trace.WriteLine(e.Message); throw; }}}} public override bool OnStart() { CloudStorageAccount.SetConfiguration SettingPublisher((configName, configSettingPublisher) => { var connectionString = RoleEnvironment. GetConfigurationSettingValue(configName); configSettingPublisher(connectionString); }); // Определение максимального количества одновременных подключений ServicePointManager.DefaultConnectionLimit = 12; // Создание очереди в том случае, если ее еще не существует string sbconnectionString = CloudConfigurationManager. GetSetting("Microsoft.ServiceBus.ConnectionString"); var namespaceManager = NamespaceManager. CreateFromConnectionString(sbconnectionString); if (!namespaceManager.QueueExists(QueueName)) { namespaceManager.CreateQueue(QueueName); } // Инициализация подключения к очереди Service Bus Client = QueueClient.Create FromConnectionString(sbconnectionString, QueueName); IsStopped = false; return base.OnStart(); } public override void OnStop() { // Закрытие подключения к очереди Service Bus IsStopped = true; Client.Close(); base.OnStop(); } public void GetBlobFromStorage(string author, string title) { try { CloudBlob sourceBlob = getBlobContainer("ourgallery").GetBlobReference(title); CloudBlob newBlob = getBlobContainer("ourgallery"). GetBlobReference(title + "small_copy"); newBlob.CopyFromBlob(sourceBlob); NameValueCollection metadata = new NameValueCollection(); metadata["title"] = title + "small_copy"; } catch (StorageClientException e) { Console.WriteLine("Возникла ошибка: " + e.Message); System.Environment.Exit(1); }} public static CloudBlobContainer getBlobContainer(string userId) { var account = CloudStorageAccount .FromConfigurationSetting("storageaccount"); CloudBlobContainer container = account. CreateCloudBlobClient().GetContainerReference(userId); container.CreateIfNotExist(); return container; }}}
using System.Collections.Generic; using System.Linq; using Microsoft.WindowsAzure; using Microsoft.WindowsAzure.Diagnostics; using Microsoft.WindowsAzure.ServiceRuntime; using Microsoft.WindowsAzure.StorageClient; namespace MVC4Gallery { public class WebRole : RoleEntryPoint { public override bool OnStart() { RoleEnvironment.Changing += RoleEnvironmentChanging; return base.OnStart(); } private void RoleEnvironment Changing(object sender, RoleEnvironmentChangingEventArgs e) { if (e.Changes.Any(change => change is RoleEnvironmentConfigurationSettingChange)) { e.Cancel = true; }}}} Нажмите два раза правой кнопкой мыши на MVC 4 Gallery в Roles облачного проекта для того, чтобы открыть графический интерфейс администрирования Web-роли (рис. 7).
На вкладке Configuration снимите отметку с опции Enable Diagnostics. Перейдите на вкладку Settings, нажмите Add Setting и создайте новую настройку конфигурации с именем storageaccount. Укажите её тип как Connection String, после чего нажмите на кнопку с троеточием и настройте строку подключения. Необходимые данные были записан в Части 1. Нажмите Add Setting и введите имя Microsoft.ServiceBus.ConnectionString (тип – String), после чего вставьте в поле Value следующую строку: Endpoint=sb://[имяпространстваимён].servicebus.windows.net;SharedSecretIssuer= Где наименование пространства имён для части Endpoint, Default Issuer для SharedSecretIssuer и Default Key для SharedSecretValue. Нажмите OK. Нажмите два раза правойкнопкой мыши на WorkerRoleWithSBQueue 1 в Roles облачного проекта для того, чтобы открыть графический интерфейс администрирования Worker-роли. На вкладке Configuration снимите отметку с опции Enable Diagnostics. Перейдите на вкладку Settings, нажмите Add Setting и создайте новую настройку конфигурации сименем storageaccount. Укажите её тип как Connection String, после чего нажмите на кнопку с троеточием и настройте строку подключения. Необходимые данные были записаны в Части 1. Нажмите OK. Вставьте необходимые значения в строку подключения для настройки Microsoft.ServiceBus.ConnectionString. Необходимые данные были записаны в Части 1 – наименование пространства имён для части Endpoint, Default Issuer для SharedSecretIssuer и Default Keyдля SharedSecretValue. Сохраните изменения и закройте графический интерфейс управления Worker-ролью. Запустите проект, нажав F5. Проект запустится в локальном эмуляторе вычислений и запустит браузер с представлением Home / Index . Выберите изображение и нажмите Сохранить. После загрузки изображения страница обновится. Обратите внимание, что в данный момент показывается только одно изображение – то, которое вы загрузили. Спустя некоторое время (достаточно нескольких секунд) обновите страницу – это время понадобится обработчику изображений, чтобы опросить очередь, получить сообщение от Web-роли, загрузить блоб, создать его копию и положить новый блоб в хранилище. Развертывание ASP.NET MVC 4 приложения на платформу Microsoft Azure в Cloud Services из Visual Studio 2012Для того, чтобы развернуть приложение в Cloud Services на платформу Microsoft Azure, необходимо соответствующим образом настроить функциональность публикации в Visual Studio 2012 Нажмите правой кнопкой мыши на облачном проекте MVC 4 Gallery. Azure. Нажмите Publish. В открывшемся диалоговом окне раскройте список под Choose your subscription и выберите < Manage …> (рис. 12).
В открывшемся диалоговом окне Microsoft Azure Cloud Service Project Management нажмите New. Введите любое удобное вам название нового сертификата, который будет использоваться для развертывания приложения. Нажмите Ok Нажмите на ссылку Copy the full path. Перейдите на портал управления Microsoft Azure. Перейдите на вкладку Hosted Services, Storage Accounts & CDN... Перейдите на вкладку Management Certificates... На вкладку Management Certificates нажмите Add Certificate. В открывшемся диалоговом окне Add New Management Certificate нажмите Browse и вставьте в поле Имя файла скопированный из Visual Studio путь к сертификату. Нажмите Открыть. Нажмите Ok. Перейдите на вкладку Hosted Services и скопируйте Subscription ID из панели Properties. Перейдите в Visual Studio 2012. Вставьте скопированный идентификатор подписки в соответствующее поле (рис. 13). Нажмите OK.
Нажмите Close. Нажмите Next . На странице Microsoft Azure Publish Settings вы можете настроить дополнительные опции развертывания. Нажмите Publish. Вы можете наблюдать за процессом развёртывания в представлении Microsoft Azure Activity Log (рис. 14).
Перейдите на портал управления Microsoft Azure на вкладку Hosted Services. Выберите развернутое приложение и нажмите на ссылку в поле DNS Name на панели Properties, чтобы перейти на веб-сайт (рис. 15).
Обратите внимание, что сайт выглядит так же, как после развёртывания его в локальный эмулятор вычислений. Это связано с тем, что в обоих случаях используется реальное хранилище Microsoft Azure. Добавьте новое изображение и пронаблюдайте результат. Автор статьи: Александр Белоцерковский, Microsoft Azure MVP. |
|||||||||
.png)
.png)
.jpg)
.png)
.jpg)
.jpg)
.jpg)
.jpg)
.jpg)
.jpg)
.gif){kind=icon}