日韩无码专区无码一级三级片|91人人爱网站中日韩无码电影|厨房大战丰满熟妇|AV高清无码在线免费观看|另类AV日韩少妇熟女|中文日本大黄一级黄色片|色情在线视频免费|亚洲成人特黄a片|黄片wwwav色图欧美|欧亚乱色一区二区三区

RELATEED CONSULTING
相關(guān)咨詢
選擇下列產(chǎn)品馬上在線溝通
服務(wù)時(shí)間：8:30-17:00
你可能遇到了下面的問題
關(guān)閉右側(cè)工具欄

新聞中心

這里有您想知道的互聯(lián)網(wǎng)營(yíng)銷解決方案
Android如何實(shí)現(xiàn)無網(wǎng)絡(luò)傳輸文件

最近的項(xiàng)目需要實(shí)現(xiàn)一個(gè) Android 手機(jī)之間無網(wǎng)絡(luò)傳輸文件的功能，就發(fā)現(xiàn)了 Wifi P2P（Wifi點(diǎn)對(duì)點(diǎn)）這么一個(gè)功能，最后也實(shí)現(xiàn)了通過 Wifi 隔空傳輸文件的功能，這里我也來整理下代碼，分享給大家。

10年積累的網(wǎng)站建設(shè)、網(wǎng)站制作經(jīng)驗(yàn)，可以快速應(yīng)對(duì)客戶對(duì)網(wǎng)站的新想法和需求。提供各種問題對(duì)應(yīng)的解決方案。讓選擇我們的客戶得到更好、更有力的網(wǎng)絡(luò)服務(wù)。我雖然不認(rèn)識(shí)你，你也不認(rèn)識(shí)我。但先網(wǎng)站設(shè)計(jì)后付款的網(wǎng)站建設(shè)流程，更有海珠免費(fèi)網(wǎng)站建設(shè)讓你可以放心的選擇與我們合作。

Wifi P2P 是在 Android 4.0 以及更高版本系統(tǒng)中加入的功能，通過 Wifi P2P 可以在不連接網(wǎng)絡(luò)的情況下，直接與配對(duì)的設(shè)備進(jìn)行數(shù)據(jù)交換。相對(duì)于藍(lán)牙，Wifi P2P 的搜索速度和傳輸速度更快，傳輸距離更遠(yuǎn)

實(shí)現(xiàn)的效果如下所示：

 

一般而言，開發(fā)步驟分為以下幾點(diǎn)：

  • 在 AndroidManifest 中聲明相關(guān)權(quán)限（網(wǎng)絡(luò)和文件讀寫權(quán)限）
  • 獲取 WifiP2pManager ，注冊(cè)相關(guān)廣播監(jiān)聽Wifi直連的狀態(tài)變化
  • 指定某一臺(tái)設(shè)備為服務(wù)器（用來接收文件），創(chuàng)建群組并作為群主存在，在指定端口監(jiān)聽客戶端的連接請(qǐng)求，等待客戶端發(fā)起連接請(qǐng)求以及文件傳輸請(qǐng)求
  • 客戶端（用來發(fā)送文件）主動(dòng)搜索附近的設(shè)備，加入到服務(wù)器創(chuàng)建的群組，獲取服務(wù)器的IP地址，向其發(fā)起文件傳輸請(qǐng)求
  • 校驗(yàn)文件完整性

一、聲明權(quán)限

Wifi P2P 技術(shù)并不會(huì)訪問網(wǎng)絡(luò)，但由于會(huì)使用到 Java socket，所以需要申請(qǐng)網(wǎng)絡(luò)權(quán)限。此外，由于是要實(shí)現(xiàn)文件互傳，所以也需要申請(qǐng)SD卡讀寫權(quán)限。   

 
 
 
 
    
  
  
  
  
  1.   
    2. 
  
  
  
  
  2.   
    3. 
  
  
  
  
  3.   
    4. 
  
  
  
  
  4.   
    5. 
  
  
  
  
  5.   
    6. 
  
  
  
  
  6.   
    7. 
  
  
  
  
  7.  
    8.

 

二、注冊(cè)廣播

與 Wifi P2P 相關(guān)的廣播有以下幾個(gè)：

  • WIFI_P2P_STATE_CHANGED_ACTION（ 用于指示 Wifi P2P 是否可用 ）
  • WIFI_P2P_PEERS_CHANGED_ACTION（ 對(duì)等節(jié)點(diǎn)列表發(fā)生了變化 ）
  • WIFI_P2P_CONNECTION_CHANGED_ACTION（ Wifi P2P 的連接狀態(tài)發(fā)生了改變 ）
  • WIFI_P2P_THIS_DEVICE_CHANGED_ACTION（ 本設(shè)備的設(shè)備信息發(fā)生了變化 ）

當(dāng)接收到這幾個(gè)廣播時(shí)，我們都需要到 WifiP2pManager （對(duì)等網(wǎng)絡(luò)管理器）來進(jìn)行相應(yīng)的信息請(qǐng)求，此外還需要用到 Channel 對(duì)象作為請(qǐng)求參數(shù)

 
 
 
 
    
  
  
  
  
  1. mWifiP2pManager = (WifiP2pManager) getSystemService(Context.WIFI_P2P_SERVICE);  
    2. 
  
  
  
  
  2. mChannel = mWifiP2pManager.initialize(this, getMainLooper(), this); 
    3.

 

