文章有点长，亲，要慢慢看！ 1. 概述 1.1 注册中心作用 在Dubbo中，注册中心为核心模块，Dubbo通过注册中心实现各个服务之间的注册与发现等功能，而本次源码的分析为registry模块的api和zookeeper的实现。 服务的提供者和消费者都需要把自己注册到注册中心，提供者让消费者感知到服务存在，从而消费者发起远程调用，也让服务治理中心感知到有服务提供者上线；消费者则是让服务治理中心可以发现自己。 1.2 Zookeeper Zookeeper是一个提供分布式协调服务的开源软件，常用于解决分布式应用中经常遇到的一些数据管理问题。Zookeeper功能非常强大，可以实现如分布式应用配置管理、统一命名服务、状态同步服务、集群管理等功能。关于Zookeeper，大家如果想了解可以关注一...阅读全文
Go不是面向对象的语言，但是使用组合、嵌套和接口可以支持代码的复用和多态。关于结构体嵌套：外层结构体类型通过匿名嵌套一个已命名的结构体类型后就可以获得匿名成员类型的所有导出成员，而且也获得了该类型导出的全部的方法。比如下面这个例子： type ShapeInterface interface { GetName() string } type Shape struct { name string } func (s *Shape) GetName() string { return s.name } type Rectangle struct { Shape w, h float64 } 复制代码Shape类型上定义了GetName()方法，而在矩形Rectangle的定义中匿名嵌套了Sha...阅读全文
微信公众号「后端进阶」，专注后端技术分享：Java、Golang、WEB框架、分布式中间件、服务治理等等。 之前写了一篇关于 RocketMQ 队列与 Kafka 分区副本的区别文章，里面提到了 RocketMQ 的消息冗余主要是通过主备同步机制实现的，这跟 Kafka 分区副本的 Leader-Follower 模型不同，HA（High Available) 指的是高可用性，而 RocketMQ 的HA机制是通过主备同步实现消息的高可用。 HA 核心类 HA 的实现逻辑放在了 store 存储模块的ha目录中，其核心实现类如下： image HAService：主从同步的核心实现类 HAService$AcceptSocketService：主服务器监听从服务器连接实现类 HAServic...阅读全文
如何使用CSS递归选择所有子元素？下面本篇文章就来给大家介绍一下使用CSS递归选择所有子元素的方法，希望对大家有所帮助。 原文地址：如何使用CSS选择所有子元素？当元素是某个元素的子元素时，可以使用子选择器匹配，该选择器选择特定父级的所有子元素。子选择器由两个或多个由“>”分隔的选择器组成；它也称为element > element选择器。注：子选择器只能选择自己的子类，第二级元素，而不能选择第二级别以下的元素。语法：选择指定元素的所有指定子元素element1 > element2如果想要递归选择所有子元素，则使用以下语法 element1 > * { // CSS样式 } 示例1：选择所有子元素 阅读全文
和Windows系统一样，Linux服务器运行过程中也会一些没用的软件服务默认运行，这些占用了很多系统资源，也会有安全隐患，所以一般是建议关闭的。那么，工作中Linux主机到底需要有哪些开机自启动服务呢? 新装Linux系统之后，有必要保留的开机自启动服务有5个： Ø sshd：远程连接Linux服务器时要用到，所以必须开启，不然就无法提供远程连接服务了。 Ø rsyslog：日志相关软件，这是操作系统提供的一种机制，系统的守护程序通常会使用rsyslog程序将各种信息写到各个系统日志文件中。 Ø network：系统启动时，如果想激活或关闭各个网络接口的话，可以考虑开启。 Ø crond：用于周期性的执行系统及用户配置的任务计划。有需要时开启。几乎是运维工作中必须要用的一个软件。 Ø sy...阅读全文
闭包简而言之，是一段有状态的代码。咱试着用闭包来做一个计数器，每次调用，闭包的状态就加1. Go func intSeq() func() int { i := 0 return func() int { i++ return i } } func main() { nextInt := intSeq() fmt.PrintLn(nextInt()) fmt.PrintLn(nextInt()) fmt.PrintLn(nextInt()) } 1 2 3 Rust 由于编译时我们无法知道闭包的体积，所以用一个Box把它套起来。另外，闭包的具体类型是不可描述的，只能用dyn关键字来通过Trait来描述。 fn main() { fn int_seq() -> Box
作者：Adam Presley | 地址：https://adampresley.github.io... 译者前言 本文是关于词法器实现的具体介绍，如果在阅读时遇到困难，建议参考源码阅读，文中的代码片段为了介绍思路。如何解析会在下一篇介绍。 最近简单看了下 Go 源码，在 src/go 目录下有几个模块，token、scanner 和 parser 应该就是 Go 词法相关实现的核心代码，打开 token 目录会发现其中的源码和上一节介绍的内容有诸多相似之处。 由于最近并发任务比较多，不能以最快的速度更新。词法的相关内容，除了本系列，我把其他一些相关文章的链接都贴在下面，如果英文阅读功底不错，可自行阅读。 A look at Go lexer/scanner packages Rob Pi...阅读全文
1、Mac配置环境 1.1 安装go: https://golang.org/dl/ 下载画圈文件，安装即可1.2 配置环境vim ~/.bash_profile 打开配置文件复制下面这些： export PATH="/opt/local/bin:/opt/local/sbin:/usr/local/go/bin:$PATH" export GOROOT=/usr/local/go export GOPATH=/Users/你的go目录/Go export GOBIN=$GOPATH/bin export PATH=$GOBIN:$PATH source ~/.bash_profile 是配置生效 使用 go env 查看go配置 或者 go version 查看版本，这两个命令来检测是否成...阅读全文
作者：Adam Presley | 地址：adampresley.github.io/2015/05/12/… 译者前言 本文是关于词法器实现的具体介绍，如果在阅读时遇到困难，建议参考源码阅读，文中的代码片段为了介绍思路。如何解析会在下一篇介绍。 最近简单看了下 Go 源码，在 src/go 目录下有几个模块，token、scanner 和 parser 应该就是 Go 词法相关实现的核心代码，打开 token 目录会发现其中的源码和上一节介绍的内容有诸多相似之处。 由于最近并发任务比较多，不能以最快的速度更新。词法的相关内容，除了本系列，我把其他一些相关文章的链接都贴在下面，如果英文阅读功底不错，可自行阅读。 A look at Go lexer/scanner packages Rob ...阅读全文
在分布式调度中为了保证服务的高可用和容灾需求，通常都会讲服务在多个区域、机架、节点上平均分布，从而避免单点故障引起的服务不可用，在k8s中自然也实现了该算法即SelectorSpread, 本文就来学习下这个算法的底层实现细节 1. 设计要点 1.1 zone与node zone即代表一个区域，node则是一个具体的节点，而该打散算法的目标就是将pod在zone和node之间进行打散操作 1.2 namespace namespace是k8s中进行资源隔离的实现，同样的筛选也是如此，在筛选的过程中，不同namespace下面的pod并不会相互影响 1.3 计数与聚合 SelectorSpread算法是scheduler中优先级算法的一种，其实现了优先级算法的map/reduce方法，其中ma...阅读全文
server1:package main import ( "fmt" "net" ) func main() { l, err := net.Listen("tcp", "127.0.0.1:9876") if err != nil { fmt.Println(err) } fmt.Println("服务器等待客户端连接") conn, err := l.Accept() if err != nil { fmt.Println(err) } defer conn.Close() fmt.Println("客户端建立连接 ") buf := make([]byte, 4096) n, err := conn.Read(buf) if err != nil { fmt.Println(err)...阅读全文
Go语言的标准库里提供两种类型的计时器Timer和Ticker。Timer经过指定的duration时间后被触发，往自己的时间channel发送当前时间，此后Timer不再计时。Ticker则是每隔duration时间都会把当前时间点发送给自己的时间channel，利用计时器的时间channel可以实现很多与计时相关的功能。 文章主要涉及如下内容： Timer和Ticker计时器的内部结构表示 Timer和Ticker的使用方法和注意事项 如何正确Reset定时器 计时器的内部表示 两种计时器都是基于Go语言的运行时计时器runtime.timer实现的，rumtime.timer的结构体表示如下： type timer struct { pp puintptr when int64 per...阅读全文
golang接口使用记录 1. 总述 接口类型是对其他类型行为的概括与抽象，Go语言的独特之在于它是隐式实现，无需申明它实现哪些接口，只要提供接口所必须的方法即可。 接口即约定 实现单词和行的计数器，考虑使用bufio.ScanWords // counter.go // 计数器 type Counter interface { Count(fileName string) error } // 单词计数 type WordCount int func (w *WordCount) Count(fileName string) error { file, err := os.Open(fileName) if err != nil { return errors.New("open file...阅读全文
在分布式调度中为了保证服务的高可用和容灾需求，通常都会讲服务在多个区域、机架、节点上平均分布，从而避免单点故障引起的服务不可用，在k8s中自然也实现了该算法即SelectorSpread, 本文就来学习下这个算法的底层实现细节 1. 设计要点 1.1 zone与node zone即代表一个区域，node则是一个具体的节点，而该打散算法的目标就是将pod在zone和node之间进行打散操作 1.2 namespace namespace是k8s中进行资源隔离的实现，同样的筛选也是如此，在筛选的过程中，不同namespace下面的pod并不会相互影响 1.3 计数与聚合 SelectorSpread算法是scheduler中优先级算法的一种，其实现了优先级算法的map/reduce方法，其中ma...阅读全文
作者：Adam Presley | 地址：adampresley.github.io/2015/06/01/… 译者前言 最近发现我的翻译是越来越随性了，刚开始文章翻译的时候比较拘束，现在更多强调可读性，比如有些对文章大意没有什么影响的文字我现在都会选择直接跳过。 这篇文章主要是关于 INI 解释器的 parser 实现，它会从上一节中 Lexer 中接收 Token 解析，最终返回给使用者具有实际意义的结构体。读了这个系列的文章，我相信大家对词法器实现的原理将会有了基本的理解，但如果要真正实践，似乎还有一段距离。有兴趣的话，我们可以实现个自己的 JSON 解释器。要求可以稍微简化，只解析到 JSON 的第一层。 译文如下： 本系列第一篇文章，英文原版，我们介绍了词法分析解析的一些基础概念，...阅读全文
作者：Adam Presley | 地址：https://adampresley.github.io... 译者前言 最近发现我的翻译是越来越随性了，刚开始文章翻译的时候比较拘束，现在更多强调可读性，比如有些对文章大意没有什么影响的文字我现在都会选择直接跳过。 这篇文章主要是关于 INI 解释器的 parser 实现，它会从上一节中 Lexer 中接收 Token 解析，最终返回给使用者具有实际意义的结构体。读了这个系列的文章，我相信大家对词法器实现的原理将会有了基本的理解，但如果要真正实践，似乎还有一段距离。有兴趣的话，我们可以实现个自己的 JSON 解释器。要求可以稍微简化，只解析到 JSON 的第一层。 译文如下： 本系列第一篇文章，英文原版，我们介绍了词法分析解析的一些基础概念，了解...阅读全文
golang中有个神奇的函数init,该函数会在所有程序执行开始前被调用，每个包可以包含多个init函数，所有被编辑器识别到的init函数都会在main函数执行前被调用。通常被用来注册一个程序需要使用的依赖，如mysql注册，配置文件加载等。 在main包的使用 package main import "fmt" func main() { fmt.Println("这里是mian") } func init() { fmt.Println("这里是Init1") } func init() { fmt.Println("这里是Init2") } //输出结果 这里是Init1 这里是Init2 这里是main 一个很简单的示例，可以看到init函数是在main函数执行之前被执行的，并且一个...阅读全文
