基于ajax與msmq技術(shù)的消息推送功能實(shí)現(xiàn)代碼

更新時(shí)間：2016年12月26日 09:07:09 作者：玻璃魚(yú)兒

這篇文章主要介紹了基于ajax與msmq技術(shù)的消息推送功能實(shí)現(xiàn)代碼，具有一定的參考價(jià)值，有興趣的可以了解一下。

周末在家搗鼓了一下消息推送的簡(jiǎn)單例子，其實(shí)也沒(méi)什么技術(shù)含量，歡迎大伙拍磚。

我設(shè)計(jì)的這個(gè)推送demo是基于ajax長(zhǎng)輪詢+msmq消息隊(duì)列來(lái)實(shí)現(xiàn)的，具體交互過(guò)程如下圖：

先說(shuō)說(shuō)這個(gè)ajax長(zhǎng)輪詢，多長(zhǎng)時(shí)間才算長(zhǎng)呢？這個(gè)還真不好界定。

這里是相對(duì)普通ajax請(qǐng)求來(lái)說(shuō)的，通常處理一個(gè)請(qǐng)求也就是毫秒級(jí)別的時(shí)間。但是這里的長(zhǎng)輪詢方式

在ajax發(fā)送請(qǐng)求給服務(wù)器之后，服務(wù)器給調(diào)用端返回?cái)?shù)據(jù)的時(shí)間多長(zhǎng)那可還真不好說(shuō)。嘿嘿，這關(guān)鍵要看

我們啥時(shí)候往msmq隊(duì)列中推送數(shù)據(jù)了，先看看推送的效果圖吧。。。。。

抱歉，沒(méi)弄張動(dòng)態(tài)效果圖給大家。實(shí)現(xiàn)的功能大體上就是這樣。上圖中的winform程序中我們點(diǎn)擊即刻發(fā)送按鈕，同時(shí)網(wǎng)頁(yè)上我們就能看到新推送的數(shù)據(jù)。

好了，說(shuō)完具體實(shí)現(xiàn)流程和效果之后馬上就開(kāi)始編碼實(shí)現(xiàn)吧。。。。

消息推送Winform程序代碼

namespace SenderApp
{
  public partial class Form1 : Form
  {
    private string queueName = @".\Private$\pushQueue";
    private MessageQueue pushQueue = null;
    
    public Form1()
    {
      InitializeComponent();
    }

    private void button1_Click(object sender, EventArgs e)
    {
      try
      {
        var queue = this.GetQueue();
        if (string.IsNullOrEmpty(this.textBox1.Text)) { this.label1.Text = "推送消息不能為空"; return; }
        queue.Send(this.textBox1.Text, "messagePush");
        this.label1.Text = "消息推送成功";
      }
      catch (Exception ex)
      {
        this.label1.Text = string.Format("消息推送失?。簕0}",ex.Message);
      }
    }

    private MessageQueue GetQueue()
    {
      if (this.pushQueue == null)
      {
        if (!MessageQueue.Exists(queueName))
        {
          this.pushQueue = MessageQueue.Create(queueName);
        }
        else
        {
          this.pushQueue = new MessageQueue(queueName);
        }
      }
      return this.pushQueue;
    }

    private void textBox1_MouseDown(object sender, MouseEventArgs e)
    {
      this.textBox1.Text = "";
      this.label1.Text = "推送狀態(tài)";
    }
  }
}

Web服務(wù)端代碼

namespace MessagePushWeb.Controllers
{
  public class HomeController : Controller
  {
    private static string queueName = @".\Private$\pushQueue";
    private static MessageQueue pushQueue = null;

    public ActionResult Index()
    {
      return View();
    }

    public async Task<ActionResult> GetMessage()
    {
      string msg = await Task.Run(() => {
        return this.ReadMessage();
      });
      
      return Content(msg);
    }


    private MessageQueue GetQueue()
    {
      if (pushQueue == null)
      {
        if (MessageQueue.Exists(queueName))
        {
          pushQueue = new MessageQueue(queueName);
          pushQueue.Formatter = new XmlMessageFormatter(new string[] { "System.String" });
        }
      }
      return pushQueue;
    }

    private string ReadMessage()
    {
      var queue = GetQueue();
      Message message = queue.Receive();
      return message.Body.ToString();
    }
  }
}

頁(yè)面視圖代碼

@{
  ViewBag.Title = "Push";
}


<h2>Push</h2>

<div>接收消息列表</div>
<div id="msg"></div>

<script type="text/javascript">
  $(function () {
    getMessage();
  });


  function getMessage() {
    $.get("/home/getmessage", {}, function (data) {
      var _msg = $("#msg").html();
      $("#msg").html(_msg + "<li>" + data + "</li>");
      getMessage();
    });
   }
</script>

當(dāng)然，在這個(gè)只是一個(gè)初級(jí)的消息推送demo，是否能勝任生產(chǎn)環(huán)境的需要還有待考證。

如果你也有更好的實(shí)現(xiàn)和建議，都?xì)g迎留言給我。

源碼在這里：http://pan.baidu.com/s/1hsHSLTy

以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

您可能感興趣的文章: