go-micro v3 rpc服务一次改造经历

地址：https://github.com/go-micro/go-micro

grpc-test-demo：https://gitee.com/jn-shao/go-gmicro-rpc-test.git

go-micro api网关：

​ api网关替换为kong ，使用consul做dns服务器。

​ 旧项目用的是http->go-micro v3 rpc,后端全都是自己的rpc，proto定义数据格式如下：

message Request {
    string method = 1;
    string path = 2;
    map<string, Pair> header = 3;
    map<string, Pair> get = 4;
    map<string, Pair> post = 5;
    string body = 6;
    string url = 7;
}

message Response {
    int32 statusCode = 1;
    map<string, Pair> header = 2;
    string body = 3;
}

不通用，非restful，参数动态前后端参数处理很麻烦，后续换网关，调整服务都很被动，go-micro v3不熟悉，发现go-micro v3 将server和client抽象出来有各自的管道处理（middleware），所以链路、熔断限流这些中间件使用框架本身封装的不需要动，只需使用插件替换server和client，改造难度不是很大，索性研究下全部替换掉。

注：服务名不能使用 . 不然dns会解析不到ip，可以通过下面命令测试自己的服务：

$ dig @<consul ip> -p 8600 <服务名>.service.consul SRV

api：

​ server转为http restful 替换为gin路由器：https://github.com/go-micro/plugins/tree/main/v3/server/http

​ 官方例子可以看出插件是把路由器放进去，可以直接替换gin，简单来讲http基础包封装的http框架即实现Handler的ServeHTTP方法的都可以替换

​ client转为grpc client:https://github.com/go-micro/plugins/tree/main/v3/client/grpc

部分修改代码:

package initialize

func Routers() *gin.Engine {
        Router := gin.Default()

        ApiGroup := Router.Group("/v1")
        router.InitPodRouter(ApiGroup)

        return Router
}

package main

 ......
        srv := httpServer.NewServer(
                func(options *server.Options) {
                        options.Advertise = serviceHost + ":" + servicePort
                },
                server.Name("podApi"),
                server.Version("latest"),
        )
        mux := initialize.Routers()
        if err := srv.Handle(srv.NewHandler(mux)); err != nil {
                common.Fatal(err)
        }
        service := micro.NewService(
                //开启gin http server
                micro.Server(srv),
                //使用grpc client
                micro.Client(grpcClient.NewClient(client.RequestTimeout(time.Second*5))),
                ......
        )
        ......
        global.PodService = go_micro_service_pod.NewPodService("podSrv", service.Client())
        ......

srv：

​ server转为grpc server:https://github.com/go-micro/plugins/tree/main/v3/server/grpc

部分修改代码：

package main

......
service := micro.NewService(
                //开启grpc server
                micro.Server(grpcServer.NewServer(func(options *server.Options) {
                        options.Advertise = global.ServerConfig.Host + ":" +
                                strconv.FormatUint(global.ServerConfig.Port, 10)
                })),
                ......
        )

配置中心consul：

​ 旧项目注册中心和配置中心使用的都是consul，这里配置中心替换为nacos，使用go-micro v3封装的config：https://github.com/go-micro/plugins/tree/main/v3/config/source

​ viper：https://github.com/spf13/viper

​ nacos-sdk-go：https://github.com/nacos-group/nacos-sdk-go

​ 部分修改代码：

package initialize

var configFileName = "config.yaml"

func InitConfig() {

        var nacosConfig localconfig.NacosConfig

        if err := GetLocalConfig(configFileName, &nacosConfig); err != nil {
                common.Fatal(err)
        }

        config, err := GetNacosConfig(nacosConfig.Host, nacosConfig.Port, nacosConfig.Namespace,
                nacosConfig.DataId, nacosConfig.Group)
        if err != nil {
                common.Fatal(err)
        }

        if err := config.Get().Scan(&global.ServerConfig); err != nil {
                common.Fatal(err)
        }
}

func GetLocalConfig(localConfigFileName string, config interface{}) error {
        v := viper.New()
        v.SetConfigFile(localConfigFileName)
        if err := v.ReadInConfig(); err != nil {
                return err
        }

        if err := v.Unmarshal(config); err != nil {
                return err
        }

        fmt.Printf("本地配置信息：%+v", config)
        zap.S().Infof("本地配置信息：%+v", config)
        // 动态监控
        func() {
                v.WatchConfig()
                v.OnConfigChange(func(e fsnotify.Event) {
                        fmt.Printf("本地配置文件产生变化：%s", e.Name)
                        zap.S().Infof("本地配置文件产生变化：%s", e.Name)
                        _ = v.ReadInConfig() // 读取配置数据
                        _ = v.Unmarshal(config)
                        fmt.Printf("本地配置信息：%+v", config)
                        zap.S().Infof("本地配置信息：%+v", config)
                })
        }()

        return nil
}

func GetNacosConfig(host string, port uint64, namespace string, dataId string, group string) (config.Config, error) 
        clientConfig := constant.ClientConfig{
                NamespaceId:         namespace,
                TimeoutMs:           5000,
                NotLoadCacheAtStart: true,
                LogDir:              "tmp/nacos/log",   
                CacheDir:            "tmp/nacos/cache", 
                LogLevel:            "debug",
        }
        nacosSource := nacos.NewSource(
                nacos.WithAddress([]string{host + ":" + strconv.FormatUint(port, 10)}),
                nacos.WithClientConfig(clientConfig),
                nacos.WithDataId(dataId),
                nacos.WithGroup(group),
        )
        conf, err := config.NewConfig()
        if err != nil {
                return conf, err
        }
        err = conf.Load(nacosSource)
        return conf, err
}

注·：

（1）clientConfig中的LogDir和CacheDir要手动创建

（2）此处有一个坑，遇到nacos v1和v2兼容性问题，v2多开了一个9848 grpc端口，nacos-sdk-go v2配置http无效，都会转成grpc请求9848端口获取配置信息，当然使用nacos-sdk-go v1请求8848是没问题的，但go-micro v3 插件依赖的是nacos-sdk-go v2，前期没注意按照v1部署，需打开9848端口。被这个bug：https://github.com/nacos-group/nacos-sdk-go/issues/531干扰了，官方应该是有意将9848专门负责拉取配置信息，并且兼容v1版本

​ nacos-docker：https://github.com/nacos-group/nacos-docker

// 获取容器ip
$ docker image inspect --format='{{json .NetworkSettings.IPAddress}}' <nacos容器>
// 映射端口
$ iptables -t nat -A DOCKER -p tcp --dport 9848 -j DNAT --to-destination <nacos ip>:9848