2. 程式人生 > >dwr推送技術深入研究

dwr推送技術深入研究

阿新 • • 發佈：2018-12-27

原文地址：https://www.cnblogs.com/momo1210/p/6283578.html

DWR 工作原理:

　　是通過動態把 Java 類生成為 Javascript。它的程式碼就像 Ajax 一樣，你感覺呼叫就像發生在瀏覽器端，但是實際上程式碼呼叫發生在伺服器端，DWR 負責資料的傳遞和轉換。這種從 Java 到JavaScript的遠端呼叫功能的方式使DWR用起來有種非常像RMI或者SOAP的常規RPC機制，而且DWR的優點在於不需要任何的網頁瀏覽器外掛就能執行在網頁上。

　　Java 從根本上講是同步機制，然而 AJAX 卻是非同步的。所以你呼叫遠端方法時，當資料已經從網路上返回的時候，你需要提供有反調 （callback） 功能的 DWR，即你的js程式碼呼叫最後一個引數是一個回撥函式，由回撥函式處理資料返回後想做的操作。

Comet

Comet方式通俗的說就是一種長連線機制(long lived http)。同樣是由Browser端主動發起請求，但是Server端以一種似乎非常慢的響應方式給出回答。這樣在這個期間內，伺服器端可以使用同一個connection把要更新的資料主動傳送給Browser。因此請求可能等待較長的時間，期間沒有任何資料返回，但是一旦有了新的資料，它將立即被髮送到客戶機。Comet又有很多種實現方式，但是總的來說對Server端的負載都會有增加.雖然對於單位操作來說，每次只需要建議一次connection,但是由於connection是保持較長時間的,對於 server端的資源的佔用要有所增加。

優點： 實時性好（訊息延時小）；效能好（能支援大量使用者）

缺點： 長期佔用連線，喪失了無狀態高併發的特點。

應用： 股票系統、實時通訊。


1.先配置web.xml

<!-- dwr start -->
<servlet>
<!-- dwr框架的核心控制器 -->
<servlet-name>dwr-invoker</servlet-name>
<servlet-class>org.directwebremoting.servlet.DwrServlet</servlet-class
 
>
<!-- 在伺服器端啟用反向ajax -->
<init-param>
<param-name>activeReverseAjaxEnabled</param-name>
<param-value>true</param-value>
</init-param>

<!-- 為了得到更詳細的除錯資訊 -->
<init-param>
<param-name>debug</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>org.directwebremoting.extend.ScriptSessionManager </param-name> 
<param-value>com.worklite.core.tools.dwr.DWRScriptSessionManager</param-value> 
</init-param> 
<!-- 在伺服器啟動階段，該servlet例項被建立 -->
<load-on-startup>1</load-on-startup>
</servlet>
<servlet-mapping>
<servlet-name>dwr-invoker</servlet-name>
<!-- 傳送如下的請求，都會交給dwr的核心控制器處理 -->
<url-pattern>/dwr/*</url-pattern>
</servlet-mapping>
<!-- dwr end -->

 

2.新建dwr.xml

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE dwr PUBLIC "-//GetAhead Limited//DTD Direct Web Remoting 3.0//EN" "http://getahead.org/dwr/dwr30.dtd">

<dwr>

<allow>

<create creator="new" javascript="DwrPush">
<param name="class" value="com.worklite.core.tools.dwr.DwrPush"/>
</create>

<create creator="new" javascript="ClientInitUtil">
<param name="class" value="com.worklite.core.tools.dwr.ClientInitUtil"/>
</create>

<create creator="new" javascript="WebMultiplePushUtil">
<param name="class" value="com.worklite.core.tools.dwr.WebMultiplePushUtil"/>
</create>

<create creator="new" javascript="WebSinglePushUtil">
<param name="class" value="com.worklite.core.tools.dwr.WebSinglePushUtil"/>
</create>

<create creator="new" javascript="WebSingleGamePushUtil">
<param name="class" value="com.worklite.core.tools.dwr.WebSingleGamePushUtil"/>
</create>

</allow>

</dwr>

 

3.編寫後臺需要的類。

（1）DWRScriptSessionListener

public class DWRScriptSessionListener implements ScriptSessionListener {

//維護一個Map key為session的Id， value為ScriptSession物件 
public static final Map<String, ScriptSession> scriptSessionMap = new MirrorMap<String, ScriptSession>(); 

/** 
* ScriptSession建立事件 
*/ 
@Override
public void sessionCreated(ScriptSessionEvent event) { 
WebContext webContext = WebContextFactory. get(); 
HttpSession session = webContext.getSession(); 
ScriptSession scriptSession = event.getSession(); 
scriptSessionMap.put(session.getId(), scriptSession); //新增scriptSession 
} 

