当前位置: 移动技术网 > IT编程>移动开发>Android > Android中Service与Activity之间通信的几种方式

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

2019年07月24日  | 移动技术网IT编程  | 我要评论

888言情,行尸走肉第六季10集,我们结婚了格斗夫妇

在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发送同样的消息的话,用这种方法就更好

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

如对本文有疑问,请在下面进行留言讨论,广大热心网友会与你互动!! 点击进行留言回复

相关文章:

验证码:
移动技术网