#kafka ##1.kafka基础架构 Kafka是一个分布式的基于发布/订阅模式的消息队列，主要应用于大数据实时处理领域。 消息生产者（发布）将消息发布到topic中，同时有多个消息消费者（订阅）消费该消息。和点对点方式不同，发布到topic的消息会被所有订阅者消费。 （1）Producer ： ...
分类：
其他好文 时间：
2021-01-30 12:13:24
阅读次数：
0
class EventBus { constructor(){} handlerBus={} //注册 $on(eventName,handler){ if(!this.handlerBus.hasOwnProperty(eventName)){ this.handlerBus[eventName] ...
分类：
Web程序 时间：
2021-01-22 12:01:16
阅读次数：
0
发布订阅模式是 生产者 通过这个路由发送到绑定额多个队列中去,然后不同的 消费者 消费不同的队列 从而做到发布订阅模式 1. 生产者 using RabbitMQMsgProducer.MessageProducer; using Microsoft.Extensions.Configuration ...
分类：
其他好文 时间：
2021-01-19 12:14:10
阅读次数：
0
Solon rpc 之 SocketD 协议 Solon rpc 之 SocketD 协议 - 概述 Solon rpc 之 SocketD 协议 - 消息上报模式 Solon rpc 之 SocketD 协议 - 消息订阅模式 SocketD 是一种二进制的点对点通信协议，是一种新的网络通信第七层 ...
分类：
其他好文 时间：
2021-01-12 10:53:22
阅读次数：
0
一、什么是消息中间件 消息队列中间件是指利用高效可靠的消息传递机制进行与平台无关的数据交流，并基于数据通信来进行分布式系统的集成。它一般有两种传递模式：点对点模式和发布/订阅模式。 消息中间件能够在不同平台之间进行通信，它常用来屏蔽各种平台及协议之间的特性，实现应用程序之间的协同，其优点在于能够在客 ...
分类：
其他好文 时间：
2021-01-06 12:05:00
阅读次数：
0
Kafka概述 定义 Kafka是一个分布式的基于发布/订阅模式的消息队列（Message Queue），主要应用于大数据实时处理领域。 传统消息队列的应用场景 使用消息队列的好处 1:解耦 允许你独立的扩展或修改两边的处理过程，只要确保它们遵守同样的接口约束。 2:可恢复性 系统的一部分组件失效时 ...
分类：
其他好文 时间：
2021-01-02 10:52:13
阅读次数：
0
在上篇文章《消息系统概述》中对消息系统进行了介绍，本次将学习Kafka中的基本概念。首先我们回顾下在消息系统的使用场景中有三种角色分别是生产者、消息系统和消费者，其中生产者负责产生消息和发送消息到消息系统，而消息系统将为消费者提供消息用于处理，如下图。Kafka是基于发布/订阅模式的消息系统，如下图。生产者会将消息推送到Kafka中的某个Topic上。引入Topic的目的则是为了对消息进行分类，这
分类：
其他好文 时间：
2020-10-27 11:52:37
阅读次数：
24
1.1 列表的局限 前面我们说通过队列的 rpush 和 lpop 可以实现消息队列（队尾进队头出），但是消费者需要不停地调用 lpop 查看 List 中是否有等待处理的消息（比如写一个 while 循环）。 为了减少通信的消耗，可以 sleep()一段时间再消费，但是会有两个问题： 1、如果生产 ...
分类：
其他好文 时间：
2020-10-14 20:38:26
阅读次数：
21
new new用构造函数创建实例对象，为实例对象添加this属性和方法。 new在调用过程中实现了以下几个步骤： 创建一个新的对象 链接到原型，将该对象 obj 的原型链指向构造函数的原型 prototype 绑定this，让this变量指向这个新创建的对象 返回新对象 1 function cre ...
分类：
移动开发 时间：
2020-10-12 20:04:55
阅读次数：
32
RabbitMQ 路由模式 在发布和订阅模式中，我们构建了一个简单的日志系统。我们能够向多个接收者广播日志消息。 在路由模式，我们将向其添加一个特性—我们将只订阅所有消息中的一部分。例如，我们只接收关键错误消息并保存到日志文件(以节省磁盘空间)，同时仍然能够在控制台上打印所有日志消息。 绑定 Bin ...
分类：
其他好文 时间：
2020-09-10 23:00:53
阅读次数：
54
