golang微服務框架go-micro 入門筆記2.1 micro工具之micro api
micro api
micro 功能很是強大,本文將詳細闡述micro api 命令行的功能 重要的事情說3次html
- 本文所有代碼https://idea.techidea8.com/open/idea.shtml?id=6
- 本文所有代碼https://idea.techidea8.com/open/idea.shtml?id=6
- 本文所有代碼https://idea.techidea8.com/open/idea.shtml?id=6
主要做用
主要做用是爲微服務提供http網關支持。假如後端服務名稱爲go.micro.srv.hello,提供call方法，則咱們可用經過http協議來調用微服務。node
curl http://127.0.0.0:8080/hello/call?name=123
複製代碼
micro api指令所有參數以下git
$micro api -h
NAME:
micro api - Run the api gateway
USAGE:
micro api [command options] [arguments...]
OPTIONS:
--address value Set the api address e.g 0.0.0.0:8080 [%MICRO_API_ADDRESS%]
--handler value Specify the request handler to be used for mapping HTTP requests to services; {api, event, http, rpc} [%MICRO_API_HANDLER%]
--namespace value Set the namespace used by the API e.g. com.example.api [%MICRO_API_NAMESPACE%]
--resolver value Set the hostname resolver used by the API {host, path, grpc} [%MICRO_API_RESOLVER%]
--enable_rpc Enable call the backend directly via /rpc [%MICRO_API_ENABLE_RPC%]
複製代碼
翻譯一下github
--address value 設置網關訪問的ip和端口,如設置成0.0.0.0:8080,則能夠經過http://127.0.0.1:8080/進行訪問,默認爲0.0.0.0:8080
--handler value 指定映射具體哪一種類型的處理程序,可選擇{api, event, http, rpc} ,默認是rpc
--namespace value 指定暴露哪些微服務,經過命名空間匹配,如指定value爲`go.micro.srv`，則該空間下全部微服務都能被訪問
--resolver value 路徑和微服務的對應關係,默認是micro,可選項爲{host, path, grpc}
--enable_rpc 是否支持直接經過rcp接口進行訪問,默認false
複製代碼
apihander
咱們經過--handler=api類型選項,實現http到api類型處理服務之間的映射,代碼解讀以下golang
- 下載
handlerapi.zip並解壓到%GOPATH%/techidea8.com/microapp/doc/下,解壓後目錄以下所示
E:\winlion\gopath\src\techidea8.com\microapp\doc\handerapi>ls
go.mod go.sum handerapi.go proto/
複製代碼
- 初始化模塊
#這一步必須作,不然會報錯`build command-line-arguments: cannot load techidea8.com/microapp/doc/handerapi/proto:`
>go mod init
>go: creating new go.mod: module techidea8.com/microapp/doc/handerapi
複製代碼
- 生成proto文件,請自行替換GOPATH路徑.
>protoc --proto_path=E:/winlion/gopath/src --proto_path=. --go_out=. --micro_out=. proto/handerapi.proto
#注意網絡上不少文檔使用--proto_path=import_proto_path:. 這種格式指定path可是在win10這種格式是行不通的
#另一種可行的格式是 -IE:/winlion/gopath/src -I. 以下也是可行的
>protoc -IE:/winlion/gopath/src -I. --go_out=. --micro_out=. proto/handerapi.proto
複製代碼
- 運行
>go run handerapi.go
2019/08/24 20:59:32 Transport [http] Listening on [::]:54208
2019/08/24 20:59:32 Broker [http] Connected to [::]:54209
2019/08/24 20:59:32 Registry [mdns] Registering node: go.micro.api.example-71c8b1fa-f84b-4cf6-957f-617f67a4083c
複製代碼
- 查看服務狀態
>micro list services
go.micro.api
go.micro.api.example
複製代碼
- 測試
>curl "http://localhost:8080/example/example1/func1?name=winlion"
{"msg":"咱們已經收到你的請求啦winlion"}
複製代碼
eventhander
咱們經過--handler=event選項,來實現發佈event事件,關鍵代碼解讀以下web
- 下載
handlerevent.zip並解壓到%GOPATH%/techidea8.com/microapp/doc/下,解壓後目錄以下所示
E:\winlion\gopath\src\techidea8.com\microapp\doc\handlerevent>ls
handlerevent.go
複製代碼
核心代碼以下json
service := micro.NewService(micro.Name("test1"))
service.Init()
//訂閱go.micro.evt.test事件,注意這個test
micro.RegisterSubscriber("go.micro.evt.test", service.Server(), new(TestEvent))
if err := service.Run(); err != nil {
log.Fatal(err)
}
複製代碼
- 運行服務
>go run handlerevent.go
2019/08/24 23:17:18 Transport [http] Listening on [::]:57093
2019/08/24 23:17:18 Broker [http] Connected to [::]:57094
2019/08/24 23:17:19 Registry [mdns] Registering node: test1-7efd3b0a-5455-4456-870d-3b34e80f1354
2019/08/24 23:17:19 Subscribing test1-7efd3b0a-5455-4456-870d-3b34e80f1354 to topic: go.micro.evt.test
複製代碼
- 查看服務狀態
>micro list services
go.micro.api
test1
topic:go.micro.evt.test
複製代碼
- 啓動event發佈支持
>micro api --handler=event --namespace=go.micro.evt
2019/08/24 23:06:28 Registering API Event Handler at /
2019/08/24 23:06:28 HTTP API Listening on [::]:8080
2019/08/24 23:06:28 Transport [http] Listening on [::]:56778
2019/08/24 23:06:28 Broker [http] Connected to [::]:56779
2019/08/24 23:06:28 Registry [mdns] Registering node: go.micro.api-c342fe3f-4a06-4955-be3f-79284e580467
複製代碼
- 測試
>curl -d "{\"message\": \"Hello,Winlion\"}" "http://localhost:8080/test/login" -X POST
#服務器側會顯示以下數據
>2019/08/24 23:18:54 Process 收到事件 login {"message": "Hello,Winlion"}
複製代碼
注意,在win系統下,經過curl發佈json數據,須要採用雙引號,而且須要使用轉義字符
\注意http://localhost:8080/test/login中的test對應go.micro.evt.test中的test後端
eventhander
咱們經過--handler=event選項,來實現發佈event事件,關鍵代碼解讀以下api
- 下載
handlerevent.zip並解壓到%GOPATH%/techidea8.com/microapp/doc/下,解壓後目錄以下所示
E:\winlion\gopath\src\techidea8.com\microapp\doc\handlerevent>ls
handlerevent.go
複製代碼
核心代碼以下bash
service := micro.NewService(micro.Name("test1"))
service.Init()
//訂閱go.micro.evt.test事件,注意這個test
micro.RegisterSubscriber("go.micro.evt.test", service.Server(), new(TestEvent))
if err := service.Run(); err != nil {
log.Fatal(err)
}
複製代碼
- 運行服務
>go run handlerevent.go
2019/08/24 23:17:18 Transport [http] Listening on [::]:57093
2019/08/24 23:17:18 Broker [http] Connected to [::]:57094
2019/08/24 23:17:19 Registry [mdns] Registering node: test1-7efd3b0a-5455-4456-870d-3b34e80f1354
2019/08/24 23:17:19 Subscribing test1-7efd3b0a-5455-4456-870d-3b34e80f1354 to topic: go.micro.evt.test
複製代碼
- 查看服務狀態
>micro list services
go.micro.api
test1
topic:go.micro.evt.test
複製代碼
- 啓動event發佈支持
>micro api --handler=event --namespace=go.micro.evt
2019/08/24 23:06:28 Registering API Event Handler at /
2019/08/24 23:06:28 HTTP API Listening on [::]:8080
2019/08/24 23:06:28 Transport [http] Listening on [::]:56778
2019/08/24 23:06:28 Broker [http] Connected to [::]:56779
2019/08/24 23:06:28 Registry [mdns] Registering node: go.micro.api-c342fe3f-4a06-4955-be3f-79284e580467
複製代碼
- 測試
>curl -d "{\"message\": \"Hello,Winlion\"}" "http://localhost:8080/test/login" -X POST
#服務器側會顯示以下數據
>2019/08/24 23:18:54 Process 收到事件 login {"message": "Hello,Winlion"}
複製代碼
注意,在win系統下,經過curl發佈json數據,須要採用雙引號,而且須要使用轉義字符
\注意http://localhost:8080/test/login中的test對應go.micro.evt.test中的test
rpchander
咱們經過--handler=rpc類型選項,實現http到rpc服務之間的映射,rpc類型和api類型比較類似,能夠參考apihanlder相關代碼,rpchander代碼包爲`handlerrpc·
- 下載
handlerrpc.zip並解壓到%GOPATH%/techidea8.com/microapp/doc/下,解壓後目錄以下所示
E:\winlion\gopath\src\techidea8.com\microapp\doc\handlerrpc>ls
handerapi.go proto/
複製代碼
- 初始化模塊
#這一步必須作,不然會報錯`build command-line-arguments: cannot load techidea8.com/microapp/doc/handerapi/proto:`
>go mod init
>go: creating new go.mod: module techidea8.com/microapp/doc/handlerrpc
複製代碼
- 生成proto文件,請自行替換GOPATH路徑.
>protoc --proto_path=. --go_out=. --micro_out=. proto/handlerrpc.proto
#注意網絡上不少文檔使用--proto_path=import_proto_path:. 這種格式指定path可是在win10這種格式是行不通的
#另一種可行的格式是 -IE:/winlion/gopath/src -I. 以下也是可行的
>protoc -IE:/winlion/gopath/src -I. --go_out=. --micro_out=. proto/handerapi.proto
複製代碼
- 運行
>go run handlerrpc.go
2019/08/24 20:59:32 Transport [http] Listening on [::]:54208
2019/08/24 20:59:32 Broker [http] Connected to [::]:54209
2019/08/24 20:59:32 Registry [mdns] Registering node: go.micro.api.example-71c8b1fa-f84b-4cf6-957f-617f67a4083c
複製代碼
- 查看服務狀態
>micro list services
go.micro.api
go.micro.api.model1
複製代碼
- 測試
>curl -H "Content-Type: application/json" -d "{\"arg\": \"Winlion\"}" "http://localhost:8080/model1/model1/action1"
{"data":"接收到數據Winlion"}
複製代碼
rpchandler 和 api handler 的區別在於apihandler 的數據交proto模型在rpc的基礎上再次進行了封裝.
httphander
咱們經過--handler=http類型選項,http服務服務映射,核心代碼以下
- 新建
handlerweb.go代碼以下
//handlerweb.go
package main
import (
"encoding/json"
"log"
"net/http"
"github.com/micro/go-micro/web"
)
//hello 處理函數,打印helloworld
func hello(w http.ResponseWriter, req *http.Request) {
//json支持
w.Header().Add("content-type", "application/json;charset=utf-8")
if err := json.NewEncoder(w).Encode(map[string]interface{}{
"code": 0,
"message": "hello,world",
}); err != nil {
//頁面報錯顯示信息
http.Error(w, err.Error(), http.StatusNotFound)
}
}
func main() {
//new 一個web服務
service := web.NewService(web.Name("go.micro.web.hello"))
//綁定映射方法
service.HandleFunc("/", hello)
//初始化
service.Init()
//運行
if err := service.Run(); err != nil {
log.Fatal(err)
}
}
複製代碼
- 啓動應用
>go run handlerweb.go
2019/08/24 23:58:14 Listening on [::]:57984
複製代碼
- 啓動api服務
>micro api --handler=http --namespace=go.micro.web
2019/08/24 23:58:42 Registering API HTTP Handler at /{service:[a-zA-Z0-9]+}
2019/08/24 23:58:42 HTTP API Listening on [::]:8080
2019/08/24 23:58:42 Transport [http] Listening on [::]:57992
2019/08/24 23:58:42 Broker [http] Connected to [::]:57993
2019/08/24 23:58:42 Registry [mdns] Registering node: go.micro.api-fecb79d6-0175-4d1c-9243-29c1d616b70d
複製代碼
- 測試
>curl http://127.0.0.1:8080/hello/
{"code":0,"message":"hello,world"}
#注意其中的hello 對應微服務`go.micro.web.hello`中的hello
複製代碼
enable_rpc
該做用是開啓rpc 直接訪問支持,設置enable_rpc=true 能夠經過以下接口訪問
- 開啓rpc支持
>>micro api --handler=rpc --namespace=go.micro.api --enable_rpc=true
複製代碼
- 新建微服務
>micro new --type=srv techidea8.com/microapp/doc/enablerpc
Creating service go.micro.srv.enablerpc in E:\winlion\gopath\src\techidea8.com\microapp\doc\e
.
├── main.go
├── plugin.go
├── handler
│ └── enablerpc.go
├── subscriber
│ └── enablerpc.go
├── proto\enablerpc
│ └── enablerpc.proto
├── Dockerfile
├── Makefile
├── README.md
└── go.mod
download protobuf for micro:
brew install protobuf
go get -u github.com/golang/protobuf/{proto,protoc-gen-go}
go get -u github.com/micro/protoc-gen-micro
compile the proto file enablerpc.proto:
cd E:\winlion\gopath\src\techidea8.com\microapp\doc\enablerpc
protoc --proto_path=.:$GOPATH/src --go_out=. --micro_out=. proto/enablerpc/enablerpc.proto
複製代碼
注意,因爲win下不能識別--proto_path=.:$GOPATH/src,所以咱們須要自行處理以下腳本，其中E:/winlion/gopath請替換成各自的GOPATH
>cd /d E:\winlion\gopath\src\techidea8.com\microapp\doc\enablerpc
>protoc --proto_path=. --proto_path=E:/winlion/gopath/src --go_out=. --micro_out=. proto/enablerpc/enablerpc.proto
複製代碼
- 啓動服務
#啓動微服務
>go run main.go
#啓動rpc支持
> micro api --handler=rpc --namespace=go.micro.srv --enable_rpc=true
複製代碼
- 測試
> curl -H "Content-Type: application/json" -d "{\"service\": \"go.micro.srv.enablerpc\",\"method\": \"Enablerpc.Call\", \"request\": {\"name\": \"Winlion\"}}" "http://localhost:8080/rpc"
#返回以下數據
{"msg":"Hello Winlion"}
複製代碼
閱讀本文前你可能須要進行以下閱讀
golang分佈式微服務框架go-micro 入門筆記1:1分鐘快速搭建go-micro環境
推薦閱讀
相關文章
- 1. golang微服務框架go-micro 入門筆記2.1 micro工具之micro api
- 2. golang微服務框架go-micro 入門筆記2.2 micro工具之微應用利器micro web
- 3. golang微服務框架go-micro 入門筆記1.搭建 go-micro環境
- 4. golang微服務框架go-micro 入門筆記2.4 go-micro service解讀
- 5. golang微服務框架go-micro 入門筆記2.3 micro工具之消息接收和發佈
- 6. golang微服務框架go-micro 入門筆記2.3 micro工具之消息訂閱和發佈
- 7. Golang 微服務框架 - 1. Micro 介紹
- 8. go-micro微服務框架使用--golang
- 9. 介紹微服務框架Micro筆記
- 10. Golang 微服務框架——Micro的使用
- 更多相關文章...
- • netwox網絡工具集入門教程 - TCP/IP教程
- • Memcached入門教程 - NoSQL教程
- • Spring Cloud 微服務實戰(三) - 服務註冊與發現
- • Tomcat學習筆記（史上最全tomcat學習筆記）
相關標籤/搜索
每日一句
-
每一个你不满意的现在，都有一个你没有努力的曾经。
最新文章
- 1. CVPR 2020 論文大盤點-光流篇
- 2. Photoshop教程_ps中怎麼載入圖案？PS圖案如何導入？
- 3. org.pentaho.di.core.exception.KettleDatabaseException:Error occurred while trying to connect to the
- 4. SonarQube Scanner execution execution Error --- Failed to upload report - 500: An error has occurred
- 5. idea 導入源碼包
- 6. python學習 day2——基礎學習
- 7. 3D將是頁遊市場新賽道？
- 8. osg--交互
- 9. OSG-交互
- 10. Idea、spring boot 圖片(pgn顯示、jpg不顯示)解決方案
歡迎關注本站公眾號,獲取更多信息
相關文章
- 1. golang微服務框架go-micro 入門筆記2.1 micro工具之micro api
- 2. golang微服務框架go-micro 入門筆記2.2 micro工具之微應用利器micro web
- 3. golang微服務框架go-micro 入門筆記1.搭建 go-micro環境
- 4. golang微服務框架go-micro 入門筆記2.4 go-micro service解讀
- 5. golang微服務框架go-micro 入門筆記2.3 micro工具之消息接收和發佈
- 6. golang微服務框架go-micro 入門筆記2.3 micro工具之消息訂閱和發佈
- 7. Golang 微服務框架 - 1. Micro 介紹
- 8. go-micro微服務框架使用--golang
- 9. 介紹微服務框架Micro筆記
- 10. Golang 微服務框架——Micro的使用