toArray 将所有的事件集合在一起作为一个数组发出,需要发送onCompleted事件 let ob = PublishSubject<String>() ob.toArray().subscribe { strArr in print(strArr) } onError: { _ in }.d ...
分类:
编程语言 时间:
2020-11-25 12:34:52
阅读次数:
3
虽然redis实现了发布订阅(publish/subscribe)的功能,但是在通常的情况下是不推荐使用的,如果想使用消息队列这种功能,最好还是使用专业的各种MQ中间件,例如rabbitMQ,rockedMQ,activitedMQ等,本文主要讲一下不推荐使用redis的发布订阅功能的原因。 概要说 ...
分类:
其他好文 时间:
2020-09-17 10:48:25
阅读次数:
55
高级特性 简单消息队列 可以用list的rpush+lpop实现简单的消息队列功能(用blpop可以阻塞连接直到有消息时才返回) 发布订阅模式 消费者通过subscribe订阅一个频道,生产者通过publish发布消息到频道,实现多条发布。 通过unsubscribe取消订阅。 订阅的频道可以用通配 ...
分类:
其他好文 时间:
2020-07-17 22:07:32
阅读次数:
87
1:所有的发布订阅就是一个对象。 class Obersve { event={} //等价于下面的constructor // constructor() { // this.event = {} // } subscribe(type, fn) { //订阅 if (Object.keys(th ...
分类:
其他好文 时间:
2020-07-15 15:47:31
阅读次数:
68
[TOC] 一.场景介绍 最近的一个项目需要用到发布/订阅的信息系统,以做到最新实时消息的通知。经查找后发现了redis pub/sub(发布/订阅的信息系统)可以满足我的开发需求,而且学习成本和使用成本也比较低。 二.什么是redis pub/sub 资料查看 大家在看我的blog的同时可以打开r ...
分类:
Web程序 时间:
2020-07-11 12:43:16
阅读次数:
81
Redis的发布与订阅,有点类似于消息队列,发送者往频道发送消息,频道的订阅者接收消息。 1. 发布与订阅示例 首先,在本机开启第1个Redis客户端,执行如下命令订阅blog.redis频道: SUBSCRIBE "blog.redis" 然后,在本机开启第2个Redis客户端,执行相同的命令订阅 ...
分类:
其他好文 时间:
2020-06-30 10:44:54
阅读次数:
61
工作模式: 1、简单模式 HelloWorld : 一个生产者、一个消费者,不需要设置交换机(使用默认的交换机) 2、工作队列模式 Work Queue: 一个生产者、多个消费者(竞争关系),不需要设置交换机(使用默认的交换机) 3、发布订阅模式 Publish/subscribe: 需要设置类型为 ...
分类:
其他好文 时间:
2020-06-28 18:11:23
阅读次数:
46
在vue框架中,使用了观察者模式和发布订阅模式,因此面试中常常会被问到: 观察者模式:观察者(Observer)直接订阅(Subscribe)主题(Subject),而当主题被激活的时候,会触发(Fire Event)观察者里的事件。 代码: // 被观察者 (小宝宝) class Subject ...
分类:
其他好文 时间:
2020-06-08 00:22:53
阅读次数:
74
未添加 EventBus的混淆,所以在Debug版本中不报错在混淆文件“proguard-rules.pro”中添加: 1 ### eventbus 2 -keepattributes *Annotation* 3 -keepclassmembers class ** { 4 @org.greenr ...
分类:
其他好文 时间:
2020-05-29 12:13:10
阅读次数:
211
一、简介EventBus是由greenrobot 组织贡献的一个Android事件发布/订阅轻量级框架。EventBus是一个Android端优化的publish/subscribe消息总线,简化了应用程序内各组件间、组件与后台线程间的通信。比如请求网络,等网络返回时通过Handler或Broadc ...
分类:
移动开发 时间:
2020-05-07 15:14:23
阅读次数:
84