Android Service BroadcastReceiver And File Download

<?xml version="1.0" encoding="utf-8"?>
<manifest xmlns:android="http://schemas.android.com/apk/res/android"
package="com.example.buzz.javatest" >

<uses-sdk
android:minSdkVersion="19"
android:targetSdkVersion="19" />

<!-- Needed permissions in order to scan for beacons. -->
<uses-permission android:name="android.permission.BLUETOOTH" />
<uses-permission android:name="android.permission.BLUETOOTH_ADMIN" />

<!-- 允许应用程序完全使用网络 -->
<uses-permission android:name="android.permission.INTERNET" />

<uses-permission android:name="android.permission.WRITE_EXTERNAL_STORAGE"/>

<!-- Declaration that this app is usable on phones with Bluetooth Low Energy. -->
<uses-feature android:name="android.hardware.bluetooth_le" android:required="true" />

<application
android:allowBackup="true"
android:icon="@drawable/ic_launcher"
android:label="@string/app_name"
android:theme="@style/AppTheme" >
<activity
android:name=".MainActivity"
android:label="@string/app_name" >

<!--
intent-filter>
<action android:name="android.intent.action.MAIN" />
<category android:name="android.intent.category.LAUNCHER" />
</intent-filter
-->
</activity>

<!-- Estimote service responsible for scanning beacons. -->
<service android:name="com.estimote.sdk.service.BeaconService" android:exported="false" />
<service android:name=".BackgroundService" android:exported="false" />

<activity
android:name=".SecondActivity"
android:label="BuzzLib" >
<intent-filter>
<action android:name="android.intent.action.MAIN" />
<category android:name="android.intent.category.LAUNCHER" />
</intent-filter>
</activity>

<activity
android:name=".DownloadActivity"
android:label="BuzzLib" >
</activity>

</application>

</manifest>

package com.example.buzz.javatest;

import android.app.Service;
import android.content.Intent;
import android.util.Log;
import android.os.*;
import android.widget.*;

import java.util.*;
import java.lang.*;
import java.io.Serializable;

import com.estimote.sdk.*;

/**
* Created by NickChung on 21/01/2015.
*/
public class BackgroundService extends Service {

private static final String TAG = BackgroundService.class.getSimpleName();

public static final String EXTRAS_TARGET_ACTIVITY = "extrasTargetActivity";
public static final String EXTRAS_BEACON = "extrasBeacon";

private static final int REQUEST_ENABLE_BT = 1234;
private static final Region ALL_ESTIMOTE_BEACONS_REGION = new Region("rid", null, null, null);

private BeaconManager beaconManager;
private Beacon beacon;
private Region region;

private Map<String, List<Integer>> dic;

private int total;
private int step = 6;

@Override
public void onCreate() {
super.onCreate();

dic = new HashMap<String, List<Integer>>();

beaconManager = new BeaconManager(this);
beaconManager.setBackgroundScanPeriod(500, 0);
beaconManager.setForegroundScanPeriod(500, 0);

beaconManager.setRangingListener(new BeaconManager.RangingListener() {
@Override
public void onBeaconsDiscovered(Region region, final List<Beacon> rangedBeacons) {
for (Beacon beacon : rangedBeacons) {
int minor = beacon.getMinor();
int major = beacon.getMajor();
String uniqueKey = String.format("%s-%s", major, minor);

if (!dic.containsKey(uniqueKey)) {
List<Integer> rawList = new ArrayList<Integer>();
rawList.add(beacon.getRssi());
dic.put(uniqueKey, rawList);
} else {
List<Integer> rawList = dic.get(uniqueKey);
rawList.add(beacon.getRssi());
}
}

Map<String, Integer> seqMap = new HashMap<String, Integer>();
for (Map.Entry<String, List<Integer>> entry : dic.entrySet()) {
total = 0;
List<Integer> rawList = entry.getValue();

if (rawList.size() > step) {
List<Integer> rawSubList = rawList.subList(rawList.size() - (step + 1), rawList.size() - 1);
for (int r : rawSubList) {
total += r;
}

int avgRssi = (int) (total / step);
seqMap.put(entry.getKey(), avgRssi);
//Log.i(TAG, String.format("%s:%s", entry.getKey(), avgRssi));
}
}

Intent intent = new Intent("android.intent.action.MY_BROADCAST");
intent.putExtra("map",(Serializable)seqMap);
sendBroadcast(intent);

}
});
}

@Override
public int onStartCommand(Intent intent, int flags, int startId) {
//Toast.makeText(this, "service starting", Toast.LENGTH_SHORT).show();

if (!beaconManager.hasBluetooth()) {
Toast.makeText(this, "Device does not have Bluetooth Low Energy", Toast.LENGTH_LONG).show();
}

if (!beaconManager.isBluetoothEnabled()) {
Toast.makeText(this, "Bluetooth does not Enabled", Toast.LENGTH_LONG).show();
} else {
connectToService();
}
return super.onStartCommand(intent, flags, startId);
}

private void connectToService() {
beaconManager.connect(new BeaconManager.ServiceReadyCallback() {
@Override
public void onServiceReady() {
try {
beaconManager.startRanging(ALL_ESTIMOTE_BEACONS_REGION);
} catch (RemoteException e) {
Log.e(TAG, "Cannot start ranging", e);
}
}
});
}

@Override
public void onDestroy() {
try {
beaconManager.stopRanging(ALL_ESTIMOTE_BEACONS_REGION);
} catch (RemoteException e) {
Log.d(TAG, "Error while stopping ranging", e);
}

beaconManager.disconnect();

super.onDestroy();
}

@Override
public IBinder onBind(Intent intent) {
return null;
}

@Override
public boolean onUnbind(Intent intent) {
return super.onUnbind(intent);
}

}

