用户登录

Saga 可以订阅监听应用里发生的事件,然后可以做出不同的反应,在 Saga 里面可以使用 rxjs 提供的各种操作员方法处理事件,可以在 Saga 里执行新的命令。

在 user 模块里面,新建一个文件,放在 sagas 里面,名字可以随便定义,比如 user.saga.ts,在这个文件里可以定义一个类,类里面添加一些 Saga 方法,它们可以去订阅处理事件流。

export 一个 class,名字可以叫做 UserSaga,在这个类的上面,添加一个 @Injectable 装饰器,它来自 @nestjs/common。

打开 UserModule 模块,在模块里配置一个 Provider,添加一个 UserSaga。

回到 UserSaga 类,在这个类里面可以定义一些 Saga 方法,添加一个方法,名字是 demoSaga,让这个方法变成一个 Saga 方法,需要在方法的上面,用 Saga 装饰器装饰一下。

这样这个方法里面可以接收一个事件流参数,名字是 events$,因为它是一个 Observable ,所以名字后面一般会加上 $ 后缀。类型是 Observable any 。

在方法里面,return 的是,用一下 events$ 这个事件流,应用里发生的事情都会出现在这个事件流里面,它是一个 Observable,所以可以使用 pipe 方法,接上一个管道,然后在这个方法里,可以使用 rxjs 提供的一些操作员方法去处理这个事件流上的事件。

可以先用一个 map 操作员,它来自 rxjs/operators,在文件顶部,从这个 rxjs/operators 里面导入一些操作员,先导入一个 map。

然后给这里用的这个 map 提供一个函数参数, 这个函数可以有个 event 参数,这里这个 event 就是 events$ 事件流上的事件。用一下 console.log 输出一个 DemoSaga: 后面再加上这个 event 参数的值。

rxjs 提供了大量的操作员方法可以使用各种方法处理数据流,比如我想延迟一点时间再在控制台上输出这个事件流里的事件,上面可以再添加一个 delay 操作员,它的参数设置成 3000,意思就是延迟 3 秒钟。

测试

打开一个 Http 客户端,再用 POST 方法带着 JSON 数据请求一下 users 这个接口。打开运行项目的终端观察一下。

过了一会儿,会输出一个 DemoSaga,后面是一个 UserCreatedEvent 事件,请求接口,执行了一个 CreateUser 命令,在这个命令的处理器那里会发布一个 UserCreatedEvent 事件,我们定义的 Saga 里面,可以获取到事件流。

demoSaga 做的事情就是,延迟了 3 秒钟,然后在控制台上输出 DemoSaga,冒号,后面是事件流上的事件。

Sagas:订阅事件流并做出反应《 企业应用架构:事件驱动 》

统计

11686
分钟
0
你学会了
0%
完成

社会化网络

关于

微信订阅号

扫描微信二维码关注宁皓网,每天进步一点