go routine with net/http 使用 viper 配置动态创建

Question

我让 viper 在 config.yml 中提供以下值并在此处附加其余配置：

servers:
  - projectname: test
    directory: D:\playgroud\test
    port: 1029
  - projectname: test1
    directory: D:\playground\test1
    port: 1030

Coniguration.go 包含

package config

import ()

type Configuration struct {
    Servers []ServerConfiguration
}



package main

    import (
        "config"
        "github.com/spf13/viper"
        "log"
        "net/http"
    )

Server.go

package config

type ServerConfiguration struct {
    ProjectName string
    Directory string
    Port string
}

Main.go

    func main() {

        viper.SetConfigName("config")
        viper.AddConfigPath(".")
        var configuration config.Configuration

        if err := viper.ReadInConfig(); err != nil {
            log.Fatalf("Error reading config file, %s", err)
        }
        err := viper.Unmarshal(&configuration)
        if err != nil {
            log.Fatalf("unable to decode into struct, %v", err)
        }
        counter := 0
        finish := make(chan bool)
        for _, h := range configuration.Servers {

            counter = counter +1
            log.Println(counter)
            counter :=  http.NewServeMux()
            counter.HandleFunc("/"+h.ProjectName, foo8001 )
            go func() {
                http.ListenAndServe(":"+h.Port, counter)
            }()

        }
        <-finish
    }

    func foo8001(w http.ResponseWriter, r *http.Request) {
        w.Write([]byte("Listening on 8001: foo "))
    }

但是当我运行服务器时，我只看到一个服务器在 1030 和 1029 服务，似乎进程已经结束。

这是输出：

2018/02/25 03:53:30 1
2018/02/25 03:53:30 2

我在这里做错了什么，感谢任何见解以更好地理解它，也感谢任何想法或建议。

提前致谢！

Answer 1

这可能是因为你的端口在启动之前在循环中改变，最安全的方法是将参数传递给 goroutine，并将对 h 参数的所有调用移动到 goroutine。类似的东西应该可以工作

for _, h := range configuration.Servers {
        counter = counter + 1
        log.Println(counter)
        go func(h ServerConfiguration) {
            server := http.NewServeMux()
            server.HandleFunc("/"+h.ProjectName, foo8001)
            http.ListenAndServe(":"+h.Port, server)
        }(h)
}

go routine with net/http 使用 viper 配置动态创建

go routine with net/http dynamically created using viper config

http

go

viper-go