go-micro v2版本微服務框架實戰1

本文轉載自查看原文 2020-05-30 16:40 1974 golang/ go-micro

go version 1.14.3

最終代碼地址：github地址

etcd 請先自行安裝或者下載win版本的直接可以啟動

etcd下載

安裝 go get github.com/micro/go-micro/v2

安裝工具protobuf相關工具

go get -u github.com/golang/protobuf/protoc-gen-go go-micro

自己的生成工具

go get github.com/micro/protoc-gen-micro/v2

1，運行第一個gprc服務

proto文件

syntax = "proto3";
package  Users;

service UserService {
    rpc Test(UserRequest) returns (UserResponse) {}
}
message UserRequest {
    string id = 1;
}
message UserResponse {
    string ret = 2;
}

type UserService struct{}

func (g *UserService) Test(ctx context.Context, req *Users.UserRequest, rsp *Users.UserResponse) error {
    rsp.Ret="users"
    return nil
}

生成

protoc --proto_path=src/protos   --micro_out=src/Users --go_out=src/Users   Users.proto

運行

service := micro.NewService(
        micro.Name("UserService"),
    )
     
    service.Init()

 
    Users.RegisterUserServiceHandler(service.Server(), new(UserService))
 
    if err := service.Run(); err != nil {
        fmt.Println(err)
    }

package main

import (
    "context"
    "github.com/micro/go-micro/v2"
    "jtthink/src/Users"
    "log"
)

type UserService struct{}
func (g *UserService) Test(ctx context.Context, req *Users.UserRequest, rsp *Users.UserResponse) error {
    rsp.Ret="users"
    return nil
}
func NewUserService() *UserService  {
    return &UserService{}
}
func main()  {

    service:=micro.NewService(
        micro.Name("UserService"))

    service.Init()

    err:=Users.RegisterUserServiceHandler(service.Server(),NewUserService())
    if err!=nil{
        log.Fatal(err)
    }
    if err = service.Run(); err != nil {
        log.Println(err)
    }



}

src\cmd\server.go

syntax = "proto3";
package  Users;

service UserService {
    rpc Test(UserRequest) returns (UserResponse) {}
}
message UserRequest {
    string id = 1;
}
message UserResponse {
    string ret = 2;
}

src\protos\Users.proto

module jtthink

go 1.14

require (
    github.com/golang/protobuf v1.3.5
    github.com/micro/go-micro/v2 v2.4.0
    github.com/micro/protoc-gen-micro/v2 v2.0.0 // indirect
)

go.mod

go run src/cmd/server.go

2，使用etcd注冊服務、web管理界面、api網關

安裝Micro工具

go get github.com/micro/micro/v2

serc/cmd/server.go

package main

import (
    "context"
    "github.com/micro/go-micro/v2"
    "jtthink/src/Users"
    "log"
)

type UserService struct{}
func (g *UserService) Test(ctx context.Context, req *Users.UserRequest, rsp *Users.UserResponse) error {
    rsp.Ret="users"+req.Id
    return nil
}
func NewUserService() *UserService  {
    return &UserService{}
}
func main()  {
//api.jtthink.com --- prefix
    service:=micro.NewService(
        micro.Name("api.jtthink.com.user"))
    service.Init()

    err:=Users.RegisterUserServiceHandler(service.Server(),NewUserService())
    if err!=nil{
        log.Fatal(err)
    }
    if err = service.Run(); err != nil {
        log.Println(err)
    }



}

package main

import (
    "context"
    "github.com/micro/go-micro/v2"
    "jtthink/src/Users"
    "log"
)

type UserService struct{}
func (g *UserService) Test(ctx context.Context, req *Users.UserRequest, rsp *Users.UserResponse) error {
    rsp.Ret="users"+req.Id
    return nil
}
func NewUserService() *UserService  {
    return &UserService{}
}
func main()  {
//api.jtthink.com --- prefix
    service:=micro.NewService(
        micro.Name("api.jtthink.com.user"))
    service.Init()

    err:=Users.RegisterUserServiceHandler(service.Server(),NewUserService())
    if err!=nil{
        log.Fatal(err)
    }
    if err = service.Run(); err != nil {
        log.Println(err)
    }



}

