基于ajax与msmq技术的消息推送功能如何实现?

本文和大家分享的主要是基于ajax与msmq技术的消息推送功能相关实现方法,一起来看看吧,希望对大家学习ajax 有所帮助。

我设计的这个推送demo是基于ajax长轮询+msmq消息队列来实现的,具体交互过程如下图:

先说说这个ajax长轮询,多长时间才算长呢?这个还真不好界定。

这里是相对普通ajax请求来说的,通常处理一个请求也就是毫秒级别的时间。但是这里的长轮询方式

在ajax发送请求给服务器之后,服务器给调用端返回数据的时间多长那可还真不好说。嘿嘿,这关键要看

我们啥时候往msmq队列中推送数据了,先看看推送的效果图吧。。。。。

抱歉,没弄张动态效果图给大家。实现的功能大体上就是这样。上图中的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 = "推送状态";

}

}

}

消息推送Winform程序代码

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 TaskGetMessage()

{

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

}

}

}

Web服务端代码

@{

ViewBag.Title = "Push";

}

<h2>Pushh2>

<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 + "

·

" + data + "

·

·

");

·

getMessage();

});

}script>

页面视图代码

当然,在这个只是一个初级的消息推送demo,是否能胜任生产环境的需要还有待考证。

来源:博客园

时间: 2024-10-29 19:06:49

基于ajax与msmq技术的消息推送功能如何实现?的相关文章

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

周末在家捣鼓了一下消息推送的简单例子,其实也没什么技术含量,欢迎大伙拍砖.我设计的这个推送demo是基于ajax长轮询+msmq消息队列来实现的,具体交互过程如下图: 先说说这个ajax长轮询,多长时间才算长呢?这个还真不好界定.这里是相对普通ajax请求来说的,通常处理一个请求也就是毫秒级别的时间.但是这里的长轮询方式在ajax发送请求给服务器之后,服务器给调用端返回数据的时间多长那可还真不好说.嘿嘿,这关键要看我们啥时候往msmq队列中推送数据了,先看看推送的效果图吧..... 抱歉,没弄张

MQTT是IBM开发的一个即时通讯协议,构建于TCP/IP协议上,是物联网IoT的订阅协议,借助消息推送功能,可以更好地实现远程控制

最近一直做物联网方面的开发,以下内容关于使用MQTT过程中遇到问题的记录以及需要掌握的机制原理,主要讲解理论. 背景 MQTT是IBM开发的一个即时通讯协议.MQTT构建于TCP/IP协议上,面向M2M和物联网IoT的连接协议,采用轻量级发布和订阅消息传输机制.Mosquitto是一款实现了 MQTT v3.1 协议的开源消息代理软件,提供轻量级的,支持发布/订阅的的消息推送模式,使设备对设备之间的短消息通信简单易用. 基本概念 [MQTT协议特点]——相比于RESTful架构的物联网系统,MQ

使用PopupWin控件实现消息推送功能

最近项目需要,急需实现消息推送功能,陆陆续续的也试用了好多办法,比如用JavaScript来实现啊,效果都不咋好,最后找了PopupWin这个,看着效果都还不错,就开始使用了. 1.准备工作,先去网上下载"EeekSoft.Web.PopupWin.dll".放到你项目根目录下面,添加引用. 2.在前台页面添加 <%@ Register TagPrefix="cc1" Namespace="EeekSoft.Web" Assembly=&q

关于iOS消息推送功能

最近由于要用到iOS消息推送,在这里就研究了一番,在此感激各位大神的指导和无私分享.本文主要是针对产品发布版本的一些问题 综合了网上一些资料根据自己实践写的 不过测试也可以看看.推送功能的原理什么的我就不说了 网上关于推送的资料很多 不过有很多一部分都写的不知所以然 不过原理还是可以弄明白的这里附上一篇英文帖子链接http://www.raywenderlich.com/3443/apple-push-notification-services-tutorial-part-12   附上中文翻译

ASP.NET 微信公众平台模板消息推送功能完整开发

最近公众平台的用户提出了新需求,他们希望当收到新的邮件或者日程的时候,公众平台能主动推送一条提醒给用户.看了看平台提供的接口,似乎只有[模板消息]能尽量满足这一需求,但不得不说微信提供的实例太少,而且只有PHP的,不过摸索了一下还是成功的实现了. 首先是准备工作,需要申请开通[模板消息]功能,网上教程很多.然后申请通过之后,用户可以从现有的模板里选择15个使用,也可以自己添加模板使用.这里吐槽一下:申请添加新的模板时,微信出于保护用户的目的禁止了一些“看起来会很频繁”的消息类型,比如这图里的——

APP消息推送功能

1.APP内部最好设计-我的消息-的功能,以便用户查看推送消息历史记录,通过角标.已读.未读等设计吸引用户读取消息.(画下来这都是重点) 2.建议提供推送设置功能,允许用户设置推送消息是否显示于通知栏.接收消息音效.接收时间等.(画下来这里重点要考) 推送策略设计 1.选择合适的时间进行推送,尽量避开用户休息时间(晚上22:00-早上8:00)推送,减少对用户的干扰: 2.一切从用户需求出发,精准推送.根据用户的地理位置.渠道.活跃度等维度对用户分群,从数据去提炼用户需求和使用场景,对不同的用户

Android 基于Netty的消息推送方案之Hello World(一)

消息推送方案(轮询.长连接) 轮询 轮询:比较简单的,最容易理解和实现的就是客户端去服务器上拉信息,信息的及时性要求越高则拉信息的频率越高.客户端拉信息的触发可以是一些事件,也可以是一个定时器,不断地去查询服务器.所以这个方案的弊端也是显而易见的,在轮询的频率较高时,服务器端的压力很大,通讯的流量也很大,并且大部分时间都是做的无用功. 长连接 长连接:客户端和服务端维持一个长连接,服务端在有信息推送的时候,借助这个连接把信息发送到客户端.这个方案的优点是信息推送的及时性很高,基本是实时的,并且除

Android 基于Netty的消息推送方案(一)

消息推送方案(轮询.长连接) 轮询 轮询:比较简单的,最容易理解和实现的就是客户端去服务器上拉信息,信息的及时性要求越高则拉信息的频率越高.客户端拉信息的触发可以是一些事件,也可以是一个定时器,不断地去查询服务器.所以这个方案的弊端也是显而易见的,在轮询的频率较高时,服务器端的压力很大,通讯的流量也很大,并且大部分时间都是做的无用功. 长连接 长连接:客户端和服务端维持一个长连接,服务端在有信息推送的时候,借助这个连接把信息发送到客户端.这个方案的优点是信息推送的及时性很高,基本是实时的,并且除

WebSocket与消息推送

B/S结构的软件项目中有时客户端需要实时的获得服务器消息,但默认HTTP协议只支持请求响应模式,这样做可以简化Web服务器,减少服务器的负担,加快响应速度,因为服务器不需要与客户端长时间建立一个通信链接,但不容易直接完成实时的消息推送功能,如聊天室.后台信息提示.实时更新数据等功能,但通过polling.Long polling.长连接.Flash Socket以及HTML5中定义的WebSocket能完成该功能需要. 一.Socket简介 Socket又称"套接字",应用程序通常通过