start、watch 无法监听配置

[shima-park]

start、watch 无法监听配置

[shima-park]

修改apollo的配置后，有没有发布配置

[MisterChing]

修改apollo的配置后，有没有发布配置

有发布。不修改apollo配置。在select中也只能打印出最初的一次值

[shima-park]

可以加入日志的参数选项，开启日志，看看具体出现了什么异常。

agolloClient, err := agollo.New(
        "localhost:8080",
        "SampleApp",
        agollo.WithLogger(agollo.NewLogger(agollo.LoggerWriter(os.Stdout))),
        agollo.AutoFetchOnCacheMiss(),
        agollo.PreloadNamespaces("application", "TEST1.json"),
    )

我用上面你给的代码，测试过了是可以的。你再检查下namspace的名字是否正确。

package main

import (
	"fmt"
	"os"
	"time"

	"github.com/shima-park/agollo"
)

func main() {
	agolloClient, err := agollo.New(
		"localhost:8080",
		"SampleApp",
		agollo.WithLogger(agollo.NewLogger(agollo.LoggerWriter(os.Stdout))),
		agollo.AutoFetchOnCacheMiss(),
		agollo.PreloadNamespaces("test.json", "TEST1.json.json"),
	)
	if err != nil {
		panic(err)
	}

	fmt.Println(agolloClient.GetNameSpace("TEST1.json.json"), agolloClient.GetNameSpace("test.json"))
	errChan := agolloClient.Start()
	watchChan := agolloClient.Watch()
	ticker := time.NewTicker(5 * time.Second)
	for {
		select {
		case <-ticker.C:
			fmt.Println("Ticker:",
				"TEST1.json.json", agolloClient.GetNameSpace("TEST1.json.json"), "\n",
				"test.json", agolloClient.GetNameSpace("test.json"),
			)
		case err := <-errChan:
			fmt.Println(err, 0)
		case resp := <-watchChan:
			fmt.Println("Notify:", resp, 0)
		}
	}
}

我在测试的时候就碰到一个坑

图中第二个namespace: TEST1.json 实际namespace是 TEST1.json.json
后面两个namespace: test.json, test.yaml

[MisterChing]

我尝试加了日志，还是不正常。能监听到了，但值没有被修改

[shima-park]

你就用我上一个回复贴的示例代码，改成你的配置试试看。
还有库的tag你看是不是最新的版本v1.2.7