Angular基础(八) Observable & RxJS
Angular基础(八) Observable & RxJS
zhixin9001 发表于8个月前
Angular基础(八) Observable & RxJS
  • 发表于 8个月前
  • 阅读 26
  • 收藏 0
  • 点赞 0
  • 评论 0

【腾讯云】新注册用户域名抢购1元起>>>   

 

 

 

对于一个应用来说,获取数据的方法可以有很多,比如:Ajax, Websockets, LocalStorage, Indexdb, Service Workers,但是如何整合多种数据源、如何避免BUG、如何提高可维护性、如何提升应用的速度,这些却又是需要解决的问题。MVC是经典的Web应用开发模式,但对于客户端应用却不太适合。针对这点又出现了一些其它的模式,比如MVW(Model-View-Whatever)双向绑定模式、Flux、Observables等。

Angular1采用双向绑定的方式,但到了Angular4,对于数据结构的选择就非常灵活了,可以根据应用的场景自行决定。

 

一、Observables and RxJS

Observables方式属于响应式编程(ReactiveProgramming),数据流是异步传输的,采用Observables方式需要导入RxJS库。接下来通过一个聊天应用的实现了解Observables和RxJS。

a) 聊天应用整体来说包含三部分,聊天列表、对话框、未读消息。相应地有三个Model、三个service。service维护数据流,数据流传输model,组件订阅数据流并渲染界面。

userModel包含is,name, avatarSrc三个属性;

threadModel包含的属性有id, lastMessage, name, avatarSrc;

messageModel包含的属性有 id, isRead, sentAt, anthor, text, thread.

b) UserService

创建的UsersService类需要标记为@Injectable,便于之后的注入。

import{ Subject, BehaviorSubject } from 'rxjs';

@Injectable()

exportclass UsersService {

  currentUser: Subject<User> = newBehaviorSubject<User>(null);

  public setCurrentUser(newUser: User): void {

    this.currentUser.next(newUser);

  }

}

currentUser是一个Subject 类型,接收了一个BehaviorSubject对象,Subject是可读可写的流,同时继承了Observable和Observer。一般来说消息发送到流后,如果没有被接收就会丢失,但可使用BehaviorSubject避免这个问题,BehaviorSubject会保存最后一次的值。

setCurrentUser()会通过Subject.next()将新的值送入流中。

 

c) MessageService

MessageService是这个应用的核心,所有的消息流都会经过这个Service。MessageService首先会包含三个“数据管理流”:newMessage发送新消息、messages发送最近消息的数组、update更新messages流。

update更新messages流时,采用操作流模式(Operation Stream Pattern)。

interfaceIMessagesOperation extends Function {

  (messages: Message[]): Message[];

}

exportclass MessagesService {

  updates: Subject<any> = newSubject<any>();

  constructor() {

    this.messages = this.updates

      .scan((messages: Message[],

             operation: IMessagesOperation)=> {

               return operation(messages);

             },

            initialMessages).

                 .publishReplay(1)

                 .refCount();

传入updates流中的是方法,这个方法的输入和输出都是message数组,为此定义接口IMessagesOperation,然后使用Subject.scan()。

流默认是不共享的,一次读取后流中的数据就会消失,但这个应用中不少地方需要多次读取流,比如最近消息,所以使用了publishReplay和refCount方法。publishReplay设置流可在多个订阅者间共享,并可设置对新加入的订阅者的滞后值。

 

 

学习资料:The Complete Book on Angular by Nate Murray, Felipe Coury, AriLerner , Carlos Taborda

 

  • 打赏
  • 点赞
  • 收藏
  • 分享
共有 人打赏支持
粉丝 5
博文 96
码字总数 76419
×
zhixin9001
如果觉得我的文章对您有用,请随意打赏。您的支持将鼓励我继续创作!
* 金额(元)
¥1 ¥5 ¥10 ¥20 其他金额
打赏人
留言
* 支付类型
微信扫码支付
打赏金额:
已支付成功
打赏金额: