⑴ android UDP通訊(簡單demo)
本章節 比較簡單
直接上code了
首先創建一個UDP class 構造方法如下
通過newFixedThreadPool 創建一個線程池
然後
一個startUdp scoket 重要步驟
startSocketThread是一個 接收消息的子線程
內部是一個接收消息的循環
BROADCAST_IP 是通信對方的地址
利用廣播 把接收到的消息列印到前台
再然後創建一個發送message的方法
文章所有code 地址---> github
https://github.com/hanjole/Udpscoket_demo
⑵ 如何實現android和伺服器長連接
1：android客戶端通過service在後台通過servreScoket不斷的accept，一旦有相應的socket到達，則啟動一個線程去處理
2:：在線程中處理完返回給我們android客戶端的消息或任務之後，要將這種結果表現在ui上，這個步驟方法就比較多了，例如你可以發一個廣播來通知ui,或者你可以通過一個static的handler來處理
*************************************service中的關鍵代碼
private void startSocketServer()
{
if (!isStarted)
{
try
{
serverSocket = new ServerSocket( 6661 );
isStarted = true;
}
catch (Exception e)
{
// TODO: handle exception
}
// 啟動線程處理
AcceptThread acceptThread = new AcceptThread();
acceptThread.start();
}
}
class AcceptThread extends Thread
{
@Override
public void run()
{
while (isStarted)
{
try
{
// 阻塞接收
Socket client = serverSocket.accept();
initClientSocket( client );
}
catch (Exception e)
{
// TODO: handle exception
}
}
super.run();
}
}
private void initClientSocket(Socket client)
{
boolean isRunnable = true;
/**
* 重置
**/
if (cInputStream != null)
{
try
{
cInputStream.close();
cInputStream = null;
}
catch (IOException e)
{
e.printStackTrace();
}
}
if (clientSocket != null)
{
try
{
clientSocket.close();
clientSocket = null;
}
catch (Exception e)
{
// TODO: handle exception
}
}
String resultStr = "";
clientSocket = client;
try
{
cInputStream = new DataInputStream( clientSocket.getInputStream() );
if (isRunnable)
{
StringBuffer sb1 = new StringBuffer();
int ss;
while ((ss = cInputStream.read()) != -1)
{
sb1.append( (char) ss );
}
resultStr = sb1.toString();
//發送廣播
Intent intent = new Intent();
intent.putExtra( "str", resultStr );
intent.setAction( "com.jone.receiver" );
sendBroadcast( intent );
// Message msg = ((MainActivity)getApplicationContext()).handler.obtainMessage();
// msg.obj = resultStr;
// ((MainActivity)getApplicationContext()).handler.sendMessage( msg );
}
}
catch (Exception e)
{
// TODO Auto-generated catch block
isRunnable = false;
e.printStackTrace();
}
}
⑶ 網路請求框架-OkHttp原理解析
okhttp是square公司貢獻的一個處理網路請求的開源框架，是目前Android開發使用最廣泛的一個網路框架，從Android4.4開始，httpURLconnection的底層實現採用的就是okhttp。內部實現就是利用java基礎，對socket進行封裝，實現http通信。最重要的兩個關鍵點就是分發器和5個攔截器。
分發器 就是內部維護隊列和線程池，完成請求分配，總結就是用於對非同步任務加入隊列管理，然後判斷條件，控制數量，加入線程池執行非同步請求任務。
五個默認攔截器 就是利用責任鏈模式對網路請求進行層層處理，完成整個請求過程，簡單總結如下。
1.橋接攔截器對用戶發出的請求添加缺少的請求配置欄位，比如keep-alive等
2.緩存攔截器就是查詢有沒有符合判斷條件的已緩存的網路請求，執行復用，直接返回response
3.連接攔截器就是創建請求，加入連接器 或者訪問連接池，根據條件判斷，是否能懟已創建的tcp請求進行復用
4.請求伺服器攔截器就是對scoket進行操作，請求網路訪問伺服器，返回response，
5.重試和重定向攔截器就是對返回的response進行code判斷，決定是否要重試或者重定向操作。
1.支持http2.0版本，並且允許對同一主機的所有請求共享一個套接字
2.即使不是http2.0版本，通過連接池，減少請求延遲
3.默認使用Gzip 壓縮數據
4.響應緩存，避免重復請求網路
最簡單的http請求案例
1.利用建造者模式構建okHttpClient實例對象,構建過程中可以動態配置參數，請求時間，響應時間，緩存信息等。
2.創建Request對象，設置請求方式，鏈接地址，參數等信息。
3.把request對象，傳給client，通過newCall函數，得到RealCall對象。
4.RealCall 分為同步和非同步執行
5.同步執行時，分發器只是做個記錄，把請求任務加到隊列中，然後直接通過攔截器訪問伺服器，返回response。
6.非同步執行
6.1先對非同步任務進一步封裝，把任務放到AsyncCall對象中
2.分發器 把 封裝後的非同步任務 添加到等待運行的隊列中
7. 通過攔截器，獲取response
okhttp 默認提供5個攔截器 重試重定向攔截器，橋接攔截器，緩存攔截器，連接攔截器，訪問伺服器攔截器。還可以自定義攔截器。
自定義攔截器分為應用攔截器(通過addInterceptor 添加)和網路攔截器(通過addNetworkInterceptor攔截)
攔截器採用責任鏈的設計默認，讓請求者和處理者解耦，最終請求從前往後，響應從後往前。
首先先判斷用戶是否取消了請求，如果沒有取消，就把請求交個橋接攔截器。
在獲得響應結果response的時候根據響應碼，判斷是否需要重試或者重定向， 重試不限制次數，重定向最多20次 ，如果需要重試或者重定向，那麼會再一次重新執行所有攔截器。
有如下幾種情況不會重試：IO異常，線路異常，配置client實例時配置不允許重試，協議異常，證書異常等等。
先獲取用戶發送的請求，判斷條件用戶是否已經配置過請求頭欄位，若用戶沒有配置，則將http協議必備的請求頭欄位補齊，比如Content-Type，Content-Length等，然後交給下一個攔截器。
在獲得響應結果response之後，調用保存cookie的介面（也可以在配置client的時候，設置cookjar進行cookie回調數據），並且解析gzip數據
獲取結果之後，對cookie進行保存，對返回的數據進行gzip解壓
就是根據緩存策略從緩存中查找是否有合適的緩存response，如果有合適的緩存，直接返回給請求任務，不在繼續執行後面的攔截器。
獲得響應結果response後，根據條件判斷，決定是否要緩存。
維護一個連接池，負責對連接的服務。在把請求交給下一個攔截器之前。會先在連接池中找到一個合適的連接（滿足適配條件相同，並且沒有正在被使用）或者新建一個連接，並且接入連接池，獲得對應的socket流，把請求交給下一個攔截器。獲得response結果後不會進行額外的處理。
連接池， 也稱之為對象池，主要用來存放request請求連接，內部維護了一個LinkedQueue隊列用來存放請求。在添加新的請求對象時，都會執行一個周期性任務，用以對連接池進行清理操作。
1.隊列長度超過5，清理最近未被使用連接，LRE演算法
2.存儲的連接，5分鍾未被復用，清理
拿到上一個攔截器返回的請求，真正的與伺服器進行通信，向伺服器發送數據，解析讀取響應的數據，返回給上一個攔截器。
1.創建request =>OkHttpClient=>RealCall()
2.同步執行 ，分發器添加同步任務，執行攔截器，訪問伺服器，返回reponse，觸發非同步分發流程。
3.非同步執行 ，封裝任務= >AsyncCall ，實現runnable介面。添加任務到非同步任務等待隊列，執行分發任務，判斷非同步任務是否能加入正在執行的非同步任務隊列，滿足兩個條件
同時執行的非同步任務數量不得大於64個
對同一個主機的訪問任務，最多不得大於5個
4.加入正在執行的非同步任務隊列，通過線程池執行任務，經過5個默認攔截器訪問伺服器，返回response，執行非同步任務分發。
分發器工作 分為同步任務和非同步任務兩種
同步任務 就是把任務加入同步任務隊列，加個標記，執行結束之後，觸發非同步任務的分發操作。
非同步任務 先封裝任務到asyncCall對象，實現了runnable介面。把任務加入等待執行隊列，執行分發操作。
先遍歷等待任務隊列，判斷是否符合加入正在運行的非同步任務隊列，要同時滿足兩個條件。
同時執行的非同步任務數量不得大於64個
對同一個主機的訪問任務，最多不得大於5個
當滿足條件後，從等待隊列中刪除任務，把任務加入正在執行的隊列中，通過自定義的線程池，執行任務，任務執行結束後，再次執行分發操作。
攔截器採用了責任鏈設計默認，讓請求者和執行者解耦，請求者只需要將請求發給責任鏈即可，無需關心請求過程和細節。okHttp 默認有5個攔截器，重試重定向攔截器，橋接攔截器，緩存攔截器，連接攔截器，請求服務攔截器。工作細節參考上面攔截器原理分析部分
1.位置的關系，應用攔截器 放在責任鏈最頂端，網路攔截器放在責任鏈倒數第二的位置。所以應用攔截器 最先攔截，最後響應，網路攔截器 倒數第二攔截，第二響應。如果列印請求日誌的情況，應用攔截器列印的是用戶請求信息，經過重試重定向，橋接，緩存，鏈接 等攔截器的層層包裝，網路攔截器列印的是實際請求的信息。
2.應用攔截器一定會被執行，網路攔截器不一定被執行。
利用連接池，緩存所有的有效連接對象。
清理機制：垃圾連接
1.超過5分鍾沒有用過的鏈接
2.超過5個閑置鏈接後，從最久閑置的鏈接開始執行清理（LRU）
⑷ 如何實現android和伺服器長連接
前言：現在的大多數移動端應用都有實時得到消息的能力，簡單來說，有發送消息的主動權和接受消息的被動權。例如：微信，QQ，天氣預報等等，相信好處和用戶體驗相信大家都知道吧。
提出問題：這種功能必須涉及client（客戶端）和server（伺服器），所以到底client如何和server實現實時連接通訊？
分析問題：這種功能實際上就是數據同步，同時要考慮手機本身、電量、網路流量等等限制因素，所以通常在移動端上有一下兩個解決方案:
1.一種是定時去server查詢數據，通常是使用HTTP協議來訪問web伺服器，稱Polling（輪詢）；
2.還有一種是移動端和伺服器建立長連接，使用XMPP長連接，稱Push（推送）。
從耗費的電量、流量和數據延遲性各方面來說，Push有明顯的優勢。但是使用Push的缺點是：
對於客戶端：實現和維護相對成本高，在移動無線網路下維護長連接，相對有一些技術上的開發難度。
對於伺服器：如何實現多核並發，cpu作業調度，數量龐大的長連接並發維護等技術，仍存在開發難點。轉載，僅供參考。