ตอนที่ 15 : How to use .Net (Asp.net) De-queue the next messag - ขยับไปยังคิวถัดไป
ตอนที่ 15 : How to use .Net (Asp.net) De-queue the next messag - ขยับไปยังคิวถัดไป บทความนี้จะเป็นตัวอย่างการใช้งาน Queue และกระบวนการทำงานกับ Queue หลังจากที่ได้ Queue ล่าสุดแล้ว จะทำงาน Queue นั้น ๆ ให้เสร็จสิ้น และลบ Queue ออกจากระบบ เพื่อให้ Queue ถัดไปขึ้นมาแทนที เพื่อที่จะรอการทำงานในลำดับถัดไป
Syntax การอ่าน Queue ทำงาน Queue และลบ Queue
// Retrieve a reference to a queue.
CloudQueue queue = queueClient.GetQueueReference("myqueue");
// Peek at the next message
CloudQueueMessage peekedMessage = queue.PeekMessage();
// Display message.
this.lblResult.Text = peekedMessage.AsString;
//*** Do Process ***//
//
//
//
//*** Do Process ***//
// Get the next message
CloudQueueMessage retrievedMessage = queue.GetMessage();
//Process the message in less than 30 seconds, and then delete the message
queue.DeleteMessage(retrievedMessage);
using System;
using System.Collections.Generic;
using System.Linq;
using System.Web;
using System.Web.UI;
using System.Web.UI.WebControls;
using Microsoft.WindowsAzure.Storage;
using Microsoft.WindowsAzure.Storage.Auth;
using Microsoft.WindowsAzure.Storage.Queue;
namespace myWebApp
{
public partial class Default : System.Web.UI.Page
{
protected void Page_Load(object sender, EventArgs 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.PeekMessage();
// Display message.
this.lblResult.Text = peekedMessage.AsString;
//*** Do Process ***//
//
//
//
//*** Do Process ***//
// Get the next message
CloudQueueMessage retrievedMessage = queue.GetMessage();
//Process the message in less than 30 seconds, and then delete the message
queue.DeleteMessage(retrievedMessage);
}
}
}
ช่วยกันสนับสนุนรักษาเว็บไซต์ความรู้แห่งนี้ไว้ด้วยการสนับสนุน 
Load balance : Server 05
