dwr3的推送功能使用

前端之家收集整理的这篇文章主要介绍了dwr3的推送功能使用前端之家小编觉得挺不错的,现在分享给大家,也给大家做个参考。

1、web.xml的配置,红色部分为dwr推技术的主要配置

<servlet>
<servlet-name>dwr-invoker</servlet-name>
<servlet-class>org.directwebremoting.servlet.DwrServlet</servlet-class>
<init-param>
<param-name>debug</param-name>
<param-value>true</param-value>
</init-param>
<init-param>
<param-name>logLevel</param-name>
<param-value>ERROR</param-value>
</init-param>
<init-param>
<param-name>crossDomainSessionSecurity</param-name>
<param-value>false</param-value>
</init-param>
<init-param>
<param-name>allowScriptTagRemoting</param-name>
<param-value>true</param-value>
</init-param>
<!--
<init-param> <param-name>crossDomainSessionSecurity</param-name>
<param-value>false</param-value> </init-param> <init-param>
<param-name>allowScriptTagRemoting</param-name>
<param-value>true</param-value> </init-param>
-->
<init-param>
<param-name>classes</param-name>
<param-value>java.lang.Object</param-value>
</init-param>
<!-- 开启反转Ajax 即所谓推技术 -->
<init-param>
<param-name>activeReverseAjaxEnabled</param-name>
<param-value>true</param-value>
</init-param>
<init-param>
<param-name>initApplicationScopeCreatorsAtStartup</param-name>
<param-value>true</param-value>
</init-param>
<init-param>
<param-name>maxWaitAfterWrite</param-name>
<param-value>1000</param-value>
</init-param>
<!-- 对dwr scriptSession 自定义管理 -->
<init-param>
<param-name>org.directwebremoting.extend.ScriptSessionManager</param-name>
<param-value>com.xx.xx.util.DwrScriptSessionManagerUtil</param-value>
</init-param>
</servlet>
<servlet-mapping>
<servlet-name>dwr-invoker</servlet-name>
<url-pattern>/dwr/*</url-pattern>
</servlet-mapping>

2、由于使用dwr推技术,在每次刷新的时候都会产生一个新的scriptsession,而dwr本身并没有对旧的scriptsession进行处理,所以需要自己对其进行处理,在初始化配置中加入自己的scriptsession管理类:DwrscriptSessionManagerUtil

public class DwrScriptSessionManagerUtil extends DefaultScriptSessionManager{
public static final String SS_ID="DWR_ScriptSession_Id";
public DwrScriptSessionManagerUtil(){
try{
addScriptSessionListener(new ScriptSessionListener() {

public void sessionDestroyed(ScriptSessionEvent event) {

}

public void sessionCreated(ScriptSessionEvent event) {
ScriptSession scriptSession = event.getSession();//得到新创建的scriptSession
HttpSession httpSession = WebContextFactory.get().getSession();//得到产生的httpSession
Users user = (Users) httpSession.getAttribute(Constant.LG_SESSION_USER);//得到当前用户

//如果当前用户已经退出系统,然后销毁这个scriptsession

if(user==null)
{
scriptSession.invalidate();
httpSession.invalidate();
return;
}
String ssId = (String) httpSession.getAttribute(SS_ID);//查找SS_ID
if(ssId!=null)
{
//说明已经存在旧的scriptSession.注销这个旧的scriptSession
DefaultScriptSession oldScriptSession = sessionMap.get(ssId);
if(oldScriptSession!=null)
{
invalidate(oldScriptSession);
}
}
httpSession.setAttribute(SS_ID,scriptSession.getId());
scriptSession.setAttribute(Constant.LG_USER_ID,user.getId());//绑定用户ID到ScriptSession上
}
});
}catch (Exception e) {
System.out.println("zhelichucuo");
e.printStackTrace();
}
}

public static void invalidate(String ssId)
{
Browser.withSession(ssId,new Runnable() {

public void run() {
Collection<ScriptSession> sessions = Browser.getTargetSessions();
for(ScriptSession session : sessions)
{
session.invalidate();
}
}
});
}

}

3.js中开启dwr推功能

在window.onload中使用dwr.engine.setActiveReverseAjax(true);

4、java代码中使用dwr推功能

//dwr3使用新的方式进行推送,2的方法已被注明为过时,一般来说,很少是做全推送的,基本都是有针对性的半推

//送,所以我们将使用一个过滤器来过滤要推送的scriptsession,这里涉及到我的具体业务,这个过滤器的原理是会对

//所有的进行循环过滤后,将符合条件的scriptsession存放到一个集合中,才开启新线程进行处理的。

Browser.withAllSessionsFiltered(new ScriptSessionFilter() {

public boolean match(ScriptSession session) {
Long loginUserId = (Long) session.getAttribute(Constant.LG_USER_ID);
if(loginUserId!=null && targetIdList.contains(loginUserId))
{
targetIdList.remove(loginUserId);//如果找到了,说明将被推送,所以不用再处理,剩下的都是要被处理的
return true;
}
return false;
}
},new Runnable() {

private ScriptBuffer script = new ScriptBuffer();
public void run()
{
script.appendCall("这里写你页面的js函数",这个参数是传给js函数);
Collection<ScriptSession> sessions = Browser.getTargetSessions();
for (ScriptSession scriptSession : sessions)
{
scriptSession.addScript(script);
}
//ScriptSessions.addFunctionCall("ExtTalk.updateMegGroup",data);//之所以不用这个方法,是因为这个

//方法有bug的存在,会对所有不论过不过滤的scriptsession进行推送,相当于全推送,没有起到过滤的作用
}
});

dwr的推功能还是很方便的,用来做消息通知还是不错的

原文链接:https://www.f2er.com/ajax/164783.html

猜你在找的Ajax相关文章