欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  移动技术

Android中Service与Activity之间通信的几种方式

程序员文章站 2024-02-13 15:26:10
在android中,activity主要负责前台页面的展示,service主要负责需要长期运行的任务,所以在我们实际开发中,就会常常遇到activity与service之间...

在android中,activity主要负责前台页面的展示,service主要负责需要长期运行的任务,所以在我们实际开发中,就会常常遇到activity与service之间的通信,我们一般在activity中启动后台service,通过intent来启动,intent中我们可以传递数据给service,而当我们service执行某些操作之后想要更新ui线程,我们应该怎么做呢?接下来我就介绍两种方式来实现service与activity之间的通信问题

1、通过binder对象

当activity通过调用bindservice(intent service, serviceconnection conn,int flags),我们可以得到一个service的一个对象实例,然后我们就可以访问service中的方法,我们还是通过一个例子来理解一下吧,一个模拟下载的小例子,带大家理解一下通过binder通信的方式

首先我们新建一个工程communication,然后新建一个service类

package com.example.communication; 
import android.app.service; 
import android.content.intent; 
import android.os.binder; 
import android.os.ibinder; 
 
public class msgservice extends service { 
 /** 
  * 进度条的最大值 
  */ 
 public static final int max_progress = 100; 
 /** 
  * 进度条的进度值 
  */ 
 private int progress = 0; 
 
 /** 
  * 增加get()方法,供activity调用 
  * @return 下载进度 
  */ 
 public int getprogress() { 
  return progress; 
 } 
 
 /** 
  * 模拟下载任务,每秒钟更新一次 
  */ 
 public void startdownload(){ 
  new thread(new runnable() { 
    
   @override 
   public void run() { 
    while(progress < max_progress){ 
     progress += 5; 
     try { 
      thread.sleep(1000); 
     } catch (interruptedexception e) { 
      e.printstacktrace(); 
     } 
      
    } 
   } 
  }).start(); 
 } 
 
 
 /** 
  * 返回一个binder对象 
  */ 
 @override 
 public ibinder onbind(intent intent) { 
  return new msgbinder(); 
 } 
  
 public class msgbinder extends binder{ 
  /** 
   * 获取当前service的实例 
   * @return 
   */ 
  public msgservice getservice(){ 
   return msgservice.this; 
  } 
 } 
 
}

上面的代码比较简单,注释也比较详细,最基本的service的应用了,相信你看得懂的,我们调用startdownload()方法来模拟下载任务,然后每秒更新一次进度,但这是在后台进行中,我们是看不到的,所以有时候我们需要他能在前台显示下载的进度问题,所以我们接下来就用到activity了

intent intent = new intent("com.example.communication.msg_action"); 
bindservice(intent, conn, context.bind_auto_create); 

通过上面的代码我们就在activity绑定了一个service,上面需要一个serviceconnection对象,它是一个接口,我们这里使用了匿名内部类

serviceconnection conn = new serviceconnection() { 
   
  @override 
  public void onservicedisconnected(componentname name) { 
    
  } 
   
  @override 
  public void onserviceconnected(componentname name, ibinder service) { 
   //返回一个msgservice对象 
   msgservice = ((msgservice.msgbinder)service).getservice(); 
    
  } 
 };

在onserviceconnected(componentname name, ibinder service) 回调方法中,返回了一个msgservice中的binder对象,我们可以通过getservice()方法来得到一个msgservice对象,然后可以调用msgservice中的一些方法,activity的代码如下

package com.example.communication; 
import android.app.activity; 
import android.content.componentname; 
import android.content.context; 
import android.content.intent; 
import android.content.serviceconnection; 
import android.os.bundle; 
import android.os.ibinder; 
import android.view.view; 
import android.view.view.onclicklistener; 
import android.widget.button; 
import android.widget.progressbar; 
 
public class mainactivity extends activity { 
 private msgservice msgservice; 
 private int progress = 0; 
 private progressbar mprogressbar; 
  
 
 @override 
 protected void oncreate(bundle savedinstancestate) { 
  super.oncreate(savedinstancestate); 
  setcontentview(r.layout.activity_main); 
   
   
  //绑定service 
  intent intent = new intent("com.example.communication.msg_action"); 
  bindservice(intent, conn, context.bind_auto_create); 
   
   
  mprogressbar = (progressbar) findviewbyid(r.id.progressbar1); 
  button mbutton = (button) findviewbyid(r.id.button1); 
  mbutton.setonclicklistener(new onclicklistener() { 
    
   @override 
   public void onclick(view v) { 
    //开始下载 
    msgservice.startdownload(); 
    //监听进度 
    listenprogress(); 
   } 
  }); 
   
 } 
  
 
 /** 
  * 监听进度,每秒钟获取调用msgservice的getprogress()方法来获取进度,更新ui 
  */ 
 public void listenprogress(){ 
  new thread(new runnable() { 
    
   @override 
   public void run() { 
    while(progress < msgservice.max_progress){ 
     progress = msgservice.getprogress(); 
     mprogressbar.setprogress(progress); 
     try { 
      thread.sleep(1000); 
     } catch (interruptedexception e) { 
      e.printstacktrace(); 
     } 
    } 
     
   } 
  }).start(); 
 } 
  
