30.普通API集成到go-micro体系中(2)：代码注册与反注册

{
    "jsonrpc": "2.0",
    "method": "Registry.Deregister",
    "params": [{
        "name": "api.jtthink.com.test",
        "version": "1.0",
        "endpoints": [],
        "nodes": [{
            "address": "192.168.29.1",
            "id": "userservice-uuid",
            "port": 8088
        }]
    }],
    "id": 1
}

package sidecar

type JSONRequest struct {
    Jsonrpc string
    Method  string
    Params  []*Service
    Id      int
}

func NewJSONRequest(service *Service, endpoint string) *JSONRequest {
    return &JSONRequest{Jsonrpc: "2.0", Method: endpoint, Params: []*Service{service}, Id: 1}
}

type Service struct {
   Name  string
   Nodes []*ServiceNode
}

{
        "name": "api.jtthink.com.test",
        "version": "1.0", //在上面的结构体中version和endpints我们暂时不传
        "endpoints": [],
        "nodes": [{
            "address": "192.168.29.1",
            "id": "userservice-uuid",
            "port": 8088
        }
｝

type ServiceNode struct {
   Id      string //服务ID,不能重复
   Port    int
   Address string
}

{
            "address": "192.168.29.1",
            "id": "userservice-uuid",
            "port": 8088
        }

package sidecar

import (
    "bytes"
    "encoding/json"
    "fmt"
    "io/ioutil"
    "log"
    "net/http"
)

type Service struct {
    Name  string
    Nodes []*ServiceNode
}
type ServiceNode struct {
    Id      string //服务ID,不能重复
    Port    int
    Address string
}

func NewService(name string) *Service {
    return &Service{Name: name, Nodes: make([]*ServiceNode, 0)}
}
func NewServiceNode(id string, port int, address string) *ServiceNode {
    return &ServiceNode{Id: id, Port: port, Address: address}
}
func (this *Service) AddNode(id string, port int, address string) {
    this.Nodes = append(this.Nodes, NewServiceNode(id, port, address))
}

var RegistryURI = "http://localhost:8000"

func requestRegistry(jsonrequest *JSONRequest) error { //关键代码。用来请求注册器
    b, err := json.Marshal(jsonrequest)
    if err != nil {
        log.Fatal(err)
        return err
    }
    rsp, err := http.Post(RegistryURI, "application/json", bytes.NewReader(b))//发送Post请求到Registry的地址带上我们的json数据，就可以成功注册啦
    if err != nil {
        return err
    }
    defer rsp.Body.Close()
    res, err := ioutil.ReadAll(rsp.Body)
    if err != nil {
        return err
    }
    fmt.Println(string(res)) //打印出结果
    return nil
}

func UnRegService(service *Service) error  {
    return requestRegistry(NewJSONRequest(service,"Registry.Deregister")) //反注册只需要改一下endpoint为Registry.Deregister就可以了
}
func RegService(service *Service) error {
    return requestRegistry(NewJSONRequest(service,"Registry.Register"))
}

package main

import (
    "context"
    "fmt"
    "github.com/gin-gonic/gin"
    "github.com/google/uuid"
    "log"
    "micro/sidecar"
    "net/http"
    "os"
    "os/signal"
    "syscall"
)

func main() {
    ginRouter := gin.Default()
    v1 := ginRouter.Group("/v1")
    {
        v1.Handle("POST", "/test", func(context *gin.Context) {
            context.JSON(200, gin.H{
                "data": "test",
            })
        })
    }
    server := &http.Server{
        Addr:    ":8088",
        Handler: ginRouter,
    }
    service := sidecar.NewService("api.jtthink.com.test")
    service.AddNode("test-"+uuid.New().String(), 8088, "localhost:8088")
    handler := make(chan error)
    go func() {
        handler 

package main

import (
    "context"
    "fmt"
    "github.com/micro/go-micro/client"
    "github.com/micro/go-micro/client/selector"
    "github.com/micro/go-micro/registry"
    "github.com/micro/go-micro/registry/etcd"
    myhttp "github.com/micro/go-plugins/client/http"
    "log"
)

func main() {
    etcdReg := etcd.NewRegistry(registry.Addrs("106.12.72.181:23791"))

    mySelector := selector.NewSelector(
        selector.Registry(etcdReg),
        selector.SetStrategy(selector.RoundRobin),
    )
    getClient := myhttp.NewClient(client.Selector(mySelector), client.ContentType("application/json"))

    //1创建request
    req := getClient.NewRequest("api.jtthink.com.test", "/v1/test", map[string]string{}) //这里的request
    //2创建response
    var rsp map[string]interface{} //var rsp map[string]string这里这么写也可以，因为我们的返回值是{"data":"test"}，所以都对的上
    err := getClient.Call(context.Background(), req, &rsp) //将返回值映射到map中
    if err != nil {
        log.Fatal(err)
    }
    fmt.Println(rsp)
}