最近做完一个用户上传视频文件,在服务器完成转码的服务。根据需要设计了一个简单的消息通知系统,使用pushlet实现。如有错误,欢迎指正,非常感谢。
[资源]
官方网站:http://www.pushlets.com/ 下载到pushlet的jar包,解压后可以看到官方的例子。
在实践中参考了pushlet-2.0.4\webapps\pushlet\examples\ajax\ajax-2.html的例子
第一步
将pushlet.jar放到工程的lib目录中,将pushlet-2.0.4\webapps\pushlet\lib\js-pushlet-client.js放到网页能访问的目录,将pushlet-2.0.4\webapps\pushlet\WEB-INF\classes\pushlet.properties和pushlet-2.0.4\webapps\pushlet\WEB-INF\classes\sources.properties拷贝到工程目录的classes目录下。
第二步
使用pushlets在网页客户端中配置非常简单
在网中页面引用如下代码
<script type="text/javascript" src="../../lib/ajax-pushlet-client.js">
</script>
<script type="text/javascript">
//可以设置debug为true,会在新标签页中打印debug信息,调试的时候非常有用。
PL.setDebug(false);
// Pushlet Event Callback from Server
//回调
function onEvent(event) {
pr(event.toString());
}
//订阅topic
function joinListen() {
pr('joinListen...');
PL.joinListen('/pushlet/ping');
}
//取消订阅
function leave() {
pr('leaving...');
PL.leave();
}
// 打印信息
function pr(aString) {
document.disp.event.value = aString;
}
//-->
</script>
第三步
在工程的web.xml中添加配置如下
<!-- Define the pushlet servlet -->
<servlet>
<servlet-name>pushlet</servlet-name>
<servlet-class>nl.justobjects.pushlet.servlet.Pushlet</servlet-class>
<load-on-startup>1</load-on-startup>
</servlet>
<!-- Define the Servlet Mappings. -->
<!-- The pushlet -->
<servlet-mapping>
<servlet-name>pushlet</servlet-name>
<url-pattern>/js/pushlet.srv</url-pattern>
</servlet-mapping>
其中url-pattern跟前面ajax-pushlet-client.js放置的目录有关,需要根据自己的项目路径调整。
第四步
服务器端实现pushlets有两种方式,第一种使用eventpullsource,需要实现包含一个继承了EventPullSource的内部静态类,如下面代码中的EncodeJobQuery。
public class EncodeJobQuery {
public static class EncodeJobEventPullSource extends EventPullSource {
Logger log = Logger.getLogger(getClass());
@Autowired
PvmsEncodeMessageManager encodeMessageManager;
@Override
protected long getSleepTime() {
return 5000l;
}
@Override
protected Event pullEvent() {
//参数是subject,与js中的subject相同
Event event = Event.createDataEvent("/pushlet/ping");
event.setField("msg", "encoding....");
return event;
}
}
}
同时要在classes/sources.properties文件中增加一个行。
source7=cn.com.people.tv.pvms.encode.EncodeJobQuery$EncodeJobEventPullSource
第二种方法是在程序中调用Dispatcher.getInstance().multicast(event),除了multicast还有其他两种方法用来发送消息。
String subject = "/pushlet/ping"
Event event = Event.createDataEvent(subject);
event.setField("msg", "ping.....");
PvmsEncodeMessage.MSG_MESSAGE_COUNT);
Dispatcher.getInstance().multicast(event);
总结:
在使用的过程中遇到了若干问题
1.怎么实现根据用户来推送消息
我在实现的时候为不同的用户定义不同的topic,根据用户id来区分。看了文档介绍,说可以绑定pushlet的session,没研究明白具体怎么操作。我的实现方式缺点是,如果服务器重启或者消息发送失败导致pushlet的session关闭,那么后续的消息就没办法发送给用户。
2.发送离线消息
我把消息存在服务器,只用pushlet来发送当前的消息数量。比如在用户登录后,发送给用户一条消息告诉用户有多少条未读消息,用户可以手动标记消息为已读或者删除消息。
分享到:
相关推荐
pushlet系统消息推送demo,pushlet消息推送示例
服务器推 pushlet 服务器推 pushlet 服务器推 pushlet 服务器推 pushlet
此实例采用 pushlet2.0.4 官方最新 servlet+jsp 实现多个客户端连接到web服务器,由服务端推送消息至客户端(或指定id的客户端),代码中没有用官网的jar文件,而是用的源码,做了一定的修改,实现了每个客户端都可以...
pushlet定时向前台推送消息,可以直接运行
NULL 博文链接:https://cuisuqiang.iteye.com/blog/1416771
pushlet开发与应用
来新消息时的通知 前台使用Ext ,后台使用pushlet /pushlet/WebRoot/index.jsp 页面主要包含几个部分。 Ext.PUSHLET_URL='piccUtil'; // 发送消息的地址 Ext.fcontent='fcontent'; // 显示窗口或有新消息时, ...
简单的消息推送实例,解决了中文错误问题!
这是自己用过的pushlet定时向页面发送消息的一个demo
pushlet白皮书pushlet白皮书pushlet白皮书pushlet白皮书pushlet白皮书
来新消息时的通知 前台使用Ext ,后台使用pushlet /pushlet/WebRoot/index.jsp 页面主要包含几个部分。 Ext.PUSHLET_URL='piccUtil'; // 发送消息的地址 Ext.fcontent='fcontent'; // 显示窗口或有新消息时, ...
pushlet配置应用实例,看了之后就能简单应用pushlet实时推送数据
NULL 博文链接:https://cuisuqiang.iteye.com/blog/1693775
自己学习所写,实例中注释较多且详细。实现定时周期性推送、按需求广角推送和点对点推送。包含重新Pushlet的js和java代码。
3.通知解决(Notification Solutions) 5 3.1轮询(Polling) 6 3.2服务器端回调(Server-side callbacks) 6 3.3 消息(Messaging MOM) 6 3.4讨论(Discussion) 7 4.pushlet基础(Pushlet Basics) 8 4.1HTTP流...
pushlet 所需夹包 和配置文件 ajax-pushlet-client.js pushlet-sessionid.jar sources.properties pushlet.properties
找了好久资料,没有找到实例,自己参考网上写的实例,可用。
Pushlet简单示例测试
pushlet例子,Pushlet 是一个开源的 Comet 框架,Pushlet 使用了观察者模式:客户端发送请求,订阅感兴趣的事件;服务器端为每个客户端分配一个会话 ID 作为标记,事件源会把新产生的事件以多播的方式发送到订阅者的...
资源简介pushlet可以用于消息及时提示.这个例子主要是一个pushlet的小小的实例。 jar包 非常实用,目前正在使用中,稳定