<\/div>\n

Merhaba,<\/p>\n

Bu i\u00e7eri\u011fimizde Azure Storage Yaz\u0131 Dizisi<\/a>nin sonuncu makalesi olan Azure Queue Storage \u00fczerine konu\u015fuyor olaca\u011f\u0131z.<\/p>\n

Azure Queue Storage Nedir?<\/h3>\n
Azure Queue Storage, bir mesaj kuyruk sistemidir. Mesaj kuyruk sistemleri; uzun s\u00fcren i\u015flemlerin arka planda bir kuyru\u011fa at\u0131larak o kuyru\u011fu dinleyen ba\u015fka uygulamalar taraf\u0131ndan e\u015fzamans\u0131z bir \u015fekilde i\u015flenmesini sa\u011flayan yap\u0131lard\u0131r. Bknz: RabbitMQ<\/a><\/span><\/p>\n
Azure Queue Storage’a g\u00f6nderilen mesaj\u0131n boyutu en fazla 64 KB<\/u> olabilir. Her bir mesaj\u0131n default \u00f6mr\u00fc 7 g\u00fcnd\u00fcr<\/u>. 7 g\u00fcn sonras\u0131nda mesajlar otomatik silinir. Mesaj \u00f6m\u00fcrlerini custom bir \u015fekilde de\u011fi\u015ftirebilir yahut -1<\/span> de\u011ferini vermek kayd\u0131yla \u00f6m\u00fcr boyu kuyrukta tutabilirsiniz. <\/p>\n

Azure Queue Storage Kavramlar\u0131 Nelerdir?<\/h3>\n

$\"Azure$ <\/a>
\nURL Format<\/em>
\nAzure Queue Storage’da ki mesaj kuyruklar\u0131n\u0131 a\u015fa\u011f\u0131daki formatta endpoint ile url bi\u00e7iminde temsil edebilirsiniz.
\nhttps:\/\/<account_name>.queue.core.windows.net\/<queue_name><\/strong><\/code><\/p>\n

\u00d6rne\u011fin yukar\u0131da payla\u015f\u0131lan \u015femadaki mesaj kuyru\u011funu \u015f\u00f6yle temsil edebilirsiniz; \nhttps:\/\/myaccount.queue.core.windows.net\/images-to-download<\/strong><\/code><\/p>\n

Storage account<\/em> \nAzure Queue Storage, bir Azure Storega servisidir. Dolay\u0131s\u0131yla t\u00fcm i\u015flemler bir storage hesab\u0131 \u00fczerinden ger\u00e7ekle\u015ftirilir.<\/p>\n

Queue<\/em> \nBir dizi mesaj i\u00e7eren yap\u0131d\u0131r. Queue isimleri komple k\u00fc\u00e7\u00fck harf olmal\u0131d\u0131r.<\/p>\n

Message<\/em> \nHerhangi bir formatta 64 KB’a<\/u> kadar varan mesajlard\u0131r.<\/p>\n

Visibility \u00d6zelli\u011fi(G\u00f6r\u00fcn\u00fcrl\u00fck)<\/h3>\nBir kuyru\u011fa verilen mesaj\u0131n ayn\u0131 anda birden fazla consumer(t\u00fcketici) taraf\u0131ndan t\u00fcketilmemesi i\u00e7in default 30 saniye<\/u> kuyrukta g\u00f6r\u00fcnmez olmas\u0131d\u0131r. Dolay\u0131s\u0131yla ilgili mesaj\u0131 30 saniye i\u00e7erisinde i\u015flemek gerekmekte aksi taktirde ba\u015fka consumerlar’a g\u00f6r\u00fcn\u00fcr olaca\u011f\u0131ndan dolay\u0131 e\u015fzamanl\u0131 olarak farkl\u0131 bir consumer taraf\u0131ndan i\u015flenebilir olacakt\u0131r. Buradaki i\u015fleme s\u00fcresinin yap\u0131lacak i\u015fin boyutuna g\u00f6re tutarl\u0131 bir \u015fekilde verilmesine \u00f6zen g\u00f6sterilmelidir. G\u00f6r\u00fcn\u00fcrl\u00fck s\u00fcresine ‘Visibility Time Out<\/em>‘ denmektedir ve maksimum 7 g\u00fcn<\/u> almaktad\u0131r.<\/p>\n

