Android MediaPlayer与Http Proxy结合之提高篇-阿里云开发者社区

Android MediaPlayer与Http Proxy结合之提高篇

2013-06-13 1060

版权

本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

简介： 本文来自http://blog.csdn.net/hellogv/ ，引用. 基础篇实现一个简单的代理服务器与Android的MediaPlayer结合(仅支持Http Get)，可以通过代理服务器来转发MediaPlayer的Request以及传输服务器的Response，但基础篇还不能支持Seek，这次提高篇支持了Seek。

本文来自http://blog.csdn.net/hellogv/ ，引用.

基础篇实现一个简单的代理服务器与Android的MediaPlayer结合(仅支持Http Get)，可以通过代理服务器来转发MediaPlayer的Request以及传输服务器的Response，但基础篇还不能支持Seek，这次提高篇支持了Seek。代理服务器可以增强MediaPlayer对复杂的Http情况的适应，可以播放带防盗链的媒体文件，边播边存，还可以对大体积的媒体文件（如视频）进行多线程预加载，达到快速播放的效果。

本文代码运行在模拟器上，使用Microsoft Network Monitor 3.4来抓包，通过抓包可以发现seek的操作会重新连接服务器，并在Http Get请求中加入Range 字段，所以代理服务器每次监听到MediaPlayer的request都需要新建socket与远程服务器连接。

本文的代码可以到http://download.csdn.net/detail/hellogv/4332362下载，本文程序运行效果如图：

接下来贴出核心代码HttpGetProxy.java：

[java]view plaincopyprint? 
   
 public class HttpGetProxy {   
     final static private String TAG = "HttpGetProxy";   
     final static private String LOCAL_IP_ADDRESS = "127.0.0.1";   
     final static private int HTTP_PORT = 80;   
        
     private int local_ip_port;   
     private ServerSocket localServer = null;   
     private Socket localSocket = null;   
     private Socket remoteSocket = null;   
     private String remoteHost;   
    
     private InputStream in_remoteSocket;   
     private OutputStream out_remoteSocket;   
     private InputStream in_localSocket;   
     private OutputStream out_localSocket;   
    
     private SocketAddress address;   
     private interface OnFinishListener {   
         void onFinishListener();   
     }   
    
     /**  
      * 初始化代理服务器  
      * @param localport 代理服务器监听的端口  
      */   
     public HttpGetProxy(int localport) {   
         local_ip_port=localport;   
         try {   
             localServer = new ServerSocket(localport, 1,   
                     InetAddress.getByName(LOCAL_IP_ADDRESS));   
         } catch (UnknownHostException e) {   
             // TODO Auto-generated catch block   
             e.printStackTrace();   
         } catch (IOException e) {   
             // TODO Auto-generated catch block   
             e.printStackTrace();   
         }   
     }   
    
     /**  
      * 结束时，清除所有资源  
      */   
     private OnFinishListener finishListener = new OnFinishListener() {   
    
         @Override   
         public void onFinishListener() {   
             System.out.println("..........release all..........");   
             Log.e(TAG, "..........release all..........");   
             try {   
                 in_localSocket.close();   
                 out_remoteSocket.close();   
    
                 in_remoteSocket.close();   
                 out_localSocket.close();   
    
                 localSocket.close();   
                 remoteSocket.close();   
             } catch (IOException e) {   
                 // TODO Auto-generated catch block   
                 e.printStackTrace();   
             }   
         }   
     };   
    
    
     /**  
      * 把网络URL转为本地URL，127.0.0.1替换网络域名  
      * @param url 网络URL  
      * @return 本地URL  
      */   
     public String getLocalURL(String url){   
         String result = null;   
         URI originalURI=URI.create(url);   
         remoteHost=originalURI.getHost();   
         if(originalURI.getPort()!=-1){//URL带Port   
             address = new InetSocketAddress(remoteHost,   
                     originalURI.getPort());//使用默认端口   
             result=url.replace(remoteHost+":"+originalURI.getPort(),   
                     LOCAL_IP_ADDRESS+":"+local_ip_port);   
         }   
         else{//URL不带Port   
             address = new InetSocketAddress(remoteHost,   
                     HTTP_PORT);//使用80端口   
             result=url.replace(remoteHost,LOCAL_IP_ADDRESS+":"+local_ip_port);   
         }   
         return result;   
            
     }   
        
     /**  
      * 启动代理服务器  
      * @throws IOException  
      */   
     public void startProxy() throws IOException {   
            
         new Thread() {   
             public void run() {   
                 int bytes_read;   
                 byte[] local_request = new byte[1024];   
                 byte[] remote_reply = new byte[1024];   
                 while (true) {   
                     try {   
                         //--------------------------------------   
                         //监听MediaPlayer的请求，MediaPlayer->代理服务器   
                         //--------------------------------------   
                         localSocket = localServer.accept();   
    
                         Log.e(TAG, "..........localSocket connected..........");   
                         in_localSocket = localSocket.getInputStream();   
                         out_localSocket = localSocket.getOutputStream();   
                         Log.e(TAG, "..........init local Socket I/O..........");   
    
                         String buffer = "";//保存MediaPlayer的HTTP请求   
                         while ((bytes_read = in_localSocket.read(local_request)) != -1) {   
                             String str = new String(local_request);   
                             Log.e("localSocket---->", str);   
                             buffer = buffer + str;   
                             if (buffer.contains("GET")   
                                     && buffer.contains("\r\n\r\n")) {   
                                 // ---把request中的本地ip改为远程ip---//   
                                 buffer = buffer.replace(LOCAL_IP_ADDRESS,remoteHost);   
                                 break;   
                             }   
                         }   
                         Log.e(TAG, "..........local finish receive..........");   
    
                         //--------------------------------------   
                         //把MediaPlayer的请求发到网络服务器，代理服务器->网络服务器   
                         //--------------------------------------   
                         remoteSocket = new Socket();   
                         remoteSocket.connect(address);   
                         Log.e(TAG,"..........remote Server connected..........");   
                         in_remoteSocket = remoteSocket.getInputStream();   
                         out_remoteSocket = remoteSocket.getOutputStream();   
                         out_remoteSocket.write(buffer.getBytes());//发送MediaPlayer的请求   
                         out_remoteSocket.flush();   
    
                         //------------------------------------------------------   
                         //把网络服务器的反馈发到MediaPlayer，网络服务器->代理服务器->MediaPlayer   
                         //------------------------------------------------------   
                         Log.e(TAG,"..........remote start to receive..........");   
                         while ((bytes_read = in_remoteSocket.read(remote_reply)) != -1) {   
                             out_localSocket.write(remote_reply, 0, bytes_read);   
                             out_localSocket.flush();   
                         }   
                         Log.e(TAG, "..........over..........");   
                         finishListener.onFinishListener();//释放资源   
                     } catch (IOException e) {   
                         // TODO Auto-generated catch block   
                         e.printStackTrace();   
                     }   
                 }   
             }   
         }.start();   
     }   
 }   
     

Android MediaPlayer与Http Proxy结合之提高篇

热门文章

最新文章

相关课程

相关电子书

相关实验场景