當(dāng)收到 WifiP2pManager.WIFI_P2P_STATE_CHANGED_ACTION 廣播時(shí)，可以判斷當(dāng)前 Wifi P2P是否可用

 
 
 
 
    
  
  
  
  
  1. int state = intent.getIntExtra(WifiP2pManager.EXTRA_WIFI_STATE, -1);if (state == WifiP2pManager.WIFI_P2P_STATE_ENABLED) {  
    2. 
  
  
  
  
  2.     mDirectActionListener.wifiP2pEnabled(true);  
    3. 
  
  
  
  
  3. } else {  
    4. 
  
  
  
  
  4.     mDirectActionListener.wifiP2pEnabled(false);  
    5. 
  
  
  
  
  5. } 
    6.

 

當(dāng)收到 WifiP2pManager.WIFI_P2P_PEERS_CHANGED_ACTION 廣播時(shí)，意味設(shè)備周圍的可用設(shè)備列表發(fā)生了變化，可以通過 requestPeers 方法得到可用的設(shè)備列表，之后就可以選擇當(dāng)中的某一個(gè)設(shè)備進(jìn)行連接操作

 
 
 
 
    
  
  
  
  
  1. mWifiP2pManager.requestPeers(mChannel, new WifiP2pManager.PeerListListener() {    @Override  
    2. 
  
  
  
  
  2.     public void onPeersAvailable(WifiP2pDeviceList peers) {  
    3. 
  
  
  
  
  3.         mDirectActionListener.onPeersAvailable(peers.getDeviceList());  
    4. 
  
  
  
  
  4.     }  
    5. 
  
  
  
  
  5. }); 
    6.

 

當(dāng)收到 WifiP2pManager.WIFI_P2P_CONNECTION_CHANGED_ACTION 廣播時(shí)，意味著 Wifi P2P 的連接狀態(tài)發(fā)生了變化，可能是連接到了某設(shè)備，或者是與某設(shè)備斷開了連接

 
 
 
 
    
  
  
  
  
  1. NetworkInfo networkInfo = intent.getParcelableExtra(WifiP2pManager.EXTRA_NETWORK_INFO);if (networkInfo.isConnected()) {  
    2. 
  
  
  
  
  2.     mWifiP2pManager.requestConnectionInfo(mChannel, new WifiP2pManager.ConnectionInfoListener() {        @Override 
    3. 
  
  
  
  
  3.  
    4. 
  
  
  
  
  4.         public void onConnectionInfoAvailable(WifiP2pInfo info) {  
    5. 
  
  
  
  
  5.             mDirectActionListener.onConnectionInfoAvailable(info);  
    6. 
  
  
  
  
  6.         }  
    7. 
  
  
  
  
  7.     });  
    8. 
  
  
  
  
  8.     Log.e(TAG, "已連接p2p設(shè)備");  
    9. 
  
  
  
  
  9. } else {  
    10. 
  
  
  
  
  10.     mDirectActionListener.onDisconnection();  
    11. 
  
  
  
  
  11.     Log.e(TAG, "與p2p設(shè)備已斷開連接");  
    12. 
  
  
  
  
  12. } 
    13.

 

如果是與某設(shè)備連接上了，則可以通過 requestConnectionInfo 方法獲取到連接信息

當(dāng)收到 WifiP2pManager.WIFI_P2P_THIS_DEVICE_CHANGED_ACTION 廣播時(shí)，則可以獲取到本設(shè)備變化后的設(shè)備信息

 
 
 
 
    
  
  
  
  
  1. (WifiP2pDevice) intent.getParcelableExtra(WifiP2pManager.EXTRA_WIFI_P2P_DEVICE) 
    2.

可以看出 Wifi P2P 的接口高度異步化，到現(xiàn)在已經(jīng)用到了三個(gè)系統(tǒng)的回調(diào)函數(shù)，一個(gè)用于 WifiP2pManager 的初始化，兩個(gè)用于在廣播中異步請(qǐng)求數(shù)據(jù)，為了簡(jiǎn)化操作，此處統(tǒng)一使用一個(gè)自定義的回調(diào)函數(shù)，方法含義與系統(tǒng)的回調(diào)函數(shù)一致

 
 
 
 
    
  
  
  
  
  1. public interface DirectActionListener extends WifiP2pManager.ChannelListener {  
    2. 
  
  
  
  
  2.     void wifiP2pEnabled(boolean enabled);      
    3. 
  
  
  
  
  3.     void onConnectionInfoAvailable(WifiP2pInfo wifiP2pInfo);  
    4. 
  
  
  
  
  4.     void onDisconnection();      
    5. 
  
  
  
  
  5.     void onSelfDeviceAvailable(WifiP2pDevice wifiP2pDevice);     
    6. 
  
  
  
  
  6.     void onPeersAvailable(Collection wifiP2pDeviceList); 
    7. 
  
  
  
  
  7. } 
    8.

 

