zookeeper 集群问题

[miibyxs]

注册中心使用zookeeper集群方式时，服务无法正常注册到注册中心

日志信息如下：

• server.ERROR

  Log file created at: 2019/04/17 16:05:36
  Running on machine: noone
  Binary: Built with gc go1.12.4 for linux/amd64
  Log line format: [IWEF]mmdd hh:mm:ss.uuuuuu threadid file:line] msg
  E0417 16:05:36.055643   12645 motan.go:282] [ZkRegistry] connect server error. err:lookup : no such host

• client.ERROR

  Log file created at: 2019/04/17 16:05:57
  Running on machine: noone
  Binary: Built with gc go1.12.4 for linux/amd64
  Log line format: [IWEF]mmdd hh:mm:ss.uuuuuu threadid file:line] msg

执行 go run client.go 时有如下输出：

start parse config path:./../conf/motan-client.yaml 
load mybasicRefer configuration success. url: motan2://:0/cn.interfaces.rpc.MotanDemoService?group=motan-demo-rpc
use log dir:./clientlogs
motan call fail! err:No referers for request, RequestID: 0, Request info: map[M_g:motan-demo-rpc M_mdu: M_p:cn.interfaces.rpc.MotanDemoService M_s:client-test M_v:]

zookeeper 集群是使用 docker 搭建的，同样情况下我使用 Java 则不存在这个问题，基本可以排除 zookeeper 集群的问题。

<!-- java: motan-server.xml -->
<motan:registry regProtocol="zookeeper" name="my_zookeeper" address="127.0.0.1:2181,127.0.0.1:2182,127.0.0.1:2183"/>

另外当 zk-registry 中配置 host 和 port 为任意一个 zookeeper 节点时，都可以正常运行

motan-registry:
  zk-registry:
    protocol: zookeeper
    host: 127.0.0.1
    port: 2181
    registrySessionTimeout: 10000

请问一下，这个可能是什么原因引起的？

具体配置如下：

• motan-server.yaml

  
  #config fo server
  motan-server:
  log_dir: "./serverlogs"
  application: "server-test"

config of registries

motan-registry: zk-registry: protocol: zookeeper address: "127.0.0.1:2181,127.0.0.1:2182,127.0.0.1:2183" registrySessionTimeout: 10000

conf of basic service

motan-basicService: mybasicService: application: "server-test" group: motan-demo-rpc protocol: motan2 registry: zk-registry haStrategy: failover loadbalance: roundrobin serialization: simple nodeType: server

conf of services

motan-service: mytest-demo: path: cn.interfaces.rpc.MotanDemoService basicService: mybasicService ref : "main.MotanDemoService" export: "motan2:8009"

* `motan-client.yaml`
```yaml
#config fo client
motan-client:
  log_dir: "./clientlogs"
  application: "client-test"

#config of registries
motan-registry:
  zk-registry:
    protocol: zookeeper
    address: "127.0.0.1:2181,127.0.0.1:2182,127.0.0.1:2183"
    registrySessionTimeout: 10000

#conf of basic refers
motan-basicRefer:
  mybasicRefer:
    application: "client-test"
    group: motan-demo-rpc
    protocol: motan2
    registry: zk-registry
    requestTimeout: 1000
    haStrategy: failover
    loadbalance: roundrobin
    serialization: simple
    retries: 1

#conf of refers
motan-refer:
  mytest-demo:
    path: cn.interfaces.rpc.MotanDemoService
    basicRefer: mybasicRefer

代码如下：

• server.go

  
  package main

import ( "fmt" "time"

"github.com/weibocom/motan-go"

)

func main() { runServer() }

func runServer() { mscontext := motan.GetMotanServerContext("./../conf/motan-server.yaml") mscontext.RegisterService(&MotanDemoService{}, "") mscontext.Start(nil) mscontext.ServicesAvailable() //注册服务后，默认并不提供服务，调用此方法后才会正式提供服务。需要根据实际使用场景决定提供服务的时机。作用与java版本中的服务端心跳开关一致。 time.Sleep(time.Second * 50000000) }

type MotanDemoService struct{}

func (m *MotanDemoService) Hello(name string) string { fmt.Printf("MotanDemoService hello:%s\n", name) return "hello " + name }

* `client.go`
```go
package main

import (
    "fmt"

    "github.com/weibocom/motan-go"
)

func main() {
    runClient()
}

func runClient() {
    mccontext := motan.GetClientContext("./../conf/motan-client.yaml")
    mccontext.Start(nil)

    var reply string

    mclient := mccontext.GetClient("mytest-demo")
    err := mclient.Call("hello", []interface{}{"Golang"}, &reply)
    if err != nil {
        fmt.Printf("motan call fail! err:%v\n", err)
    } else {
        fmt.Printf("motan call success! reply:%s\n", reply)
    }
}

[Zha-Zha]

感谢反馈问题！ 该问题已经定位，是zookeeper模块的address获取有问题 马上修复，merge代码后回复您

[Zha-Zha]

@Lizhg 问题已经解决，请更新一下代码 pr: #155 commit: bd795a91ff67f91932d5616d3b43986beb753bfc

[miibyxs]

@Zha-Zha 好的，感谢。