小編給大家分享一下Golang中g(shù)rpc怎么用，相信大部分人都還不怎么了解，因此分享這篇文章給大家參考一下，希望大家閱讀完這篇文章后大有收獲，下面讓我們一起去了解一下吧！

成都創(chuàng)新互聯(lián)-專(zhuān)業(yè)網(wǎng)站定制、快速模板網(wǎng)站建設(shè)、高性?xún)r(jià)比通城網(wǎng)站開(kāi)發(fā)、企業(yè)建站全套包干低至880元,成熟完善的模板庫(kù),直接使用。一站式通城網(wǎng)站制作公司更省心,省錢(qián),快速模板網(wǎng)站建設(shè)找我們，業(yè)務(wù)覆蓋通城地區(qū)。費(fèi)用合理售后完善，十多年實(shí)體公司更值得信賴(lài)。

1.  grpc安裝

pip install --upgrade pip

pip install grpcio --user 

pip install protobuf --user

pip install grpcio-tools --user

sudo yum -y install protobuf-compiler protobuf-static protobuf protobuf-devel

dnf install protobuf-compiler.x86_64 

pip install googleapis-common-protos --user

2. 導(dǎo)入grpc包

go get -u google.golang.org/grpc

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

3. 編寫(xiě)test.proto文件

// 指定版本
syntax = "proto3";
option objc_class_prefix = "HLW";
// 定義包名
package demo;

// 定義服務(wù)
service ServerBase{
  // 定義接口
  // 方法
  rpc MakeMD5(Request) returns (Response){}
  rpc SayHello(HelloRequest) returns (HelloReplay){}
}

//請(qǐng)求的結(jié)構(gòu)體
message HelloRequest{
   // 類(lèi)型 字段 = 標(biāo)識(shí)號(hào)
    string name = 1;
}
//返回的結(jié)構(gòu)體
message HelloReplay{
    string message = 1;
}

// 定義請(qǐng)求結(jié)構(gòu)體
message Request{
  string Data = 1;
}

// 定義返回接口體數(shù)據(jù)
message Response{
  string Msg = 1;
}

4. 生成.go文件

protoc --go_out=plugins=grpc: . test.proto

這時(shí)候目錄低下會(huì)自動(dòng)生成test.pb.go文件

5. 簡(jiǎn)單的書(shū)寫(xiě)server.go

package main
import (
  "crypto/md5"
  "errors"
  "fmt"
  "github.com/srlemon/note/grpc_"
  "golang.org/x/net/context"
  "google.golang.org/grpc"
  "log"
  "net"
)

const (
  PORT = ":5003"
)

func main() {
  // 開(kāi)啟監(jiān)聽(tīng)
  lis, err := net.Listen("tcp", PORT)
  if err != nil {
     log.Fatal(err)
  }
  // new
  s := grpc.NewServer()
  // 注冊(cè)服務(wù)
  demo.RegisterServerBaseServer(s, &Serve{})
  log.Println("rpc服務(wù)已經(jīng)開(kāi)啟")
  s.Serve(lis)
}

// Serve 服務(wù)端
type Serve struct {
}

// MakeMD5 方法
func (s *Serve) MakeMD5(ctx context.Context, req *demo.Request) (ret *demo.Response, err error) {
  if req == nil {
     err = errors.New("請(qǐng)求數(shù)據(jù)為空")
     return
  }
  md := md5.New()
  data := md.Sum([]byte(req.Data))
  ret = new(demo.Response)
  ret.Msg = fmt.Sprintf("%x", data)
  return
}

// SayHello 方法
func (s *Serve) SayHello(ctc context.Context, req *demo.HelloRequest) (ret *demo.HelloReplay, err error) {
  if req == nil {
     err = errors.New("請(qǐng)求數(shù)據(jù)為空")
     return
  }
  ret = new(demo.HelloReplay)
  ret.Message = req.Name
  return
}

    go run server.go  開(kāi)啟rpc服務(wù)

6. 寫(xiě)client.go文件

package main
import (
  "fmt"
  demo "github.com/srlemon/note/grpc_"
  "golang.org/x/net/context"
  "google.golang.org/grpc"
  "log"
)

const (
  addr = "127.0.0.1:5003"
)

func main() {
  ctx := context.Background()
  // 連接代理
  conn, err := grpc.Dial(addr, grpc.WithInsecure())
  if err != nil {
     log.Fatal("did no connect", err)
  }
  defer conn.Close()
  // 生成一個(gè)客戶(hù)端
  client := demo.NewServerBaseClient(conn)
  var (
     data *demo.Request
     res  *demo.Response
  )
  data = new(demo.Request)
  data.Data = "哈哈,和黑"
  // 使用服務(wù)端方法
  if res, err = client.MakeMD5(ctx, data); err != nil {

     log.Fatal("sssssssssss", err)
  }
  // 輸出進(jìn)行加密后的信息
  fmt.Println(string(res.Msg))
  // 使用服務(wù)端方法
  _d, _ := client.SayHello(ctx, &demo.HelloRequest{Name: "哈哈哈"})
  // 輸出要說(shuō)的內(nèi)容
  fmt.Println(_d.Message)
}

go run client.go

終端輸出:

以上是“Golang中g(shù)rpc怎么用”這篇文章的所有內(nèi)容，感謝各位的閱讀！相信大家都有了一定的了解，希望分享的內(nèi)容對(duì)大家有所幫助，如果還想學(xué)習(xí)更多知識(shí)，歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道！