所以，整個(gè)廣播接收器使用到的所有代碼是：

 
 
 
 
    
  
  
  
  
  1. /** 
    2. 
  
  
  
  
  2.  
    3. 
  
  
  
  
  3.  * 作者：chenZY 
    4. 
  
  
  
  
  4.  
    5. 
  
  
  
  
  5.  * 時(shí)間：2018/2/9 17:53 
    6. 
  
  
  
  
  6.  
    7. 
  
  
  
  
  7.  * 描述： 
    8. 
  
  
  
  
  8.  
    9. 
  
  
  
  
  9.  */  
    10. 
  
  
  
  
  10. public class DirectBroadcastReceiver extends BroadcastReceiver {  
    11. 
  
  
  
  
  11.     private static final String TAG = "DirectBroadcastReceiver";     
    12. 
  
  
  
  
  12.     private WifiP2pManager mWifiP2pManager;     
    13. 
  
  
  
  
  13.     private WifiP2pManager.Channel mChannel;    
    14. 
  
  
  
  
  14.     private DirectActionListener mDirectActionListener;      
    15. 
  
  
  
  
  15.  
    16. 
  
  
  
  
  16.     public DirectBroadcastReceiver(WifiP2pManager wifiP2pManager, WifiP2pManager.Channel channel, DirectActionListener directActionListener) {  
    17. 
  
  
  
  
  17.         mWifiP2pManager = wifiP2pManager;  
    18. 
  
  
  
  
  18.         mChannel = channel;  
    19. 
  
  
  
  
  19.         mDirectActionListener = directActionListener;  
    20. 
  
  
  
  
  20.     }     
    21. 
  
  
  
  
  21.     public static IntentFilter getIntentFilter() {  
    22. 
  
  
  
  
  22.         IntentFilter intentFilter = new IntentFilter();  
    23. 
  
  
  
  
  23.         intentFilter.addAction(WifiP2pManager.WIFI_P2P_STATE_CHANGED_ACTION);  
    24. 
  
  
  
  
  24.         intentFilter.addAction(WifiP2pManager.WIFI_P2P_PEERS_CHANGED_ACTION);  
    25. 
  
  
  
  
  25.         intentFilter.addAction(WifiP2pManager.WIFI_P2P_CONNECTION_CHANGED_ACTION);  
    26. 
  
  
  
  
  26.         intentFilter.addAction(WifiP2pManager.WIFI_P2P_THIS_DEVICE_CHANGED_ACTION);  
    27. 
  
  
  
  
  27.  
    28. 
  
  
  
  
  28.         return intentFilter;  
    29. 
  
  
  
  
  29.     }   
    30. 
  
  
  
  
  30.  
    31. 
  
  
  
  
  31.     @Override  
    32. 
  
  
  
  
  32.     public void onReceive(Context context, Intent intent) {  
    33. 
  
  
  
  
  33.         Log.e(TAG, "接收到廣播： " + intent.getAction()); 
    34. 
  
  
  
  
  34.         if (!TextUtils.isEmpty(intent.getAction())) {  
    35. 
  
  
  
  
  35.             switch (intent.getAction()) {      
    36. 
  
  
  
  
  36.                 // 用于指示 Wifi P2P 是否可用 
    37. 
  
  
  
  
  37.                 case WifiP2pManager.WIFI_P2P_STATE_CHANGED_ACTION: {     
    38. 
  
  
  
  
  38.                     int state = intent.getIntExtra(WifiP2pManager.EXTRA_WIFI_STATE, -1);   
    39. 
  
  
  
  
  39.                     if (state == WifiP2pManager.WIFI_P2P_STATE_ENABLED) { 
    40. 
  
  
  
  
  40.                         mDirectActionListener.wifiP2pEnabled(true); 
    41. 
  
  
  
  
  41.                     } else { 
    42. 
  
  
  
  
  42.                         mDirectActionListener.wifiP2pEnabled(false); 
    43. 
  
  
  
  
  43.                         List wifiP2pDeviceList = new ArrayList<>(); 
    44. 
  
  
  
  
  44.                         mDirectActionListener.onPeersAvailable(wifiP2pDeviceList); 
    45. 
  
  
  
  
  45.                     }                     
    46. 
  
  
  
  
  46.                     break; 
    47. 
  
  
  
  
  47.                  }                 
    48. 
  
  
  
  
  48.  
    49. 
  
  
  
  
  49.                 // 對(duì)等節(jié)點(diǎn)列表發(fā)生了變化  
    50. 
  
  
  
  
  50.                 case WifiP2pManager.WIFI_P2P_PEERS_CHANGED_ACTION: {  
    51. 
  
  
  
  
  51.                     mWifiP2pManager.requestPeers(mChannel, new WifiP2pManager.PeerListListener() {  
    52. 
  
  
  
  
  52.                         @Override 
    53. 
  
  
  
  
  53.                          public void onPeersAvailable(WifiP2pDeviceList peers) { 
    54. 
  
  
  
  
  54.                             mDirectActionListener.onPeersAvailable(peers.getDeviceList()); 
    55. 
  
  
  
  
  55.                         } 
    56. 
  
  
  
  
  56.                     });          
    57. 
  
  
  
  
  57.                     break; 
    58. 
  
  
  
  
  58.                 }                 
    59. 
  
  
  
  
  59.                  // Wifi P2P 的連接狀態(tài)發(fā)生了改變  
    60. 
  
  
  
  
  60.                 case WifiP2pManager.WIFI_P2P_CONNECTION_CHANGED_ACTION: { 
    61. 
  
  
  
  
  61.                     NetworkInfo networkInfo = intent.getParcelableExtra(WifiP2pManager.EXTRA_NETWORK_INFO);   
    62. 
  
  
  
  
  62.                     if (networkInfo.isConnected()) { 
    63. 
  
  
  
  
  63.                         mWifiP2pManager.requestConnectionInfo(mChannel, new WifiP2pManager.ConnectionInfoListener() {   
    64. 
  
  
  
  
  64.                             @Override 
    65. 
  
  
  
  
  65.                             public void onConnectionInfoAvailable(WifiP2pInfo info) { 
    66. 
  
  
  
  
  66.                                 mDirectActionListener.onConnectionInfoAvailable(info); 
    67. 
  
  
  
  
  67.                             } 
    68. 
  
  
  
  
  68.                         });  
    69. 
  
  
  
  
  69.                         Log.e(TAG, "已連接p2p設(shè)備");  
    70. 
  
  
  
  
  70.                     } else {  
    71. 
  
  
  
  
  71.                         mDirectActionListener.onDisconnection();  
    72. 
  
  
  
  
  72.                         Log.e(TAG, "與p2p設(shè)備已斷開連接");  
    73. 
  
  
  
  
  73.                     }                     
    74. 
  
  
  
  
  74.                     break;  
    75. 
  
  
  
  
  75.                 }                 
    76. 
  
  
  
  
  76.  
    77. 
  
  
  
  
  77.                 //本設(shè)備的設(shè)備信息發(fā)生了變化  
    78. 
  
  
  
  
  78.                 case WifiP2pManager.WIFI_P2P_THIS_DEVICE_CHANGED_ACTION: { 
    79. 
  
  
  
  
  79.                     mDirectActionListener.onSelfDeviceAvailable((WifiP2pDevice) intent.getParcelableExtra(WifiP2pManager.EXTRA_WIFI_P2P_DEVICE));   
    80. 
  
  
  
  
  80.                     break; 
    81. 
  
  
  
  
  81.                 } 
    82. 
  
  
  
  
  82.             } 
    83. 
  
  
  
  
  83.         } 
    84. 
  
  
  
  
  84.     } 
    85. 
  
  
  
  
  85. } 
    86.

 

