微服务实战Go Micro v3 系列（二）- HelloWorld(2)-木庄网络博客

类似tcp通信，客户端和服务端可以互相发消息。

// 注意stream关键词在什么地方
rpc BidiHello(stream HelloRequest) returns (stream HelloResponse){
}

更多关于grpc教程请点击这里

编写 go-micro HTTP服务

安装 gofast插件

//gofast
go get -u -v github.com/gogo/protobuf/protoc-gen-gofast

开始编写 go-micro HTTP服务

创建 go-micro-examples 目录，然后在该目录下创建 helloworld目录

在 helloworld 目录下，创建 proto 和 handler，并创建 main.go 和使用 go mod init 初始化项目，如下图所示

其它文件暂时忽略，后面会解释

在 proto 目录创建 helloworld.proto，并写入下面代码

syntax = "proto3";

package helloworld;

option go_package = "proto;helloworld";

service Helloworld {
    rpc Call(Request) returns (Response) {}
    rpc Stream(StreamingRequest) returns (stream StreamingResponse) {}
    rpc PingPong(stream Ping) returns (stream Pong) {}
}

message Message {
    string say = 1;
}

message Request {
    string name = 1;
}

message Response {
    string msg = 1;
}

message StreamingRequest {
    int64 count = 1;
}

message StreamingResponse {
    int64 count = 1;
}

message Ping {
    int64 stroke = 1;
}

message Pong {
    int64 stroke = 1;
}

进入该目录并输入以下命令

并生成 helloworld.pb.go、helloworld.pb.micro.go

在 main.go，创建服务并注册一下 handler，运行服务

package main

import (
    "github.com/asim/go-micro/v3"
    "github.com/asim/go-micro/v3/logger"
    "go-micro-examples/helloworld/handler"
    pb "go-micro-examples/helloworld/proto"
)

const (
    ServerName = "go.micro.srv.HelloWorld" // server name
)

func main() {
    // Create service
    service := micro.NewService(
        micro.Name(ServerName),
        micro.Version("latest"),
    )

    // Register handler
    if err := pb.RegisterHelloworldHandler(service.Server(), new(handler.Helloworld)); err != nil {
        logger.Fatal(err)
    }

    // Run service
    if err := service.Run(); err != nil {
        logger.Fatal(err)
    }
}

client 调用 service

创建 client 目录并创建client.go，写入一下代码

package main

import (
    "context"
    "fmt"
    "github.com/asim/go-micro/v3"
    helloworld "go-micro-examples/helloworld/proto"
)

func main() {
    // create a new service
    service := micro.NewService()

    // parse command line flags
    service.Init()

    // Use the generated client stub
    cl := helloworld.NewHelloworldService("go.micro.srv.HelloWorld", service.Client())

    // Make request
    rsp, err := cl.Call(context.Background(), &helloworld.Request{
        Name: "John",
    })
    if err != nil {
        fmt.Println(err)
        return
    }
    fmt.Println(rsp.Msg)
}