go-micro、consul、rpc、gin构建微服务入门

不念不忘少年蓝@ 2022-11-12 13:52 241阅读 0赞

使用micro构建微服务框架

micro new --type "web" gweb
    micro new --type "srv" trpc

首先，将生成的文件进行更改，目前版本micro默认注册到etcd，所以需要指定注册到consul  
在main.go中

reg := consul.NewRegistry(registry.Addrs(":8500"))
    service := web.NewService(
    //在原有的参数基础上，添加
    	web.Registry(reg),
    )

我们还要结合gin框架  
还是在main.go中

r := gin.Default()
    r.POST("/" , func (c *gin.Context){
        
    	//逻辑
    })
    service := web.NewService(
    	//在原有基础上添加传入参数
    	web.Handler(r),
    )

注意，此时生成的文件还在报错，是micro自动导入一个handler function，由于我们自己写了一个post页面，所以目前不需要自动生成的handler。

## 修改rpc ##

由于使用命令行进行自动生成的rpc，会自动生成一个proto文件，我们需要将其转化为pb.go和pb.micro.go文件  
所以，到proto文件的目录下，执行命令，会自动生成go文件。

protoc --go_out=./ --micro_out=./ trpc.proto

将生成的两个文件，放到gweb目录下，先在gweb目录下，创建proto文件夹

mkdir proto

再进行复制

cp ./*.go ../../../gweb/proto

由于rpc我们还是使用的是micro进行创建，所以默认注册到etcd，所以我们需要指定注册到consul  
在trpc中的main.go文件进行更改

reg := consul.NewRegistry(registry.Adds("：8500"))
    micro := micro.NewService(
    	//在原有的基础上添加参数
    	micro.Registry(reg),
    )

## web调用rpc ##

首先回到web的main.go中  
我们需要在post请求中进行远程调用rpc服务  
首先main.go

r := gin.Default()
    r.POST("/" , func (c *gin.Context){
        
    	//逻辑
    	var name proto.Request
    	c.Bind(&name)//将接收到的参数，进行绑定
    	//使用micro封装好的接口进行访问
    	client := micro.NewService(micro.Name("go.micro.web.client"))
    	Uapi := proto.NewTrpcService("go.micro.srv.trpc" , client.Client())
    	rep ,err := Uapi.Call(context.Background() , &name)
    	if err != nil {
        
    		c.JSON(500 , err)
    	}else{
        
    		c.JSON(200 , rep)
    	}
    })
    service := web.NewService(
    	web.Handler(r),
    )