gopls setting.md : https://github.com/golang/tools/blob/master/gopls/doc/settings.md#directoryfilters-string
directoryFilters 配置：https://newreleases.io/project/github/golang/tools/release/gopls%2Fv0.6.0
具体代码逻辑应该是在/Users/bytedance/kulvenv/vim/bundle/YouCompleteMe/third_party/ycmd/third_party/go/pkg/mod/golang.org/x/tools@v0.1.1-0.20210119222907-0a1a9685734a/internal/lsp
x
接下来的问题是看怎么把 directoryFilters 参数传递给gopls了。可能是传给lsp.
之前的文章讲过P2P模块的UDP节点发现机制以及TCP连接池机制，接下来讲一下连接池后面，连接到一个新的节点后，接下来的流程是什么样的，怎么开始的区块同步，交易同步等。
阅读全文...
geth的P2P模块有2个重要的部分：基于UDP的节点发现模块 以及 TCP数据传输连接池模块。
之前讲过节点发现部分，用来根据设置的少了BootstrapNodes节点来发现更多全网的其他节点，这部分只是发现节点并找出其中可以ping通的节点，但是还没有进行使用，还没建立TCP连接进行数据传输，协议处理等。
这里分析一下P2P系统的TCP连接池是怎么建立的，以及是怎么跟其他节点通信的。
上篇文章分析到了p2p模块是怎么通过UDP协议去测试其他节点的连通性的（geth以太坊源码分析-P2P模块基于UDP的服务发现机制原理（1））。接下来分析一下是怎么发现其他邻近节点的。
节点发现主要是findnode, neighbors消息的处理。
阅读全文...
以太坊的底层P2P模块承担了节点之间的通信和服务发现，新节点发现连接的功能，对于geth来说，P2P模块氛围2个部分：
- 节点发现， 怎么发现附近的其他节点；
- 节点连接，怎么去连接其他节点并互相通信；
以太坊使用UDP进行服务发现，通讯内容比较简单，所以没有加密。而使用TCP进行真正的数据传输和交互，这部分是使用加密连接进行传输的。
上一篇geth以太坊源码学习-启动服务1写到geth（）入口函数，这里继续后面看看以太坊是怎么创建一个节点，并且启动服务的。
再看下geth函数，主要是节点创建函数makeFullNode 和启动函数 startNode ， 后者会创建协程启动节点，然后进入等待状态。
上篇文章介绍了一下nsqlookupd 启动服务的简单流程，限于篇幅到这里来写一下nsqlookupd主要的工作：通道注册登记，以及查询服务。
nsqlookupd 有两个主要的功能：
- nsqd来注册所有topic、channel的分布信息，nsqlookupd记录哪些topic在哪些机器上；
- 给消费端来查询对应的topic所在的机器列表，以供订阅消费；
之前的文章写了nsqd的代码逻辑，这里简单介绍一下作为负载均衡或者消息topic/channel汇总的nsqlookupd 的实现原理。相对来说nsqlookupd 比nsqd简单很多，不需要持久化，不需要太多的携程，也没有那么多channel。因此这里简单介绍一下。
nsqlookupd作为其他nsqd的中心，主要负责topic的等级注册，以及channel的登记注册，topic位置查询等服务。生产者一般可以不用连接nsqlookupd，但是消费者在消费时，如果是分布式环境就得连接nsqlookupd，查询指定topic在哪些机器上，进而连接对应的机器，SUB上去消费内容。这里类似redis的集群方案，只是redis集群是纯分散的，而nsqd则是把这个任务交给了nsqlookupd, 这样有利有弊，设计结构复杂一些，但是nsqlookupd的存在让服务维护容易，并且模块清晰一些。
这里记录一下消息的消费者订阅流程，配合上面文章写的消息发送流程。不过这里暂时没讲lookupd的过程，后面在详细介绍。
本文从消息发送者的PUB到最后消息被SUB接收，整个流程串起来讲一下nsqd是怎么接收消息的，这部分先写发送流程。
写一下Channel的实现，比topic相对简单一些，但channel是最接近消费者端的，有他特有的东西，包括投递，确认等；
nsqd的channel的作用在于能对指定的队列topic，进行多份投递，或者说消费，一份队列可以给多个消费者重复消费，有点类似于kafka的consumer_group，每个consumer_group拥有独立的position， 不同group之间可以消费同一份内容的多个副本。
这里稍微做个对比，kafka的已经消费国的消息是可以继续保留的，而nsq则如果消费完了，就会删除掉，也就是没有position可以供回溯，或者重复消费，只要客户端发发送FIN后，消息就会销毁，也不会保留在磁盘上面，这点比kafka简单多了，当然，轻量级消息队列也不太需要这么复杂的功能。
前段时间了解Go语言，开始了解Go的优秀开源服务，所以找出NSQ学习一下，下载了一份nsq源码开始学习，顺便记录一下阅读的笔记。
对协程实现原理感兴趣的话推荐看一看libtask，几年前在看源码的时候写过2篇笔记，里面有代码和注释：libtask协程库实现源码学习
NSQ是一个实时分布式消息处理服务，支持分布式，其源码包括：
1. nsqd 作为一个主要的消息接受，发送， 跟客户端沟通的后台进程，负责监听客户端连接，处理客户端的发送接收请求；
2. nsqlookupd 是一个管理进程，其他所有nsqd启动会尝试不断连接他，上报topic信息等；
3. nsqadmin 管理进程；
4. 其他便利工具；
近期评论