成人免费xxxxx在线视频软件_久久精品久久久_亚洲国产精品久久久_天天色天天色_亚洲人成一区_欧美一级欧美三级在线观看

在Android上實現HttpServer

移動開發 Android
在最近的項目中因為要用Android作為一個服務器去做一個實時接收數據的功能,所以這個時候就要去做一個Android本地的微型服務器。

在Android上實現HttpServer

在最近的項目中因為要用Android作為一個服務器去做一個實時接收數據的功能,所以這個時候就要去做一個Android本地的微型服務器。

那么此時我首先想到了spring boot,因為他是一個服務器的框架。但是實際上我們根本用不到這么大型的服務器框架,配置這些都太麻煩。所以,我又找到了Ijetty、NanoHttpd和AndroidAsync這三個框架,都是比較微型的,適用于Android的。

經過對比,Ijetty使用起來過于復雜,而且會莫名其妙的報一些不太容易解決的問題,所以,舍棄掉了。

因為沒仔細深究Ijetty,所以就重點放到NanoHttpd和AndroidAsync;

那么就先來說下兩個的優缺點:

1.NanoHttpd是BIO為底層封裝的框架,而AndroidAsync是NIO為底層封裝的,其他的是一樣的,而且其實AndroidAsync是仿照NanoHttpd框架寫的。所以,一定意義上來說,AndroidAsync是NanoHttpd的優化版,當然也要看具體應用場景辣。

2.NanoHttpd只能用于HttpServer,但是AndroidAsync除了HttpServer的應用還能用在webSocket、HttpClient等方面,其中從AndroidAsync中脫離出來的Ion的庫也是比較有名的。

3.NanoHttpd底層處理包含的返回狀態碼(例如: 200、300、400、500等)比較多;但是經過筆者閱讀AndroidAsync的源碼發現,AndroidAsync底層封裝返回的狀態碼只有兩種:200、404,正好筆者發現了這個坑(下面會講到,OPTIONS的例子)

下面看一下具體使用方法吧。

1.先說NanoHttpd:

因為NanoHttpd的框架實際就是一個單文件,可以直接去github上下載,下載地址

