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

Android MediaPlayer与Http Proxy结合之提高篇

2013-06-13 1088

版权

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

简介： 本文来自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结合之提高篇

热门文章

最新文章

相关课程

相关电子书

相关实验场景

热门

活动广场

任务中心

开发者评测

高校计划

乘风者计划

训练营

阿里云MVP

话题

直播

下载

镜像站

技术资料

插件

Android MediaPlayer与Http Proxy结合之提高篇

热门文章

最新文章

相关课程

相关电子书

相关实验场景