func main() { f, err := os.OpenFile("debug.log", os.O_RDWR, 0666) if err != nil { panic(err) } go func() { defer f.Write([]byte("2")) for { f.Write([] ...
分类：
其他好文 时间：
2020-03-12 09:18:24
阅读次数：
47
一.项目搭建 1.步骤 建立一个空项目，添加两个springboot模块：provide-server和consumer-server 一个提供服务另一个消费服务（略） 两个模块的pom.xml中都导入依赖 编写provide-server代码 编写consumer-server代码 启动dubbo ...
分类：
编程语言 时间：
2020-03-09 17:57:44
阅读次数：
59
Dubbox 致力于提供高性能和透明化的RPC远程服务调用方案，以及SOA服务治理方案。 节点角色说明： ? Provider: 暴露服务的服务提供方。 Consumer: 调用远程服务的服务消费方。 Registry: 服务注册与发现的注册中心。 Monitor: 统计服务的调用次数和调用时间的监 ...
分类：
其他好文 时间：
2020-03-08 14:02:24
阅读次数：
72
Now, let's say we would like to give a specific consumer a higher rate-limit. For this, we can create a KongPlugin resource and then associate it with ...
分类：
其他好文 时间：
2020-03-07 20:25:17
阅读次数：
80
一：推文 Kafka学习之路 （一）Kafka的简介 Kafka学习之路 （二）Kafka的架构 Kafka学习之路 （三）Kafka的高可用 Kafka学习之路 （四）Kafka的安装 Kafka学习之路 （五）Kafka在zookeeper中的存储 二：Kafka架构原理 （一）Kafka应用场 ...
分类：
其他好文 时间：
2020-03-07 16:22:14
阅读次数：
77
1.redis消息模式 发布消息通常有两种模式分为：队列模式（queuing）和发布订阅模式（publish-subscribe）。 队列模式中，consumers可以同时从服务端读取消息，每个消息只被其中一个consumer读到。 发布订阅模式中消息被广播到所有的consumer中，topic中的 ...
分类：
其他好文 时间：
2020-03-06 01:19:35
阅读次数：
100
YAML遵循流程的标准程序。YAML中的本机数据结构包括简单表示，例如:节点。 它也称为表示节点图。 它包括映射，序列和标量，正在序列化以创建序列化树。通过序列化，对象将使用字节流进行转换。 序列化事件树有助于创建字符流的表示，反向过程将字节流解析为序列化事件树。 之后节点将转换为节点图。之后在YA ...
分类：
其他好文 时间：
2020-03-06 00:59:05
阅读次数：
94
package main import ( "fmt" "time" ) func consumer(cname string, ch chan int) { //可以循环 for i := range ch 来不断从 channel 接收值，直到它被关闭。 for i := range ch { ...
分类：
其他好文 时间：
2020-03-04 12:56:55
阅读次数：
274
1.Kafka文件存储基本结构 1）在Kafka文件存储中，同一个topic下有多个不同partition，每个partition为一个目录，partiton命名规则为topic名称+有序序号，第一个partiton序号从0开始，序号最大值为partitions数量减1 2）每个partion(目录 ...
分类：
其他好文 时间：
2020-03-03 22:34:12
阅读次数：
102
什么是再平衡 所谓的再平衡，指的是在kafka consumer所订阅的topic发生变化时发生的一种分区重分配机制。一般有三种情况会触发再平衡： consumer group中的新增或删除某个consumer，导致其所消费的分区需要分配到组内其他的consumer上； consumer订阅的top ...
分类：
其他好文 时间：
2020-03-03 20:35:52
阅读次数：
86