src/protos/Users.proto

生成文件：

protoc --proto_path=src/protos   --micro_out=src/Users --go_out=src/Users   Users.proto

啟動我們的服務

set MICRO_REGISTRY=etcd

set MICRO_REGISTRY_ADDRESS=localhost:2379

go run src/cmd/server.go

web管理界面

set MICRO_REGISTRY=etcd
set MICRO_REGISTRY_ADDRESS=localhost:2379
micro web
默認是 localhost:8082   就可以看到我們的服務

啟動網關

set MICRO_REGISTRY=etcd
set MICRO_REGISTRY_ADDRESS=127.0.0.1:2379
set MICRO_CLIENT=grpc
set MICRO_SERVER=grpc
set MICRO_API_NAMESPACE=api.jtthink.com
micro api

請求：

POST http://localhost:8080/user/userService/test

3，快速創建第二個服務：課程服務

syntax = "proto3";
package  Course;

service CourseService {
    rpc ListForTop(ListRequest) returns (ListResponse) {}
}
message CourseModel{
    int32 course_id=1;
    string course_name=2;

}
message ListRequest {
    int32 size = 1;
}
message ListResponse {
    repeated CourseModel result = 1;
}

D:\gocode1.14.3\gocode\gjj\src\protos\Course.proto

package main

import (
    "github.com/micro/go-micro/v2"
    "jtthink/src/Course"

    "log"
)


func main()  {
    service:=micro.NewService(
        micro.Name("api.jtthink.com.course"))
    service.Init()

    err:=Course.RegisterCourseServiceHandler(service.Server(),Course.NewCourseServiceImpl())
    if err!=nil{
        log.Fatal(err)
    }
    if err = service.Run(); err != nil {
        log.Println(err)
    }
}

D:\gocode1.14.3\gocode\gjj\src\cmd\course_server.go

package Course

import "context"

func NewCourseModel(id int32,name string) *CourseModel  {
    return &CourseModel{CourseId:id,CourseName:name}
}
type CourseServiceImpl struct{}
func(this *CourseServiceImpl) ListForTop(ctx context.Context, req *ListRequest, rsp *ListResponse) error{
   ret:=make([]*CourseModel,0)
   ret=append(ret,NewCourseModel(101,"java課程"),NewCourseModel(102,"PHP課程"))
   rsp.Result=ret
   return nil
}
func NewCourseServiceImpl() *CourseServiceImpl  {
  return &CourseServiceImpl{}
}

D:\gocode1.14.3\gocode\gjj\src\Course\helper.go

生成文件：

protoc --proto_path=src/protos   --micro_out=src/Users --go_out=src/Users   Users.proto
protoc --proto_path=src/protos   --micro_out=src/Course --go_out=src/Course   Course.proto

啟動服務

課程服務：

set MICRO_REGISTRY=etcd
set MICRO_REGISTRY_ADDRESS=localhost:2379
go run src/cmd/course_server.go --server_address :9091

用戶服務

set MICRO_REGISTRY=etcd
set MICRO_REGISTRY_ADDRESS=localhost:2379
go run src/cmd/user_server.go --server_address :9090

web管理界面

set MICRO_REGISTRY=etcd
set MICRO_REGISTRY_ADDRESS=localhost:2379
micro web

啟動micro網關

set MICRO_REGISTRY=etcd
set MICRO_REGISTRY_ADDRESS=localhost:2379
set MICRO_API_NAMESPACE=api.jtthink.com
set MICRO_CLIENT=grpc
set MICRO_SERVER=grpc
micro api --handler=rpc

如果不出問題：

通過網關訪問課程服務

通過網關訪問用戶服務

使用micro管理工具：

micro get service  api.jtthink.com.course

 micro get service  api.jtthink.com.course
service  api.jtthink.com.course

version latest