/** 
* ScriptSession銷燬事件 
*/ 
@Override
public void sessionDestroyed(ScriptSessionEvent event) { 
//WebContext webContext = WebContextFactory. get(); 
//HttpSession session = webContext.getSession(); 
//scriptSessionMap.remove(session.getId()); //移除scriptSession 
} 

/** 
* 獲取所有ScriptSession 
*/ 
public static Collection<ScriptSession> getScriptSessions(){ 
return scriptSessionMap.values(); 
} 


public static ScriptSession getScriptSession(String str){
Collection<ScriptSession> sessions = DWRScriptSessionListener.getScriptSessions(); 
//遍歷每一個ScriptSession
for (ScriptSession scriptSession : sessions){ 
String tag = (String)scriptSession.getAttribute(str); 
if ( tag!=null&&str.equals(tag)) {
return scriptSession;
}

}
return null; 

}

public static int Count(String wId){

Collection<ScriptSession> sessions = DWRScriptSessionListener.getScriptSessions(); 
//遍歷每一個ScriptSession
int i=0;
for (ScriptSession scriptSession : sessions){ 
String tag = (String)scriptSession.getAttribute(wId); 
if ( tag!=null&&wId.equals(tag)) {
i++; 
}

} 
return i;

}

public static boolean getCustomList(String wId,int customId){

Collection<ScriptSession> sessions = DWRScriptSessionListener.getScriptSessions(); 
//遍歷每一個ScriptSession
for (ScriptSession scriptSession : sessions){ 
String tagId=customId+wId;
String tag = (String)scriptSession.getAttribute(tagId); 

if(tag!=null&&tagId.equals(tag)){
return true;
}

} 
return false;

}


public static List<String> getCustomList(String wId){
List<String> customList=new ArrayList<String>();
Collection<ScriptSession> sessions = DWRScriptSessionListener.getScriptSessions(); 
//遍歷每一個ScriptSession
for (ScriptSession scriptSession : sessions){ 
Iterator<String> iter = scriptSession.getAttributeNames();
while(iter.hasNext()){
String str=iter.next();
if(str!=null&&str.contains(String.valueOf(","+wId))){
String customId = str.split(",")[0];
if (!customList.contains(customId))
customList.add(customId);
}
}
} 


return customList;

}

public void init() throws ServletException {

Container container = ServerContextFactory.get().getContainer();

ScriptSessionManager manager = container.getBean(ScriptSessionManager.class);

ScriptSessionListener listener = new ScriptSessionListener() {

public void sessionCreated(ScriptSessionEvent ev) {

WebContext webContext = WebContextFactory. get(); 
HttpSession session = webContext.getSession(); 
ScriptSession scriptSession = ev.getSession(); 
scriptSessionMap.put(session.getId(), scriptSession); //新增scriptSession 
}

public void sessionDestroyed(ScriptSessionEvent ev) {

WebContext webContext = WebContextFactory. get(); 
HttpSession session = webContext.getSession(); 
ScriptSession scriptSession = scriptSessionMap.remove(session.getId()); //移除scriptSession 
}

};

manager.addScriptSessionListener(listener);

}

}

　　

（2）DWRScriptSessionManager

