中文字幕乱码人妻无码久久,亚洲中文字幕无码久久精品1,大香网伊人久久综合网2020

用 Lile 創建 gRPC-go 服務

用 Lile 創建 gRPC-go 服務

(金慶的專欄 2017.11)

Lile 是一個工具，用于 Go 語言快速創建 gRPC 服務。
https://github.com/lileio/lile

會自動添加 Prometheus, Zipkin 和 Google PubSub 支持。

go get -u github.com/lileio/lile/...
將安裝所有依賴包，并生成 bin/lile.exe, bin/protoc-gen-lile-server.exe.
另外還需要安裝 protoc.exe.

按照示例創建 users 服務：

E:\gopath\src\github.com
λ lile new jinq0123/users
Creating project in E:\gopath\src\github.com\jinq0123\users
Is this OK? [y]es/[n]o
y
.
├── server
│   ├── server.go
│   └── server_test.go
├── subscribers
│   └── subscribers.go
├── users
│   ├── cmd
│   │   ├── root.go
│   │   ├── serve.go
│   │   ├── subscribe.go
│   │   └── up.go
│   └── main.go
├── users.proto
├── Makefile
├── Dockerfile
├── .travis.yml
└── .gitignore

查看 Makefile, 復制其中 protoc 腳本，將 $$GOPATH 改為 %GOPATH%，運行：

E:\gopath\src\github.com\jinq0123\users
λ protoc -I . users.proto --lile-server_out=. --go_out=plugins=grpc:%GOPATH%/src
2017/11/28 16:59:24 [Creating] server\read.go
2017/11/28 16:59:24 [Creating test] server\read_test.go

protoc-gen-lile-server.exe 將生成 server\read.go, 對應 user.proto 中的方法 Users::Read().
grpc的插件將生成 users.pb.go，與僅僅用 grpc 生成的代碼相同。

D:/Go/bin/go.exe install -v [E:/gopath/src/github.com/jinq0123/users/users]
github.com/jinq0123/users/users
成功: 進程退出代碼 0.

可直接編譯生成 user.exe.

無參數運行則顯示命令行幫助：

E:\gopath\src\github.com\jinq0123\users
λ users
A gRPC based service

Usage:
users [command]

Available Commands:
help        Help about any command
serve       Run the RPC server
subscribe   Subscribe to and process queue messages
up          up runs both RPC and pubub subscribers

Flags:
-h, --help   help for users

Use "users [command] --help" for more information about a command.

用子命令serve啟動服務：

E:\gopath\src\github.com\jinq0123\users
λ users serve
INFO[0000] Serving gRPC on :8000
INFO[0000] Using Zipkin Global tracer
INFO[0000] Prometheus metrics at :9000/metrics

http://localhost:9000/metrics 會顯示

# HELP go_gc_duration_seconds A summary of the GC invocation durations.
# TYPE go_gc_duration_seconds summary
go_gc_duration_seconds{quantile="0"} 0
go_gc_duration_seconds{quantile="0.25"} 0
...

用 grpc-lua 來測試下：

E:\Git\grpc-lua\examples\helloworld (master)
λ lua-cpp.exe
Lua 5.3.4 Copyright (C) 1994-2017 Lua.org, PUC-Rio
> package.path = "../../src/lua/?.lua;" .. package.path
> grpc = require("grpc_lua.grpc_lua")
> grpc.import_proto_file("users.proto")
> stub = grpc.service_stub("localhost:8000", "users.Users")
D1128 17:28:13.711000000 4612 dns_resolver.c:301] Using native dns resolver
> request = {id = "abcd"}
> response, err, cod = stub:sync_request("Read", request)
> cod
2
> insp = require("inspect")
> insp(resonse)
nil
> insp(err)
"not yet implemented"

缺省實現返回 "not yet implemented" 錯誤。更改實現代如下：

func (s UsersServer) Read(ctx context.Context, r *users.Request) (*users.Response, error) {
   // return nil, errors.New("not yet implemented")
   return &users.Response{Id: "Hello, " + r.Id}, nil
}

再次請求：

> response, err, cod = stub:sync_request("Read", request)
> err
Endpoint read failed
...
> response, err, cod = stub:sync_request("Read", request)
> err
nil
> insp(response)
{
id = "Hello, abcd"
}

posted on 2017-11-28 18:47 金慶閱讀(846) 評論(0) 編輯收藏引用所屬分類: 9. 其它

只有注冊用戶登錄后才能發表評論。
【推薦】100%開源！大型工業跨平臺軟件C++源碼提供，建模，組態！

相關文章: TortoiseGit is OK but GitExtensions fails DeathVoteExpirationTimeout in Orleans How to delete local branches of GitExtension Clustering provider in Orleans Why Orleans' actor is virutal What comes after microservice? Rust Deref coercion example Rust Error Return Check Policy Rust visibility Why does Rust check borrow even in single thread

網站導航: 博客園 IT新聞 BlogJava 博問 Chat2DB 管理

金慶的專欄

公告

留言簿(12)

隨筆分類(502)

隨筆檔案(423)

相冊

搜索

積分與排名

最新評論

閱讀排行榜

評論排行榜