Forgot Password ??

PHP , ASP , ASP.NET, VB.NET, C#, Java , jQuery , Android , iOS , Windows Phone

	Registered : 109,038

HOME > Windows Store Apps > Windows Store and Windows Azure Storage (C#) > Windows Store Apps and Windows Azure Queue Storage (C#)

Windows Store Apps and Windows Azure Queue Storage (C#)

Windows Store Apps and Windows Azure Queue Storage (C#) ในบทความนี้จะเป็นการเขียน Windows Store Apps กับ Windows Azure Queue Storage เซึ่ง Queue เป็นบริการภายใต้ Storage ใช้สำหรับการสร้าง Queue หรือกลุ่มของลำดับข้อมูล แบบ First-In Last-Out เรียงลำดับก่อนหลัง เช่นในระบบการส่ง Message ไปยังสมาชิก ประมาณ 100,000 คน เราก็อาจจะสร้าง Queue Services จัดเก็บลำดับของสมาชิกทั้ง 100,000 คนด้วยการนำข้อมูลทั้งหมดบันทึกลงใน Queue และเมื่อได้ Queue แล้ว เราจะใช้ Windows Store Apps เข้าไปจัดการกับ Queue เช่น การอ่าน Queue เพื่อทำงาน และการขยับไปยัง Queue ถัดไป รวมทั้งการ Delete หรือ Insert รายการ Queue ต่าง ๆ

โครงสร้างของ Queue จะแบ่งเป็นขั้นลำดับคือ Account -> Queue-> Queue List (ซึ่งข้อมูล Queue จะถูกจัดเก็บไว้ที่นี่)

การติดตั้ง Library API : Windows Store Apps and Windows Azure Storage

https://www.thaicreate.com/windows-store/windows-store-app-windows-azure-storage-config.html

ขั้นตอนการเเขียน Windows Store Apps กับ Queue (Windows Azure Storage) ในขั้นแรกสุดเราหลังจากที่เราสร้าง Services ของ Storage บน Azure Portal Management เรียบร้อยแล้ว คือจะต้องสร้าง Queue (เปรียบเหมือนกลุ่มของ Queue ที่จะจัดเก็บลำดับต่าง ๆ)

เรียกใช้ Class ของ AzureStorage

using Microsoft.WindowsAzure.Storage;
using Microsoft.WindowsAzure.Storage.Auth;
using Microsoft.WindowsAzure.Storage.Queue;

สิ่งที่จะต้องเตรียมคือ Account และ API Key

DefaultEndpointsProtocol=https;AccountName=[yourAccount];AccountKey=[yourKey]

สร้าง Connection สำหรับการเชื่อมต่อ

1.// Create the connectionstring

2.String StorageConnectionString = "DefaultEndpointsProtocol=https;AccountName=[yourAccount];AccountKey=[yourKey]";

ทำการเชื่อมต่อไปยัง Azure Storage

1.// Retrieve storage account from connection string.

2. CloudStorageAccount storageAccount = CloudStorageAccount.Parse(StorageConnectionString);

การเรียกใช้งาน Queue Services

1.// Create the queue client

2.CloudQueueClient queueClient = storageAccount.CreateCloudQueueClient();

หลังจากนั้นเราสามารถทำการสร้าง Queue ตาม Code นี้

Code การสร้าง Queue

public sealed partial class MainPage : Page
{
 
 
    protected async override void OnNavigatedTo(NavigationEventArgs e)
    {
        // Create the connectionstring
        String StorageConnectionString = "DefaultEndpointsProtocol=https;AccountName=[yourAccount];AccountKey=[yourKey]";
 
        // Retrieve storage account from connection string.
        CloudStorageAccount storageAccount = CloudStorageAccount.Parse(StorageConnectionString);
 
        // Create the queue client
        CloudQueueClient queueClient = storageAccount.CreateCloudQueueClient();
 
        // Retrieve a reference to a queue
        CloudQueue queue = queueClient.GetQueueReference("myqueue");
 
        // Create the queue if it doesn't already exist
        await queue.CreateIfNotExistsAsync();
   
    }
 
}

จาก Code จะได้ Queue ชื่อว่า myqueue เมื่อใช้ Azure Storage Explorer เราจะพบกับ Queue ที่เราสร้างขึ้น

Example 1 การ Insert Queue เพื่อสร้างลำดับของ Queue

public sealed partial class MainPage : Page
{
 
 
    protected async override void OnNavigatedTo(NavigationEventArgs e)
    {
        // Create the connectionstring
        String StorageConnectionString = "DefaultEndpointsProtocol=https;AccountName=[yourAccount];AccountKey=[yourKey]";
 
        // Retrieve storage account from connection string.
        CloudStorageAccount storageAccount = CloudStorageAccount.Parse(StorageConnectionString);
 
        // Create the queue client
        CloudQueueClient queueClient = storageAccount.CreateCloudQueueClient();
 
        // Retrieve a reference to a queue.
        CloudQueue queue = queueClient.GetQueueReference("myqueue");
 
        // Create the queue if it doesn't already exist.
        await queue.CreateIfNotExistsAsync();
 
        // Create a message and add it to the queue.
        CloudQueueMessage message = new CloudQueueMessage("Hello World! 1");
        await queue.AddMessageAsync(message);
   
    }
 
}

จาก Code จะเป็นการสร้าง Queue โดยจัดเก็บข้อความว่า Hello World! 1 ลงใน myqueue

Windows Store Apps and Windows Azure Queue Storage (C#)

หลังจากที่ Insert เรียบร้อยแล้ว สามารถดู Queue ผ่าน Azure Storage Explorer ก็จะพบ Queue ที่ Insert เข้าไป

ดูผ่านโปรแกรม Azure Storage Explorer เลือก Edit

Windows Store Apps and Windows Azure Queue Storage (C#)

แสดงข้อมูลที่ถูก Messageลงไปใน Queue

Windows Store Apps and Windows Azure Queue Storage (C#)

เมื่อทดสอบการเพิ่ม Message อื่น ๆ เข้าไปหลาย ๆ รายการ ข้อมูลก็จะแบ่งออกเป็นหลาย ๆ แถว และแสดงข้อมูลตามลำดับ จากภาพประกอบด้วย Hello World! 1 , Hello World! 2 , Hello World! 3 และ Hello World! 4

Example 2 การนับจำนวน Queue ที่อยู่ใน Queue ทั้งหมด

public sealed partial class MainPage : Page
{
 
 
    protected async override void OnNavigatedTo(NavigationEventArgs e)
    {
        // Create the connectionstring
        String StorageConnectionString = "DefaultEndpointsProtocol=https;AccountName=[yourAccount];AccountKey=[yourKey]";
 
        // Retrieve storage account from connection string.
        CloudStorageAccount storageAccount = CloudStorageAccount.Parse(StorageConnectionString);
 
        // Create the queue client
        CloudQueueClient queueClient = storageAccount.CreateCloudQueueClient();
 
        // Retrieve a reference to a queue.
        CloudQueue queue = queueClient.GetQueueReference("myqueue");
 
        // Fetch the queue attributes.
        await queue.FetchAttributesAsync();
 
        // Retrieve the cached approximate message count.
        int? cachedMessageCount = queue.ApproximateMessageCount;
 
        // Display number of messages.
 
        this.lblResult.Text = cachedMessageCount.ToString();
 
   
    }
 
}

แสดงจำนวน Queue

Example 3 การอ่าน Queue ล่าสุดที่กำลังจะถึง หรือรอคิวลำดับแรกสุด

public sealed partial class MainPage : Page
{
    public MainPage()
    {
        this.InitializeComponent();
    }
 
 
    protected async override void OnNavigatedTo(NavigationEventArgs e)
    {
 
        // Create the connectionstring
        String StorageConnectionString = "DefaultEndpointsProtocol=https;AccountName=[yourAccount];AccountKey=[yourKey]";
 
        // Retrieve storage account from connection string.
        CloudStorageAccount storageAccount = CloudStorageAccount.Parse(StorageConnectionString);
 
        // Create the queue client
        CloudQueueClient queueClient = storageAccount.CreateCloudQueueClient();
 
        // Retrieve a reference to a queue.
        CloudQueue queue = queueClient.GetQueueReference("myqueue");
 
        // Peek at the next message
       // CloudQueueMessage peekedMessage = queue.PeekMessageAsync();
        CloudQueueMessage peekedMessage = await queue.PeekMessageAsync();
 
        // Display message.
        this.lblResult.Text = peekedMessage.AsString;
   
    }
 
}

แสดง Message หรือ Queue ที่กำลังรอคิว

Example 4 การสร้างการทำงานใน Queue และการขยับไปยัง Queue ถัดไป

Windows Store Apps and Windows Azure Queue Storage (C#)

ใน Queue ปัจจุบันมีรออยู่ 4 Queue คือ Hello World! 1 , Hello World! 2 , Hello World! 3 และ Hello World! 4

public sealed partial class MainPage : Page
{
    public MainPage()
    {
        this.InitializeComponent();
    }
 
 
    protected async override void OnNavigatedTo(NavigationEventArgs e)
    {
 
        // Create the connectionstring
        String StorageConnectionString = "DefaultEndpointsProtocol=https;AccountName=[yourAccount];AccountKey=[yourKey]";
 
        // Retrieve storage account from connection string.
        CloudStorageAccount storageAccount = CloudStorageAccount.Parse(StorageConnectionString);
 
        // Create the queue client
        CloudQueueClient queueClient = storageAccount.CreateCloudQueueClient();
 
        // Retrieve a reference to a queue.
        CloudQueue queue = queueClient.GetQueueReference("myqueue");
 
        // Peek at the next message
        CloudQueueMessage peekedMessage = await queue.PeekMessageAsync();
 
        // Display message.
        this.lblResult.Text = peekedMessage.AsString;
 
        //*** Do Process ***//
        //
        //
        //
        //*** Do Process ***//
 
        // Get the next message
        CloudQueueMessage retrievedMessage = await queue.GetMessageAsync();
 
        //Process the message in less than 30 seconds, and then delete the message
        await queue.DeleteMessageAsync(retrievedMessage);
   
    }
 
}

จาก Code จะเห็นว่ามีช่วงการทำ Process

//*** Do Process ***//
//
//
//
//*** Do Process ***//

โดยเราสามารถแทรกคำสั่งการทำงานต่าง ๆ เช่น ส่งข้อความไปยัง User หรือทำงานอื่น ๆ จากนั้นเราสามารถลบ Queue ด้วยคำสั่ง

1.//Process the message in less than 30 seconds, and then delete the message

2.await queue.DeleteMessageAsync(retrievedMessage);

หลังจากนั้นเมื่อเรียกใช้งานอีกครั้งโปรแกรมก็จะขยับไปยัง Queue ถัดไป

Windows Store Apps and Windows Azure Queue Storage (C#)

Queue แรกถูกทำงานโดยแสดงข้อความ Hello World! 2

Windows Store Apps and Windows Azure Queue Storage (C#)

หลังจากที่ Queue แรกถูกทำงาน ก็จะถูกลบออกไปจากระบบ Queue

Windows Store Apps and Windows Azure Queue Storage (C#)

Queue ของ Hello World! 2

Windows Store Apps and Windows Azure Queue Storage (C#)

Queue ของ Hello World! 3

Windows Store Apps and Windows Azure Queue Storage (C#)

Queue ของ Hello World! 4

.

Total Votes: 2Overall Rating: 2.5 / 5

ช่วยกันสนับสนุนรักษาเว็บไซต์ความรู้แห่งนี้ไว้ด้วยการสนับสนุน Source Code 2.0 ของทีมงานไทยครีเอท

ลองใช้ค้นหาข้อมูล


	By :	ThaiCreate.Com Team (บทความเป็นลิขสิทธิ์ของเว็บไทยครีเอทห้ามนำเผยแพร่ ณ เว็บไซต์อื่น ๆ)
	Score Rating :
	Create/Update Date :	2014-07-21 12:34:43 / 2017-03-19 14:26:19
	Download :	No files

Sponsored Links / Related

Windows Store Apps and Windows Azure Storage
Rating :

Windows Store Apps and Windows Azure Blob Storage (C#)
Rating :

Windows Store Apps and Windows Azure Table Storage (C#)
Rating :

สอน Windows Phone การเขียนโปรแกรม Windows Phone 7 และ 8

สอน Java GUI การเขียนโปรแกรม ภาษา Java GUI

Free Tutorial

	สอน Google Maps Api
	สอน Windows Service
	สอน Entity Framework
	สอน Android
	สอน Java เขียน Java
	Java GUI Swing
	สอน JSP (Web App)
	iOS (iPhone,iPad)
	Windows Phone
	Windows Azure
	Windows Store
	Laravel Framework
	Yii PHP Framework
	สอน jQuery
	สอน jQuery กับ Ajax
	สอน PHP OOP (Vdo)
	Ajax Tutorials
	SQL Tutorials
	สอน SQL (Part 2)
	JavaScript Tutorial
	Javascript Tips
	VBScript Tutorial
	VBScript Validation
	Microsoft Access
	MySQL Tutorials
	-- Stored Procedure
	MariaDB Database
	SQL Server Tutorial
	SQL Server 2005
	SQL Server 2008
	SQL Server 2012
	-- Stored Procedure
	Oracle Database
	-- Stored Procedure
	SVN (Subversion)
	แนวทางการทำ SEO
	ปรับแต่งเว็บให้โหลดเร็ว

Hit Link

ShotDev

แลกเปลี่ยน Exchange Link

Registered : 109,038

Windows Store Apps and Windows Azure Queue Storage (C#)

ลองใช้ค้นหาข้อมูล