public class DWRScriptSessionManager extends DefaultScriptSessionManager {

public DWRScriptSessionManager(){ 
//繫結一個ScriptSession增加銷燬事件的監聽器 
this.addScriptSessionListener( new DWRScriptSessionListener()); 
Log.debug( "bind DWRScriptSessionListener"); 
} 
}

　　

（3）DwrPush註冊scriptSession 

public class DwrPush {

public void onPageLoad(final String tag){ 
//獲取當前的ScriptSession 
ScriptSession scriptSession = WebContextFactory.get().getScriptSession(); 
scriptSession.setAttribute( tag, tag); 
} 
}

　　

（4）WebMultiplePushUtil 用於群發

public class WebMultiplePushUtil {

public void push(final String wId,final String content,final String command){ 

//過濾器 
ScriptSessionFilter filter = new ScriptSessionFilter() { 

public boolean match(ScriptSession scriptSession) {

String tag = (String)scriptSession.getAttribute(wId); 
if ( tag== null) {
return false;
} else {
return wId.equals(tag); 
}
} 
};

Runnable run = new Runnable(){ 
private ScriptBuffer script = new ScriptBuffer(); 

public void run() { 
//設定要呼叫的 js及引數 
script.appendCall( "showMessage","{\"wId\":\""+wId+"\",\"content\":\""+content+"\",\"command\":\""+command+"\"}"); 
//得到所有ScriptSession 
Collection<ScriptSession> sessions = Browser.getTargetSessions(); 
//遍歷每一個ScriptSession 
for (ScriptSession scriptSession : sessions){ 
scriptSession.addScript( script); 
} 
} 
}; 
//執行推送 
Browser. withAllSessionsFiltered(filter, run); //注意這裡呼叫了有filter功能的方法 
} 
}

　　

（5）WebSingleGamePushUtil 用於單發遊戲

public class WebSingleGamePushUtil {

public void push(final String customId,final String wId,final Webcast_game_push push){

Runnable run = new Runnable(){ 
private ScriptBuffer script = new ScriptBuffer(); 
public void run() { 
//設定要呼叫的 js及引數 
script.appendCall( "show",JSONObject.fromObject(push).toString()); 
ScriptSession scriptSession =DWRScriptSessionListener.getScriptSession(customId+","+wId);
if(null!=scriptSession){
scriptSession.addScript( script); 
}

} 
}; 

//執行推送 
Browser.withAllSessions(run);
} 
}

　　

（6）WebSinglePushUtil 用於單發通知

 

public class WebSinglePushUtil {

public void push(final String customId,final String wId,final String content,final String command){ 
//過濾器 
ScriptSessionFilter filter = new ScriptSessionFilter() {

public boolean match(ScriptSession scriptSession) {
String tagId=customId+","+wId;
String tag = (String)scriptSession.getAttribute(tagId); 
if ( tag== null) {
return false;
} else {
return tagId.equals(tag); 
}
} 
};

Runnable run = new Runnable(){ 
private ScriptBuffer script = new ScriptBuffer(); 
public void run() { 
//設定要呼叫的 js及引數 
script.appendCall( "show","{\"customId\":\""+customId+"\",\"wId\":\""+wId+"\",\"content\":\""+content+"\",\"command\":\""+command+"\"}"); 
//得到所有ScriptSession 
Collection<ScriptSession> sessions = Browser.getTargetSessions(); 
//遍歷每一個ScriptSession 
for (ScriptSession scriptSession : sessions){ 
scriptSession.addScript( script); 
} 
} 
}; 

//執行推送 
Browser. withAllSessionsFiltered(filter, run); //注意這裡呼叫了有filter功能的方法 
} 
}

　　

4.在jsp頁面引入相應的js

<script type="text/javascript" src="/worklite/dwr/engine.js"></script>
<script type="text/javascript" src="/worklite/dwr/util.js"></script>
<script type="text/javascript" src="/worklite/dwr/interface/DwrPush.js"></script>

dwr.engine.setActiveReverseAjax(true);
dwr.engine.setAsync(true);

dwr.engine._errorHandler = function(message, ex) {dwr.engine._debug("Error: " + ex.name + ", " + ex.message, true);};