ID      Address Metadata
api.jtthink.com.course-9da60d36-d727-4891-b88f-74cecf90b80d     192.168.1.101:9091      transport=grpc,broker=http,protocol=grpc,registry=etcd,server=grpc

Endpoint: CourseService.ListForTop

Request: {
        message_state MessageState {
                no_unkeyed_literals NoUnkeyedLiterals
                do_not_compare DoNotCompare
                do_not_copy DoNotCopy
                message_info MessageInfo
        }
        int32 int32
        unknown_fields []uint8
        size int32
}

Response: {
        message_state MessageState {
                no_unkeyed_literals NoUnkeyedLiterals
                do_not_compare DoNotCompare
                do_not_copy DoNotCopy
                message_info MessageInfo
        }
        int32 int32
        unknown_fields []uint8
        result []CourseModel
}

micro call  api.jtthink.com.course  CourseService.ListForTop "{\"size\":10}"

$ micro call  api.jtthink.com.course  CourseService.ListForTop "{\"size\":10}"
{
        "result": [
                {
                        "course_id": 101,
                        "course_name": "java課程"
                },
                {
                        "course_id": 102,
                        "course_name": "PHP課程"
                }
        ]
}

4，創建”單純”的http api、調用grpc服務

package main

import (
    "context"
    "github.com/micro/go-micro/v2/client/grpc"
    "github.com/micro/go-micro/v2/web"
    "jtthink/src/Course"
    "log"
    "net/http"
)

func main()  {
    service:=web.NewService(
        web.Name("api.jtthink.com.http.course"))
    c:=grpc.NewClient()

    service.HandleFunc("/test", func(writer http.ResponseWriter, request *http.Request) {
        c:=Course.NewCourseService("api.jtthink.com.course",c)
        course_rsp,_:=c.ListForTop(context.Background(),&Course.ListRequest{Size:10})
        log.Println(course_rsp.Result)
        writer.Write([]byte("http api test"))
    })
    service.Init()
    if err:= service.Run(); err != nil {
        log.Println(err)
    }
}

D:\gocode1.14.3\gocode\gjj\src\cmd\course_http_server.go

啟動http服務

set MICRO_REGISTRY=etcd
set MICRO_REGISTRY_ADDRESS=localhost:2379
go run src/cmd/course_http_server.go --server_address :9000

5，go-micro快速集成gin開發http api

package main

import (
	"context"
	"github.com/gin-gonic/gin"
	"github.com/micro/go-micro/v2/client/grpc"
	"github.com/micro/go-micro/v2/web"
	"jtthink/src/Course"
	"log"
)

func main()  {
	c:=grpc.NewClient()
	r:=gin.New()
	r.Handle("GET","/test", func(ctx *gin.Context) {
	    c:=Course.NewCourseService("api.jtthink.com.course",c)
	    course_rsp,_:=c.ListForTop(context.Background(),&Course.ListRequest{Size:10})
		ctx.JSON(200,gin.H{"Result":course_rsp.Result})
	})
	service:=web.NewService(
		web.Name("api.jtthink.com.http.course"),
		web.Handler(r),
	 )

	service.Init()
	if err:= service.Run(); err != nil {
		log.Println(err)
	}

}

運行：

set MICRO_REGISTRY=etcd
set MICRO_REGISTRY_ADDRESS=localhost:2379
go run src/cmd/course_http_server.go --server_address :9000

免責聲明！

本站轉載的文章為個人學習借鑒使用，本站對版權不負任何法律責任。如果侵犯了您的隱私權益，請聯系本站郵箱yoyou2525@163.com刪除。

猜您在找 go-micro v2版本微服務框架實戰二三層架構開發模式 go-micro微服務框架微服務框架go-micro go 微服務之go-micro v3+gin golang微服務框架go-micro 入門筆記2.4 go-micro service解讀微服務框架 Go-Micro 集成 Nacos 實戰之服務注冊與發現微服務學習--micro和go-micro 微服務學習（三）--micro和go-micro go微服務框架go-micro深度學習-目錄 golang微服務框架go-micro 入門筆記1.搭建 go-micro環境

go-micro v2版本 微服務框架 實戰1