 serviceconnection conn = new serviceconnection() { 
  @override 
  public void onservicedisconnected(componentname name) { 
    
  } 
   
  @override 
  public void onserviceconnected(componentname name, ibinder service) { 
   //返回一个msgservice对象 
   msgservice = ((msgservice.msgbinder)service).getservice(); 
    
  } 
 }; 
 
 @override 
 protected void ondestroy() { 
  unbindservice(conn); 
  super.ondestroy(); 
 } 
 
 
} 

其实上面的代码我还是有点疑问,就是监听进度变化的那个方法我是直接在线程中更新ui的,不是说不能在其他线程更新ui操作吗,可能是progressbar比较特殊吧,我也没去研究它的源码,知道的朋友可以告诉我一声,谢谢!

上面的代码就完成了在service更新ui的操作,可是你发现了没有,我们每次都要主动调用getprogress()来获取进度值,然后隔一秒在调用一次getprogress()方法,你会不会觉得很被动呢?可不可以有一种方法当service中进度发生变化主动通知activity,答案是肯定的,我们可以利用回调接口实现service的主动通知,不理解回调方法的可以看


新建一个回调接口

public interface onprogresslistener { 
 void onprogress(int progress); 
} 

msgservice的代码有一些小小的改变,为了方便大家看懂,我还是将所有代码贴出来

package com.example.communication; 
 
import android.app.service; 
import android.content.intent; 
import android.os.binder; 
import android.os.ibinder; 
 
public class msgservice extends service { 
 /** 
  * 进度条的最大值 
  */ 
 public static final int max_progress = 100; 
 /** 
  * 进度条的进度值 
  */ 
 private int progress = 0; 
  
 /** 
  * 更新进度的回调接口 
  */ 
 private onprogresslistener onprogresslistener; 
  
  
 /** 
  * 注册回调接口的方法,供外部调用 
  * @param onprogresslistener 
  */ 
 public void setonprogresslistener(onprogresslistener onprogresslistener) { 
  this.onprogresslistener = onprogresslistener; 
 } 
 
 /** 
  * 增加get()方法,供activity调用 
  * @return 下载进度 
  */ 
 public int getprogress() { 
  return progress; 
 } 
 
 /** 
  * 模拟下载任务,每秒钟更新一次 
  */ 
 public void startdownload(){ 
  new thread(new runnable() { 
    
   @override 
   public void run() { 
    while(progress < max_progress){ 
     progress += 5; 
      
     //进度发生变化通知调用方 
     if(onprogresslistener != null){ 
      onprogresslistener.onprogress(progress); 
     } 
      
     try { 
      thread.sleep(1000); 
     } catch (interruptedexception e) { 
      e.printstacktrace(); 
     } 
      
    } 
   } 
  }).start(); 
 } 
 
 
 /** 
  * 返回一个binder对象 
  */ 
 @override 
 public ibinder onbind(intent intent) { 
  return new msgbinder(); 
 } 
  
 public class msgbinder extends binder{ 
  /** 
   * 获取当前service的实例 
   * @return 
   */ 
  public msgservice getservice(){ 
   return msgservice.this; 
  } 
 } 
 
} 

activity中的代码如下

package com.example.communication; 
 
import android.app.activity; 
import android.content.componentname; 
import android.content.context; 
import android.content.intent; 
import android.content.serviceconnection; 
import android.os.bundle; 
import android.os.ibinder; 
import android.view.view; 
import android.view.view.onclicklistener; 
import android.widget.button; 
import android.widget.progressbar; 
 
public class mainactivity extends activity { 
 private msgservice msgservice; 
 private progressbar mprogressbar; 
  
 
 @override 
 protected void oncreate(bundle savedinstancestate) { 
  super.oncreate(savedinstancestate); 
  setcontentview(r.layout.activity_main); 
   
   
  //绑定service 
  intent intent = new intent("com.example.communication.msg_action"); 
  bindservice(intent, conn, context.bind_auto_create); 
   
   
  mprogressbar = (progressbar) findviewbyid(r.id.progressbar1); 
  button mbutton = (button) findviewbyid(r.id.button1); 
  mbutton.setonclicklistener(new onclicklistener() { 
    
   @override 
   public void onclick(view v) { 
    //开始下载 
    msgservice.startdownload(); 
   } 
  }); 
   
 } 

