经过前面几篇的学习，相信大家对nsq已经有了一个大概的了解，我在写这篇文章的时候也看了很多其他人写的教程，发现大家对于分析系统每个点写的很不错，但是都很少有整体串起来一起走一遍，所以，我打算分成2-3章来带着大家从nsq启动到创建一个topic,然后发一条消息，最后再开个消费者接收消息，中间的所有流程都带大家一起走一遍，从而让大家能够深入地理解nsq的整体运行机制。今天，这篇文章是整个 《一条消息的生命周期》第一章，我会从nsq的启动，nsqlookupd连接等方面开始讲起。 启动nsq 相信看了nsq这个系列的童…
diskQueue是backendQueue接口的一个实现。backendQueue的作用是在实现在内存go channel缓冲区满的情况下对消息的处理的对象。 除了diskQueue外还有dummyBackendQueue实现了backendQueue接口。 对于临时（#ephemeral结尾）Topic/Channel，在创建时会使用dummyBackendQueue初始化backend， dummyBackendQueue只是为了统一临时和非临时Topic/Channel而写的，它只是实现了接口，不做任何实质…
这篇文章我们就正式的开始分析nsq的代码了，上一篇给大家介绍了下nsq的特性和功能。再分析代码的同时，大家可以比对着我写的nsq精注版代码一遍看一遍调试。这样的效果更佳。 nsq精注版地址：https://github.com/gwyy/nsq-learn 下面进入正题，nsqd的主函数位于apps/nsqd.go中的main函数。 在初始化的时候，它使用了第三方进程管理包 go-svc 来托管进程，go-svc有三个方法进行管理： func main() { if err := svc.Run(pr…
一、Golang指针与C/C++指针的差别 在Golang支持的数据类型中，是包含指针的，但是Golang中的指针，与C/C++的指针却又不同，笔者觉得主要表现在下面的两个方面： 弱化了指针的操作，在Golang中，指针的作用仅是操作其指向的对象，不能进行类似于C/C++的指针运算，例如指针相减、指针移动等。从这一点来看，Golang的指针更类似于C++的引用 指针类型不能进行转换，如int不能转换为int32 上述的两个限定主要是为了简化指针的使用，减少指针使用过程中出错的机率，提高代码的鲁棒性。但是在开发过程中…
Handler //86 type Handler interface { ServeHTTP(ResponseWriter, *Request) } Handler 是个接口，只要结构体有了 ServeHTTP 这个方法，都可以实现这个接口。 ServeMux & DefaultServerMux //2192行 type ServeMux struct { mu sync.RWMutex m map[string]muxEntry es []muxEntry // slice of ent…
我们继续看，直接进入ListenAndServe函数 func ListenAndServe(addr string, handler Handler) error { server := &Server{Addr: addr, Handler: handler} return server.ListenAndServe() } 可以看到，把addr放到一个Server结构中，并且调用ListenAndServer()。这里面向对象的方法，相当于Java中new一个对象的实例，并且调用该实例的方法。 继续进…
首先，熟悉http协议的都知道，http协议是基于TCP实现的。 http服务器的工作方式大概就是监听socket端口，接受连接，获取到请求，处理请求，返回响应。 所以，对应的会有几个部分 Request：用户请求的信息。post、get、url等这些信息 Response: 返回给客户端的信息 Conn: 用户每次的连接请求 Handler：处理请求和返回信息的逻辑处理 我们直接调用2个方法就可以开启一个http服务器。 func hello(w http.ResponseWriter, r * http…
最近评论
发布于 7 个月前（04月10日）
发布于 7 个月前（04月10日）
发布于 7 个月前（04月02日）