三、服務(wù)器端創(chuàng)建群組

假設(shè)當(dāng)設(shè)備A搜索到了設(shè)備B，并與設(shè)備B連接到了一起，此時(shí)系統(tǒng)會(huì)自動(dòng)創(chuàng)建一個(gè)群組（Group）并隨機(jī)指定一臺(tái)設(shè)備為群主（GroupOwner）。此時(shí)，對(duì)于兩臺(tái)設(shè)備來說，群主的IP地址是可知的（系統(tǒng)回調(diào)函數(shù)中有提供），但客戶端的IP地址需要再來通過其他方法來主動(dòng)獲取。例如，可以在設(shè)備連接成功后，客戶端主動(dòng)發(fā)起對(duì)服務(wù)器端的Socket連接請(qǐng)求，服務(wù)器端在指定端口監(jiān)聽客戶端的連接請(qǐng)求，當(dāng)連接成功后，服務(wù)器端就可以獲取到客戶端的IP地址了

此處為了簡(jiǎn)化操作，直接指定某臺(tái)設(shè)備作為服務(wù)器端（群主），即直接指定某臺(tái)設(shè)備用來接收文件

因此，服務(wù)器端要主動(dòng)創(chuàng)建群組，并等待客戶端的連接

 
 
 
 
    
  
  
  
  
  1. wifiP2pManager.createGroup(channel, new WifiP2pManager.ActionListener() {  
    2. 
  
  
  
  
  2.     @Override 
    3. 
  
  
  
  
  3.     public void onSuccess() { 
    4. 
  
  
  
  
  4.         Log.e(TAG, "createGroup onSuccess"); 
    5. 
  
  
  
  
  5.         dismissLoadingDialog(); 
    6. 
  
  
  
  
  6.         showToast("onSuccess"); 
    7. 
  
  
  
  
  7.     }     
    8. 
  
  
  
  
  8.  
    9. 
  
  
  
  
  9.     @Override 
    10. 
  
  
  
  
  10.      public void onFailure(int reason) { 
    11. 
  
  
  
  
  11.         Log.e(TAG, "createGroup onFailure: " + reason); 
    12. 
  
  
  
  
  12.         dismissLoadingDialog(); 
    13. 
  
  
  
  
  13.         showToast("onFailure"); 
    14. 
  
  
  
  
  14.     } 
    15. 
  
  
  
  
  15. }); 
    16.

 

