Android从本地服务器获取Mp3实现边下边播(JavaEE+Tomcat+SQLServer)

package com.example.ffy.other; import android.os.Environment; import android.text.TextUtils; import android.util.Log; import java.io.File; import java.io.FileInputStream; import java.io.FileOutputStream; import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; import java.net.InetAddress; import java.net.InetSocketAddress; import java.net.ServerSocket; import java.net.Socket; import java.net.SocketAddress; import java.net.URI; import java.util.ArrayList; import java.util.List; import java.util.regex.Matcher; import java.util.regex.Pattern; import static java.lang.Thread.sleep; /** * Created by ffy on 18-6-9. */ public class MediaPlayerProxy { public static boolean proxyIdle = true;//代理是否空闲 //手机ip地址 final static private String LOCAL_IP_ADDRESS = "192.168.43.1"; private static int local_ip_port = 9090; //空闲端口 final static private int HTTP_PORT = 80; //空闲端口 public static List<String> bufferingMusicUrlList = new ArrayList<>();//正在缓存的网络音乐地址 private OnCaChedProgressUpdateListener mOnCaChedProgressUpdateListener; public static long lastProxyId = 0;//最新的代理ID public long currProxyId = 0;//当前代理ID private ServerSocket localServer = null; private String remoteHostAndPort = "";//这个用来到时替换本地地址的 public SocketAddress remoteAddress; int socketTimeoutTime = 5000; //超时时间 public String writeFileName = ""; boolean writeFile = true;//是否缓存播放文件 String trueSocketRequestInfoStr = "";//音乐的远程socket请求地址 String remotUrl = "";//远程音乐地址 String musicKey = "";//音乐对象的key public int currPlayDegree = 0;//当前音乐播放进度 public boolean proxyFail = false;//代理播放失败了 private static long cachedFileLength = 0;//已缓存的文件长度 private static long fileTotalLength = 0;//要缓存的文件总长度 public int currMusicCachedProgress = 0;//当前的音乐缓冲值（seekbar上的缓冲值） //初始化本地socket代理 public MediaPlayerProxy(String writeFileName, boolean writeFile) throws Exception { currPlayDegree = 0;//当前音乐播放进度 proxyFail = false;//代理播放失败了 cachedFileLength = 0;//已缓存的文件长度 fileTotalLength = 0;//要缓存的文件总长度 currMusicCachedProgress = 0;//当前的音乐缓冲值（seekbar上的缓冲值） proxyIdle = false; //代理忙 this.writeFile = writeFile; this.writeFileName = writeFileName; try { if (localServer == null || localServer.isClosed()) { //创建本地socket服务器，用来监听mediaplayer请求和给mediaplayer提供数据 localServer = new ServerSocket(); localServer.setReuseAddress(true); //创建IP地址为192.168.43.1，端口号为9090的本地端口地址 InetSocketAddress socketAddress = new InetSocketAddress(InetAddress.getByName(LOCAL_IP_ADDRESS), local_ip_port); //本地socket绑定本地端口地址 localServer.bind(socketAddress); } } catch (Exception e) { Log.e("1111111111111111+++++++",e.getMessage()); try { local_ip_port--; //端口号非空闲，自减 localServer = new ServerSocket(); localServer.setReuseAddress(true); //创建IP地址为192.168.43.1，端口号为9090的本地端口地址 InetSocketAddress socketAddress = new InetSocketAddress(InetAddress.getByName(LOCAL_IP_ADDRESS), local_ip_port); //本地socket绑定本地端口地址 localServer.bind(socketAddress); } catch (Exception e2) { Log.e("22222222222222++++++",e2.getMessage()); throw new Exception(); } } } /** * 把网络URL转为本地URL，192.168.43.1替换网络域名,且设置远程的socket连接地址 * */ public String getLocalURLAndSetRemotSocketAddr(String url) { try { remotUrl = url; if (writeFile) { //正在缓存的音乐地址 bufferingMusicUrlList.add(remotUrl); } String localProxyUrl = ""; final URI originalURI = URI.create(url); final String remoteHost = originalURI.getHost(); //服务器主机 if (!TextUtils.isEmpty(remoteHost)) { //存在主机 if (originalURI.getPort() != -1) {//URL带Port new Thread(new Runnable() { @Override public void run() { //服务器的主机号和端口 remoteAddress = new InetSocketAddress(remoteHost, originalURI.getPort()); } }).start(); //替换 localProxyUrl = url.replace(remoteHost + ":" + originalURI.getPort(), LOCAL_IP_ADDRESS + ":" + local_ip_port); remoteHostAndPort = remoteHost + ":" + originalURI.getPort(); } else {//URL不带Port,使用80端口 if (!TextUtils.isEmpty(remoteHost)) { new Thread(new Runnable() { @Override public void run() { remoteAddress = new InetSocketAddress(remoteHost, HTTP_PORT);//使用80端口 } }).start(); localProxyUrl = url.replace(remoteHost, LOCAL_IP_ADDRESS + ":" + local_ip_port); remoteHostAndPort = remoteHost; } } } return localProxyUrl; } catch (Exception e) { Log.e("+333333333333++++++++++",e.getMessage()); return ""; } } //获得真实的socket请求信息 public void getTrueSocketRequestInfo(Socket localSocket) throws Exception { InputStream in_localSocket = localSocket.getInputStream(); String trueSocketRequestInfoStr = "";//保存MediaPlayer的真实HTTP请求 byte[] local_request = new byte[1024]; while (in_localSocket.read(local_request) != -1) { String str = new String(local_request); trueSocketRequestInfoStr = trueSocketRequestInfoStr + str; if (trueSocketRequestInfoStr.contains("GET") && trueSocketRequestInfoStr.contains("\r\n\r\n")) { //把request中的本地ip改为远程ip trueSocketRequestInfoStr = trueSocketRequestInfoStr.replace(LOCAL_IP_ADDRESS + ":" + local_ip_port, remoteHostAndPort); this.trueSocketRequestInfoStr = trueSocketRequestInfoStr; //如果用户拖动了进度条，因为拖动了滚动条还有Range则表示本地歌曲还未缓存完，不再保存 if (trueSocketRequestInfoStr.contains("Range")) { Log.e("+44444++++Range++++++",""); writeFile = false; } break; } } } //通过远程socket连接远程请求，并返回remot_socket public Socket sendRemoteRequest() throws Exception { //创建远程socket用来请求网络数据 Socket remoteSocket = new Socket(); remoteSocket.connect(remoteAddress, socketTimeoutTime); remoteSocket.getOutputStream().write(trueSocketRequestInfoStr.getBytes()); remoteSocket.getOutputStream().flush(); return remoteSocket; } //处理真实请求信息, 把网络服务器的反馈发到MediaPlayer，网络服务器->代理服务器->MediaPlayer public void processTrueRequestInfo(Socket remoteSocket