有了下載的文件,那么就可以繼承這個文件寫一個類,具體如下:

  1. public class HttpServer extends NanoHTTPD { 
  2.     private static final String TAG = "HttpServer"
  3.  
  4.     public static final String DEFAULT_SHOW_PAGE = "index.html"
  5.     public static final int DEFAULT_PORT = 9511;//此參數隨便定義,***定義1024-65535;1-1024是系統常用端口,1024-65535是非系統端口 
  6.  
  7.     public enum Status implements Response.IStatus { 
  8.         REQUEST_ERROR(500, "請求失敗"), 
  9.         REQUEST_ERROR_API(501, "無效的請求接口"), 
  10.         REQUEST_ERROR_CMD(502, "無效命令"); 
  11.  
  12.         private final int requestStatus; 
  13.         private final String description; 
  14.  
  15.         Status(int requestStatus, String description) { 
  16.             this.requestStatus = requestStatus; 
  17.             this.description = description; 
  18.         } 
  19.  
  20.         @Override 
  21.         public String getDescription() { 
  22.             return description; 
  23.         } 
  24.  
  25.         @Override 
  26.         public int getRequestStatus() { 
  27.             return requestStatus; 
  28.         } 
  29.     } 
  30.  
  31.     public HttpServer() {//初始化端口 
  32.         super(DEFAULT_PORT); 
  33.     } 
  34.  
  35.     @Override 
  36.     public Response serve(IHTTPSession session) { 
  37.         String uri = session.getUri(); 
  38.         Map<String, String> headers = session.getHeaders(); 
  39.  
  40.         //接收不到post參數的問題,              http://blog.csdn.net/obguy/article/details/53841559 
  41.         try { 
  42.             session.parseBody(new HashMap<String, String>()); 
  43.         } catch (IOException e) { 
  44.             e.printStackTrace(); 
  45.         } catch (ResponseException e) { 
  46.             e.printStackTrace(); 
  47.         } 
  48.         Map<String, String> parms = session.getParms(); 
  49.         try { 
  50.             LogUtil.d(TAG, uri); 
  51.  
  52. //判斷uri的合法性,自定義方法,這個是判斷是否是接口的方法 
  53.             if (checkUri(uri)) { 
  54.                 // 針對的是接口的處理 
  55.                 if (headers != null) { 
  56.                     LogUtil.d(TAG, headers.toString()); 
  57.                 } 
  58.                 if (parms != null) { 
  59.                     LogUtil.d(TAG, parms.toString()); 
  60.                 } 
  61.  
  62.                 if (StringUtil.isEmpty(uri)) { 
  63.                     throw new RuntimeException("無法獲取請求地址"); 
  64.                 } 
  65.  
  66.                 if (Method.OPTIONS.equals(session.getMethod())) { 
  67.                     LogUtil.d(TAG, "OPTIONS探測性請求"); 
  68.                     return addHeaderResponse(Response.Status.OK); 
  69.                 } 
  70.  
  71.                 switch (uri) { 
  72.                     case "/test": {//接口2 
  73.                        //此方法包括了封裝返回的接口請求數據和處理異常以及跨域 
  74.                         return getXXX(parms); 
  75.                     } 
  76.                     default: { 
  77.                         return addHeaderResponse(Status.REQUEST_ERROR_API); 
  78.                     } 
  79.                 } 
  80.             } else { 
  81.                 //針對的是靜態資源的處理 
  82.                 String filePath = getFilePath(uri); // 根據url獲取文件路徑 
  83.  
  84.                 if (filePath == null) { 
  85.                     LogUtil.d(TAG, "sd卡沒有找到"); 
  86.                     return super.serve(session); 
  87.                 } 
  88.                 File file = new File(filePath); 
  89.  
  90.                 if (file != null && file.exists()) { 
  91.                     LogUtil.d(TAG, "file path = " + file.getAbsolutePath()); 
  92. //根據文件名返回mimeType: image/jpg, video/mp4, etc 
  93.                     String mimeType = getMimeType(filePath);  
  94.  
  95.                     Response res = null
  96.                     InputStream is = new FileInputStream(file); 
  97.                     res = newFixedLengthResponse(Response.Status.OK, mimeType, isis.available()); 
  98. //下面是跨域的參數(因為一般要和h5聯調,所以***設置一下) 
  99.                     response.addHeader("Access-Control-Allow-Headers", allowHeaders); 
  100.                     response.addHeader("Access-Control-Allow-Methods""GET, POST, PUT, DELETE, HEAD"); 
  101.                     response.addHeader("Access-Control-Allow-Credentials""true"); 
  102.                     response.addHeader("Access-Control-Allow-Origin""*"); 
  103.                     response.addHeader("Access-Control-Max-Age""" + 42 * 60 * 60); 
  104.  
  105.                     return res; 
  106.                 } else { 
  107.                     LogUtil.d(TAG, "file path = " + file.getAbsolutePath() + "的資源不存在"); 
  108.                 } 
  109.  
  110.             } 
  111.  
  112.         } catch (Exception e) { 
  113.             e.printStackTrace(); 
  114.         } 
  115.         //自己封裝的返回請求 
  116.         return addHeaderRespose(Status.REQUEST_ERROR); 
  117.     } 

 

根據上面的例子,主要說以下幾點: 1)請求都能接收到,無論post還是get,或者是其他請求,如果需要過濾則自己去處理;

2)注意上面處理的接收不到post參數的問題,已經給了參考鏈接在代碼注釋中,請查閱;

3)如果請求中既有接口又有靜態資源(例如html),那注意區分兩種請求,例如可以用uri去識別;當然返回都可以用流的形式,都可以調用API方法newFixedLengthResponse();

4)筆者建議,***處理一下跨域的問題,因為是Android有可能和h5聯調,所以設置了跨域以后比較方便調試,當然某些場景也可以忽略,看個人需求;方法已經在以上代碼中寫了;

