事件是传递的最小单位，可以把任何类作为一个事件。
RxBus代码如下：
/** * Author: wangjie * Email: [email protected] * Date: 6/11/15. */public class RxBus { private static final String TAG = RxBus.class.getSimpleName(); private static RxBus instance; public static boolean DEBUG = false; public static synchronized RxBus get() { if (null == instance) { instance = new RxBus(); } return instance; } private RxBus() { } private ConcurrentHashMap<Object, List<Subject>> subjectMapper = new ConcurrentHashMap<>(); @SuppressWarnings("unchecked") public <T> Observable<T> register(@NonNull Object tag, @NonNull Class<T> clazz) { List<Subject> subjectList = subjectMapper.get(tag); if (null == subjectList) { subjectList = new ArrayList<>(); subjectMapper.put(tag, subjectList); } Subject<T, T> subject; subjectList.add(subject = PublishSubject.create()); if (DEBUG) Log.d(TAG, "[register]subjectMapper: " + subjectMapper); return subject; } public void unregister(@NonNull Object tag, @NonNull Observable observable) { List<Subject> subjects = subjectMapper.get(tag); if (null != subjects) { subjects.remove((Subject) observable); if (ABTextUtil.isEmpty(subjects)) { subjectMapper.remove(tag); } } if (DEBUG) Log.d(TAG, "[unregister]subjectMapper: " + subjectMapper); } public void post(@NonNull Object content) { post(content.getClass().getName(), content); } @SuppressWarnings("unchecked") public void post(@NonNull Object tag, @NonNull Object content) { List<Subject> subjectList = subjectMapper.get(tag); if (!ABTextUtil.isEmpty(subjectList)) { for (Subject subject : subjectList) { subject.onNext(content); } } if (DEBUG) Log.d(TAG, "[send]subjectMapper: " + subjectMapper); }}
如上述代码，RxBus只提供了register、unregister、post三个方法。
这里又加入了一个tag的概念，也可以理解为channel，注册Subject、反注册Subject和post事件的时候都需要这个tag，只有tag一致才能正常接收到事件。
比如有一个事件类HelloEvent，这个事件的作用是接收到后toast一个提示“hello”，如果两个Activity都注册了这个HelloEvent事件，但是没有tag去限制，一旦post了一个helloEvent事件后，两个Activity都会收到这个事件，导致两个Activity都会toast。如果使用tag，post这个HelloEvent的时候可以设置这个tag，只有register时也使用了这个tag才会接收到这个event。
2. 在Present（如Activity的onCreate）中注册一个Observer（以下以发送一个String类型的事件为例）
Observable<String> addOb = RxBus.get() .register("addFeedTag", String.class); addOb.observeOn(AndroidSchelers.mainThread()) .subscribe(s -> { // todo: Accept event and process here });
如上，注册了一个String类型的事件，事件的tag是“addFeedTag”，用来增加一个Feed。使用RxAndroid在Action1中处理接收到的这个事件。
3. 在任何地方发送一个事件：
RxBus.get().post("addFeedTag", "hello RxBus!");
这里发送了一个tag为“addFeedTag”的String类型的事件。
4. 反注册Observer：
RxBus.get().unregister("addFeedTag", addOb);
注意：这里的Tag都为“addFeedTag”。
下面使用注解的方式更简单方便地使用RxBus（嗯－。－这里才是重点）。
首先来看下使用注解后的代码：
1. 注册Observer
这一步可以省略掉。
2. 发送一个事件（这里我们换一个事件：FeedItemCl3. ickEvent，我们定义这个事件是用来处理当Feed被点击后的事件）
RxBus.get().post(new FeedItemClickEvent().setPosition(position).setFeed(feed));
3. 接收事件，然后处理
1 @Accept2 public void onPostAccept(Object tag, FeedItemClickEvent event) {3 Logger.d(TAG, "onPostAccept event: " + event);4 Feed feed = event.getFeed();5 // 跳转到feed详情页面...6 }
如上，这里只需要编写一个方法，加上Accept注解，然后在方法中进行事件处理即可。
注意：方法名可以任意
方法参数一：必须为Object类型的tag；
方法参数二，如果这个方法只接收一种事件，则写明具体的事件类型，如上；如果这个方法接收多种事件，则类型需要为Object。
4. 反注册Observer
这一步也可以省略掉。
接收多种事件：
@Accept( acceptScheler = AcceptScheler.NEW_THREAD, value = { @AcceptType(tag = ActionEvent.CLOSE, clazz = String.class), @AcceptType(tag = ActionEvent.BACK, clazz = String.class), @AcceptType(tag = ActionEvent.EDIT, clazz = String.class), @AcceptType(tag = ActionEvent.REFRESH, clazz = String.class) } ) public void onPostAccept(Object tag, Object actionEvent) { Logger.d(TAG, "[ActionEvent]onPostAccept action event name: " + actionEvent); // todo: Accept event and process here (in new thread) }
这里@Accept注解中设置了acceptScheler为AcceptScheler.NEW_THREAD，指明方法运行在子线程中.
value中指明了接收的事件类型，这里表示这个方法接收4种类型的事件：CLOSE, BACK, EDIT, REFRESH.
注解解释：
@Accept注解
acceptScheler: 指定被注解的方法运行的Scheler。
value[]: AcceptType注解数组，用于指定接收事件的tag和class。
@AcceptType注解：
tag: 接收事件的tagclazz: 接收事件的类型
AcceptScheler：
详情见：rx.schelers.Schelers和rx.android.schelers.AndroidSchelers
如果设置的是AcceptScheler.EXECUTOR或AcceptScheler.HANDLER，则需要在Application中配置Executor和Handler：/** * Author: wangjie * Email: [email protected] * Date: 6/15/15. */public class MyApplication extends Application { private Executor acceptExecutor = Executors.newCachedThreadPool(); private Handler handler = new Handler(Looper.getMainLooper()); @Override public void onCreate() { super.onCreate(); RxBus.DEBUG = true; DefaultAcceptConfiguration.getInstance().registerAcceptConfiguration(new DefaultAcceptConfiguration.OnDefaultAcceptConfiguration() { @Override public Executor applyAcceptExecutor() { return acceptExecutor; } @Override public Handler applyAcceptHandler() { return handler; } }); }}
Ⅱ android开发框架有哪些
1、Rajawali
介绍：
安卓的OpenGL ES 2.0/3.0 引擎。可以用于制作普通应用或者动态壁纸，当然也可以用于制作游戏。
项目地址： https://github.com/Rajawali/Rajawali
2、RxAndroid
介绍：
RxAndroid是RxJava的一个针对Android平台的扩展。它包含了一些能够简化Android开发的工具。
项目地址： https://github.com/ReactiveX/RxAndroid
3、Paginize
介绍：
Paginize 是一个轻量级的UI框架，使用注解来注入布局和view，除了使用注解之外，该框架还有两个特色：1.用Page的概念来取代Fragment，2.切换page时自带ios风格的动画效果。
项目地址： https://github.com/neevek/Paginize
4、otto
介绍：
Otto 是square公司出的一个事件库（pub/sub模式），用来简化应用程序组件之间的通讯。 Otto 修改自Google的Guava库，专门为Android平台进行了优化。
项目地址： https://github.com/square/otto
5 、rebound
介绍：
rebound是facebook的开源动画库。可以认为这个动画库是独立于android Framework之外的一种动画实现。
项目地址： https://github.com/facebook/rebound
6、KJFrameForAndroid
介绍：
KJFrameForAndroid 又叫KJLibrary，是一个帮助快速开发的框架。使用KJFrameForAndroid，你可以只用一行代码就完成http请求、网络图片加载、数据库数据保存或读取。
项目地址： https://github.com/kymjs/KJFrameForAndroid
7、xUtils
介绍：
xUtils
包含了很多实用的android工具。 xUtils
支持大文件上传，更全面的http请求协议支持(10种谓词)，拥有更加灵活的ORM，更多的事件注解支持且不受混淆影响... xUitls
最低兼容android 2.2 (api level 8)
项目地址： https://github.com/wyouflf/xUtils
目前xUtils主要有四大模块：
DbUtils模块：
android中的orm框架，一行代码就可以进行增删改查；
支持事务，默认关闭；
可通过注解自定义表名，列名，外键，唯一性约束，NOT NULL约束，CHECK约束等（需要混淆的时候请注解表名和列名）；
支持绑定外键，保存实体时外键关联实体自动保存或更新；
自动加载外键关联实体，支持延时加载；
支持链式表达查询，更直观的查询语义，参考下面的介绍或sample中的例子。
ViewUtils模块：
android中的ioc框架，完全注解方式就可以进行UI，资源和事件绑定；
新的事件绑定方式，使用混淆工具混淆后仍可正常工作；
目前支持常用的20种事件绑定，参见ViewCommonEventListener类和包com.lidroid.xutils.view.annotation.event。
HttpUtils模块：
支持同步，异步方式的请求；
支持大文件上传，上传大文件不会oom；
支持GET，POST，PUT，MOVE，COPY，DELETE，HEAD，OPTIONS，TRACE，CONNECT请求；
下载支持301/302重定向，支持设置是否根据Content-Disposition重命名下载的文件；
返回文本内容的请求(默认只启用了GET请求)支持缓存，可设置默认过期时间和针对当前请求的过期时间。
BitmapUtils模块：
加载bitmap的时候无需考虑bitmap加载过程中出现的oom和android容器快速滑动时候出现的图片错位等现象；
支持加载网络图片和本地图片；
内存管理使用lru算法，更好的管理bitmap内存；
可配置线程加载线程数量，缓存大小，缓存路径，加载显示动画等...
8、butterknife-view
注入工具
介绍：
为了减少频繁的调用findViewById(R.id...)，可以采用一些注入框架，可以简化自己的代码，让你更专注于实际的功能开发，butterknife就是这样的一个框架，他是jakewharton大神的作品，值得一试。
class ExampleActivity extends Activity {
@InjectView(R.id.title) TextView title;
@InjectView(R.id.subtitle) TextView subtitle;
@InjectView(R.id.footer) TextView footer;
@Override public void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.simple_activity);
ButterKnife.inject(this);
// TODO Use "injected" views...
}
}
这是博客地址：
http://jakewharton.github.io/butterknife/
项目地址： https://github.com/JakeWharton/butterknife
9、cube-sdk
一淘推出的开发框架
介绍：
cube一个Android开发包, 可极大提高你的开发效率。主要提供了图片加载以及网络请求方面的api功能。
项目地址： https://github.com/etao-open-source/cube-sdk
他们的网站：http://cube-sdk.liaohuqiu.net/cn/
10、ASimpleCache
一个简单的缓存框架
介绍：
ASimpleCache
是一个为android制定的 轻量级的 开源缓存框架。轻量到只有一个java文件（由十几个类精简而来）。
它可以缓存什么东西？普通的字符串、JsonObject、JsonArray、Bitmap、Drawable、序列化的java对象，和
byte数据。
项目地址： https://github.com/yangfuhai/ASimpleCache
11、androidannotations
介绍：
AndroidAnnotations是一个能够让你快速进行Android开发的开源框架，它能让你专注于真正重要的地方。
使代码更加精简，使项目更加容易维护，它的目标就是“Fast Android Development.Easy maintainance”。
通过一段时间的使用发现，相比原生的Android开发，确实能够让你少些很多代码
项目地址： https://github.com/excilys/androidannotations
12、Event Bus
解耦android模块
介绍：
当一个Android应用功能越来越多的时候，保证应用的各个部分之间高效的通信将变得越来越困难。如何优雅地解决这个问题？这时候，就需要使用到EventBus。
EventBus是GreenRobot出品的Android系统的一个Event
Bus类库，使用起来和之前我们所介绍的Square的Otto差不多，都是用来简化应用组件之间的通信。
项目地址： https://github.com/greenrobot/EventBus
13、BeeFramework_Android
介绍：
BeeFramework
Android版主要为Android初级开发人员提供一个基于MVC开发模式的APP DEMO,并提供一套APP内调试工具,包括
查看网络数据请求历史 Crash Log列表 真机WIFI环境下模拟2G\3G网络 查看APP性能(内存占用，CPU占用等)
项目地址： https://github.com/BeeFramework/BeeFramework_Android
14、afinal
介绍：
Afinal是一个android的ioc，orm框架，内置了四大模块功能：FinalAcitivity,FinalBitmap,FinalDb,FinalHttp。通过finalActivity，我们可以通过注解的方式进行绑定ui和事件。通过finalBitmap，我们可以方便的加载bitmap图片，而无需考虑oom等问题。通过finalDB模块，我们一行代码就可以对android的sqlite数据库进行增删改查。通过FinalHttp模块，我们可以以ajax形式请求http数据。
Afinal里面目前包含了四大组件：
FinalHttp：用于请求http数据，直接ajax方式请求，文件上传， 断点续传下载文件等
FinalBitmap：用于显示bitmap图片，而无需考虑线程并发和oom等问题。
FinalActivity：完全可以通过注解方式绑定控件和事件，无需编写代码。
FinalDb：android中sqlite的orm框架，一行代码搞定增删改查。
Afinal是一个android的ioc，orm框架，内置了四大模块功能：FinalAcitivity,FinalBitmap,FinalDb,FinalHttp。通过finalActivity，我们可以通过注解的方式进行绑定ui和事件。通过finalBitmap，我们可以方便的加载bitmap图片，而无需考虑oom等问题。通过finalDB模块，我们一行代码就可以对android的sqlite数据库进行增删改查。通过FinalHttp模块，我们可以以ajax形式请求http数据。详情请通过以下网址查看。
项目地址： https://github.com/yangfuhai/afinal
15、Volley
介绍：
在这之前，我们在程序中需要和网络通信的时候，大体使用的东西莫过于AsyncTaskLoader，HttpURLConnection，AsyncTask，HTTPClient（Apache）等，今年的Google
I/O 2013上，Volley发布了。Volley是Android平台上的网络通信库，能使网络通信更快，更简单，更健壮。
项目地址： https://github.com/mcxiaoke/android-volley
Ⅲ android 用rxjava和retrofit时怎么解决返回数据类型不一致
1这种方法有两大步第一步是拼接需要的json数据，第二步是用servlet的内置对象response返回到前台。2String 类型的数据可以不用借助任何工具直接返回，只要把它拼接对了就可以。如我需要返回一个{“success”:true,“msg”:“修改失败！”}的json,就可以如下图这样写。（注意，java里的引号要用的转义字符“\”）3如果需要返回的是一个list或者别的类的化，需要用到JSONArray的辅助工具类，然后使用response.getWriter().print(),返回到打到前台。具体代码如下图。END方法2:用Spring框架如果你使用了Spring框架那就更简单了，你只需要在你的方法返回的时候加一个@ResponseBody的注解就可以了。就这么简单。
Ⅳ rxandroid和rxjava的区别
RxJava要比EventBus的应用更广泛，EventBus仅仅是作为一种消息的传递工具，但是RxJava里面几乎可以做任何事情。
如果是Android开发的话，可以使用RxAndroid，这是对RxJava的一个扩展，结合sqare公司的retrofit可以很轻松的完成网络的访问。
我们知道，在Android中异步操作一般使用AsycTask来完成，但是AsycTask有很多缺点，如不能方便的终止任务的执行等。
RxAndroid完全可以替代AsycTask来完成各种异步操作，而且还有BindActivity和BindFragment方法，你根本不需要考虑异步操作时的Activity和Fragment的生命周期问题，还有更加强大的的链式调用，可以使程序很简洁。
EventBus有个缺点就是凡是使用了EventBus的类都不能进行混淆了，否则Evnetbus就找不到OnEvent方法了。
以上，推荐使用RxAndroid。
Ⅳ 谁来讲讲Rxjava，rxandroid中的操作符的作用
作者：冷月
链接：https://www.hu.com/question/32209660/answer/63984697
来源：知乎
着作权归作者所有，转载请联系作者获得授权。
用于创建Observable的操作符
Create — 通过调用观察者的方法从头创建一个Observable
Defer — 在观察者订阅之前不创建这个Observable，为每一个观察者创建一个新的Observable
Empty/Never/Throw — 创建行为受限的特殊Observable
From — 将其它的对象或数据结构转换为Observable
Interval — 创建一个定时发射整数序列的Observable
Just — 将对象或者对象集合转换为一个会发射这些对象的Observable
Range — 创建发射指定范围的整数序列的Observable
Repeat — 创建重复发射特定的数据或数据序列的Observable
Start — 创建发射一个函数的返回值的Observable
Timer — 创建在一个指定的延迟之后发射单个数据的Observable
变换操作
这些操作符可用于对Observable发射的数据进行变换，详细解释可以看每个操作符的文档
Buffer — 缓存，可以简单的理解为缓存，它定期从Observable收集数据到一个集合，然后把这些数据集合打包发射，而不是一次发射一个
FlatMap — 扁平映射，将Observable发射的数据变换为Observables集合，然后将这些Observable发射的数据平坦化的放进一个单独的Observable，可以认为是一个将嵌套的数据结构展开的过程。
GroupBy — 分组，将原来的Observable分拆为Observable集合，将原始Observable发射的数据按Key分组，每一个Observable发射一组不同的数据
Map — 映射，通过对序列的每一项都应用一个函数变换Observable发射的数据，实质是对序列中的每一项执行一个函数，函数的参数就是这个数据项
Scan — 扫描，对Observable发射的每一项数据应用一个函数，然后按顺序依次发射这些值
Window — 窗口，定期将来自Observable的数据分拆成一些Observable窗口，然后发射这些窗口，而不是每次发射一项。类似于Buffer，但Buffer发射的是数据，Window发射的是Observable，每一个Observable发射原始Observable的数据的一个子集
过滤操作
这些操作符用于从Observable发射的数据中进行选择
Debounce — 只有在空闲了一段时间后才发射数据，通俗的说，就是如果一段时间没有操作，就执行一次操作
Distinct — 去重，过滤掉重复数据项
ElementAt — 取值，取特定位置的数据项
Filter — 过滤，过滤掉没有通过谓词测试的数据项，只发射通过测试的
First — 首项，只发射满足条件的第一条数据
IgnoreElements — 忽略所有的数据，只保留终止通知(onError或onCompleted)
Last — 末项，只发射最后一条数据
Sample — 取样，定期发射最新的数据，等于是数据抽样，有的实现里叫ThrottleFirst
Skip — 跳过前面的若干项数据
SkipLast — 跳过后面的若干项数据
Take — 只保留前面的若干项数据
TakeLast — 只保留后面的若干项数据
组合操作
组合操作符用于将多个Observable组合成一个单一的Observable
And/Then/When — 通过模式(And条件)和计划(Then次序)组合两个或多个Observable发射的数据集
CombineLatest — 当两个Observables中的任何一个发射了一个数据时，通过一个指定的函数组合每个Observable发射的最新数据（一共两个数据），然后发射这个函数的结果
Join — 无论何时，如果一个Observable发射了一个数据项，只要在另一个Observable发射的数据项定义的时间窗口内，就将两个Observable发射的数据合并发射
Merge — 将两个Observable发射的数据组合并成一个
StartWith — 在发射原来的Observable的数据序列之前，先发射一个指定的数据序列或数据项
Switch — 将一个发射Observable序列的Observable转换为这样一个Observable：它逐个发射那些Observable最近发射的数据
Zip — 打包，使用一个指定的函数将多个Observable发射的数据组合在一起，然后将这个函数的结果作为单项数据发射
错误处理
这些操作符用于从错误通知中恢复
Catch — 捕获，继续序列操作，将错误替换为正常的数据，从onError通知中恢复
Retry — 重试，如果Observable发射了一个错误通知，重新订阅它，期待它正常终止
辅助操作
一组用于处理Observable的操作符
Delay — 延迟一段时间发射结果数据
Do — 注册一个动作占用一些Observable的生命周期事件，相当于Mock某个操作
Materialize/Dematerialize — 将发射的数据和通知都当做数据发射，或者反过来
ObserveOn — 指定观察者观察Observable的调度程序（工作线程）
Serialize — 强制Observable按次序发射数据并且功能是有效的
Subscribe — 收到Observable发射的数据和通知后执行的操作
SubscribeOn — 指定Observable应该在哪个调度程序上执行
TimeInterval — 将一个Observable转换为发射两个数据之间所耗费时间的Observable
Timeout — 添加超时机制，如果过了指定的一段时间没有发射数据，就发射一个错误通知
Timestamp — 给Observable发射的每个数据项添加一个时间戳
Using — 创建一个只在Observable的生命周期内存在的一次性资源
条件和布尔操作
这些操作符可用于单个或多个数据项，也可用于Observable
All — 判断Observable发射的所有的数据项是否都满足某个条件
Amb — 给定多个Observable，只让第一个发射数据的Observable发射全部数据
Contains — 判断Observable是否会发射一个指定的数据项
DefaultIfEmpty — 发射来自原始Observable的数据，如果原始Observable没有发射数据，就发射一个默认数据
SequenceEqual — 判断两个Observable是否按相同的数据序列
SkipUntil — 丢弃原始Observable发射的数据，直到第二个Observable发射了一个数据，然后发射原始Observable的剩余数据
SkipWhile — 丢弃原始Observable发射的数据，直到一个特定的条件为假，然后发射原始Observable剩余的数据
TakeUntil — 发射来自原始Observable的数据，直到第二个Observable发射了一个数据或一个通知
TakeWhile — 发射原始Observable的数据，直到一个特定的条件为真，然后跳过剩余的数据
算术和聚合操作
这些操作符可用于整个数据序列
Average — 计算Observable发射的数据序列的平均值，然后发射这个结果
Concat — 不交错的连接多个Observable的数据
Count — 计算Observable发射的数据个数，然后发射这个结果
Max — 计算并发射数据序列的最大值
Min — 计算并发射数据序列的最小值
Rece — 按顺序对数据序列的每一个应用某个函数，然后返回这个值
Sum — 计算并发射数据序列的和
连接操作
一些有精确可控的订阅行为的特殊Observable
Connect — 指示一个可连接的Observable开始发射数据给订阅者
Publish — 将一个普通的Observable转换为可连接的
RefCount — 使一个可连接的Observable表现得像一个普通的Observable
Replay — 确保所有的观察者收到同样的数据序列，即使他们在Observable开始发射数据之后才订阅
转换操作
To — 将Observable转换为其它的对象或数据结构
Blocking 阻塞Observable的操作符
操作符决策树
几种主要的需求
直接创建一个Observable（创建操作）
组合多个Observable（组合操作）
对Observable发射的数据执行变换操作（变换操作）
从Observable发射的数据中取特定的值（过滤操作）
转发Observable的部分值（条件/布尔/过滤操作）
对Observable发射的数据序列求值（算术/聚合操作）
Ⅵ rxjava android怎样使用
不同的实现之间有很多重叠的部分，也有一些操作符只存在特定的实现中。每种实现都倾向于用那种编程语言中他们熟悉的上下文中相似的方法给这些操作符命名
Ⅶ rxandroid 生命周期什么时候调用
Dagger2：依赖注入并不是什么新技术，但是使用在Android确实一个新的尝试。AndroidApp越来越被当成严肃的大型项目来构建，很多在以前大型服务器开发上使用的技术都被应用到了移动开发。Android开发分模块开发，使用Dagger来松耦合模块。特别值得一体的是，Dagger2现在由Google亲自接管。Dagger‡。MVP：因为Android并没有严格的业务和界面区分，项目一复杂，就很容易使代码陷入混乱。现在Android开发社区对MVP模式讨论越来越热，觉得MVP是非常适合AndroidAPP开发。MVPforAndroid:。RxAndroid:函数响应式编程（FunctionalReactiveProgramming）也不是新内容，RxAndroid把RxJava带到Android环境中。很多时候，编写Android程序，你也可以看成是数据的处理和流动，换一种思想编程，曾经看起来很棘手的问题，瞬间就很优雅的解决了：ReactiveX/RxAndroid。MVVM：这是因为开始官方支持DataBinding，把MVVM直接带到Android中。数据绑定在WindowsWPF和Web已经非常常见，它非常高效的开发效率，让你只关心你的数据和业务。这也对Android开发来说，无疑是一个非常重大的影响：androidUI设计MVVM设计模式讨论？。插件化：针对大型Android项目，很多App开始使用插件来分模块构建相对独立的功能。Hybrid：完全使用HTML5开发App，目前还不成熟。但是折中方案在很多情况下是非常适合的，典型的就是微信，大部分信息展示都是通过H5来完成，同时通过Hybird方式，把Web和Native打通，提供给网页访问本地资源的能力。
Ⅷ rxandroid怎么使用定时器
JSONObject json = new JSONObject(json字符串); String str = json.getString("videoId"); 需要用到一个类库