此處，使用 IntentService 在后臺(tái)監(jiān)聽客戶端的Socket連接請(qǐng)求，并通過輸入輸出流來傳輸文件。此處的代碼比較簡(jiǎn)單，就只是在指定端口一直堵塞監(jiān)聽客戶端的連接請(qǐng)求，獲取待傳輸?shù)奈募畔⒛Ｐ?FileTransfer ，之后就進(jìn)行實(shí)際的數(shù)據(jù)傳輸

 
 
 
 
    
  
  
  
  
  1. @Override  
    2. 
  
  
  
  
  2.  protected void onHandleIntent(Intent intent) { 
    3. 
  
  
  
  
  3.      clean(); 
    4. 
  
  
  
  
  4.      File file = null;      
    5. 
  
  
  
  
  5.      try {  
    6. 
  
  
  
  
  6.          serverSocket = new ServerSocket();  
    7. 
  
  
  
  
  7.          serverSocket.setReuseAddress(true);  
    8. 
  
  
  
  
  8.          serverSocket.bind(new InetSocketAddress(PORT));  
    9. 
  
  
  
  
  9.          Socket client = serverSocket.accept();  
    10. 
  
  
  
  
  10.          Log.e(TAG, "客戶端IP地址 : " + client.getInetAddress().getHostAddress());  
    11. 
  
  
  
  
  11.          inputStream = client.getInputStream();  
    12. 
  
  
  
  
  12.          objectInputStream = new ObjectInputStream(inputStream);  
    13. 
  
  
  
  
  13.          FileTransfer fileTransfer = (FileTransfer) objectInputStream.readObject(); 
    14. 
  
  
  
  
  14.          Log.e(TAG, "待接收的文件: " + fileTransfer);  
    15. 
  
  
  
  
  15.          String name = new File(fileTransfer.getFilePath()).getName();         
    16. 
  
  
  
  
  16.  
    17. 
  
  
  
  
  17.          //將文件存儲(chǔ)至指定位置  
    18. 
  
  
  
  
  18.          file = new File(Environment.getExternalStorageDirectory() + "/" + name);  
    19. 
  
  
  
  
  19.          fileOutputStream = new FileOutputStream(file);    
    20. 
  
  
  
  
  20.          byte buf[] = new byte[512];       
    21. 
  
  
  
  
  21.          int len;             
    22. 
  
  
  
  
  22.          long total = 0;            
    23. 
  
  
  
  
  23.          int progress;            
    24. 
  
  
  
  
  24.          while ((len = inputStream.read(buf)) != -1) { 
    25. 
  
  
  
  
  25.              fileOutputStream.write(buf, 0, len); 
    26. 
  
  
  
  
  26.              total += len; 
    27. 
  
  
  
  
  27.              progress = (int) ((total * 100) / fileTransfer.getFileLength()); 
    28. 
  
  
  
  
  28.              Log.e(TAG, "文件接收進(jìn)度: " + progress);     
    29. 
  
  
  
  
  29.              if (progressChangListener != null) { 
    30. 
  
  
  
  
  30.                  progressChangListener.onProgressChanged(fileTransfer, progress); 
    31. 
  
  
  
  
  31.              } 
    32. 
  
  
  
  
  32.           } 
    33. 
  
  
  
  
  33.          serverSocket.close(); 
    34. 
  
  
  
  
  34.          inputStream.close(); 
    35. 
  
  
  
  
  35.          objectInputStream.close();  
    36. 
  
  
  
  
  36.          fileOutputStream.close();  
    37. 
  
  
  
  
  37.          serverSocket = null;  
    38. 
  
  
  
  
  38.          inputStream = null;  
    39. 
  
  
  
  
  39.          objectInputStream = null;  
    40. 
  
  
  
  
  40.          fileOutputStream = null;  
    41. 
  
  
  
  
  41.          Log.e(TAG, "文件接收成功，文件的MD5碼是：" + Md5Util.getMd5(file));  
    42. 
  
  
  
  
  42.      } catch (Exception e) {  
    43. 
  
  
  
  
  43.          Log.e(TAG, "文件接收 Exception: " + e.getMessage());  
    44. 
  
  
  
  
  44.      } finally {  
    45. 
  
  
  
  
  45.          clean();            
    46. 
  
  
  
  
  46.           if (progressChangListener != null) {  
    47. 
  
  
  
  
  47.              progressChangListener.onTransferFinished(file);  
    48. 
  
  
  
  
  48.          }     
    49. 
  
  
  
  
  49.          //再次啟動(dòng)服務(wù)，等待客戶端下次連接 
    50. 
  
  
  
  
  50.          startService(new Intent(this, WifiServerService.class)); 
    51. 
  
  
  
  
  51.      }  
    52. 
  
  
  
  
  52.  } 
    53.

 

因?yàn)榭蛻舳丝赡軙?huì)多次發(fā)起連接請(qǐng)求，所以當(dāng)此處文件傳輸完成后（不管成功或失敗），都需要重新 startService ，讓服務(wù)再次堵塞等待客戶端的連接請(qǐng)求

FileTransfer 包含三個(gè)字段，MD5碼值用于校驗(yàn)文件的完整性，fileLength 是為了用于計(jì)算文件的傳輸進(jìn)度

 
 
 
 
    
  
  
  
  
  1. public class FileTransfer implements Serializable { 
    2. 
  
  
  
  
  2.     //文件路徑 
    3. 
  
  
  
  
  3.     private String filePath;      
    4. 
  
  
  
  
  4.     //文件大小 
    5. 
  
  
  
  
  5.     private long fileLength;   
    6. 
  
  
  
  
  6.     //MD5碼  
    7. 
  
  
  
  
  7.     private String md5;  
    8. 
  
  
  
  
  8.     ··· 
    9. 
  
  
  
  
  9. } 
    10.

 

為了將文件傳輸進(jìn)度發(fā)布到外部界面，所以除了需要啟動(dòng)Service外，界面還需要綁定Service，此處就需要用到一個(gè)更新文件傳輸狀態(tài)的接口

 
 
 
 
    
  
  
  
  
  1. public interface OnProgressChangListener {  
    2. 
  
  
  
  
  2.     //當(dāng)傳輸進(jìn)度發(fā)生變化時(shí)  
    3. 
  
  
  
  
  3.     void onProgressChanged(FileTransfer fileTransfer, int progress);  
    4. 
  
  
  
  
  4.     //當(dāng)傳輸結(jié)束時(shí) 
    5. 
  
  
  
  
  5.     void onTransferFinished(File file); 
    6. 
  
  
  
  
  6. } 
    7.

 

