基於HTTP長輪詢實現簡單推送
應用場景:裝置為安卓、PC以及伺服器,要求PC端能夠單向給移動端傳送訊息指令,安卓端解析訊息,進行後續處理動作。其中安卓端為基於Phonegap開發,說白了,就是HTML+JS。
規模:正常應用為200移動端,PC端數量有限,不超過10臺,最多移動端為不超過500臺。
可以看出這是一個很小規模的應用,也正如此,才可以給我像這樣大方的保有HTTP連線不釋放的機會。
當前背景:目前關於推送的實現,無非就是谷歌,HTML5的websocket,韓國某牛寫的androidpn,以及第三方和偽推送方式。
谷歌的推送在中國大陸據說不穩定,所以被中國人棄之不用,然後就是HTML5的websocket居然在安卓4.0的機器上還不能被很好的支援,這些足以讓那位韓國人寫的androidpn在國內火了一陣子,不過後來因為國內的第三方推送開始發力,大部分應用開發者只要不是特別需要的話,就不會自己再做推送了。而偽推送方式,無外乎就是HTTP的長連線或者AJAX的長輪詢,以及iframe流的方式(或許還有其他方式),這種技術就被稱為comet
基本原理:安卓端頁面不間斷的發起輪詢請求,伺服器接收請求後,如果沒有訊息可以返回,就先不釋放連線,即執行緒等待,等待超時或者中途被喚醒後,返回給頁面,釋放連線,安卓端的頁面再次發起輪詢請求。
伺服器端接收到PC端指令後,喚醒等待執行緒,讓安卓端的下次輪詢可以獲取訊息。
程式碼實現:
- 伺服器端啟動時,像ServletContext內新增一個map用於儲存PC端像安卓端傳送的訊息。
public class AppListener implements ServletContextListener{//監聽ServletContext的初始化 @Override publicvoid contextDestroyed(ServletContextEvent arg0) { // TODO Auto-generated method stub } @Override public void contextInitialized(ServletContextEvent event) { // TODO Auto-generated method stub event.getServletContext().setAttribute(Constant.IMMSG, new HashMap<String,String>()); System.out.println("新增Map成功"); } }
- 接收安卓端長輪詢的servlet:
private static int num=0; public void service(HttpServletRequest req,HttpServletResponse res) throws UnsupportedEncodingException{ req.setCharacterEncoding("UTF-8"); res.setContentType("text/html,charset=UTF-8"); ServletContext application=req.getSession().getServletContext(); req.getParameter("userID"); HashMap<String,String>msg=new HashMap<String,String>(); Map<String,String> map=((Map)application.getAttribute(Constant.IMMSG)); synchronized(map){ String temp=map.remove(req.getParameter("userID")); if(temp==null||temp.trim().equals("")){ try { System.out.println("休眠等待60秒"+(++num)); map.wait(60000);//伺服器保留此連線60秒 msg.put("msg","nomsg");//沒有訊息時,返回nomsg } catch (InterruptedException e) { // TODO Auto-generated catch block msg.put("msg", "error"); e.printStackTrace(); } }else{ msg.put("msg", temp);//如果有訊息,則立刻返回 } } PrintWriter out; try { out = res.getWriter(); out.print(JSONObject.fromObject(msg)); out.flush(); out.close(); System.out.println("----等待數"+(--num)); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } }
- 接收PC端訊息的Servlet:
public class SendMsgService extends HttpServlet { public void service(HttpServletRequest req,HttpServletResponse res) throws UnsupportedEncodingException{ req.setCharacterEncoding("UTF-8"); res.setContentType("text/html,charset=UTF-8"); ServletContext application=req.getSession().getServletContext(); Map<String,String> map=((Map)application.getAttribute(Constant.IMMSG)); synchronized(map){ map.put(req.getParameter("userID"), req.getParameter("msg")); map.notifyAll();//通知所有等待的執行緒,讓安卓端發起下次輪詢 } }
所謂安卓端的頁面就是簡單的js,在一次請求結束後發起下一次請求而已。
function longPolling(){ $.ajax({ //url:ip+'/haveMsg', url:"http://192.168.1.109:8081/mobileinspect/haveMsg", data:{'userID':111}, dataType:'json', timeout:70000, cache:false, type:"post", success:function(data){ if(data.msg){ if(data.msg=="nomsg"){ window.setTimeout(longPolling,1000) }else{ navigator.notification.confirm(data.msg,onConfirm,"新的訊息","接受,拒絕"); window.setTimeout(navigator.notification.beep(1),100); window.setTimeout(longPolling,1000) } } }, error:function(xhr,err){//如果出現錯誤,則在十秒鐘之後,再進行長輪詢 window.setTimeout(longPolling,10000) } }) }
然後就是修改Tomcat的最大連線數,以讓伺服器能夠處理這麼多的連線而不至於停止響應:
<Connector connectionTimeout="20000" port="8081" protocol="HTTP/1.1" redirectPort="8443" maxThreads="600" acceptCount="100"/>
針對我的這個應用,最大600個處理執行緒足以應付那500臺機器了。單純我的辦公電腦就可以支援發起500個HTTP連線,並由本地的Tomcat處理,相信伺服器更能夠輕鬆應付。
另外,需要注意的是:據說單機windows下只支援2000左右的HTTP連線,而Linux下約是1000個,所以各位如果使用這種方法的時候,要注意是否會超出這些限制。
為什麼要伺服器hold住連線一段時間後釋放呢?主要是因為長時間的靜態連線容易出問題,另外移動端的網路複雜,所以才會有釋放的必要。