up

.gitignore

 /go.sum
 /go.sum
 /cmd/*
 /cmd/*
 /logs/*
 /logs/*
+/logs

http_proxy_router/httpserver.go

@@ -23,8 +23,8 @@ func HttpServerRun() {
 	r := InitRouter(middleware.RecoveryMiddleware(),
 	r := InitRouter(middleware.RecoveryMiddleware(),
 		middleware.RequestLog())
 		middleware.RequestLog())
 	HttpSrvHandler = &http.Server{
 	HttpSrvHandler = &http.Server{
-		//Addr:           lib.GetStringConf("proxy.http.addr"),
-		Addr:           "192.168.1.234:2002",
+		Addr:           lib.GetStringConf("proxy.http.addr"),
+		//Addr:           "192.168.1.234:2002",
 		Handler:        r,
 		Handler:        r,
 		ReadTimeout:    time.Duration(lib.GetIntConf("proxy.http.read_timeout")) * time.Second,
 		ReadTimeout:    time.Duration(lib.GetIntConf("proxy.http.read_timeout")) * time.Second,
 		WriteTimeout:   time.Duration(lib.GetIntConf("proxy.http.write_timeout")) * time.Second,
 		WriteTimeout:   time.Duration(lib.GetIntConf("proxy.http.write_timeout")) * time.Second,

main.go

@@ -26,6 +26,7 @@ func registryEtcd(){
 		//registry.WithAddrs([]string{"192.168.2.232:2379"}),
 		//registry.WithAddrs([]string{"192.168.2.232:2379"}),
 		registry.WithAddrs(lib.GetStringSliceConf("base.etcd.addrs")),
 		registry.WithAddrs(lib.GetStringSliceConf("base.etcd.addrs")),
 		registry.WithTimeout(5*time.Second),
 		registry.WithTimeout(5*time.Second),
+		registry.WithPasswrod(""),
 		registry.WithRegistryPath("/ichuntMicroService/"),
 		registry.WithRegistryPath("/ichuntMicroService/"),
 		registry.WithHeartBeat(5),
 		registry.WithHeartBeat(5),
 	)
 	)

registry/etcd/etcd.go

@@ -81,6 +81,7 @@ func (e *EtcdRegistry) Init(ctx context.Context, opts ...registry.Option) (err e
 	clientConfig := clientv3.Config{
 	clientConfig := clientv3.Config{
 		Endpoints:   e.options.Addrs,
 		Endpoints:   e.options.Addrs,
 		DialTimeout: e.options.Timeout,
 		DialTimeout: e.options.Timeout,
+		Password:	 e.options.Password,
 	}
 	}
 
 
 	e.client, err = clientv3.New(clientConfig)
 	e.client, err = clientv3.New(clientConfig)

registry/etcd/etcd_test.go

@@ -100,6 +100,7 @@ func TestGetService(t *testing.T){
 	registryInst, err := registry.InitRegistry(context.TODO(), "etcd",
 	registryInst, err := registry.InitRegistry(context.TODO(), "etcd",
 		registry.WithAddrs([]string{"192.168.2.232:2379"}),
 		registry.WithAddrs([]string{"192.168.2.232:2379"}),
 		registry.WithTimeout(time.Second),
 		registry.WithTimeout(time.Second),
+		registry.WithPasswrod(""),
 		registry.WithRegistryPath("/ichuntMicroService/"),
 		registry.WithRegistryPath("/ichuntMicroService/"),
 		registry.WithHeartBeat(5),
 		registry.WithHeartBeat(5),
 	)
 	)

registry/options.go

@@ -7,6 +7,7 @@ import (
 type Options struct {
 type Options struct {
 	Addrs   []string
 	Addrs   []string
 	Timeout time.Duration
 	Timeout time.Duration
+	Password string
 	// example:  /xxx_company/app/kuaishou/service_A/10.192.1.1:8801
 	// example:  /xxx_company/app/kuaishou/service_A/10.192.1.1:8801
 	// example:  /xxx_company/app/kuaishou/service_A/10.192.1.2:8801
 	// example:  /xxx_company/app/kuaishou/service_A/10.192.1.2:8801
 	RegistryPath string
 	RegistryPath string
@@ -27,6 +28,12 @@ func WithAddrs(addrs []string) Option {
 	}
 	}
 }
 }
 
 
+func WithPasswrod(password string) Option {
+	return func(opts *Options) {
+		opts.Password = password
+	}
+}
+
 func WithRegistryPath(path string) Option {
 func WithRegistryPath(path string) Option {
 	return func(opts *Options) {
 	return func(opts *Options) {
 		opts.RegistryPath = path
 		opts.RegistryPath = path