一对多的关系(发布,订阅) 1,一个按钮,绑定多个相同的点击事件。 2,一个promise 绑定多个then 3,jquery 4,vue中的watch 5,vue和react中的生命周期 ...
分类:
其他好文 时间:
2020-12-14 12:46:57
阅读次数:
3
cmd打开窗口redis-server.exe redis.windows.conf cmd打开另一个窗口redis-cli.exeset key1 ligyget key1ligy 发布订阅cmd打开另一个窗口redis-cli.exesubscribe channel1 cmd打开另一个窗口re ...
分类:
其他好文 时间:
2020-12-08 12:32:29
阅读次数:
5
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
今天抛一个话题,根据业务现象,一起讨论其后端实现是推还是拉?一、feed流可以理解为一个发布订阅业务,典型业务是微博(朋友圈)。你关注了姚晨的微博,姚晨发布了消息,你的主页能看到她最新发布的消息,这个场景是推送,还是拉取呢?画外音:微博是弱关系,关注无需对方同意,粉丝可以无上限;朋友圈是强关系,好友需要对方同意,好友个数有上线。如果推送,姚晨发布消息的时候,要把消息ID投递到所有粉丝的主页消息队列
分类:
其他好文 时间:
2020-11-18 12:21:07
阅读次数:
4
AMQP,即Advanced Message Queuing Protocol,高级消息队列协议,是应用层协议的一个开放标准,为面向消息的中间件设计。消息中间件主要用于组件之间的解耦,消息的发送者无需知道消息使用者的存在,反之亦然。 AMQP的主要特征是面向消息、队列、路由(包括点对点和发布/订阅) ...
分类:
其他好文 时间:
2020-11-13 13:06:15
阅读次数:
7
在上篇文章《消息系统概述》中对消息系统进行了介绍,本次将学习Kafka中的基本概念。首先我们回顾下在消息系统的使用场景中有三种角色分别是生产者、消息系统和消费者,其中生产者负责产生消息和发送消息到消息系统,而消息系统将为消费者提供消息用于处理,如下图。Kafka是基于发布/订阅模式的消息系统,如下图。生产者会将消息推送到Kafka中的某个Topic上。引入Topic的目的则是为了对消息进行分类,这
分类:
其他好文 时间:
2020-10-27 11:52:37
阅读次数:
24
1. 说明一下主要逻辑 当我们发送多个请求时使用的时同一个接口,并且这个接口支持多个参数获取多个条数据,而我们不想要每次请求一条数据就发送一条请求 而是在指定的时间段类发送一次请求,得到一些数据,然后把这些数据 返回到对应的发起请求的地方 2. 使用场景 比如像QQ聊天会有一个联系人列表,这个列表每 ...
分类:
编程语言 时间:
2020-10-24 11:53:23
阅读次数:
41
RPC和消息队列 1 消息队列 1 两个服务调用:restful(http协议),rpc(远程过程调用) 2 rpc:远程过程调用 -gRPC:谷歌出的,跨语言 3 不管用rpc或者restful来通信,涉及到同步,异步 4 消息队列解决的问题 -应用解耦 -流量消峰 -消息分发(发布订阅:观察者模 ...
分类:
其他好文 时间:
2020-10-22 22:15:29
阅读次数:
23
1.1 列表的局限 前面我们说通过队列的 rpush 和 lpop 可以实现消息队列(队尾进队头出),但是消费者需要不停地调用 lpop 查看 List 中是否有等待处理的消息(比如写一个 while 循环)。 为了减少通信的消耗,可以 sleep()一段时间再消费,但是会有两个问题: 1、如果生产 ...
分类:
其他好文 时间:
2020-10-14 20:38:26
阅读次数:
21