Android多线程之Handler、Looper、Message在基于HTTP系统中的应用

超、凢脫俗 2022-06-13 09:49 155阅读 0赞

## 1.背景 ##

在应用TCP/IP协议进行数据传输的时候，经常用到的是IOCP的概念。我们经常试想如果HTTP的能够应用多线程的模式来进行数据的交互，将会给系统/应用带来更好的用户体验。通过线程访问WEB获取数据并将数据交给另一个线程处理是本节研究的重点。关于Handler、Looper、Message详细的原理可以参考其他博文。这里推荐《Android Looper和Handler分析》本人也是受到其启发，设计了一个简单的应用框架。

## 2.应用功能/任务 ##

(1) 连接服务器获取控制指令；

(2) 执行服务器的命令；

(3) 返回执行结果；

## 3.设计 ##

系统设计总图如下图所示，系统由三个线程组成：主线程、连接服务器线程、数据处理线程。

### 3.1基本原理 ###

主线程用来设置定时器，开启线程；ConnectThread用来连接服务器，ConnectThread获取的数据发送给DataProcessThread，而DataProcessThread则仅仅进行数据处理，数据处理完成之后，又通过Message将结果告知ConnectThread，由ConnectThread将处理结果返回给服务器。

也就是说，在整个过程中，与服务器进行数据交互的是ConnectThread，数据处理是DataProcessThread，并且仅仅是这样。

线程ConnectThread和DataProcessThread的数据交互则通过Handler、Looper等接口来完成。ConnectThread和DataProcessThread各与一个私有的Looper和公共的Handler (分别设为handler1、handler2)绑定。

这里要注意的是，线程不存在默认的Looper，只能自行创建。并且只能在线程内部创建。如下实例：为每个线程创建一个Handler的继承类，而handleMessage则是进行数据提取的真正方法。

//定义子线程类中的接收消息
        class ThreadHandler extends Handler{
            
            public ThreadHandler(Looper looper){
                super(looper);
            }    
            @Override      
            public void handleMessage(Message msg) {  
                switch (msg.what) {  
                case  UPDATE_DATA://常量
               	 getData();  
                    break;  
                default:
    					break;	
                }  
            }  
           
        }
    	//接收数据、处理线程
    	private Thread ReceiveThread = new Thread(){	
    		
    		public void run()
    		{	
    			Looper.prepare();
    			//当前线程的Looper对象
    			handler1=new ThreadHandler(Looper.myLooper());	    
                Looper.loop(); 
    		}
    	};

![1333675226_2626.jpg][]

在两个线程进行数据传输的时候，可以采取两种方式：

①设置Request响应的全局变量Response，当ConnectThread请求到数据之后，通过handler2.sendEmptyMessage(int what)方法告知DataProcessThread，而DataProcessThread一旦接收到ConnectThread发来的空消息(因为是sendEmptyMessage发来的)，则通过Response来获取数据，并进行命令执行；

② ConnectThread利用包android.os.Handler中的obtainMessage (int what, int arg1, int arg2,Object obj)和sendMessage (Message msg)对接收数据直接进行封装并发送给DataProcessThread，DataProcessThread再进行命令执行。

这两种方法就好比，我们在取信件的时候有两种方式一样，一是人家告诉我，我自己去拿二人家直接给我送来；

测试代码：(本人加入一些显示界面)