 serviceconnection conn = new serviceconnection() { 
  @override 
  public void onservicedisconnected(componentname name) { 
    
  } 
   
  @override 
  public void onserviceconnected(componentname name, ibinder service) { 
   //返回一个msgservice对象 
   msgservice = ((msgservice.msgbinder)service).getservice(); 
    
   //注册回调接口来接收下载进度的变化 
   msgservice.setonprogresslistener(new onprogresslistener() { 
     
    @override 
    public void onprogress(int progress) { 
     mprogressbar.setprogress(progress); 
      
    } 
   }); 
    
  } 
 }; 
 
 @override 
 protected void ondestroy() { 
  unbindservice(conn); 
  super.ondestroy(); 
 } 
} 

用回调接口是不是更加的方便呢,当进度发生变化的时候service主动通知activity,activity就可以更新ui操作了

2、通过broadcast(广播)的形式

当我们的进度发生变化的时候我们发送一条广播,然后在activity的注册广播接收器,接收到广播之后更新progressbar,代码如下

package com.example.communication; 
import android.app.activity; 
import android.content.broadcastreceiver; 
import android.content.context; 
import android.content.intent; 
import android.content.intentfilter; 
import android.os.bundle; 
import android.view.view; 
import android.view.view.onclicklistener; 
import android.widget.button; 
import android.widget.progressbar; 
 
public class mainactivity extends activity { 
 private progressbar mprogressbar; 
 private intent mintent; 
 private msgreceiver msgreceiver; 
  
 
 @override 
 protected void oncreate(bundle savedinstancestate) { 
  super.oncreate(savedinstancestate); 
  setcontentview(r.layout.activity_main); 
   
  //动态注册广播接收器 
  msgreceiver = new msgreceiver(); 
  intentfilter intentfilter = new intentfilter(); 
  intentfilter.addaction("com.example.communication.receiver"); 
  registerreceiver(msgreceiver, intentfilter); 
   
   
  mprogressbar = (progressbar) findviewbyid(r.id.progressbar1); 
  button mbutton = (button) findviewbyid(r.id.button1); 
  mbutton.setonclicklistener(new onclicklistener() { 
    
   @override 
   public void onclick(view v) { 
    //启动服务 
    mintent = new intent("com.example.communication.msg_action"); 
    startservice(mintent); 
   } 
  }); 
   
 } 
 
  
 @override 
 protected void ondestroy() { 
  //停止服务 
  stopservice(mintent); 
  //注销广播 
  unregisterreceiver(msgreceiver); 
  super.ondestroy(); 
 } 
 
 
 /** 
  * 广播接收器 
  * @author len 
  * 
  */ 
 public class msgreceiver extends broadcastreceiver{ 
 
  @override 
  public void onreceive(context context, intent intent) { 
   //拿到进度,更新ui 
   int progress = intent.getintextra("progress", 0); 
   mprogressbar.setprogress(progress); 
  } 
   
 } 
 
} 
package com.example.communication; 
 
import android.app.service; 
import android.content.intent; 
import android.os.ibinder; 
 
public class msgservice extends service { 
 /** 
  * 进度条的最大值 
  */ 
 public static final int max_progress = 100; 
 /** 
  * 进度条的进度值 
  */ 
 private int progress = 0; 
  
 private intent intent = new intent("com.example.communication.receiver"); 
  
 
 /** 
  * 模拟下载任务,每秒钟更新一次 
  */ 
 public void startdownload(){ 
  new thread(new runnable() { 
    
   @override 
   public void run() { 
    while(progress < max_progress){ 
     progress += 5; 
      
     //发送action为com.example.communication.receiver的广播 
     intent.putextra("progress", progress); 
     sendbroadcast(intent); 
      
     try { 
      thread.sleep(1000); 
     } catch (interruptedexception e) { 
      e.printstacktrace(); 
     } 
      
    } 
   } 
  }).start(); 
 } 
 
  
 
 @override 
 public int onstartcommand(intent intent, int flags, int startid) { 
  startdownload(); 
  return super.onstartcommand(intent, flags, startid); 
 } 
 
 
 
 @override 
 public ibinder onbind(intent intent) { 
  return null; 
 } 
 
 
}

总结:

  • activity调用bindservice (intent service, serviceconnection conn, int flags)方法,得到service对象的一个引用,这样activity可以直接调用到service中的方法,如果要主动通知activity,我们可以利用回调方法
  •  service向activity发送消息,可以使用广播,当然activity要注册相应的接收器。比如service要向多个activity发送同样的消息的话,用这种方法就更好

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。