文档章节

golang微服务框架go-micro 入门笔记2.1 micro工具之micro api

 非正式解决方案
发布于 08/25 01:40
字数 2283
阅读 9
收藏 0

micro api

micro 功能非常强大,本文将详细阐述micro api 命令行的功能 重要的事情说3次

主要作用

主要作用是为微服务提供http网关支持。假如后端服务名称为go.micro.srv.hello,提供call方法,则我们可用通过http协议来调用微服务。

curl http://127.0.0.0:8080/hello/call?name=123

micro api指令全部参数如下

$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%]

翻译一下

   --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类型处理服务之间的映射,代码解读如下

  1. 下载handlerapi.zip并解压到%GOPATH%/techidea8.com/microapp/doc/下,解压后目录如下所示
E:\winlion\gopath\src\techidea8.com\microapp\doc\handerapi>ls
go.mod  go.sum  handerapi.go  proto/
  1. 初始化模块
#这一步必须做,否则会报错`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
  1. 生成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
  1. 运行
>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
  1. 查看服务状态
>micro list services
go.micro.api
go.micro.api.example
  1. 测试
>curl  "http://localhost:8080/example/example1/func1?name=winlion"
{"msg":"我们已经收到你的请求啦winlion"}

eventhander

我们通过--handler=event选项,来实现发布event事件,关键代码解读如下

  1. 下载handlerevent.zip 并解压到%GOPATH%/techidea8.com/microapp/doc/下,解压后目录如下所示
E:\winlion\gopath\src\techidea8.com\microapp\doc\handlerevent>ls
handlerevent.go

核心代码如下

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)
}
  1. 运行服务
>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
  1. 查看服务状态
>micro list services
go.micro.api
test1
topic:go.micro.evt.test
  1. 启动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
  1. 测试
>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事件,关键代码解读如下

  1. 下载handlerevent.zip 并解压到%GOPATH%/techidea8.com/microapp/doc/下,解压后目录如下所示
E:\winlion\gopath\src\techidea8.com\microapp\doc\handlerevent>ls
handlerevent.go

核心代码如下

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)
}
  1. 运行服务
>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
  1. 查看服务状态
>micro list services
go.micro.api
test1
topic:go.micro.evt.test
  1. 启动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
  1. 测试
>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·

  1. 下载handlerrpc.zip并解压到%GOPATH%/techidea8.com/microapp/doc/下,解压后目录如下所示
E:\winlion\gopath\src\techidea8.com\microapp\doc\handlerrpc>ls
handerapi.go  proto/
  1. 初始化模块
#这一步必须做,否则会报错`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
  1. 生成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
  1. 运行
>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
  1. 查看服务状态
>micro list services
go.micro.api
go.micro.api.model1
  1. 测试
>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环境

推荐阅读

扫微信二维码实现网站登陆提供体验地址和源代码

开源项目golang go语言后台管理框架restgo-admin

支持手势触摸,可左右滑动的日历插件

你必须知道的18个互联网业务模型

© 著作权归作者所有

粉丝 0
博文 7
码字总数 10436
作品 0
私信 提问
go micro 学习笔记 1:熟悉micro工具集和go-micro的体系架构

https://micro.mu/blog/2016/03/20/micro.html https://micro.mu/blog/2016/04/18/micro-architecture.html https://github.com/micro 1、Micro是一个专注于简化分布式系统开发的微服务生态系......

污湖洞主
2017/10/27
0
0
Go micro 源码阅读-结构

介绍 micro 是一个用来开发cloud native application的程序工具集,采用的是微服务架构,使用go语言编写。 micro主要包括: toolkits framework 即go-micro的部分,一个插件式的基于grpc的分...

invictuslee
2018/05/16
0
0
go micro 学习笔记 2:环境搭建(可运行示例)

1、创建镜像: docker run -it -v /opt:/wz -p 8080:8080 -p 8081:8081 -p 8082:8082 --name gomicro centos:latest /sbin/init -v是将主机的/opt目录映射到容器的/wz目录,所有在主机的/op......

污湖洞主
2017/10/27
0
0
基于微服务库的可插拔RPC - go-micro

Go-Micro 是一个基于微服务库的可插拔 RPC,为编写分布式应用程序提供基本构件。它是 Micro 工具包的一部分,支持 Proto-RPC 和 JSON-RPC 的请求/响应协议,默认设置Consul为探索。 示例服务...

匿名
2016/03/22
4.9K
2
脚本化微服务开源框架 - NHMicro

MVC 框架的缺点: 系统按照Controller、Service、Dao层次划分,虽然在建设初期技术结构清晰。但每个业务逻辑代码都分散到不同代码框,业务结构不直观,不利于后期业务重构。 业务代码与MVC技...

杰睿宁
2017/06/23
2.9K
5

没有更多内容

加载失败,请刷新页面

加载更多

二叉查找树的第 K 个结点

private TreeNode ret;private int cnt = 0;public TreeNode KthNode(TreeNode pRoot, int k) { inOrder(pRoot, k); return ret;}private void inOrder(TreeNode root......

Garphy
今天
4
0
windo8 weblogic

需要的软件包 现在安装jdk 则先进入你电脑自带jdk \bin目录下 然后java -jar 执行你的jar包就可以了 欢迎界面直接点击下一步,跳到更新界面,直接选择跳过 然后选择安装目录(注意:目录不要有...

恩多
今天
8
0
Activiti 批注

Activiti添加批注(comment)信息 在每次提交任务的时候需要描述一些批注信息,例如:请假流程提交的时候要描述信息为什么请假,如果领导驳回可以批注驳回原因等  1、添加批注 // 由于流程...

奔跑的android
今天
4
0
centos7命令行和图形界面的相互切换

最近安装了centos7,发现在命令行和图形界面的相互切换命令上,与centos以往版本有很大不同。 1,centos7默认安装后,跟其他版本一样,启动默认进入图形界面; 2,在图形化桌面,右击鼠标,选...

无名氏的程序员
今天
6
0
快速失败 (fail-fast) 和安全失败 (fail-safe) 的区别是什么

一:快速失败(fail—fast) 在用迭代器遍历一个集合对象时,如果遍历过程中对集合对象的内容进行了修改(增加、删除、修改),则会抛出Concurrent Modification Exception。 原理:迭代器在...

Bb进阶
今天
7
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部