在我的上一篇文章：Android 實現(xiàn)無網(wǎng)絡(luò)傳輸文件蒲凶，我介紹了通過 Wifi Direct（Wifi 直連）實現(xiàn) Android 設(shè)備之間進行文件傳輸?shù)姆椒ㄆ睿梢栽跓o移動網(wǎng)絡(luò)的情況下實現(xiàn)點對點的文件傳輸
本來覺得這樣也就夠了，可在要應(yīng)用到實際項目的時候旋圆，又考慮到用戶的設(shè)備系統(tǒng)版本可能并不都符合要求（Wifi Direct 是 Android 4.0 后支持的功能宠默，話說低于 4.4 版本的手機應(yīng)該都很少了吧？）灵巧，而且我也不確定 IOS 系統(tǒng)是否支持 Wifi Direct搀矫，所以為了讓文件傳輸邏輯可以應(yīng)用到更多的設(shè)備上，就又實現(xiàn)了通過 Wifi熱點 進行文件傳輸?shù)墓δ?/p>
相比于通過 Wiif Direct 進行文件傳輸刻肄，通過 Wifi 熱點進行設(shè)備配對更加方便瓤球，邏輯也更為直接，傳輸一個1G左右的壓縮包用了5分鐘左右的時間敏弃，平均傳輸速率有 3.5 M/S 左右。此外麦到，相對于上個版本，新版本除了提供傳輸進度外蝴罪，還提供了傳輸速率步清、預(yù)估完成時間廓啊、文件傳輸前后的MD5碼等數(shù)據(jù)
項目地址：WifiFileTransfer
實現(xiàn)的效果如下所示：
開啟Ap熱點接收文件
開啟Ap熱點接收文件
連接Wiif熱點發(fā)送文件
連接Wiif熱點發(fā)送文件
文件傳輸完成后校驗文件完整性
文件傳輸完成后校驗文件完整性
開發(fā)步驟分為以下幾點：
- 在 AndroidManifest 中聲明相關(guān)權(quán)限（網(wǎng)絡(luò)和文件讀寫權(quán)限）
- 文件接收端開啟Ap熱點谴轮，作為服務(wù)器端建立Socket，在指定端口等待客戶端的連接
- 文件發(fā)送端連接到Wifi熱點第步，作為客戶端主動連接到服務(wù)器端
- 文件發(fā)送端將待發(fā)送的文件信息模型（包括文件路徑缘琅，文件大小和文件MD5碼等信息）通過Socket發(fā)送給文件接收端
- 文件發(fā)送端發(fā)起實際的文件傳輸請求粘都，接收端和發(fā)送端根據(jù)已接收到或已發(fā)送的的文件字節(jié)數(shù)，計算文件傳輸進度刷袍、文件傳輸速率和預(yù)估完成時間等數(shù)據(jù)
- 文件傳輸結(jié)束后翩隧，對比文件信息模型攜帶來的MD5碼值與本地文件重新計算生成的MD5碼是否相等，以此校驗文件完整性
一呻纹、聲明權(quán)限
本應(yīng)用并不會消耗移動數(shù)據(jù)堆生，但由于要使用到 Wifi 以及 Java Socket专缠，所以需要申請網(wǎng)絡(luò)相關(guān)的權(quán)限。此外淑仆，由于是要實現(xiàn)文件互傳涝婉，所以也需要申請SD卡讀寫權(quán)限。
<uses-permission android:name="android.permission.ACCESS_WIFI_STATE" />
<uses-permission android:name="android.permission.CHANGE_WIFI_STATE" />
<uses-permission android:name="android.permission.CHANGE_NETWORK_STATE" />
<uses-permission android:name="android.permission.INTERNET" />
<uses-permission android:name="android.permission.ACCESS_NETWORK_STATE" />
<uses-permission android:name="android.permission.WRITE_EXTERNAL_STORAGE" />
<uses-permission android:name="android.permission.READ_EXTERNAL_STORAGE" />
二蔗怠、文件接收端
文件接收端作為服務(wù)器存在嘁圈，需要主動開啟Ap熱點供文件發(fā)送端連接，此處開啟Ap熱點的方法是通過反射來實現(xiàn)蟀淮，這種方法雖然方便最住，但并不保證在所有系統(tǒng)上都能成功，比如我在 7.1.2 版本系統(tǒng)上就開啟不了怠惶，最好還是引導(dǎo)用戶去主動開啟
/**
* 開啟便攜熱點
*
* @param context 上下文
* @param ssid SSID
* @param password 密碼
* @return 是否成功
*/
public static boolean openAp(Context context, String ssid, String password) {
WifiManager wifimanager = (WifiManager) context.getApplicationContext().getSystemService(WIFI_SERVICE);
if (wifimanager == null) {
return false;
}
if (wifimanager.isWifiEnabled()) {
wifimanager.setWifiEnabled(false);
}
try {
Method method = wifimanager.getClass().getMethod("setWifiApEnabled", WifiConfiguration.class, boolean.class);
method.invoke(wifimanager, null, false);
method = wifimanager.getClass().getMethod("setWifiApEnabled", WifiConfiguration.class, boolean.class);
method.invoke(wifimanager, createApConfiguration(ssid, password), true);
return true;
} catch (Exception e) {
e.printStackTrace();
}
return false;
}
/**
* 關(guān)閉便攜熱點
*
* @param context 上下文
*/
public static void closeAp(Context context) {
WifiManager wifimanager = (WifiManager) context.getApplicationContext().getSystemService(WIFI_SERVICE);
try {
Method method = wifimanager.getClass().getMethod("setWifiApEnabled", WifiConfiguration.class, boolean.class);
method.invoke(wifimanager, null, false);
} catch (Exception e) {
e.printStackTrace();
}
}
此處需要先定義一個文件信息模型 FileTransfer 涨缚，F(xiàn)ileTransfer 包含三個字段，MD5碼值用于校驗文件的完整性策治，fileLength 是為了用于計算文件的傳輸進度和傳輸速率
public class FileTransfer implements Serializable {
//文件路徑
private String filePath;
//文件大小
private long fileLength;
//MD5碼
private String md5;
···
}
Ap熱點開啟成功后脓魏，就可以啟動一個服務(wù)在后臺等待文件發(fā)送端來主動連接了，這里使用 IntentService 在后臺監(jiān)聽客戶端的Socket連接請求通惫，并通過輸入輸出流來傳輸文件茂翔。此處的代碼比較簡單，就只是在指定端口一直堵塞監(jiān)聽客戶端的連接請求履腋，獲取待傳輸?shù)奈募畔⒛Ｐ?FileTransfer 珊燎，之后就進行實際的數(shù)據(jù)傳輸
文件傳輸速率是每一秒計算一次，根據(jù)這段時間內(nèi)接收的字節(jié)數(shù)與消耗的時間做除法谋国，從而得到傳輸速率芦瘾，再通過將剩余的未傳輸字節(jié)數(shù)與傳輸速率做除法近弟，從而得到預(yù)估的剩余傳輸時間
@Override
protected void onHandleIntent(Intent intent) {
clean();
File file = null;
try {
serverSocket = new ServerSocket();
serverSocket.setReuseAddress(true);
serverSocket.bind(new InetSocketAddress(Constants.PORT));
Socket client = serverSocket.accept();
Log.e(TAG, "客戶端IP地址 : " + client.getInetAddress().getHostAddress());
inputStream = client.getInputStream();
objectInputStream = new ObjectInputStream(inputStream);
FileTransfer fileTransfer = (FileTransfer) objectInputStream.readObject();
Log.e(TAG, "待接收的文件: " + fileTransfer);
String name = new File(fileTransfer.getFilePath()).getName();
//將文件存儲至指定位置
file = new File(Environment.getExternalStorageDirectory() + "/" + name);
fileOutputStream = new FileOutputStream(file);
byte buf[] = new byte[512];
int len;
//文件大小
long fileSize = fileTransfer.getFileLength();
//當(dāng)前的傳輸進度
int progress;
//總的已接收字節(jié)數(shù)
long total = 0;
//緩存-當(dāng)次更新進度時的時間
long tempTime = System.currentTimeMillis();
//緩存-當(dāng)次更新進度時已接收的總字節(jié)數(shù)
long tempTotal = 0;
//傳輸速率（Kb/s）
double speed = 0;
//預(yù)估的剩余完成時間（秒）
long remainingTime;
while ((len = inputStream.read(buf)) != -1) {
fileOutputStream.write(buf, 0, len);
total += len;
long time = System.currentTimeMillis() - tempTime;
//每一秒更新一次傳輸速率和傳輸進度
if (time > 1000) {
//當(dāng)前的傳輸進度
progress = (int) (total * 100 / fileSize);
Logger.e(TAG, "---------------------------");
Logger.e(TAG, "傳輸進度: " + progress);
Logger.e(TAG, "時間變化：" + time / 1000.0);
Logger.e(TAG, "字節(jié)變化：" + (total - tempTotal));
//計算傳輸速率，字節(jié)轉(zhuǎn)Kb迫摔，毫秒轉(zhuǎn)秒 17:45:07
speed = ((total - tempTotal) / 1024.0 / (time / 1000.0));
//預(yù)估的剩余完成時間
remainingTime = (long) ((fileSize - total) / 1024.0 / speed);
Logger.e(TAG, "傳輸速率：" + speed);
Logger.e(TAG, "預(yù)估的剩余完成時間：" + remainingTime);
//緩存-當(dāng)次更新進度時已傳輸?shù)目傋止?jié)數(shù)
tempTotal = total;
//緩存-當(dāng)次更新進度時的時間
tempTime = System.currentTimeMillis();
if (progressChangListener != null) {
progressChangListener.onProgressChanged(fileTransfer, progress, speed, remainingTime);
}
}
}
progressChangListener.onProgressChanged(fileTransfer, 100, 0, 0);
serverSocket.close();
inputStream.close();
objectInputStream.close();
fileOutputStream.close();
serverSocket = null;
inputStream = null;
objectInputStream = null;
fileOutputStream = null;
Log.e(TAG, "文件接收成功");
} catch (Exception e) {
Log.e(TAG, "文件接收 Exception: " + e.getMessage());
} finally {
clean();
if (progressChangListener != null) {
FileTransfer fileTransfer = new FileTransfer();
if (file != null && file.exists()) {
String md5 = Md5Util.getMd5(file);
fileTransfer.setFilePath(file.getPath());
fileTransfer.setFileLength(file.length());
fileTransfer.setMd5(md5);
Log.e(TAG, "文件的MD5碼是：" + md5);
}
progressChangListener.onTransferFinished(fileTransfer);
}
//再次啟動服務(wù)躯嫉，等待客戶端下次連接
startService(new Intent(this, FileReceiverService.class));
}
}
因為客戶端可能會多次發(fā)起連接請求擂啥，所以當(dāng)此處文件傳輸完成后（不管成功或失敳负）山宾，都需要重新 startService 资锰，讓服務(wù)再次堵塞等待客戶端的連接請求
為了讓界面能夠?qū)崟r獲取到文件的傳輸狀態(tài)绷杜，所以此處除了需要啟動Service外接剩，界面還需要綁定Service疫稿，所以需要用到一個更新文件傳輸狀態(tài)的接口
public interface OnProgressChangListener {
/**
* 當(dāng)傳輸進度發(fā)生變化時回調(diào)
*
* @param fileTransfer 文件發(fā)送方傳來的文件模型
* @param progress 文件傳輸進度
* @param speed 文件傳輸速率
* @param remainingTime 預(yù)估的剩余完成時間
*/
void onProgressChanged(FileTransfer fileTransfer, int progress, double speed, long remainingTime);
//當(dāng)傳輸結(jié)束時
void onTransferFinished(FileTransfer fileTransfer);
}
在界面層刷新UI
private FileReceiverService.OnProgressChangListener progressChangListener = new FileReceiverService.OnProgressChangListener() {
private FileTransfer originFileTransfer;
@Override
public void onProgressChanged(final FileTransfer fileTransfer, final int progress, final double speed, final long remainingTime) {
this.originFileTransfer = fileTransfer;
runOnUiThread(new Runnable() {
@Override
public void run() {
progressDialog.setTitle("正在接收的文件： " + new File(fileTransfer.getFilePath()).getName());
progressDialog.setMessage("原始文件的MD5碼是：" + fileTransfer.getMd5()
+ "\n" + "傳輸速率：" + (int) speed + " Kb/s"
+ "\n" + "預(yù)估的剩余完成時間：" + remainingTime + " 秒");
progressDialog.setProgress(progress);
progressDialog.setCancelable(false);
progressDialog.show();
}
});
}
@Override
public void onTransferFinished(final FileTransfer fileTransfer) {
runOnUiThread(new Runnable() {
@Override
public void run() {
progressDialog.setTitle("傳輸結(jié)束");
progressDialog.setMessage("原始文件的MD5碼是：" + originFileTransfer.getMd5()
+ "\n" + "本地文件的MD5碼是：" + fileTransfer.getMd5()
+ "\n" + "文件位置：" + fileTransfer.getFilePath());
progressDialog.setCancelable(true);
}
});
}
};
三、文件發(fā)送端
文件發(fā)送端作為客戶端存在猛遍，需要主動連接文件接收端開啟的Wifi熱點
/**
* 連接指定Wifi
*
* @param context 上下文
* @param ssid SSID
* @param password 密碼
* @return 是否連接成功
*/
public static boolean connectWifi(Context context, String ssid, String password) {
String connectedSsid = getConnectedSSID(context);
if (!TextUtils.isEmpty(connectedSsid) && connectedSsid.equals(ssid)) {
return true;
}
openWifi(context);
WifiConfiguration wifiConfiguration = isWifiExist(context, ssid);
if (wifiConfiguration == null) {
wifiConfiguration = createWifiConfiguration(ssid, password);
}
WifiManager wifiManager = (WifiManager) context.getApplicationContext().getSystemService(Context.WIFI_SERVICE);
if (wifiManager == null) {
return false;
}
int networkId = wifiManager.addNetwork(wifiConfiguration);
return wifiManager.enableNetwork(networkId, true);
}
/**
* 開啟Wifi
*
* @param context 上下文
* @return 是否成功
*/
public static boolean openWifi(Context context) {
WifiManager wifiManager = (WifiManager) context.getApplicationContext().getSystemService(Context.WIFI_SERVICE);
return wifiManager != null && (wifiManager.isWifiEnabled() || wifiManager.setWifiEnabled(true));
}
/**
* 獲取當(dāng)前連接的Wifi的SSID
*
* @param context 上下文
* @return SSID
*/
public static String getConnectedSSID(Context context) {
WifiManager wifiManager = (WifiManager) context.getApplicationContext().getSystemService(Context.WIFI_SERVICE);
WifiInfo wifiInfo = wifiManager == null ? null : wifiManager.getConnectionInfo();
return wifiInfo != null ? wifiInfo.getSSID().replaceAll("\"", "") : "";
}
連接到指定Wifi后，在選擇了要發(fā)送的文件后腌紧，就啟動一個后臺線程去主動請求連接服務(wù)器端号胚，然后就是進行實際的文件傳輸操作了
發(fā)起選取文件請求的方法
Intent intent = new Intent(Intent.ACTION_GET_CONTENT);
intent.setType("*/*");
intent.addCategory(Intent.CATEGORY_OPENABLE);
startActivityForResult(intent, CODE_CHOOSE_FILE);
獲取選取的文件的實際路徑猫胁，并啟動 AsyncTask 去進行文件傳輸操作
@Override
protected void onActivityResult(int requestCode, int resultCode, Intent data) {
if (requestCode == CODE_CHOOSE_FILE && resultCode == RESULT_OK) {
Uri uri = data.getData();
if (uri != null) {
String path = getPath(this, uri);
if (path != null) {
File file = new File(path);
if (file.exists()) {
FileTransfer fileTransfer = new FileTransfer(file.getPath(), file.length());
Log.e(TAG, "待發(fā)送的文件：" + fileTransfer);
new FileSenderTask(this, fileTransfer).execute(WifiLManager.getHotspotIpAddress(this));
}
}
}
}
}
private String getPath(Context context, Uri uri) {
if ("content".equalsIgnoreCase(uri.getScheme())) {
Cursor cursor = context.getContentResolver().query(uri, new String[]{"_data"}, null, null, null);
if (cursor != null) {
if (cursor.moveToFirst()) {
String data = cursor.getString(cursor.getColumnIndex("_data"));
cursor.close();
return data;
}
}
} else if ("file".equalsIgnoreCase(uri.getScheme())) {
return uri.getPath();
}
return null;
}
將服務(wù)器端的IP地址作為參數(shù)傳給 FileSenderTask ，在正式發(fā)送文件前驾茴，先發(fā)送包含文件信息的 FileTransfer 锈至，并在發(fā)送文件的過程中實時更新文件傳輸狀態(tài)
/**
* 作者：chenZY
* 時間：2018/2/24 10:21
* 描述：
*/
public class FileSenderTask extends AsyncTask<String, Double, Boolean> {
private ProgressDialog progressDialog;
private FileTransfer fileTransfer;
private static final String TAG = "FileSenderTask";
public FileSenderTask(Context context, FileTransfer fileTransfer) {
this.fileTransfer = fileTransfer;
progressDialog = new ProgressDialog(context);
progressDialog.setProgressStyle(ProgressDialog.STYLE_HORIZONTAL);
progressDialog.setCancelable(false);
progressDialog.setCanceledOnTouchOutside(false);
progressDialog.setTitle("發(fā)送文件：" + fileTransfer.getFilePath());
progressDialog.setMax(100);
}
@Override
protected void onPreExecute() {
progressDialog.show();
}
@Override
protected Boolean doInBackground(String... strings) {
Logger.e(TAG, "開始計算文件的MD5碼");
fileTransfer.setMd5(Md5Util.getMd5(new File(fileTransfer.getFilePath())));
Log.e(TAG, "計算結(jié)束，文件的MD5碼值是：" + fileTransfer.getMd5());
Socket socket = null;
OutputStream outputStream = null;
ObjectOutputStream objectOutputStream = null;
InputStream inputStream = null;
try {
socket = new Socket();
socket.bind(null);
socket.connect((new InetSocketAddress(strings[0], Constants.PORT)), 10000);
outputStream = socket.getOutputStream();
objectOutputStream = new ObjectOutputStream(outputStream);
objectOutputStream.writeObject(fileTransfer);
inputStream = new FileInputStream(new File(fileTransfer.getFilePath()));
byte buf[] = new byte[512];
int len;
//文件大小
long fileSize = fileTransfer.getFileLength();
//當(dāng)前的傳輸進度
double progress;
//總的已傳輸字節(jié)數(shù)
long total = 0;
//緩存-當(dāng)次更新進度時的時間
long tempTime = System.currentTimeMillis();
//緩存-當(dāng)次更新進度時已傳輸?shù)目傋止?jié)數(shù)
long tempTotal = 0;
//傳輸速率（Kb/s）
double speed;
//預(yù)估的剩余完成時間（秒）
double remainingTime;
while ((len = inputStream.read(buf)) != -1) {
outputStream.write(buf, 0, len);
total += len;
long time = System.currentTimeMillis() - tempTime;
//每一秒更新一次傳輸速率和傳輸進度
if (time > 1000) {
//當(dāng)前的傳輸進度
progress = total * 100 / fileSize;
Logger.e(TAG, "---------------------------");
Logger.e(TAG, "傳輸進度: " + progress);
Logger.e(TAG, "時間變化：" + time / 1000.0);
Logger.e(TAG, "字節(jié)變化：" + (total - tempTotal));
//計算傳輸速率，字節(jié)轉(zhuǎn)Kb砚婆，毫秒轉(zhuǎn)秒
speed = ((total - tempTotal) / 1024.0 / (time / 1000.0));
//預(yù)估的剩余完成時間
remainingTime = (fileSize - total) / 1024.0 / speed;
publishProgress(progress, speed, remainingTime);
Logger.e(TAG, "傳輸速率：" + speed);
Logger.e(TAG, "預(yù)估的剩余完成時間：" + remainingTime);
//緩存-當(dāng)次更新進度時已傳輸?shù)目傋止?jié)數(shù)
tempTotal = total;
//緩存-當(dāng)次更新進度時的時間
tempTime = System.currentTimeMillis();
}
}
outputStream.close();
objectOutputStream.close();
inputStream.close();
socket.close();
outputStream = null;
objectOutputStream = null;
inputStream = null;
socket = null;
Log.e(TAG, "文件發(fā)送成功");
return true;
} catch (Exception e) {
Log.e(TAG, "文件發(fā)送異常 Exception: " + e.getMessage());
return false;
} finally {
if (outputStream != null) {
try {
outputStream.close();
} catch (IOException e) {
e.printStackTrace();
}
}
if (objectOutputStream != null) {
try {
objectOutputStream.close();
} catch (IOException e) {
e.printStackTrace();
}
}
if (inputStream != null) {
try {
inputStream.close();
} catch (IOException e) {
e.printStackTrace();
}
}
if (socket != null) {
try {
socket.close();
} catch (Exception e) {
e.printStackTrace();
}
}
}
}
@Override
protected void onProgressUpdate(Double... values) {
progressDialog.setProgress(values[0].intValue());
progressDialog.setTitle("傳輸速率：" + values[1].intValue() + "Kb/s" + "\n"
+ "預(yù)計剩余完成時間：" + values[2].longValue() + "秒");
}
@Override
protected void onPostExecute(Boolean aBoolean) {
progressDialog.cancel();
Log.e(TAG, "onPostExecute: " + aBoolean);
}
}
四、校驗文件完整性
文件的完整性主要是通過對比文件前后的MD5碼值來校驗了埂奈，文件發(fā)送端在發(fā)送文件前账磺，先計算得到文件的MD5碼垮抗，將值賦給 FileTransfer 模型傳給文件接收端借宵，文件接收端在傳輸結(jié)束后壤玫，再次計算本地的文件MD5碼值欲间，通過對比前后值是否相等猎贴，就可以判斷文件是否傳輸完整
MD5碼值通過如下方法計算得到
/**
* 作者：chenZY
* 時間：2018/4/3 15:20
* 描述：http://www.reibang.com/u/9df45b87cfdf
* https://github.com/leavesC
*/
public class Md5Util {
public static String getMd5(File file) {
InputStream inputStream = null;
byte[] buffer = new byte[2048];
int numRead;
MessageDigest md5;
try {
inputStream = new FileInputStream(file);
md5 = MessageDigest.getInstance("MD5");
while ((numRead = inputStream.read(buffer)) > 0) {
md5.update(buffer, 0, numRead);
}
inputStream.close();
inputStream = null;
return md5ToString(md5.digest());
} catch (Exception e) {
return null;
} finally {
if (inputStream != null) {
try {
inputStream.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
private static String md5ToString(byte[] md5Bytes) {
StringBuilder hexValue = new StringBuilder();
for (byte b : md5Bytes) {
int val = ((int) b) & 0xff;
if (val < 16) {
hexValue.append("0");
}
hexValue.append(Integer.toHexString(val));
}
return hexValue.toString();
}
}