Asp.NET Core \u0130le Azure Queue Storage Kullan\u0131m\u0131<\/h3>\n
Asp.NET Core ile Azure Queue Storage kullan\u0131m\u0131 i\u00e7in a\u015fa\u011f\u0131daki ad\u0131mlar\u0131 s\u0131ras\u0131yla ger\u00e7ekle\u015ftirmeniz yeterli olacakt\u0131r;<\/p>\n
\n
Ad\u0131m 1<\/strong>
\nBir Asp.NET Core uygulamas\u0131 olu\u015fturunuz ve Azure.Storage.Queues<\/a> k\u00fct\u00fcphanesini uygulamaya entegre ediniz.
\n $\"Azure$ <\/a>\n<\/li>\n
Ad\u0131m 2<\/strong>
\n‘AzQueue’ isminde bir s\u0131n\u0131f olu\u015fturunuz ve i\u00e7eri\u011fini a\u015fa\u011f\u0131daki gibi geli\u015ftiriniz.<\/p>\n
\r\n public class AzQueue\r\n {\r\n readonly QueueClient _queueClient;\r\n public AzQueue(string queueName)\r\n {\r\n _queueClient = new QueueClient("DefaultEndpointsProtocol=https;AccountName=gencayy******2Zsyk7Rk54Bs1BxP4MT7tTeHbNe\/WljTCZQt7RfM****************ndows.net", queueName);\r\n _queueClient.CreateIfNotExists();\r\n }\r\n public async Task SendMessageAsync(string message)\r\n {\r\n if (await _queueClient.ExistsAsync())\r\n await _queueClient.SendMessageAsync(message);\r\n else\r\n throw new Exception("Mesaj g\u00f6nderilmeye \u00e7al\u0131\u015f\u0131l\u0131rken beklenmeyen bir hatayla kar\u015f\u0131la\u015f\u0131ld\u0131.");\r\n }\r\n \/\/\/ <summary>\r\n \/\/\/ Mesaj\u0131 kuyruktan al\u0131r ve siler.\r\n \/\/\/ <\/summary>\r\n public async Task<QueueMessage> RetrieveNextMessageAsync()\r\n {\r\n if (await _queueClient.ExistsAsync())\r\n {\r\n Response<QueueProperties> response = await _queueClient.GetPropertiesAsync();\r\n \/\/ApproximateMessagesCount : \u00d6nbelle\u011fe al\u0131nan yakla\u015f\u0131k mesaj say\u0131s\u0131n\u0131 d\u00f6ner.\r\n if (response.Value.ApproximateMessagesCount > 0)\r\n {\r\n QueueMessage[] queueMessages = await _queueClient.ReceiveMessagesAsync();\r\n if (queueMessages.Any())\r\n return queueMessages[0];\r\n }\r\n return null;\r\n }\r\n else\r\n throw new Exception("Mesaj okunurken(Retrieve) beklenmeyen bir hatayla kar\u015f\u0131la\u015f\u0131ld\u0131.");\r\n }\r\n \/\/\/ <summary>\r\n \/\/\/ Mesaj\u0131 kuyruktan al\u0131r lakin silmez!\r\n \/\/\/ <\/summary>\r\n public async Task<PeekedMessage> PeekMessageAsync()\r\n {\r\n if (await _queueClient.ExistsAsync())\r\n {\r\n Response<QueueProperties> response = await _queueClient.GetPropertiesAsync();\r\n \/\/ApproximateMessagesCount : \u00d6nbelle\u011fe al\u0131nan yakla\u015f\u0131k mesaj say\u0131s\u0131n\u0131 d\u00f6ner.\r\n if (response.Value.ApproximateMessagesCount > 0)\r\n {\r\n PeekedMessage[] peekedMessages = await _queueClient.PeekMessagesAsync();\r\n if (peekedMessages.Any())\r\n return peekedMessages[0];\r\n }\r\n return null;\r\n }\r\n else\r\n throw new Exception("Mesaj okunurken(Peek) beklenmeyen bir hatayla kar\u015f\u0131la\u015f\u0131ld\u0131.");\r\n }\r\n public async Task UpdateMessageAsync(string newMessage)\r\n {\r\n if (await _queueClient.ExistsAsync())\r\n {\r\n QueueMessage[] queueMessages = await _queueClient.ReceiveMessagesAsync();\r\n \/\/TimeSpan.FromSeconds(60) ile 60 saniye daha visiblty \u00f6zelli\u011fini geni\u015fleterek ilgili mesaj\u0131 g\u00f6r\u00fcnmez yap\u0131yoruz.\r\n await _queueClient.UpdateMessageAsync(queueMessages[0].MessageId, queueMessages[0].PopReceipt, newMessage, TimeSpan.FromSeconds(60));\r\n }\r\n else\r\n throw new Exception("Mesaj g\u00fcncellenirken beklenmeyen bir hatayla kar\u015f\u0131la\u015f\u0131ld\u0131.");\r\n }\r\n public async Task DeleteMessageAsync()\r\n {\r\n if (await _queueClient.ExistsAsync())\r\n {\r\n QueueMessage[] queueMessages = await _queueClient.ReceiveMessagesAsync();\r\n await _queueClient.DeleteMessageAsync(queueMessages[0].MessageId, queueMessages[0].PopReceipt);\r\n }\r\n else\r\n throw new Exception("Mesaj silinirken beklenmeyen bir hatayla kar\u015f\u0131la\u015f\u0131ld\u0131.");\r\n }\r\n public async Task DeleteQueueAsync()\r\n {\r\n if (await _queueClient.ExistsAsync())\r\n await _queueClient.DeleteAsync();\r\n else\r\n throw new Exception("Kuyruk silinirken beklenmeyen bir hatayla kar\u015f\u0131la\u015f\u0131ld\u0131.");\r\n }\r\n }\r\n<\/pre>\n
Yukar\u0131daki kod blo\u011funu izah etmemiz gerekirse e\u011fer;<\/p>\n
\n
6. sat\u0131rda, storage account’un connection string’i verilmektedir.<\/em><\/li>\n
12. sat\u0131rda, ‘SendMessageAsync’ metodu ile kuyru\u011fa mesaj g\u00f6nderilmektedir. \u0130lgili metodun 3. overload’\u0131na g\u00f6z atarsak e\u011fer;
\n $\"\"$ <\/a>
\n‘visibilityTimeout’ ve ‘timeToLive’ parametreleri mevcuttur. Bu parametreleri s\u0131ras\u0131yla a\u00e7\u0131klarsak e\u011fer;<\/p>\n
visibilityTimeout<\/span>, kuyruktan mesaj al\u0131nd\u0131\u011f\u0131nda o mesaj\u0131n kuyrukta ne kadar s\u00fcre g\u00f6r\u00fcnmez olmas\u0131n\u0131 istiyorsan\u0131z e\u011fer buradan belirleyebilirsiniz. Default 30 saniyedir.<\/p>\n
timeToLive<\/span>, mesaj\u0131n ya\u015fam s\u00fcresini belirler. Default olarak 7 g\u00fcnd\u00fcr. TimeSpan.FromSecond(-1) de\u011feri ile \u00f6m\u00fcr boyu mesaj tutulabilir.<\/em>\n<\/li>\n
25. sat\u0131rda, ‘ApproximateMessagesCount’ property’si \u00f6nbelle\u011fe al\u0131nan yakla\u015f\u0131k mesaj say\u0131s\u0131n\u0131 belirtmektedir. B\u00f6ylece, yakla\u015f\u0131k olarak ne kadarl\u0131k mesaj \u00fczerinde i\u015flem yapabildi\u011fimizi \u00f6l\u00e7m\u00fc\u015f oluyoruz.<\/em><\/li>\n
27. sat\u0131rda, ‘ReceiveMessagesAsync’ metodu ile kuyruktaki mesaj elde edilmekte ve kuyruktan silinmektedir.<\/em><\/li>\n
47. sat\u0131rda, ‘PeekMessagesAsync’ metodu ise kuyruktaki mesaj\u0131 elde etmekte lakin kuyruktan silmemektedir.<\/em><\/li>\n<\/ul>\n<\/li>\n
Ad\u0131m 3<\/strong>
\nGeli\u015ftirilen bu s\u0131n\u0131f\u0131 uygulamaya servis olarak ekleyiniz.<\/p>\n
\r\n public class Startup\r\n {\r\n .\r\n .\r\n .\r\n public void ConfigureServices(IServiceCollection services)\r\n {\r\n .\r\n .\r\n .\r\n services.AddSingleton<AzQueue>(new AzQueue("mymessage"));\r\n .\r\n .\r\n .\r\n }\r\n\r\n .\r\n .\r\n .\r\n }\r\n<\/pre>\n
Yukar\u0131daki kod blo\u011funa bakarsan\u0131z e\u011fer ilgili s\u0131n\u0131f servis olarak eklenirken biryandan da constructor \u00fczerinden mesaj kuyru\u011funun ismide belirtilmektedir.\n<\/li>\n
Ad\u0131m 4<\/strong>
\nArd\u0131ndan isimleri ‘ProducerController’ ve ‘ConsumerController’ olmak \u00fczere iki adet controller s\u0131n\u0131f\u0131 olu\u015fturunuz ve i\u00e7eriklerini a\u015fa\u011f\u0131daki gibi geli\u015ftiriniz.<\/p>\n
ProducerController;<\/p>\n
\r\n [Route("api\/[controller]")]\r\n [ApiController]\r\n public class ProducerController : ControllerBase\r\n {\r\n readonly AzQueue _azQueue;\r\n public ProducerController(AzQueue azQueue)\r\n {\r\n _azQueue = azQueue;\r\n }\r\n [HttpGet("[action]\/{messageText}")]\r\n public async Task<IActionResult> SendMessageAsync(string messageText)\r\n {\r\n try\r\n {\r\n await _azQueue.SendMessageAsync(messageText);\r\n return Ok(true);\r\n }\r\n catch (Exception ex)\r\n {\r\n return Ok(ex.Message);\r\n }\r\n }\r\n [HttpGet("[action]\/{newMessageText}")]\r\n public async Task<IActionResult> UpdateMessageAsync(string newMessageText)\r\n {\r\n try\r\n {\r\n await _azQueue.UpdateMessageAsync(newMessageText);\r\n return Ok(true);\r\n }\r\n catch (Exception ex)\r\n {\r\n return Ok(ex.Message);\r\n }\r\n }\r\n [HttpGet("[action]")]\r\n public async Task<IActionResult> DeleteMessageAsync()\r\n {\r\n try\r\n {\r\n await _azQueue.DeleteMessageAsync();\r\n return Ok(true);\r\n }\r\n catch (Exception ex)\r\n {\r\n return Ok(ex.Message);\r\n }\r\n }\r\n [HttpGet("[action]")]\r\n public async Task<IActionResult> DeleteQueueAsync()\r\n {\r\n try\r\n {\r\n await _azQueue.DeleteQueueAsync();\r\n return Ok(true);\r\n }\r\n catch (Exception ex)\r\n {\r\n return Ok(ex.Message);\r\n }\r\n }\r\n }\r\n<\/pre>\n
ConsumerController;<\/p>\n
\r\n [Route("api\/[controller]")]\r\n [ApiController]\r\n public class ConsumerController : ControllerBase\r\n {\r\n readonly AzQueue _azQueue;\r\n public ConsumerController(AzQueue azQueue)\r\n {\r\n _azQueue = azQueue;\r\n }\r\n [HttpGet("[action]")]\r\n public async Task<IActionResult> RetrieveMessageAsync()\r\n {\r\n try\r\n {\r\n QueueMessage queueMessage = await _azQueue.RetrieveNextMessageAsync();\r\n return Ok(queueMessage?.MessageText);\r\n }\r\n catch (Exception ex)\r\n {\r\n return Ok(ex.Message);\r\n }\r\n }\r\n [HttpGet("[action]")]\r\n public async Task<IActionResult> PeekMessageAsync()\r\n {\r\n try\r\n {\r\n PeekedMessage peekedMessage = await _azQueue.PeekMessageAsync();\r\n return Ok(peekedMessage?.MessageText);\r\n }\r\n catch (Exception ex)\r\n {\r\n return Ok(ex.Message);\r\n }\r\n }\r\n }\r\n<\/pre>\n<\/li>\n<\/ul>\n
Bu i\u015flemlerden sonra art\u0131k uygulamay\u0131 test etmek i\u00e7in derleyip, \u00e7al\u0131\u015ft\u0131rabilirsiniz.<\/p>\n
Test Edelim<\/strong>
\n $\"Azure$ <\/a><\/p>\n
S\u00fcre\u00e7te kuyru\u011fu Azure portal<\/a> \u00fczerinden takip edebilmek i\u00e7in storage account’unuzdan ‘Queues’e ve onun da ard\u0131ndan ilgili kuyru\u011fa t\u0131klay\u0131n\u0131z.
\n $\"Azure$ <\/a>
\n $\"Azure$ <\/a><\/p>\n
G\u00f6r\u00fcld\u00fc\u011f\u00fc \u00fczere… Kuyruktaki t\u00fcm mesajlar burada listelenmektedir.<\/p>\n
\u0130lgilenenlerin faydalanmas\u0131 dile\u011fiyle…
\nSonraki yaz\u0131lar\u0131mda g\u00f6r\u00fc\u015fmek \u00fczere…
\n\u0130yi \u00e7al\u0131\u015fmalar…<\/p>\n
Not : \u00d6rnek projeyi indirmek i\u00e7in buraya<\/a> t\u0131klay\u0131n\u0131z.<\/p>\n","protected":false},"excerpt":{"rendered":"
Merhaba, Bu i\u00e7eri\u011fimizde Azure Storage Yaz\u0131 Dizisinin sonuncu makalesi olan Azure Queue Storage \u00fczerine konu\u015fuyor olaca\u011f\u0131z. Azure Queue Storage Nedir? Azure Queue Storage, bir mesaj kuyruk sistemidir. Mesaj kuyruk sistemleri; uzun s\u00fcren i\u015flemlerin arka...<\/p>\n","protected":false},"author":1,"featured_media":16718,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[3102,3121],"tags":[3657,3658,3659,3604,3660],"class_list":["post-16966","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-asp-net-core","category-azure","tag-azure-queue-storage","tag-azure-queue-storage-asp-net-core","tag-azure-queue-storage-visibility","tag-azure-storage","tag-visibility-time-out"],"amp_enabled":true,"_links":{"self":[{"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/posts\/16966","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/comments?post=16966"}],"version-history":[{"count":31,"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/posts\/16966\/revisions"}],"predecessor-version":[{"id":17007,"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/posts\/16966\/revisions\/17007"}],"wp:featuredmedia":[{"embeddable":true,"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/media\/16718"}],"wp:attachment":[{"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/media?parent=16966"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/categories?post=16966"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/tags?post=16966"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}