package com.example.buzz.javatest;

import android.content.Intent;
import android.support.v7.app.ActionBarActivity;
import android.os.Bundle;
import android.view.Menu;
import android.view.MenuItem;
import android.content.BroadcastReceiver;
import android.content.Context;
import android.view.View;
import android.widget.Button;
import android.widget.TextView;
import android.content.IntentFilter;

import java.util.*;

public class SecondActivity extends ActionBarActivity {

private BackgroundServiceReceiver backgroundServiceReceiver;

@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_second);

backgroundServiceReceiver = new BackgroundServiceReceiver();
IntentFilter intentFilter = new IntentFilter();
intentFilter.addAction("android.intent.action.MY_BROADCAST");
registerReceiver(backgroundServiceReceiver, intentFilter);

Button btnGoThird = (Button) findViewById(R.id.btnGoThird);
btnGoThird.setOnClickListener(new View.OnClickListener() {
@Override
public void onClick(View v) {
Intent intent = new Intent(SecondActivity.this, DownloadActivity.class);
startActivity(intent);
}
});
}

@Override
public boolean onCreateOptionsMenu(Menu menu) {
// Inflate the menu; this adds items to the action bar if it is present.
getMenuInflater().inflate(R.menu.menu_second, menu);
return true;
}

@Override
public boolean onOptionsItemSelected(MenuItem item) {
// Handle action bar item clicks here. The action bar will
// automatically handle clicks on the Home/Up button, so long
// as you specify a parent activity in AndroidManifest.xml.
int id = item.getItemId();

//noinspection SimplifiableIfStatement
if (id == R.id.action_settings) {
return true;
}

return super.onOptionsItemSelected(item);
}

@Override
protected void onStart() {
super.onStart();
Intent intent = new Intent(this, BackgroundService.class);
startService(intent);
}

@Override
protected void onDestroy() {
super.onDestroy();
unregisterReceiver(backgroundServiceReceiver);
}

public class BackgroundServiceReceiver extends BroadcastReceiver {
@Override
public void onReceive(Context context, Intent intent) {
TextView txtUI = (TextView) findViewById(R.id.txtUI);
StringBuilder sb = new StringBuilder();

HashMap<String, Integer> map = (HashMap<String, Integer>) intent.getSerializableExtra("map");

for (Map.Entry<String, Integer> m : map.entrySet()) {
sb.append(String.format("%s:%s,", m.getKey(), m.getValue()));
}

txtUI.setText(sb.toString());

}

}
}

package com.example.buzz.javatest;

/**
* Created by NickChung on 3/5/15.
*/

import java.io.BufferedReader;
import java.io.File;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.net.HttpURLConnection;
import java.net.MalformedURLException;
import java.net.URL;

import android.util.Log;
import android.content.Context;