因此，需要將 progressChangListener 作為參數(shù)傳給  WifiServerService ，并在進(jìn)度變化時(shí)更新進(jìn)度對(duì)話框

 
 
 
 
    
  
  
  
  
  1. private WifiServerService.OnProgressChangListener progressChangListener = new WifiServerService.OnProgressChangListener() {    
    2. 
  
  
  
  
  2.        @Override 
    3. 
  
  
  
  
  3.        public void onProgressChanged(final FileTransfer fileTransfer, final int progress) { 
    4. 
  
  
  
  
  4.            runOnUiThread(new Runnable() { 
    5. 
  
  
  
  
  5.                @Override 
    6. 
  
  
  
  
  6.                public void run() { 
    7. 
  
  
  
  
  7.                   progressDialog.setMessage("文件名： " + new File(fileTransfer.getFilePath()).getName()); 
    8. 
  
  
  
  
  8.                    progressDialog.setProgress(progress); 
    9. 
  
  
  
  
  9.                    progressDialog.show(); 
    10. 
  
  
  
  
  10.                } 
    11. 
  
  
  
  
  11.            }); 
    12. 
  
  
  
  
  12.         }      
    13. 
  
  
  
  
  13.  
    14. 
  
  
  
  
  14.        @Override  
    15. 
  
  
  
  
  15.        public void onTransferFinished(final File file) {  
    16. 
  
  
  
  
  16.            runOnUiThread(new Runnable() {   
    17. 
  
  
  
  
  17.                @Override 
    18. 
  
  
  
  
  18.                public void run() { 
    19. 
  
  
  
  
  19.                    progressDialog.cancel();  
    20. 
  
  
  
  
  20.                    if (file != null && file.exists()) { 
    21. 
  
  
  
  
  21.                        openFile(file.getPath()); 
    22. 
  
  
  
  
  22.                    } 
    23. 
  
  
  
  
  23.                } 
    24. 
  
  
  
  
  24.            }); 
    25. 
  
  
  
  
  25.        } 
    26. 
  
  
  
  
  26.    }; 
    27.

 

四、客戶端加入群組并發(fā)起文件傳輸請(qǐng)求

文件發(fā)送界面 SendFileActivity 需要實(shí)現(xiàn) DirectActionListener 接口

首先，需要先注冊(cè)P2P廣播，以便獲取周邊設(shè)備信息以及連接狀態(tài)

 
 
 
 
    
  
  
  
  
  1. @Override  
    2. 
  
  
  
  
  2. protected void onCreate(Bundle savedInstanceState) { 
    3. 
  
  
  
  
  3.     super.onCreate(savedInstanceState);  
    4. 
  
  
  
  
  4.     setContentView(R.layout.activity_send_file);  
    5. 
  
  
  
  
  5.     initView();  
    6. 
  
  
  
  
  6.     mWifiP2pManager = (WifiP2pManager) getSystemService(Context.WIFI_P2P_SERVICE);  
    7. 
  
  
  
  
  7.     mChannel = mWifiP2pManager.initialize(this, getMainLooper(), this);  
    8. 
  
  
  
  
  8.     broadcastReceiver = new DirectBroadcastReceiver(mWifiP2pManager, mChannel, this);  
    9. 
  
  
  
  
  9.     registerReceiver(broadcastReceiver, DirectBroadcastReceiver.getIntentFilter());  
    10. 
  
  
  
  
  10. } 
    11.

 

通過 discoverPeers 方法搜索周邊設(shè)備，回調(diào)函數(shù)用于通知方法是否調(diào)用成功

 
 
 
 
    
  
  
  
  
  1. mWifiP2pManager.discoverPeers(mChannel, new WifiP2pManager.ActionListener() {    @Override  
    2. 
  
  
  
  
  2.     public void onSuccess() {  
    3. 
  
  
  
  
  3.         showToast("Success");  
    4. 
  
  
  
  
  4.     }     
    5. 
  
  
  
  
  5.  
    6. 
  
  
  
  
  6.     @Override  
    7. 
  
  
  
  
  7.     public void onFailure(int reasonCode) {  
    8. 
  
  
  
  
  8.         showToast("Failure");  
    9. 
  
  
  
  
  9.         loadingDialog.cancel(); 
    10. 
  
  
  
  
  10.      }  
    11. 
  
  
  
  
  11. }); 
    12.

 

當(dāng)搜索結(jié)束后，系統(tǒng)就會(huì)觸發(fā) WifiP2pManager.WIFI_P2P_PEERS_CHANGED_ACTION 廣播，此時(shí)就可以調(diào)用 requestPeers 方法獲取設(shè)備列表信息，此處用 RecyclerView 展示列表，在  onPeersAvailable 方法刷新列表

 
 
 
 
    
  
  
  
  
  1. mWifiP2pManager.requestPeers(mChannel, new WifiP2pManager.PeerListListener() {  
    2. 
  
  
  
  
  2.     @Override  
    3. 
  
  
  
  
  3.     public void onPeersAvailable(WifiP2pDeviceList peers) {  
    4. 
  
  
  
  
  4.         mDirectActionListener.onPeersAvailable(peers.getDeviceList());  
    5. 
  
  
  
  
  5.     } 
    6. 
  
  
  
  
  6. }); 
    7. 
  
  
  
  
  7.  
    8. 
  
  
  
  
  8.     @Override  
    9. 
  
  
  
  
  9.     public void onPeersAvailable(Collection wifiP2pDeviceList) {  
    10. 
  
  
  
  
  10.         Log.e(TAG, "onPeersAvailable :" + wifiP2pDeviceList.size());  
    11. 
  
  
  
  
  11.         this.wifiP2pDeviceList.clear();         
    12. 
  
  
  
  
  12.         this.wifiP2pDeviceList.addAll(wifiP2pDeviceList);  
    13. 
  
  
  
  
  13.         deviceAdapter.notifyDataSetChanged(); 
    14. 
  
  
  
  
  14.         loadingDialog.cancel(); 
    15. 
  
  
  
  
  15.     } 
    16.

 

