0
点赞
收藏
分享

微信扫一扫

go-micro v2版本 微服务框架 实战1

律楷粑粑 2022-05-13 阅读 70
go-microgithubphpjavaGo语言编程语言

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)
    }

go-micro v2版本 微服务框架 实战1_go-microgo-micro v2版本 微服务框架 实战1_java_02

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

go-micro v2版本 微服务框架 实战1_go-microgo-micro v2版本 微服务框架 实战1_java_02

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

go-micro v2版本 微服务框架 实战1_go-microgo-micro v2版本 微服务框架 实战1_java_02

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网关

go-micro v2版本 微服务框架 实战1_github_07


安装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)
    }



}

go-micro v2版本 微服务框架 实战1_go-microgo-micro v2版本 微服务框架 实战1_java_02

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

go-micro v2版本 微服务框架 实战1_php_10

启动我们的服务

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，快速创建第二个服务：课程服务

go-micro v2版本 微服务框架 实战1_php_11

go-micro v2版本 微服务框架 实战1_go-microgo-micro v2版本 微服务框架 实战1_java_02

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

go-micro v2版本 微服务框架 实战1_go-microgo-micro v2版本 微服务框架 实战1_java_02

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

go-micro v2版本 微服务框架 实战1_go-microgo-micro v2版本 微服务框架 实战1_java_02

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


如果不出问题：

go-micro v2版本 微服务框架 实战1_github_18

通过网关访问课程服务

go-micro v2版本 微服务框架 实战1_java_19


通过网关访问用户服务

go-micro v2版本 微服务框架 实战1_php_20


使用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服务

go-micro v2版本 微服务框架 实战1_go-microgo-micro v2版本 微服务框架 实战1_java_02

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


go-micro v2版本 微服务框架 实战1_php_23



go-micro v2版本 微服务框架 实战1_github_24


 go-micro v2版本 微服务框架 实战1_go-micro_25


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



go-micro v2版本 微服务框架 实战1_php_26


举报

相关推荐

go-micro v2版本 微服务框架 实战二 三层架构开发模式

go-microgithubjsonbootstrapGo语言编程语言

GO 微服务GO-Micro -（4）Micro和GO-Micro

GO Micro 微服务系列

Go-Micro微服务框架速学

go-microgithubjson服务端Go语言编程语言

GO 微服务GO-Micro -（2）Consul 基本认知

GO Micro 微服务系列

GO 微服务GO-Micro -（1）服务注册和服务发现

GO Micro 微服务系列

GO 微服务GO-Micro -（3）Consul 安装

GO Micro 微服务系列

[Go 微服务] go-micro + consul 的使用

golang微服务consulgo-micro

Go 微服务实战之如何使用 go-micro 写微服务应用

微服务服务发现服务框架Go语言编程语言私藏项目实操分享

GO 微服务GO-Micro -（5）来自GO 夜读 关于Go-Micro （第一期）学习笔记

GO Micro 微服务系列

[golang 微服务] 8.go-micro的负载均衡操作，go Web框(Gin,Beego)调用go-micro微服务

机器人人工智能
0 条评论