在运行 Go 程序时重新加载配置表

Question

我有一个具有多个 HTTP 处理程序包装器的 Web 服务器。其中之一是 ACL，它作为结构数组从 CSV 加载并传递给 ACL HTTP 处理程序。我希望能够更改 csv 文件以更新新的过滤器条目，而无需重新启动 Web 服务器。

我尝试添加标志，然后使用删除数组的布尔值调用它，并通过调用新的 csv 文件重新加载它。但这并没有真正起作用，它没有调用正在运行的进程中的现有数组表。

实现这一目标的最佳方法是什么？这是我的程序结构，我只是想避免在必须更新 ACL 时重新启动 Web 服务器。我可以使用单独的键值数据库，但在这个阶段我必须保持简单，因为服务器不属于我。

func main() {
    ACL := aclGroup()
    mux := http.NewServeMux()

    srv := &http.Server{
        Handler:        aclAction(logRequestHandler(mux), ACL),
        Addr:           listen,
        ReadTimeout:    5 * time.Second,
        WriteTimeout:   10 * time.Second,
        IdleTimeout:    5 * time.Second,
        MaxHeaderBytes: 1 << 20,
    }

...
}

func aclAction(h http.Handler, acl []*ACLlist) http.Handler {
...
}

Answer 1

一种方法是传递aclAction 一个将返回当前ACLList 的函数，而不是传递ACLList 本身。每当处理程序需要列表时，它应该调用函数来获取它。这样做可以相对简单地实现更新列表的代码（但要确保它是线程安全的！）并且新列表将在下次请求时返回。

这是一个简单的（有些做作和简化的）示例；试试the playground:

package main

import (
    "fmt"
    "sync"
    "time"
)

type ACLlist struct {
    text string
}


// For now the ACL List is stored in a global variable; the true structure is likely to be a bit more complex
var currentList []ACLlist
var mu sync.Mutex

func main() {
    currentList = []ACLlist{{"one"}}
    go aclAction(aclGroup)
    time.Sleep(time.Millisecond) // Give go routine time to get one value

    // Lets update the list (in reality this may run on a timer or you might watch a file)
    mu.Lock() 
    currentList = []ACLlist{{"one"}, {"two"}}
    mu.Unlock()

    // Give the go routine time to request the list again
    time.Sleep(10 * time.Millisecond)
}

// aclGroup returns the current ACL List
func aclGroup() []ACLlist {
    mu.Lock()
    defer mu.Unlock()
    return currentList
}

// aclAction - accepts a function which will be called when the current ACL list is needed
func aclAction(getACL func() []ACLlist) {
    fmt.Printf("First call: %#v\n", getACL())
    time.Sleep(5 * time.Millisecond)
    fmt.Printf("Second Call: %#v]\n", getACL())
}

注意：一种潮汐方法是创建一个具有管理更新功能的 ACLListManager 结构和一个传递给 aclAction 的 getter 方法，但这会使示例代码复杂化。