5)當然***最重要的一點肯定是開啟和關閉的代碼了:

  1. /** 
  2.  * 開啟本地網頁點歌的服務 
  3.  */ 
  4. public static void startLocalChooseMusicServer() { 
  5.  
  6.     if (httpServer == null) { 
  7.         httpServer = new HttpServer(); 
  8.     } 
  9.  
  10.     try { 
  11.         // 啟動web服務 
  12.         if (!httpServer.isAlive()) { 
  13.             httpServer.start(); 
  14.         } 
  15.         Log.i(TAG, "The server started."); 
  16.     } catch (Exception e) { 
  17.         httpServer.stop(); 
  18.         Log.e(TAG, "The server could not start. e = " + e.toString()); 
  19.     } 
  20.  
  21.  
  22. /** 
  23.  * 關閉本地服務 
  24.  */ 
  25. public static void quitChooseMusicServer() { 
  26.     if (httpServer != null) { 
  27.         if (httpServer.isAlive()) { 
  28.             httpServer.stop(); 
  29.             Log.d(TAG, "關閉局域網點歌的服務"); 
  30.         } 
  31.     } 

 

2再看一下AndroidAsync: 這個框架就比較有意思了,功能也多,本文直說HttpServer方面的相關知識,其余按下不表。

老規矩,先說用法: 在Gradle中加入:

  1. dependencies { 
  2.  
  3.   compile 'com.koushikdutta.async:androidasync:2.2.1' 
  4.  

 

代碼示例:(此處沒有處理跨域,如果需要的話,請根據上一個例子去處理)

  1. public class NIOHttpServer implements HttpServerRequestCallback { 
  2.  
  3.     private static final String TAG = "NIOHttpServer"
  4.  
  5.     private static NIOHttpServer mInstance; 
  6.  
  7.     public static int PORT_LISTEN_DEFALT = 5000; 
  8.  
  9.     AsyncHttpServer server = new AsyncHttpServer(); 
  10.  
  11.     public static NIOHttpServer getInstance() { 
  12.         if (mInstance == null) { 
  13.             // 增加類鎖,保證只初始化一次 
  14.             synchronized (NIOHttpServer.class) { 
  15.                 if (mInstance == null) { 
  16.                     mInstance = new NIOHttpServer(); 
  17.                 } 
  18.             } 
  19.         } 
  20.         return mInstance; 
  21.     } 
  22.  
  23. //仿照nanohttpd的寫法 
  24.     public static enum Status { 
  25.         REQUEST_OK(200, "請求成功"), 
  26.         REQUEST_ERROR(500, "請求失敗"), 
  27.         REQUEST_ERROR_API(501, "無效的請求接口"), 
  28.         REQUEST_ERROR_CMD(502, "無效命令"), 
  29.         REQUEST_ERROR_DEVICEID(503, "不匹配的設備ID"), 
  30.         REQUEST_ERROR_ENV(504, "不匹配的服務環境"); 
  31.  
  32.         private final int requestStatus; 
  33.         private final String description; 
  34.  
  35.         Status(int requestStatus, String description) { 
  36.             this.requestStatus = requestStatus; 
  37.             this.description = description; 
  38.         } 
  39.  
  40.         public String getDescription() { 
  41.             return description; 
  42.         } 
  43.  
  44.         public int getRequestStatus() { 
  45.             return requestStatus; 
  46.         } 
  47.     } 
  48.  
  49.     /** 
  50.  * 開啟本地服務 
  51.  */ 
  52.     public void startServer() { 
  53. //如果有其他的請求方式,例如下面一行代碼的寫法 
  54.         server.addAction("OPTIONS""[\\d\\D]*", this); 
  55.         server.get("[\\d\\D]*", this); 
  56.         server.post("[\\d\\D]*", this); 
  57.         server.listen(PORT_LISTEN_DEFALT); 
  58.     } 
  59.  
  60.     @Override 
  61.     public void onRequest(AsyncHttpServerRequest request, AsyncHttpServerResponse response) { 
  62.         Log.d(TAG, "進來了,哈哈"); 
  63.         String uri = request.getPath(); 
  64. //這個是獲取header參數的地方,一定要謹記哦 
  65.         Multimap headers = request.getHeaders().getMultiMap(); 
  66.  
  67.         if (checkUri(uri)) {// 針對的是接口的處理 
  68.             //注意:這個地方是獲取post請求的參數的地方,一定要謹記哦 
  69.             Multimap parms = (( AsyncHttpRequestBody<Multimap>)request.getBody()).get(); 
  70.             if (headers != null) { 
  71.                 LogUtil.d(TAG, headers.toString()); 
  72.             } 
  73.             if (parms != null) { 
  74.                 LogUtil.d(TAG, "parms = " + parms.toString()); 
  75.             } 
  76.  
  77.             if (StringUtil.isEmpty(uri)) { 
  78.                 throw new RuntimeException("無法獲取請求地址"); 
  79.             } 
  80.  
  81.             if ("OPTIONS".toLowerCase().equals(request.getMethod().toLowerCase())) { 
  82.                 LogUtil.d(TAG, "OPTIONS探測性請求"); 
  83.                 addCORSHeaders(Status.REQUEST_OK, response); 
  84.                 return
  85.             } 
  86.  
  87.             switch (uri) { 
  88.                     case "/test": {//接口2 
  89.                        //此方法包括了封裝返回的接口請求數據和處理異常以及跨域 
  90.                         return getXXX(parms); 
  91.                     } 
  92.                     default: { 
  93.                         return addHeaderResponse(Status.REQUEST_ERROR_API); 
  94.                     } 
  95.                 } 
  96.         } else { 
  97.             // 針對的是靜態資源的處理 
  98.             String filePath = getFilePath(uri); // 根據url獲取文件路徑 
  99.  
  100.             if (filePath == null) { 
  101.                 LogUtil.d(TAG, "sd卡沒有找到"); 
  102.                 response.send("sd卡沒有找到"); 
  103.                 return
  104.             } 
  105.             File file = new File(filePath); 
  106.  
  107.             if (file != null && file.exists()) { 
  108.                 Log.d(TAG, "file path = " + file.getAbsolutePath()); 
  109.  
  110.                 response.sendFile(file);//和nanohttpd不一樣的地方 
  111.  
  112.             } else { 
  113.                 Log.d(TAG, "file path = " + file.getAbsolutePath() + "的資源不存在"); 
  114.             } 
  115.         } 
  116.     } 

 

根據上面的例子,主要說以下幾點:{大概說的就是api用法啊這一類的}

1)例如:server.addAction(“OPTIONS”, “[\d\D]“, this)是通用的過濾請求的方法。***個參數是請求的方法,例如用“OPTIONS”、“DELETE”、“POST”、“GET”等(注意用大寫),第二個參數是過濾uri的正則表達式,此處是過濾所有的uri,第三個是回調參數。server.post(“[\d\D]“, this)、server.get(“[\d\D]*”, this)這個是上一個方法的特例。server.listen(PORT_LISTEN_DEFALT)這個是監聽端口;

2) request.getHeaders().getMultiMap()

這個是獲取header參數的地方,一定要謹記哦;

3)(( AsyncHttpRequestBody<Multimap>)request.getBody()).get()這個地方是獲取post請求的參數的地方;

4)獲取靜態資源的代碼是在回調方法onResponse的else中,例子如上。

