I have two micro services deployed on different pc, the two services reg the same cons

micro service reg consul by extranet ip about plugins HOT 2 OPEN

hzxgo commented on September 6, 2024

micro service reg consul by extranet ip

from plugins.

Comments (2)

lhqbalabala commented on September 6, 2024

I also encountered this problem.

My reason is that the server opens an intranet port

And go micro registers the intranet port to etcd

This makes the two servers unable to connect through the intranet

In grpc, I registered the public IP to etcd. The local server opens the intranet IP so that other servers can perform RPC through the public IP

However, in go micro, the registry and the open port seem to be integrated, so I did not find a solution

from plugins.

lhqbalabala commented on September 6, 2024

In the source code micro_ web_ service
I found gensrv(), which is used to return the IP registered in the registry
If advertise is set, advertise will be registered instead of address

func (s *service) genSrv() *registry.Service {
	var host string
	var port string
	var err error

	// default host:port
	if len(s.opts.Address) > 0 {
		host, port, err = net.SplitHostPort(s.opts.Address)
		if err != nil {
			logger.Fatal(err)
		}
	}

	// check the advertise address first
	// if it exists then use it, otherwise
	// use the address
	if len(s.opts.Advertise) > 0 {
		host, port, err = net.SplitHostPort(s.opts.Advertise)
		if err != nil {
			logger.Fatal(err)
		}
	}

	addr, err := maddr.Extract(host)
	if err != nil {
		logger.Fatal(err)
	}

	if strings.Count(addr, ":") > 0 {
		addr = "[" + addr + "]"
	}

	return &registry.Service{
		Name:    s.opts.Name,
		Version: s.opts.Version,
		Nodes: []*registry.Node{{
			Id:       s.opts.Id,
			Address:  net.JoinHostPort(addr, port),
			Metadata: s.opts.Metadata,
		}},
	}
}

Therefore, web services only need the following settings:

http := web.NewService(
		web.Name("xxx"),
		web.Address("Your intranet IP"),
		web.Registry(Reg),
		web.Handler(engine),
		web.Advertise("Your Internet IP"),
)

Similarly, if it is an RPC service, you can set the server's advertise

app := micro.NewService(
		micro.Name(""),
		micro.Address(""),
		micro.Registry(Reg),
		func(o *micro.Options) {
			o.Server.Init(server.Advertise(""))
		},
	)

from plugins.

Recommend Projects