nsqd Main函数

谁借莪１个温暖的怀抱￠ 2023-02-28 15:25 51阅读 0赞

# 源码 #

func (n *NSQD) Main() error {
        
    	ctx := &context{
        n}
    
    	exitCh := make(chan error)//退出chan 无缓存的
    	var once sync.Once
    	exitFunc := func(err error) {
        //定义退出函数
    		once.Do(func() {
        //once 保证只执行一次
    			if err != nil {
        
    				n.logf(LOG_FATAL, "%s", err)
    			}
    			exitCh <- err//只有err返回后 Main才会退出
    		})
    	}
    
    	n.tcpServer.ctx = ctx	//关联ctx nsqd.tcpServer tcpServer.ctx 相互关联。
    	//接下来运行三个后台Server 1. TCPServer 2.HTTPServer 3.HTTPSServer
    	n.waitGroup.Wrap(func() {
        //Wrap就只是封装waitGroup 进去Add 出来Done
    		exitFunc(protocol.TCPServer(n.tcpListener, n.tcpServer, n.logf))//就是普通的TCPServer Listen，accept，do handler
    	})
    
    	httpServer := newHTTPServer(ctx, false, n.getOpts().TLSRequired == TLSRequired)
    	n.waitGroup.Wrap(func() {
        
    		exitFunc(http_api.Serve(n.httpListener, httpServer, "HTTP", n.logf))
    	})
    
    	if n.tlsConfig != nil && n.getOpts().HTTPSAddress != "" {
        
    		httpsServer := newHTTPServer(ctx, true, true)
    		n.waitGroup.Wrap(func() {
        
    			exitFunc(http_api.Serve(n.httpsListener, httpsServer, "HTTPS", n.logf))
    		})
    	}
    
    	n.waitGroup.Wrap(n.queueScanLoop)//queueScanLoop 负责处理延迟消息,算法借鉴 Redis probabilistic expiration algorithm
    	n.waitGroup.Wrap(n.lookupLoop)//启动一个goroutine，处理与nsqlookupd进程的交互
    	if n.getOpts().StatsdAddress != "" {
        
    		n.waitGroup.Wrap(n.statsdLoop)// 处理与stasd进程的交互
    	}
    
    	err := <-exitCh
    	return err
    }

发表评论取消回复

表情：

评论列表（有 0 条评论，51人围观）

还没有评论，来说两句吧...

相关阅读

相关 init函数与main函数

init函数与main函数 init函数 `go`语言中`init`函数用于包`(package)`的初始化，该函数是`go`语言的一个重要特性。有下面的特征：

约定不等于承诺〃/ 2023年10月01日 21:42/ 0 赞/ 100 阅读

相关 Java main()函数

main函数的详解： public ：公共的。权限是最大，在任何情况下都可以访问。原因：为了保证让jvm在任何情况下都可以访问到main方法。 static

淡淡的烟草味﹌/ 2023年05月28日 05:18/ 0 赞/ 48 阅读

相关 nsqd New函数

func New(opts Options) (NSQD, error) { var err error dataPat

深藏阁楼爱情的钟/ 2023年02月28日 15:27/ 0 赞/ 31 阅读

相关 nsqd Main函数

源码 func (n NSQD) Main() error { ctx := &context{ n}

谁借莪１个温暖的怀抱￠/ 2023年02月28日 15:25/ 0 赞/ 52 阅读

相关 C++ main函数

主函数目前我看到的有这几种： int main() int main(int argc, char argv[]) int main(int

ゝ一世哀愁。/ 2023年02月15日 12:42/ 0 赞/ 57 阅读

相关关于main函数

main函数是个什么鬼？提到main函数大家一定不陌生。可是最近看书的时候，发现对它了解甚少。因此在这里做一些总结。 C语言基本组成单位是函数，既然是一个一个函数组成了一个完

清疚/ 2022年07月30日 14:21/ 0 赞/ 305 阅读

相关 main函数前后

void f1(void)__attribute__((constructor)); void f2(void)__attribute__((destructo

「爱情、让人受尽委屈。」/ 2022年06月15日 08:46/ 0 赞/ 235 阅读

相关（main函数）

public static void main(String\[\] arge) 主函数：是一个特殊的函数，作为程序的入口，可以被jvm（虚拟机）调用。主函数的定义：

不念不忘少年蓝@/ 2022年06月08日 00:58/ 0 赞/ 298 阅读

相关 main主函数

public static void main（String\[\] args） \{ //虚拟机调用main函数，需要传个args的参数，传入的是new St

矫情吗；*/ 2022年06月01日 10:26/ 0 赞/ 295 阅读

相关 nsqd中的消息流程

用一张图来看nsqd中的消息流程（可以点击放大查看） ![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cH

╰+哭是因爲堅強的太久メ/ 2022年03月08日 15:15/ 0 赞/ 74 阅读