<body onload="dwr.engine.setActiveReverseAjax(true);dwr.engine.setNotifyServerOnPageUnload(true);onPageLoad();">

 

在頁面上要先掉用下DwrPush.onPageLoad（），加入scriptSession

function onPageLoad(){
DwrPush.onPageLoad(wId);
DwrPush.onPageLoad(""+customId+","+wId);
}

然後在程式碼中呼叫相應的push方法即可完成推送。

相關推薦

dwr推送技術深入研究

原文地址：https://www.cnblogs.com/momo1210/p/6283578.html DWR 工作原理: 　　是通過動態把 Java 類生成為 Javascript。它的程式碼就像 Ajax 一樣，你感覺呼叫就像發生在瀏覽器端，但是實際上程式碼呼叫發生在伺服器端，DWR 負責資料的傳遞

伺服器推送技術

什麼是伺服器推送技術 推送技術是指通過客戶端與伺服器端建立長連結，客戶端可以接收由伺服器端不定時傳送的訊息。 解決方案 1.Ajax短輪詢 2.Ajax長輪詢 3.WebSocket 短輪詢 Ajax短輪詢：http 短輪詢是 server 收到請求不管是否有資料

web的實時推送技術--websocket

Python的tornado框架中，websocket允許瀏覽器和伺服器之間進行雙向，實時，持久的，全雙工通訊。協議本身使用 ws://URL的格式，如果是加密的websocket則使用的是wss://URL websocket和其他方式的比較： 1、http協

JavaEE開發之SpringMVC中的靜態資源對映及伺服器推送技術

在上篇部落格中，我們聊了《》。本篇部落格我們繼續的來聊SpringMVC的東西，下方我們將會聊到js、css這些靜態檔案的載入配置，以及伺服器推送的兩種實現方式。當然我們在伺服器推送時，會用到JQuery的東西，所以我們先聊一下如何載入靜態資原始檔，然後我們再聊如何實現伺服器推送。 下方給出了兩種實現伺服器推

HTML5中的伺服器‘推送’技術 -Server-Sent Events

一直以來，HTTP協議都是嚴格遵循Request-Response模型的。客戶端傳送一個Request到伺服器，伺服器對Request作出響應並將Response傳送回客戶端。也就是說，所有的互動都是由客戶端發起的，伺服器不會發起任何互動。為了建立互動性更強的web應用程

java推送技術的選擇（一）

java推送技術 這段時間一直在做關於伺服器端向APP端推送訊息，查閱了大量的資料，這裡做下總結。 關於推送我們常見的推送有APP外推送，APP內推送。APP外推送有各大平臺極光，友盟等，而APP內的推送可以用的服務基本需要自己去實現，這裡我給大家介紹的就是

伺服器推送技術之——SSE

一 點睛 伺服器推送技術在日常開發中較為常用。 SSE：Server send Event：服務端傳送事件。 本專案推送技術是基於：當客戶端向服務端傳送請求，服務端會抓住這個請求不放，等有資料更新的時候才返回給客戶端，當客戶端接收到訊息後，再向服務端傳送請求，周而復始。

ASP.NET Web實時訊息後臺伺服器推送技術--GoEasy

越來越多的專案需要用到實時訊息的推送與接收，怎樣用asp.net實現最方便呢？我這裡推薦大家使用GoEasy, 它是一款第三方推送服務平臺，使用它的API可以輕鬆搞定實時推送！ 瀏覽器相容性：GoEasy推送 支援websocket 和polling兩種連線方式，從而可以支

【Web基礎】HTTP長連線和短連線以及推送技術原理

HTTP長連線和短連線 1. HTTP協議與TCP/IP協議的關係 HTTP的長連線和短連線本質上是TCP長連線和短連線。HTTP屬於應用層協議，在傳輸層使用TCP協議，在網路層使用IP協議。IP協議主要解決網路路由和定址問題，TCP協議主要解決

java web 伺服器推送技術 comet實現（原理）

