我正在像這樣初始化我的代理： conf := serf.DefaultConfig() conf.NodeName = "node-a" conf.MemberlistConfig.BindAddr = "127.0.0.1" conf.MemberlistConfig.BindPort = 6666 conf.MemberlistConfig.AdvertiseAddr = "127.0.0.1" conf.MemberlistConfig.AdvertisePort = 6666我還有一個(gè)客戶端代碼試圖連接到 RPC 客戶端： c, err := client.NewRPCClient("127.0.0.1:7373") if err != nil { fmt.Println("error creating RCP Client:", err) return }我啟動我的代理，我看到了這個(gè)輸出：2020/05/06 07:15:18 [INFO] serf: EventMemberJoin: node-a 127.0.0.1[{node-a 127.0.0.1 6666 map[] alive 1 5 2 2 5 4}]當(dāng)我啟動我的客戶時(shí)，我得到了這個(gè)：error creating RCP Client: dial tcp 127.0.0.1:7373: connect: connection refused如果我使用 CLI 啟動代理，如下所示：serf agent -bind=0.0.0.0:6667 -advertise=0.0.0.0:6667 -join=0.0.0.0:6666 -node=agent-2 -log-level=debug并運(yùn)行我的客戶端代碼，它會連接到 RPC 客戶端。我確信我的代碼或我對 Serf 工作原理的理解存在錯(cuò)誤。
2 回答
函數(shù)式編程
TA貢獻(xiàn)1807條經(jīng)驗(yàn) 獲得超9個(gè)贊
這是因?yàn)楫?dāng)您在 Go 中運(yùn)行 serf 時(shí)serf.Create（我假設(shè)您將上述配置傳遞給），它只會啟動與配置中提到的端口的連接，而不會啟動 RPC 服務(wù)。
但是，當(dāng)serf agent它運(yùn)行時(shí)，它還會在端口 7373 上生成一個(gè)偵聽器。
這是我假設(shè)您正在為代理運(yùn)行的程序：
package main
import (
"fmt"
"github.com/hashicorp/serf/serf"
"os"
"os/signal"
"syscall"
"time"
)
func main() {
c := make(chan os.Signal)
signal.Notify(c, os.Interrupt, syscall.SIGTERM)
go func() {
<-c
fmt.Println("\r- Ctrl+C pressed")
os.Exit(0)
}()
conf := serf.DefaultConfig()
conf.NodeName = "node-a"
conf.MemberlistConfig.BindAddr = "127.0.0.1"
conf.MemberlistConfig.BindPort = 6666
conf.MemberlistConfig.AdvertiseAddr = "127.0.0.1"
conf.MemberlistConfig.AdvertisePort = 6666
serf.Create(conf)
for {
fmt.Println("- Sleeping")
time.Sleep(10 * time.Second)
}
}
使用netcat，你可以看到是這樣的：
#running my go program
$ nc localhost 7373 -v
nc: connectx to localhost port 7373 (tcp) failed: Connection refused
nc: connectx to localhost port 7373 (tcp) failed: Connection refused
如果該 TCP 端口已綁定，則與此輸出對比：
#running serf agent
$ nc localhost 7373 -v
Connection to localhost port 7373 [tcp/*] succeeded!
縹緲止盈
TA貢獻(xiàn)2041條經(jīng)驗(yàn) 獲得超4個(gè)贊
我終于明白我做錯(cuò)了什么。
我的目標(biāo)是擁有一個(gè) Serf 集群并使節(jié)點(diǎn)相互通信。為此，我必須像我一樣啟動 serf 服務(wù)，但不需要客戶端，節(jié)點(diǎn)在加入集群后相互通信。
我將按照我嘗試的方式使用 Serf 客戶端，前提是我通過 Serf cli 啟動 Serf 代理。
- 2 回答
- 0 關(guān)注
- 115 瀏覽
添加回答
舉報(bào)
0/150
提交
取消