dependencies {

  compile fileTree(dir: 'libs', include: ['*.jar'])

  compile 'com.android.support:appcompat-v7:19.+'

  /

/otto 所需要依赖的包

}

Bus.register(this);

Bus.unregister(this);

 @Subscribe public void getMessage(@NonNull SomeEvent s) {
     //TODO: 在回掉中使用这个事件
  }

Bus.post(SomeEvent);

/**
 * Created by leon on 15/5/27.
 * 主线程事件总线，方便在异步任务中回掉
 */
public class MainThreadBus extends Bus {
 private final Handler handler = new Handler(Looper.getMainLooper());

 @Override public void post(final Object event) {
  if (Looper.myLooper() == Looper.getMainLooper()) {
   //直接通过反射调用
   super.post(event);
  } else {
   //通过handler把异步任务发送到UI线程，然后再反射调用
   handler.post(new Runnable() {
    @Override
    public void run() {
     MainThreadBus.super.post(event);
    }
   });
  }
 }
}

public class GlobalContext extends Application {

 //event bus singleton
 public static final MainThreadBus bus = new MainThreadBus();
 public static GlobalContext instance;

 @Override public void onCreate() {
  super.onCreate();
  instance = this;
 }

 public static MainThreadBus getBusInstance(){
  return bus;
 }

 public static GlobalContext getContextInstance(){
  return instance;
 }
}

public class SmsService extends Service {

 private SmsReceiver mReceiver = null;

 public SmsService() {
 }

 @Override public IBinder onBind(Intent intent) {
  // TODO: Return the communication channel to the service.
  throw new UnsupportedOperationException("Not yet implemented");
 }

 @Override public void onCreate() {
  super.onCreate();
  Log.d(TAG, "onCreate");
  IntentFilter iFilter = null; // 意图过滤对象
  mReceiver = new SmsReceiver(); // 广播接收类初始化
  iFilter = new IntentFilter("android.provider.Telephony.SMS_RECEIVED");
  iFilter.setPriority(Integer.MAX_VALUE); // 设置优先级
  GlobalContext.getBusInstance().register(mReceiver);//注册Bus
  registerReceiver(mReceiver, iFilter); // 注册广播
 }

 @Override public void onDestroy() {
  super.onDestroy();
  if (mReceiver != null){
   GlobalContext.getBusInstance().unregister(mReceiver);//取消注册Bus
   unregisterReceiver(mReceiver);
  } 
 }
}

public class SmsReceiver extends BroadcastReceiver {

 public SmsReceiver() {
 }

 @Override public void onReceive(Context context, Intent intent) {

  Bundle bundle = intent.getExtras();
  //获取链路层的协议数据单元
  Object[] messages = (Object[]) bundle.get("pdus");
  SmsMessage[] sms = new SmsMessage[messages.length];
  // Create messages for each incoming PDU
  for (int n = 0; n < messages.length; n++) {
   sms[n] = SmsMessage.createFromPdu((byte[]) messages[n]);
  }
  for (SmsMessage msg : sms) {
   //TODO: 这里应该加上你自己的过滤条件，比如手机号，短信内容
   //尽可能的拦截短信，这个命令在MIUI，flyme上都没有用
   abortBroadcast();
   GlobalContext.getBusInstance().post(msg);
  }
 }
}

GlobalContext.getBusInstance().post(msg);

public class SMSControlFragment extends Fragment {

  Bus bus = GlobalContext.getBusInstance();

  @Override public void onAttach(Activity activity) {
    super.onAttach(activity);
    bus.register(this);
   }

  @Override public void onDetach() {
    super.onDetach();
    bus.unregister(this);
   }

  @Subscribe public void getMessage(SmsMessage s) {
    mTvNumber.setText(s.getOriginatingAddress());
    mTvMessage.setText(s.getMessageBody());
  }

}

public class MyActivity extends ActionBarActivity {

 @Override
 protected void onCreate(Bundle savedInstanceState) {
  super.onCreate(savedInstanceState);
  setContentView(R.layout.activity_my);
  findViewById(R.id.button_change).setOnClickListener(new View.OnClickListener() {
   @Override
   public void onClick(View view) {
    BusProvider.getBusInstance().post(new DataChangedEvent("this is changed String"));//发布事件
   }
  });
 }

 @Override
 protected void onResume() {
  super.onResume();
  BusProvider.getBusInstance().register(this);//注册
  
 }

 @Override
 protected void onPause() {
  super.onPause();
  BusProvider.getBusInstance().unregister(this);//注销
 }

 @Subscribe  //订阅事件DataChangedEvent
 public void sayGoodOnEvent(DataChangedEvent event){
  Log.e("event", "good");
 }

 @Subscribe //订阅事件
 public void sayBadOnEvent(DataChangedEvent event){
  Log.e("event", "bad");
 }

 @Produce //产生事件
 public DataChangedEvent produceDataChangedEvent(){
  return new DataChangedEvent("this is changed String");
 }

}