public class HttpDownloader {
private URL url = null;

/**
* 根据URL下载文件，前提是文件当中的内容为文本，返回值就是文件当中的内容
*
* @param urlStr
* @return
*/
public String download(String urlStr) {

StringBuffer buffer = new StringBuffer();
String line = null;
BufferedReader reader = null;

try {
url = new URL(urlStr);
try {
HttpURLConnection conn = (HttpURLConnection) url.openConnection();
reader = new BufferedReader(new InputStreamReader(conn.getInputStream()));
while ((line = reader.readLine()) != null) {
buffer.append(line);
}
} catch (IOException e) {
Log.e("io", "HttpURLConnection -> IOException");
e.printStackTrace();
}

} catch (MalformedURLException e) {
Log.e("url", "url -> MalformedURLException");
e.printStackTrace();
} finally {
try {
reader.close();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
return buffer.toString();

}

/**
* 该函数返回整形： -1代表下载出错，0代表下载成功，1代表下载文件已存在
*
* @param urlStr
* @param path
* @param fileName
* @return
*/
public int download(Context context, String urlStr, String path, String fileName) {
InputStream input = null;
FileUtils fileUtils = new FileUtils();
if (fileUtils.isFileExist(path + fileName)) {
((DownloadActivity) context).sendMsg(2, 0);
return 1;
} else {
try {
input = getInputStreamFromUrl(context, urlStr);
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
File resultFile = fileUtils.writeToSDFromInput(context, path, fileName, input);
if (resultFile == null) {
return -1;
}
}
return 0;
}

public InputStream getInputStreamFromUrl(Context context, String urlStr) throws IOException {
url = new URL(urlStr);
HttpURLConnection conn = (HttpURLConnection) url.openConnection();

InputStream s = conn.getInputStream();

((DownloadActivity) context).sendMsg(0, conn.getContentLength());

return s;
}
}

package com.example.buzz.javatest;

/**
* Created by NickChung on 3/4/15.
*/

import java.io.File;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;

import android.content.Context;
import android.os.Environment;

public class FileUtils {
private String SDPATH;
/**
*
*/
public FileUtils() {
// TODO Auto-generated constructor stub
//获得当前外部存储设备的目录
SDPATH = Environment.getExternalStorageDirectory() + "/";
}

/**
* 在SD卡上创建文件
*
* @param fileName
* @return
*/
public File createSdFile(String fileName) {
File file = new File(SDPATH + fileName);
try {
file.createNewFile();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}

return file;
}

/**
* 创建SD卡目录
*
* @param dirName
* @return
*/
public File createSDDir(String dirName) {
File file = new File(SDPATH + dirName);
file.mkdirs();

return file;
}

public boolean isFileExist(String fileName) {
File file = new File(SDPATH + fileName);

return file.exists();

}

public File writeToSDFromInput(Context context, String path, String fileName, InputStream input) {
File file = null;
OutputStream output = null;

try {
createSDDir(path);
file = createSdFile(path + fileName);
output = new FileOutputStream(file);

byte[] buffer = new byte[4 * 1024];
int total = 0;
while ((input.read(buffer)) != -1) {
total = total + buffer.length;
output.write(buffer);
//更新下载进度条
((DownloadActivity) context).sendMsg(1, total);
}
output.flush();
} catch (FileNotFoundException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} finally {
try {
output.close();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
//下载完成
((DownloadActivity) context).sendMsg(2, 0);
return file;
}

}

package com.example.buzz.javatest;

import android.app.Dialog;
import android.content.BroadcastReceiver;
import android.content.Context;
import android.content.Intent;
import android.content.IntentFilter;
import android.os.Looper;
import android.os.StrictMode;
import android.support.v7.app.ActionBarActivity;
import android.os.Bundle;
import android.view.Menu;
import android.view.MenuItem;
import android.view.View;
import android.widget.TextView;
import android.widget.Button;
import android.widget.Toast;
import android.app.ProgressDialog;
import android.os.Message;
import android.os.Handler;

import java.util.HashMap;
import java.util.Map;

public class DownloadActivity extends ActionBarActivity {

private String TAG = this.getClass().getSimpleName();
private BackgroundServiceReceiver backgroundServiceReceiver;
private Button btnDownload;
private ProgressDialog dialog = null;
public static final int DIALOG_DOWNLOAD_PROGRESS = 0;

@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_third);

backgroundServiceReceiver = new BackgroundServiceReceiver();
IntentFilter intentFilter = new IntentFilter();
intentFilter.addAction("android.intent.action.MY_BROADCAST");
registerReceiver(backgroundServiceReceiver, intentFilter);

StrictMode.setThreadPolicy(
new StrictMode
.ThreadPolicy
.Builder()
.detectDiskReads()
.detectDiskWrites()
.detectNetwork()
.penaltyLog()
.build());

StrictMode.setVmPolicy(
new StrictMode
.VmPolicy
.Builder()
.detectLeakedSqlLiteObjects()
.detectLeakedClosableObjects()
.penaltyLog()
.penaltyDeath()
.build());

btnDownload = (Button) this.findViewById(R.id.btnDownload);
btnDownload.setOnClickListener(new View.OnClickListener() {
@Override
public void onClick(View v) {
//打开进度条
showDialog(DIALOG_DOWNLOAD_PROGRESS);

Thread t = new Thread(runnable);
t.start();
}
});
}

Runnable runnable = new Runnable() {
@Override
public void run() {

Looper.prepare();

try {
HttpDownloader httpDownloader = new HttpDownloader();
int result = httpDownloader.download(DownloadActivity.this, "http://192.168.0.106:8080/exhibition/audio/a.mp3", "com.buzz.exhibition/audio/", "a.mp3");

System.out.println(result);
String str = null;
if (result == 0) {
str = "下载完成";
} else if (result == 1) {
str = "文件已经存在";
} else {
str = "下载错误";
}

Toast.makeText(getApplicationContext(), str, Toast.LENGTH_LONG).show();
}
catch(Exception ex) {
Toast.makeText(getApplicationContext(), ex.toString(), Toast.LENGTH_LONG).show();
}

Looper.loop();
}

};

public void sendMsg(int flag, int value) {
Message message = new Message();
message.what = flag;
message.arg1 = value;
handler.sendMessage(message);
}

@Override
protected Dialog onCreateDialog(int id) {
switch (id) {
case DIALOG_DOWNLOAD_PROGRESS:
dialog = new ProgressDialog(this);
dialog.setMessage("downloading…");
dialog.setProgressStyle(ProgressDialog.STYLE_HORIZONTAL);
dialog.setCancelable(false);
dialog.show();
return dialog;
default:
return null;
}
}

private Handler handler = new Handler() {
@Override
public void handleMessage(Message msg) {
if (!Thread.currentThread().isInterrupted()) {
switch (msg.what) {
case 0:
dialog.setMax(msg.arg1);
break;
case 1:
dialog.setProgress(msg.arg1);
break;
case 2:
dialog.dismiss();
break;
case -1:
String error = msg.getData().getString("error");
Toast.makeText(DownloadActivity.this, error, Toast.LENGTH_LONG).show();
break;

}
}
super.handleMessage(msg);
}
};

@Override
public boolean onCreateOptionsMenu(Menu menu) {
// Inflate the menu; this adds items to the action bar if it is present.
getMenuInflater().inflate(R.menu.menu_third, menu);
return true;
}

@Override
public boolean onOptionsItemSelected(MenuItem item) {
// Handle action bar item clicks here. The action bar will
// automatically handle clicks on the Home/Up button, so long
// as you specify a parent activity in AndroidManifest.xml.
int id = item.getItemId();

//noinspection SimplifiableIfStatement
if (id == R.id.action_settings) {
return true;
}

return super.onOptionsItemSelected(item);
}

@Override
protected void onDestroy() {
super.onDestroy();
unregisterReceiver(backgroundServiceReceiver);
}

public class BackgroundServiceReceiver extends BroadcastReceiver {
@Override
public void onReceive(Context context, Intent intent) {
TextView txtTUI = (TextView) findViewById(R.id.txtTUI);
StringBuilder sb = new StringBuilder();

HashMap<String, Integer> map = (HashMap<String, Integer>) intent.getSerializableExtra("map");

for (Map.Entry<String, Integer> m : map.entrySet()) {
sb.append(String.format("%s:%s,", m.getKey(), m.getValue()));
}

txtTUI.setText(sb.toString());
}
}
}