사용자가 온라인 스트림을들을 수있는 기능을 내가 만들고있는 앱에 구현하려고합니다. 내가해야 할 일은 재생과 함께 파일을 다운로드하는 것입니다.
나는 NanoHTTPD를 사용하는 로컬 HTTP 서버가 필요하다는 것을 너무 많이 알아 냈습니다 . 이제 까다로운 부분은 실제로 오디오를 동시에 다운로드하고 스트리밍하는 방법입니다.
이것은 내가 지금까지 생각 해낸 코드입니다.
public class LocalHttpServer extends NanoHTTPD {
public static final int SERVER_PORT = 5987;
private String mUrl;
private InputStream input;
private FileOutputStream output;
public LocalHttpServer(String url) {
super(SERVER_PORT);
mUrl = url;
}
private File createFile(String url) {
File path = new File(MyApplication.getContext().getFilesDir(), "audio/");
path.mkdirs();
return new File(path, Util.md5(url));
}
@Override
public Response serve(IHTTPSession session) {
input = null;
output = null;
HttpURLConnection connection = null;
try {
URL url = new URL(mUrl);
connection = (HttpURLConnection) url.openConnection();
connection.connect();
if (connection.getResponseCode() != HttpURLConnection.HTTP_OK) {
return new Response(Response.Status.BAD_REQUEST, "audio/mpeg3", null, 0);
}
int fileLength = connection.getContentLength();
input = connection.getInputStream();
output = new FileOutputStream(createFile(mUrl));
new Thread(new Runnable() {
@Override
public void run() {
byte data[] = new byte[4096];
int count;
try {
while ((count = input.read(data)) != -1) {
output.write(data, 0, count);
}
} catch (IOException e) {
e.printStackTrace();
} finally {
try {
if (output != null)
output.close();
if (input != null)
//input.close(); don't close it
} catch (IOException e) {
e.printStackTrace();
}
}
}
}).start();
return new Response(Response.Status.OK, "audio/mpeg3", input, fileLength);
} catch (IOException e) {
e.printStackTrace();
}
return new Response(Response.Status.BAD_REQUEST, "audio/mpeg3", null, 0);
}
}
문제는 MediaPlayer에 공급할 때 the unexpected end of stream
예외가 발생 한다는 것입니다 .
아무도 내 질문에 대한 답변을 게시하지 않았기 때문에 비슷한 작업을 수행하는 데 사용한 또 다른 솔루션을 여기에 가져 왔습니다.
AsyncTask를 사용하여 파일을 다운로드하고 다운로드가 전체의 10 %에 도달하면 인터페이스 콜백을 사용하여 MediaPlayer를 시작할 수 있다고 생각했습니다. 그리고 추가 20 %가 다운로드 될 때마다 MediaPlayer를 업데이트합니다.
다음은 AsyncTask의 소스입니다 : https://gist.github.com/2hamed/63a31bd55fc6514d12b5
public class DownloadAndPlayAsyncTask extends AsyncTask<String, Integer, Integer> {
private static final String TAG = "DownloadAndPlayAsync";
DownloadCallback downloadCallback;
File tempFile, fullFile;
private void createFiles(String url) {
tempFile = Util.getTempFilePath(url);
fullFile = Util.getFilePath(url);
}
public void setOnDownloadCallback(DownloadCallback callback) {
downloadCallback = callback;
}
@Override
protected Integer doInBackground(String... strings) {
if (Util.isFileDownloaded(strings[0])) {
createFiles(strings[0]);
return 1;
}
InputStream input = null;
OutputStream output = null;
HttpURLConnection connection = null;
try {
URL url = new URL(strings[0]);
connection = (HttpURLConnection) url.openConnection();
connection.connect();
// expect HTTP 200 OK, so we don't mistakenly save error report
// instead of the file
if (connection.getResponseCode() != HttpURLConnection.HTTP_OK) {
Log.d(TAG, "Server returned HTTP " + connection.getResponseCode()
+ " " + connection.getResponseMessage());
return -1;
}
// this will be useful to display download percentage
// might be -1: server did not report the length
int fileLength = connection.getContentLength();
createFiles(strings[0]);
// download the file
input = connection.getInputStream();
output = new FileOutputStream(tempFile);
byte data[] = new byte[4096];
long total = 0;
int count;
while ((count = input.read(data)) != -1) {
// allow canceling with back button
if (isCancelled()) {
input.close();
return null;
}
total += count;
// publishing the progress....
if (fileLength > 0) // only if total length is known
publishProgress((int) (total * 100 / fileLength));
output.write(data, 0, count);
}
} catch (Exception e) {
e.printStackTrace();
return -1;
} finally {
try {
if (output != null)
output.close();
if (input != null)
input.close();
} catch (IOException ignored) {
}
if (connection != null)
connection.disconnect();
}
return 0;
}
@Override
protected void onPreExecute() {
super.onPreExecute();
}
@Override
protected void onPostExecute(Integer result) {
super.onPostExecute(result);
if (result == 0) {
try {
Util.copy(tempFile, fullFile);
tempFile.delete();
if (downloadCallback != null) {
downloadCallback.onFinished(fullFile.getAbsolutePath());
}
} catch (IOException e) {
e.printStackTrace();
}
} else if (result == 1) {
if (downloadCallback != null) {
downloadCallback.onFinished(fullFile.getAbsolutePath());
}
} else {
if (downloadCallback != null) {
downloadCallback.onFailed();
}
}
}
@Override
protected void onProgressUpdate(Integer... values) {
super.onProgressUpdate(values);
if (downloadCallback != null) {
downloadCallback.onProgressUpdate(values[0], tempFile.getAbsolutePath());
}
}
@Override
protected void onCancelled(Integer result) {
super.onCancelled(result);
}
@Override
protected void onCancelled() {
super.onCancelled();
}
public interface DownloadCallback {
void onProgressUpdate(int progress, String filePath);
void onFinished(String fullFile);
void onFailed();
}
}
DownloadCallback
코드 끝에 가있는 것을 알 수 있습니다 .
이 기사는 인터넷에서 수집됩니다. 재 인쇄 할 때 출처를 알려주십시오.
침해가 발생한 경우 연락 주시기 바랍니다[email protected] 삭제
몇 마디 만하겠습니다