register bug about rpcx-gateway HOT 11 CLOSED

package main

import (
	"errors"
	"flag"
	"fmt"
	"log"
	"strings"
	"time"

	gateway "github.com/rpcx-ecosystem/rpcx-gateway"
	"github.com/smallnest/rpcx/client"
)

var (
	addr       = flag.String("addr", ":9981", "http server address")
	st         = flag.String("st", "http1", "server type: http1 or h2c")
	//registry   = flag.String("registry", "peer2peer://127.0.0.1:8972", "registry address")
	registry   = flag.String("registry", "consul://localhost:8500", "registry address")
 //-------------  改成了我自己的-------
	basePath   = flag.String("basepath", "/rpcx_test", "basepath for zookeeper, etcd and consul")
	failmode   = flag.Int("failmode", int(client.Failover), "failMode, Failover in default")
	selectMode = flag.Int("selectmode", int(client.RoundRobin), "selectMode, RoundRobin in default")
)

func main() {
	flag.Parse()

	d, err := createServiceDiscovery(*registry)
	if err != nil {
		log.Fatal(err)
	}
	gw := gateway.NewGateway(*addr, gateway.ServerType(*st), d, client.FailMode(*failmode), client.SelectMode(*selectMode), client.DefaultOption)
   fmt.Print("--------网关开始接受请求-----")
	gw.Serve()
}

func createServiceDiscovery(regAddr string) (client.ServiceDiscovery, error) {
	i := strings.Index(regAddr, "://")
	if i < 0 {
		return nil, errors.New("wrong format registry address. The right fotmat is [registry_type://address]")
	}

	regType := regAddr[:i]
	regAddr = regAddr[i+3:]

	switch regType {
	case "peer2peer": //peer2peer://127.0.0.1:8972
		return client.NewPeer2PeerDiscovery("tcp@"+regAddr, ""), nil
	case "multiple":
		var pairs []*client.KVPair
		pp := strings.Split(regAddr, ",")
		for _, v := range pp {
			pairs = append(pairs, &client.KVPair{Key: v})
		}
		return client.NewMultipleServersDiscovery(pairs), nil
	case "zookeeper":
		return client.NewZookeeperDiscovery(*basePath, "placeholder", []string{regAddr}, nil), nil
	case "etcd":
		return client.NewEtcdDiscovery(*basePath, "placeholder", []string{regAddr}, nil), nil
	case "consul": // -------- 改成了我自己的 ----
		return client.NewConsulDiscovery(*basePath, "Login", []string{regAddr}, nil), nil
	case "mdns":
		client.NewMDNSDiscovery("placeholder", 10*time.Second, 10*time.Second, "")
	default:
		return nil, fmt.Errorf("wrong registry type %s. only support peer2peer,multiple, zookeeper, etcd, consul and mdns", regType)
	}

	return nil, errors.New("wrong registry type. only support peer2peer,multiple, zookeeper, etcd, consul and mdns")
}

app.get('/test', function (req, res) {

  request({
    url: "http://localhost:9981/",
    method: "POST",
    headers: {
      'Content-Type': 'application/rpcx',
      'X-RPCX-MessageID': '12345678',
      'X-RPCX-MesssageType': '0',  //设置0作为请求 1--响应
      'X-RPCX-SerializeType': '1',
      'X-RPCX-ServicePath': '',
      'X-RPCX-ServiceMethod': 'Login'
    },
    body: '{"Name":"node.js", "Psw":"调用网关"}'
  }, function (error, response, body) {
    if (!error && response.statusCode == 200) {
      console.log(body);
    }else{
      console.log(error.message)
    }
  });
});

// -------- 改成了我自己的 ----

 'X-RPCX-ServicePath': '',