1. 程式人生 > >基於HTTP長輪詢實現簡單推送

基於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
    public
void 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住連線一段時間後釋放呢?主要是因為長時間的靜態連線容易出問題,另外移動端的網路複雜,所以才會有釋放的必要。