#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
EDI电子数据交换是指以标准化商业文档,实现点对点的连接。本质上来说,通过EDI方式交换业务数据信息,可以提高传输速率,数据准确性和生产效率。但不同的客户都有自己不同的内部业务模式,标准化的EDI报文在这些业务模式中是如何应用的呢?本文以Arrow EDI项目为例,为大家介绍不同的业务模式与EDI报 ...
分类:
其他好文 时间:
2021-01-21 10:38:00
阅读次数:
0
发布订阅模式是 生产者 通过这个路由发送到绑定额多个队列中去,然后不同的 消费者 消费不同的队列 从而做到发布订阅模式 1. 生产者 using RabbitMQMsgProducer.MessageProducer; using Microsoft.Extensions.Configuration ...
分类:
其他好文 时间:
2021-01-19 12:14:10
阅读次数:
0
Redis除了提供5种基本数据结构外,还提供了一些附加功能: 慢查询分析 Redis Shell Pipeline 事务与Lua Bitmaps HyperLogLog 发布订阅 GEO 慢查询分析 Redis客户端执行一条命令分为4个部分: 发送命令 命令排队 命令执行 返回结果 慢查询只统计步骤 ...
分类:
其他好文 时间:
2021-01-19 11:41:30
阅读次数:
0
Solon rpc 之 SocketD 协议 Solon rpc 之 SocketD 协议 - 概述 Solon rpc 之 SocketD 协议 - 消息上报模式 Solon rpc 之 SocketD 协议 - 消息订阅模式 SocketD 是一种二进制的点对点通信协议,是一种新的网络通信第七层 ...
分类:
其他好文 时间:
2021-01-12 10:53:22
阅读次数:
0
1. 简介 SocketD 是一种二进制的点对点通信协议,是一种新的网络通信第七层协议。旨在用于分布式应用程序中。从这个意义上讲,SocketD可以是RSocket等其他类似协议的替代方案。它的消息协议规范具有异步,背压的双向,多路复用,断线重连,基于消息等特性。暂时只提供Java实现,目前做为So ...
分类:
其他好文 时间:
2021-01-12 10:48:09
阅读次数:
0
一、什么是消息中间件 消息队列中间件是指利用高效可靠的消息传递机制进行与平台无关的数据交流,并基于数据通信来进行分布式系统的集成。它一般有两种传递模式:点对点模式和发布/订阅模式。 消息中间件能够在不同平台之间进行通信,它常用来屏蔽各种平台及协议之间的特性,实现应用程序之间的协同,其优点在于能够在客 ...
分类:
其他好文 时间:
2021-01-06 12:05:00
阅读次数:
0
一、谈谈你是如何理解JS异步编程的,EventLoop、消息队列都是做什么的,什么是宏任务,什么是微任务? 1. 异步编程:回调函数、事件监听、发布/订阅、Promises对象 2. EventLoop是主线程从"任务队列"中读取事件,这个过程是循环不断的,所以整个的这种运行机制又称为Event L ...
分类:
Web程序 时间:
2021-01-05 11:31:05
阅读次数:
0
Kafka概述 定义 Kafka是一个分布式的基于发布/订阅模式的消息队列(Message Queue),主要应用于大数据实时处理领域。 传统消息队列的应用场景 使用消息队列的好处 1:解耦 允许你独立的扩展或修改两边的处理过程,只要确保它们遵守同样的接口约束。 2:可恢复性 系统的一部分组件失效时 ...
分类:
其他好文 时间:
2021-01-02 10:52:13
阅读次数:
0