神刀安全网

Silk,一个基于java bean的轻量级响应式框架

Silk

一个基于java bean的响应式框架

Why we need this?

假设我们有这么一个需求:
我们登陆成功之后通过服务器拿到一个useraccount对象,useraccount对象长这个样子

public class UserAccount{   private String userName;//姓名   private int age;//年龄   private String userImage;//头像    public void setUserName(String userName){     this.userName = userName;   }    public String getUserName(){     return userName;   }    //后略...... }

我们会在界面上展示登陆用户的姓名,头像等等:

UserAccount useraccount = getUserAccount();//获取到了useraccount对象 TextView tvName = findViewById(R.id.tv_name); tvName.setText(useraccount.getUserName());

OK,接下来如果我们需要修改用户的姓名,那么以往我们是这样的:

useraccount.setUserName("mike"); //其他的工作 tvName.setText(useraccount.getUserName()); //其他的展示

这里面,我们一般是给对象set了某个值之后,再更新UI。

Now,We change

使用silk之后,现在我们的useraccount定义是这样的:(就多了一个注解而已)

@RxBean public class UserAccount{   private String userName;//姓名   private int age;//年龄   private String userImage;//头像    public void setUserName(String userName){     this.userName = userName;   }    public String getUserName(){     return userName;   }    //后略...... }

我们接下来这样展示里面的数据:

TextView tvName = findViewById(R.id.tv_name); SilkBrite<UserAccount> brite = SilkBrite.create();//初始化了一个brite UserAccount useraccount = brite.asSilkBean(getUserAccount());//获取useraccount对象,其实这是一个“换了包”的对象 brite.asModeObservable()     .subscribeOn(Schedulers.io())     .observeOn(AndroidSchedulers.mainThread())     .subscribe(new Action1<UserAccount>() {                     @Override                     public void call(UserAccount info) {                         tvName.setText(useraccount.getUserName());                     }                 });

然后我们要修改用户姓名了!

//你只需要做下面这件事,UI上面就会同步 useraccount.setUserName("mike");

所以,用了silk,我们就不需要每次修改了bean之后还要去同步UI。

引用

  • gradle,在你的app的build.gradle文件中引入依赖
    dependencies {   ...   compile 'com.github.landscapeside:SilkLib:1.0'   apt 'com.github.landscapeside:SilkComplier:0.1'   ... }

    然后在你的app的build.gradle中应用apt插件:

    apply plugin: 'com.neenbedankt.android-apt'

    project的build.gradle中申明:

    dependencies {       classpath 'com.neenbedankt.gradle.plugins:android-apt:1.8'   }

    用的是jitpack仓库,所以需要在project的build.gradle中注明

    allprojects {   repositories {       jcenter()       maven { url "https://jitpack.io" }   } }

用法

  • 如上所说,在你需要silk功能的java bean类上使用RxBean注解,然后重新构建一下项目
  • 然后要新建一个SilkBrite出来SilkBrite<UserAccount> brite = SilkBrite.create();,注意,目前来说,一个brite就对应处理一个bean对象
  • 接下来需要将原有的bean对象设置一个代理UserAccount useraccount = brite.asSilkBean(getUserAccount());
  • 上一步生成的代理对象才能真正嵌入到Silk响应式框架之中,通过bean的setter即可触发相应
  • 我们需要监听到事件源发出的消息并作出反应
    brite.asModeObservable()   .subscribeOn(Schedulers.io())   .observeOn(AndroidSchedulers.mainThread())   .subscribe(new Action1<UserAccount>() {                   @Override                   public void call(UserAccount info) {                       tvName.setText(useraccount.getUserName());                   }               });
  • 当然,还可以嵌套使用,比如一个Parent对象有2个Child,不管是修改Parent的属性或者是child属性,我们都希望能得到通知,则两个类都标记上RxBean注解即可
@RxBean public class Parent{   private String userName;//姓名   private int age;//年龄   private String userImage;//头像   private Child child1;   private Child child2;    public void setUserName(String userName){     this.userName = userName;   }    public String getUserName(){     return userName;   }    //后略...... }  @RxBean public class Child{   private String userName;//姓名   private int age;//年龄   //...... }
  • 有时候我们有这样的需求,显示UserAccount的nick的时候希望能加上如果为空的默认显示
brite.asNodeObservable("nick")         .subscribeOn(Schedulers.io())         .observeOn(AndroidSchedulers.mainThread())         .map(o1 -> {             String name = String.valueOf(o1);             if (TextUtils.isEmpty(name)) {                 return "unknown user";             }             return name;         })         .subscribe(new Action1<String>() {                 @Override                 public void call(String name) {                     tvName.setText(name);                 }             });
  • 如果是要加上child的默认显示
    brite.asNodeObservable("child1::userName")       .subscribeOn(Schedulers.io())       .observeOn(AndroidSchedulers.mainThread())       .map(o1 -> {           String name = String.valueOf(o1);           if (TextUtils.isEmpty(name)) {               return "unknown user";           }           return name;       })       .subscribe(new Action1<String>() {               @Override               public void call(String name) {                   tvName.setText(name);               }           });

限制

  • 首先,一个brite就是用来处理一个bean对象,所以并不太适合列表类的应用,当然后续会考虑改进
  • 而且就如Silk的开发目的一样,它就只是为了解决基于bean的响应式编程,如果是基于sqlite的响应式需求,请移步sqlbrite

最后

感谢如下项目给我的指导和参考:

项目地址

https://github.com/landscapeside/Silk

转载本站任何文章请注明:转载至神刀安全网,谢谢神刀安全网 » Silk,一个基于java bean的轻量级响应式框架

分享到:更多 ()

评论 抢沙发

  • 昵称 (必填)
  • 邮箱 (必填)
  • 网址