基于ajax与msmq技术的消息推送功能实现代码

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 = "推送状态";    }  }}

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();    }  }}

@{  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>