之后，通過點(diǎn)擊事件選中群主（服務(wù)器端）設(shè)備，通過 connect 方法請(qǐng)求與之進(jìn)行連接

 
 
 
 
    
  
  
  
  
  1. private void connect() {  
    2. 
  
  
  
  
  2.     WifiP2pConfig config = new WifiP2pConfig();  
    3. 
  
  
  
  
  3.     if (config.deviceAddress != null && mWifiP2pDevice != null) {  
    4. 
  
  
  
  
  4.         config.deviceAddress = mWifiP2pDevice.deviceAddress;  
    5. 
  
  
  
  
  5.         config.wps.setup = WpsInfo.PBC;  
    6. 
  
  
  
  
  6.         showLoadingDialog("正在連接 " + mWifiP2pDevice.deviceName);  
    7. 
  
  
  
  
  7.         mWifiP2pManager.connect(mChannel, config, new WifiP2pManager.ActionListener() {           
    8. 
  
  
  
  
  8.  
    9. 
  
  
  
  
  9.             @Override  
    10. 
  
  
  
  
  10.             public void onSuccess() {  
    11. 
  
  
  
  
  11.                 Log.e(TAG, "connect onSuccess");  
    12. 
  
  
  
  
  12.             }         
    13. 
  
  
  
  
  13.  
    14. 
  
  
  
  
  14.             @Override  
    15. 
  
  
  
  
  15.             public void onFailure(int reason) { 
    16. 
  
  
  
  
  16.                 showToast("連接失敗 " + reason);  
    17. 
  
  
  
  
  17.                 dismissLoadingDialog(); 
    18. 
  
  
  
  
  18.             }  
    19. 
  
  
  
  
  19.         });  
    20. 
  
  
  
  
  20.     } 
    21. 
  
  
  
  
  21.  } 
    22.

 

此處依然無法通過函數(shù)函數(shù)來判斷連接結(jié)果，需要依靠系統(tǒng)發(fā)出的 WifiP2pManager.WIFI_P2P_CONNECTION_CHANGED_ACTION  方法來獲取到連接結(jié)果，在此處可以通過 requestConnectionInfo 獲取到組連接信息，信息最后通過 onConnectionInfoAvailable 方法傳遞出來，在此可以判斷當(dāng)前設(shè)備是否為群主，獲取群組IP地址

 
 
 
 
    
  
  
  
  
  1. @Override  
    2. 
  
  
  
  
  2. public void onConnectionInfoAvailable(WifiP2pInfo wifiP2pInfo) {  
    3. 
  
  
  
  
  3.     dismissLoadingDialog();  
    4. 
  
  
  
  
  4.     wifiP2pDeviceList.clear();  
    5. 
  
  
  
  
  5.     deviceAdapter.notifyDataSetChanged();  
    6. 
  
  
  
  
  6.     btn_disconnect.setEnabled(true);  
    7. 
  
  
  
  
  7.     btn_chooseFile.setEnabled(true);  
    8. 
  
  
  
  
  8.     Log.e(TAG, "onConnectionInfoAvailable");  
    9. 
  
  
  
  
  9.     Log.e(TAG, "onConnectionInfoAvailable groupFormed: " + wifiP2pInfo.groupFormed);  
    10. 
  
  
  
  
  10.     Log.e(TAG, "onConnectionInfoAvailable isGroupOwner: " + wifiP2pInfo.isGroupOwner);  
    11. 
  
  
  
  
  11.     Log.e(TAG, "onConnectionInfoAvailable getHostAddress: " + wifiP2pInfo.groupOwnerAddress.getHostAddress());  
    12. 
  
  
  
  
  12.     StringBuilder stringBuilder = new StringBuilder();   
    13. 
  
  
  
  
  13.  
    14. 
  
  
  
  
  14.     if (mWifiP2pDevice != null) {  
    15. 
  
  
  
  
  15.         stringBuilder.append("連接的設(shè)備名：");  
    16. 
  
  
  
  
  16.         stringBuilder.append(mWifiP2pDevice.deviceName);  
    17. 
  
  
  
  
  17.         stringBuilder.append("\n");  
    18. 
  
  
  
  
  18.         stringBuilder.append("連接的設(shè)備的地址：");  
    19. 
  
  
  
  
  19.         stringBuilder.append(mWifiP2pDevice.deviceAddress);  
    20. 
  
  
  
  
  20.     } 
    21. 
  
  
  
  
  21.  
    22. 
  
  
  
  
  22.     stringBuilder.append("\n");  
    23. 
  
  
  
  
  23.     stringBuilder.append("是否群主：");  
    24. 
  
  
  
  
  24.     stringBuilder.append(wifiP2pInfo.isGroupOwner ? "是群主" : "非群主");  
    25. 
  
  
  
  
  25.     stringBuilder.append("\n");  
    26. 
  
  
  
  
  26.     stringBuilder.append("群主IP地址：");  
    27. 
  
  
  
  
  27.     stringBuilder.append(wifiP2pInfo.groupOwnerAddress.getHostAddress());  
    28. 
  
  
  
  
  28.     tv_status.setText(stringBuilder);     
    29. 
  
  
  
  
  29.     if (wifiP2pInfo.groupFormed && !wifiP2pInfo.isGroupOwner) {  
    30. 
  
  
  
  
  30.         this.wifiP2pInfo = wifiP2pInfo;  
    31. 
  
  
  
  
  31.     }  
    32. 
  
  
  
  
  32. } 
    33.

 

