什么是隊(duì)列:簡單的說就是數(shù)據(jù)存儲到一個(gè)空間里(可以是內(nèi)存,也可以是物理文件),先存儲的數(shù)據(jù)對象,先被取出來,這與堆棧正好相反,消息隊(duì)列也是這樣,將可能出現(xiàn)高并發(fā)的數(shù)據(jù)進(jìn)行隊(duì)列存儲,并按著入隊(duì)的順序依次處理,實(shí)現(xiàn)消息隊(duì)列的工具有很多,如微軟的MSMQ,及一些開源的KV存儲工具,今天主要介紹用Redis實(shí)現(xiàn)消息隊(duì)列。
噶爾網(wǎng)站建設(shè)公司創(chuàng)新互聯(lián),噶爾網(wǎng)站設(shè)計(jì)制作,有大型網(wǎng)站制作公司豐富經(jīng)驗(yàn)。已為噶爾超過千家提供企業(yè)網(wǎng)站建設(shè)服務(wù)。企業(yè)網(wǎng)站搭建\外貿(mào)網(wǎng)站建設(shè)要多少錢,請找那個(gè)售后服務(wù)好的噶爾做網(wǎng)站的公司定做!這是我的redis項(xiàng)目結(jié)構(gòu)
redis服務(wù)有一個(gè)console的程序,可以支持在windows和linux下運(yùn)行。
我用MVC應(yīng)用程序來作這個(gè)例子,由表單向內(nèi)存中寫信息,然后每5秒中從內(nèi)存中將消息取出來,看代碼
///
/// 消息對象類型
///
public class MessageQuene
{
static System.Timers.Timer timer = new System.Timers.Timer(5000);
public static ChatModels CurrentChatModels = new ChatModels();
static Redis.Utils.RedisClient redisClient;
static MessageQuene()
{
redisClient = new Redis.Utils.RedisClient();
timer.AutoReset = true;
timer.Enabled = true;
timer.Elapsed += new System.Timers.ElapsedEventHandler(timer_Elapsed);//subscribe a event
timer.Start();
}
private static void timer_Elapsed(object sender, ElapsedEventArgs e)
{
CurrentChatModels = (ChatModels)redisClient.LeftPop("MessageQuene");
}
}
前臺顯示的action
public ActionResult Index()
{
ViewData["pop"] = MessageQuene.CurrentChatModels == null ? "沒?有D記?錄?" : MessageQuene.CurrentChatModels.Chat;
ViewData["MSMQ"] = redisClient.ListRange("MessageQuene") == null
? new List()
: redisClient.ListRange("MessageQuene").Cast().ToList();
}
表單提交的action
事件上,如果我們在項(xiàng)目中用到消息隊(duì)列時(shí),可以直接使用ViewData["pop"]
這個(gè)對象,它就是當(dāng)前取出的隊(duì)列元素,我們可以對它進(jìn)行數(shù)據(jù)操作等。
創(chuàng)新互聯(lián)www.cdcxhl.cn,專業(yè)提供香港、美國云服務(wù)器,動態(tài)BGP最優(yōu)骨干路由自動選擇,持續(xù)穩(wěn)定高效的網(wǎng)絡(luò)助力業(yè)務(wù)部署。公司持有工信部辦法的idc、isp許可證, 機(jī)房獨(dú)有T級流量清洗系統(tǒng)配攻擊溯源,準(zhǔn)確進(jìn)行流量調(diào)度,確保服務(wù)器高可用性。佳節(jié)活動現(xiàn)已開啟,新人活動云服務(wù)器買多久送多久。