5)說一下OPTIONS的坑點,因為AndroidAsync這個框架中封裝的返回http的狀態碼只有兩種,假如過濾方法中沒有包含例如OPTIONS的請求方法,實際上返回給客戶端的http狀態碼是400,而反映到瀏覽器的報錯信息竟然是跨域的問題,找了很久才找到,請注意。

總結:

1)同一個頁面:

NanoHttpd耗時:1.4s

AndroidAsync耗時:1.4s

但是在第二次進去的時候,AndroidAsync的耗時明顯比***個少了,筆者猜測是因為AndroidAsync底層做了一些處理。

2)從api分析的話,NanoHttpd的用法比較方便,獲取傳遞的參數那些的api比較好用;AndroidAsync的api就相對來說要復雜一些,例如params的獲取。

3)從場景來分析的話,如果需要并發量高的需求,一定要用AndroidAsync;但是如果不需要的話,那就再具體分析。

責任編輯:龐桂玉 來源: Android開發中文站
相關推薦

2011-12-07 11:57:12

ibmdw

2011-02-25 15:49:09

NecessitasQtAndroid

2012-05-22 15:55:41

AIXiSCSI

2015-10-14 10:02:33

ClojureScri Android

2019-03-20 16:48:07

交通運輸新交通京東云

2019-08-19 08:14:52

深度鏈接iOSAndroid

2010-09-17 14:27:18

NetBeansAndroid

2011-05-30 15:35:06

Android 廣播接收者

2011-12-15 01:11:07

ibmdw

2023-01-04 07:46:10

單選按鈕雙擊效果

2019-07-12 14:41:31

微服務Kubernetes容器

2011-06-02 10:09:18

2011-10-12 11:24:44

AndroidPC

2010-10-13 09:29:53

JUnit單元測試Android

2010-12-13 14:41:44

Android 2.3MyEclipse

2010-11-18 13:25:25

Android 2.2Android SDK

2009-07-06 17:49:02

Apache的配置JBoss的配置

2011-02-14 10:46:37

ChromeIE 9固定網站

2010-04-02 09:42:47

Windows云計算IPAD

2011-04-01 10:19:13

點贊
收藏

51CTO技術棧公眾號

主站蜘蛛池模板: 夜夜夜夜夜夜曰天天天 | 精品欧美一区二区在线观看欧美熟 | 一级黄色片在线看 | 毛片一区二区三区 | 色综合一区二区 | 91资源在线 | 欧美中文字幕在线观看 | 午夜看电影在线观看 | 日本久久精 | 欧美日韩精品久久久免费观看 | 波多野结衣一区二区 | 日韩一级免费电影 | 色综合视频 | 久久久www成人免费无遮挡大片 | 91久久夜色精品国产网站 | 911精品国产 | 91精品久久久久久久久中文字幕 | 综合色在线 | 欧美精品一区二区三区四区五区 | 中文字幕丁香5月 | 羞羞的视频在线看 | www亚洲精品 | 波多野结衣一二三区 | av香港经典三级级 在线 | 国产片一区二区三区 | 羞视频在线观看 | 久久国产精品免费一区二区三区 | 亚洲91视频 | 中文字幕日韩av | 精品国产视频 | 亚洲精品一区久久久久久 | 中文字幕一区二区三 | 欧美日韩成人在线 | 国产高清视频在线观看 | 日日拍夜夜 | 91精品国产欧美一区二区成人 | 日韩欧美第一页 | 一区二区三区四区在线视频 | 亚洲一级av毛片 | 久久免费观看视频 | 国产精品高清在线 |