最近對伺服器推送技術比較感興趣，在網上也看了好些文章，由於每個人理解的不同，實現細節或者語言表達方式不同，本人被各種名詞或者技術實現搞的頭大，於是自己準備整理下。 首先實現伺服器推送技術一直一來是B/S應用開發的一塊難題，因為是基於HTTP協議的，HTTP協議為無狀態，單

推送技術-icomet學習和分析

1 iComet 在Web系統和移動應用系統中的角色 2 iComet 的工作流程 3實現原理 3.1關鍵技術     使用libevent構建一個web伺服器，然後定時響應各種請求。libevent庫使得高併發響應HTTP Server的編寫變得很容易。整個過程包括如

【PWA】web推送技術

伴隨著今年 Google I/O 大會的召開，一個很火的概念–Progressive Web Apps 誕生了。這代表著我們 web 端有了和原生 APP 媲美的能力。但是，有一個很重要的痛點，web 一直不能使用訊息推送，雖然，後面提出了 Notification API，但這需要網頁持續開啟，這對於常規

springMVC學習--8 SSE(Server Send Event)--服務端推送技術之一

SSE技術，即Server Send Event與非同步Servlet 3.0+、Websocket等為伺服器端推送技術。SSE技術的特點是使用Http協議，輕量級易使用，在伺服器端只要通過ContentType=“text/event-stream; char

Android推送技術總結

Android平臺接入推送機制一般有兩種，一種是Google官方提供的C2DM雲端推送方案；另外一種是第三方，如極光、個推和友盟等推送平臺。C2DM雲端推送方案1)簡單介紹在Android手機平臺上，Google提供了C2DM（Cloudto Device Messaging）服務。Android Cloud

HTTP長連線和短連線以及推送技術原理

建立連線——資料傳輸——關閉連線...建立連線——資料傳輸——關閉連線長連線的操作步驟是： 建立連線——資料傳輸...（保持連線）...資料傳輸——關閉連線4. 長連線和短連線的優點和缺點           由上可以看出，長連線可以省去較多的TCP建立和關閉的操作，減少浪費，節約時間。對於頻繁請求資源的客

看了極光推送技術原理的幾點思考

移動網際網路應用現狀 因為手機平臺本身、電量、網路流量的限制，移動網際網路應用在設計上跟傳統 PC 上的應用很大不一樣，需要根據手機本身的特點，儘量的節省電量和流量，同時又要儘可能的保證資料能及時到達客戶端。 為了解決資料同步的問題，在手機平臺上，常用的方法有2種。一種是定時去伺服器上查詢資料，也叫Poll

.NET基於comet伺服器推送技術(web實時聊天)

Comet 也稱反向 Ajax 或伺服器端推技術.其思想很簡單：將資料直接從伺服器推到瀏覽器，而不必等到瀏覽器請求資料。 主要思想：伺服器端將資料推送到客戶端(瀏覽器) 系統簡單說明如下： { 系統所用資料庫：sqlite資料庫 　　UserInfo：使用者資訊表

HTTP推送技術

在一般的Web應用中，瀏覽器和伺服器之間使用的是請求/響應的互動模式。瀏覽器發出請求，伺服器根據收到的請求來生成相應的響應。瀏覽器再對收到的響應進行處理，展現給使用者。響應的格式可能是 HTML、XML 或 JSON 等。為了防止頁面整個重新整理，引入了Ajax

HTTP長連線與短連結以及推送技術原理

HTTP長連線和短連線以及推送服務原理 HTTP長連線和短連線1 1. HTTP協議與TCP/IP協議的關係 HTTP的長連線和短連線本質上是TCP長連線和短連線。HTTP屬於應用層協議，在傳輸層使用TCP協議，在網路層使用IP協議。IP協議主要解決網

springboot實戰第四章-服務端推送技術

服務端推送技術本節的服務端推送技術基於：當客戶端向服務端傳送請求，服務端會抓住這個請求不放，當有資料更新的時候才返回給客戶端，當客戶端接收到訊息後，再向服務端傳送請求，周而復始第一種：基於SSE(Server Send Event)1.演示控制器package com.jus