Apache Kafka由Scala和Java编写，基于生产者和消费者模型作为开源的分布式发布订阅消息系统。它提供了类似于JMS的特性，但设计上又有很大区别，它不是JMS规范的实现，如Kafka允许多个消费者主动拉取数据，而在JMS中只有点对点模式消费者才会主动拉取数据 ...
分类：
其他好文 时间：
2020-12-04 11:04:22
阅读次数：
7
简单应用 我们先来看一个简单的应用示例： <div id="app"> <input id="input" type="text" v-model="text"> <div id="text">输入的值为：{{text}}</div> </div> <script> var vm = new Vue ...
分类：
其他好文 时间：
2020-11-26 15:22:40
阅读次数：
14
Subjects 介绍 1. Subjects 是订阅者，也是Observable 订阅者：它能动态的接收新的值。 Observable： 当Subjects有了新值后会通过Event将新值发出给他的所有订阅者。 2. 常用的方法 onNext(:)：是 on(.next(:)) 的简便写法。该方法 ...
分类：
编程语言 时间：
2020-11-25 12:36:45
阅读次数：
6
map 同 Swift中 map 用法一样，对值进行处理并返回 let sub = PublishSubject<String>() sub.map { $0 + "mmmmm" } .subscribe { event in print(event.element) } .disposed(by: ...
分类：
编程语言 时间：
2020-11-25 12:36:31
阅读次数：
4
distinctUntilChanged 过滤连续重复的事件 let ob = Observable.of(1, 1, 1, 3, 5, 7, 9, 9) ob.distinctUntilChanged().subscribe(onNext: { element in print(element) ...
分类：
编程语言 时间：
2020-11-25 12:36:02
阅读次数：
6
startWith 在订阅的时候插入发送事件，后加入的先发送。完成事件发送时不会插入。 let ob = PublishSubject<String>() ob.startWith("插入1").startWith("插入2").subscribe(onNext: { element in prin ...
分类：
编程语言 时间：
2020-11-25 12:35:08
阅读次数：
3
1.通过rqt_graph指令，可以看到ROS节点之间的关系 从上图中可以看到，有两个节点/teleop_turtle 和 /turtlesim /teleop_turtle节点发布话题,话题名为/turtle1/cmd_vel /turtlesim订阅了该节点 我们已知/teleop_turtle ...
漫画：如何用Zookeeper实现分布式锁？点击上方“程序员小灰”，选择“置顶公众号”有趣有内涵的文章第一时间送达！在上一篇漫画中，小灰介绍了如何使用redis实现分布式锁。没看过的小伙伴可以点击下面链接：漫画：什么是分布式锁？那么，如何用Zookeeper来实现分布式锁呢？这一次我们会为大家详细讲述。什么是临时顺序节点？让我们来回顾一下Zookeeper节点的概念：Zookeeper的数据存储结
分类：
其他好文 时间：
2020-11-20 11:23:17
阅读次数：
2
1.創建隊列及隊列表且启动之 aq_admin login begin --Create a table for queues dbms_aqadm.create_queue_table (queue_table=>'aq_msg_qtab2',queue_payload_type=>'AQ_ADM ...
分类：
数据库 时间：
2020-11-19 12:45:07
阅读次数：
17
漫画：如何将一个链表“逆序”？—————第二天—————（现实里的小灰在刚入行的时候，面试官也问了我这个问题，当时小灰就傻傻的问面试官是单链表还是双链表？然后就没然后了......）————————————让我们从链表头部开始，建立三个临时节点的引用，分别为p1，p2，p3。它们分别指向头节点、第二个节点、第三个节点。实现链表逆序的完整步骤如下：1.以p2节点为视角，把p2节点原本指向p3的nex
分类：
其他好文 时间：
2020-11-18 13:18:03
阅读次数：
9