package home.handler;
    
    import java.io.BufferedReader;
    import java.io.IOException;
    import java.io.InputStream;
    import java.io.InputStreamReader;
    import java.util.Timer;
    import java.util.TimerTask;
    
    import org.apache.http.HttpEntity;
    import org.apache.http.HttpResponse;
    import org.apache.http.client.HttpClient;
    import org.apache.http.client.methods.HttpGet;
    import org.apache.http.impl.client.DefaultHttpClient;
    
    
    import android.app.Activity;
    import android.os.Bundle;
    import android.os.Handler;
    import android.os.Looper;
    import android.os.Message;
    import android.view.View;
    import android.widget.Button;
    import android.widget.EditText;
    
    public class PHPHandlerActivity extends Activity {
    	protected static final int UPDATE_TEXT = 0;
    	protected static final int RETURN_RESULT = 1;
    	private Handler handler1,handler2,handler3;
    	private EditText etGet;
    	//private HttpPost request;
    	//private HttpClient client;
    	private HttpResponse response=null;
    						
        /** Called when the activity is first created. */
        @Override
        public void onCreate(Bundle savedInstanceState) {
            super.onCreate(savedInstanceState);
            setContentView(R.layout.main);
            etGet = (EditText)findViewById(R.id.etGet);
    		 //按钮函数：开启线程
           final Button mThreadStartButton=(Button)findViewById(R.id.button1);
    	   mThreadStartButton.setOnClickListener(new Button.OnClickListener() {
    		
    		@Override
    		public void onClick(View v) {
    			// TODO Auto-generated method stub
    			ReceiveThread.start();
    			Timer timer = new Timer();
    			timer.schedule(new mTask(), 30, 1000*60*2);	
    			mThreadStartButton.setEnabled(false);
    		}
    	   }); 
    	}
     
    	//*****************************************************************************************
    	//从此处添加自定义函数
    	//*****************************************************************************************
        class MyHandler extends Handler{
            
            public MyHandler(Looper looper){
                super(looper);
            }
            @Override
            public void handleMessage(Message msg){
                super.handleMessage(msg);
                etGet.setText("主线程的Handler，收到了消息："+(String)msg.obj);
            }
        }
        //返回执行结果Handler
        class ReturnHandler extends Handler{
            
            public ReturnHandler(Looper looper){
                super(looper);
            }
            @Override
            public void handleMessage(Message msg){
                super.handleMessage(msg);
                switch (msg.what) {  
                case  RETURN_RESULT:
                	phpweb(); 
                    break;  
                default:
    					break;	
                }  
            }
        }
        
    	//定时器线程，连接服务器线程
    	 private class mTask extends TimerTask{
    		 
             @Override  
             public void run() { 
            	 //连接服务器
            	 HttpResponse response=phpweb();
            	 if (response!=null) 
            		 handler1.sendEmptyMessage(UPDATE_TEXT);
            	 
            	 Looper.prepare();
     			 //当前线程的Looper对象
     			 handler3=new ReturnHandler(Looper.myLooper());	    
                 Looper.loop(); 
             }     
         }  
    	//定义子线程类中的接收消息
        class ThreadHandler extends Handler{
            
            public ThreadHandler(Looper looper){
                super(looper);
            }    
            @Override      
            public void handleMessage(Message msg) {  
                switch (msg.what) {  
                case  UPDATE_TEXT:
               	 getData();  
                    break;  
                default:
    					break;	
                }  
            }  
           
        }
    	//接收数据、处理线程
    	private Thread ReceiveThread = new Thread(){	
    		
    		public void run()
    		{	
    			Looper.prepare();
    			//当前线程的Looper对象
    			handler1=new ThreadHandler(Looper.myLooper());	    
                Looper.loop(); 
    		}
    	};
    	
    	
    	//数据流转换为字符串
    	private static String convertStreamToString(InputStream is) {
    		BufferedReader reader = new BufferedReader(new InputStreamReader(is));
    		StringBuilder sb = new StringBuilder();
    		String line = null;
    		try {
    		while ((line = reader.readLine()) != null) {
    		sb.append(line + "\r\n");
    		}
    		} catch (IOException e) {
    		e.printStackTrace();
    		} finally {
    		try {
    		is.close();
    		} catch (IOException e) {
    		e.printStackTrace();
    		}
    		}
    		return sb.toString();
    		}
    	//访问web函数
        private HttpResponse phpweb(){
    
            try {      	
    			HttpClient client = new DefaultHttpClient();	
    			String url = "http://www.google.com";
    			HttpGet httpGetRequest=new HttpGet(url);
    			//响应
    			response = client.execute(httpGetRequest);
    			return response;
            }
    		catch (Exception e) {
    			// TODO: handle exception
    			e.printStackTrace();
    		}
    		return response;         
    	}
       
        //获取数据函数
        private void getData() {
        	try
    		{			
    			HttpEntity entity = response.getEntity();
    			//返回值不为空
    			if (entity != null) {
    				
    				InputStream instream = entity.getContent();
    				String result = convertStreamToString(instream);
    				//将收到的数据返回给主界面：主线程--构造别人的Handler
    				handler2 = new MyHandler(Looper.getMainLooper());
    	            Message msg2 = handler2.obtainMessage(1,1,1,result);      
    	            handler2.sendMessage(msg2);
    
    	            handler3.sendEmptyMessage(RETURN_RESULT);
    			}	
    
    		}
    		catch (Exception e)
    		{
    		}
    	}
    	
    }

[1333675226_2626.jpg]: https://img-my.csdn.net/uploads/201204/06/1333675226_2626.jpg