至此服務(wù)器端和客戶端已經(jīng)通過 Wifi P2P 連接在了一起，客戶端也獲取到了服務(wù)器端的IP地址，在選取好待發(fā)送的文件后就可以主動(dòng)發(fā)起對(duì)服務(wù)器端的連接請(qǐng)求了

發(fā)起選取文件的方法

 
 
 
 
    
  
  
  
  
  1. Intent intent = new Intent(Intent.ACTION_GET_CONTENT);  
    2. 
  
  
  
  
  2. intent.setType("*/*"); 
    3. 
  
  
  
  
  3. intent.addCategory(Intent.CATEGORY_OPENABLE);  
    4. 
  
  
  
  
  4. startActivityForResult(intent, 1); 
    5.

 

獲取選取的文件的實(shí)際路徑

 
 
 
 
    
  
  
  
  
  1. @Override  
    2. 
  
  
  
  
  2. protected void onActivityResult(int requestCode, int resultCode, Intent data) {     
    3. 
  
  
  
  
  3.     super.onActivityResult(requestCode, resultCode, data);      
    4. 
  
  
  
  
  4.     if (requestCode == 1) {
    5. 
  
  
  
  
  5.         if (resultCode == RESULT_OK) { 
    6. 
  
  
  
  
  6.             Uri uri = data.getData(); 
    7. 
  
  
  
  
  7.              if (uri != null) {  
    8. 
  
  
  
  
  8.                 String path = getPath(this, uri);  
    9. 
  
  
  
  
  9.                 if (path != null) { 
    10. 
  
  
  
  
  10.                     File file = new File(path);  
    11. 
  
  
  
  
  11.                     if (file.exists() && wifiP2pInfo != null) { 
    12. 
  
  
  
  
  12.                         FileTransfer fileTransfer = new FileTransfer(file.getPath(), file.length());
    13. 
  
  
  
  
  13.                         Log.e(TAG, "待發(fā)送的文件：" + fileTransfer);      
    14. 
  
  
  
  
  14.                         new WifiClientTask(this, fileTransfer).execute(wifiP2pInfo.groupOwnerAddress.getHostAddress()); 
    15. 
  
  
  
  
  15.                     } 
    16. 
  
  
  
  
  16.                 }  
    17. 
  
  
  
  
  17.             }  
    18. 
  
  
  
  
  18.         }  
    19. 
  
  
  
  
  19.     }  
    20. 
  
  
  
  
  20. }                          
    21. 
  
  
  
  
  21.  
    22. 
  
  
  
  
  22. private String getPath(Context context, Uri uri) {     
    23. 
  
  
  
  
  23.     if ("content".equalsIgnoreCase(uri.getScheme())) {  
    24. 
  
  
  
  
  24.         Cursor cursor = context.getContentResolver().query(uri, new String[]{"_data"}, null, null, null);   
    25. 
  
  
  
  
  25.         if (cursor != null) {           
    26. 
  
  
  
  
  26.             if (cursor.moveToFirst()) { 
    27. 
  
  
  
  
  27.                 String data = cursor.getString(cursor.getColumnIndex("_data")); 
    28. 
  
  
  
  
  28.                 cursor.close();                 
    29. 
  
  
  
  
  29.             return data;  
    30. 
  
  
  
  
  30.             }  
    31. 
  
  
  
  
  31.         }  
    32. 
  
  
  
  
  32.     } else if ("file".equalsIgnoreCase(uri.getScheme())) {    
    33. 
  
  
  
  
  33.             return uri.getPath(); 
    34. 
  
  
  
  
  34.     }     
    35. 
  
  
  
  
  35.     return null;  
    36. 
  
  
  
  
  36. } 
    37.

 

文件的發(fā)送操作放到 AsyncTask 中處理，將服務(wù)器端的IP地址作為參數(shù)傳進(jìn)來，在正式發(fā)送文件前，先發(fā)送包含文件信息（文件名，文件大小，文件MD5碼）的信息模型 FileTransfer ，并在發(fā)送文件的過程中同時(shí)更新進(jìn)度

 
 
 
 
    
  
  
  
  
  1. /**  
    2. 
  
  
  
  
  2.  * 作者：葉應(yīng)是葉  
    3. 
  
  
  
  
  3.  * 時(shí)間：2018/2/15 8:51  
    4. 
  
  
  
  
  4.  * 描述：客戶端發(fā)送文件  
    5. 
  
  
  
  
  5.  */ 
    6. 
  
  
  
  
  6.  
    7. 
  
  
  
  
  7. public class WifiClientTask extends AsyncTask {   
    8. 
  
  
  
  
  8.     private ProgressDialog progressDialog;  
    9. 
  
  
  
  
  9.     private FileTransfer fileTransfer;                                                    
    
                                                網(wǎng)站名稱：Android如何實(shí)現(xiàn)無網(wǎng)絡(luò)傳輸文件                                                
    
                                                網(wǎng)站鏈接：http://m.5511xx.com/article/dpdoedh.html