微服务的调用
调用的代码来自大神：go-micro V2 从零开始（一）使用micro工具自动生成项目
上一期我们的把我们的服务注册到了我们的Consul中，怎么去使用客户端代码的形式去调用微服务呐？
package main
import (
"context"
"github.com/micro/go-micro/v2"
"github.com/micro/go-micro/v2/client"
pb "greeter/proto/greeter"
"log"
)
func main() {
// 这里以HelloService默认提供的Call接口调用为例示范服务的调用
// 可以看到他的调用就像调用本地方法一样，go-micro为我们隐藏了背后的服务注册、发现、负载均衡以及网络操作
testCallFunc()
// 这里示范消息的发送
testSendMessage()
}
func testCallFunc(){
// 获取hello服务
// 这里第一个参数"go.micro.service.hello"必须与hello-service注册信息一致
// 一般由micro生成的项目默认服务名为：{namespace 默认[go.micro]}.{type 默认[service]}.{项目名}组成
// 如果要修改默认值，在生成项目时可以这样： micro --namespace=XXX --type=YYYY ZZZZ
// 当然也可以直接修改main.go中micro.Name("go.micro.service.hello")的内容
helloService := pb.NewGreeterService("go.micro.service.greeter", client.DefaultClient)
// 默认生成的hello服务中自带三个接口: Call() Stream() PingPong(),分别对应参数调用、流传输和心跳
resp, err := helloService.Call(context.Background(), &pb.Request{
Name: "xiao xie",
})
if err != nil {
log.Panic("call func", err)
}
log.Println("call func success!", resp.Msg)
}
func testSendMessage(){
// 消息主题，定义规则与服务一致
// 同样，也可以修改main.go的micro.RegisterSubscriber("go.micro.service.hello", service.Server(), new(subscriber.Hello))
const topic = "go.micro.service.greeter"
// 获取消息发送接口，这里我一直使用的时micro.NewPublisher()
// 但在写文时发现NewPublisher()已经被废止，改为NewEvent()，二者参数和返回值一致
event := micro.NewEvent(topic, client.DefaultClient)
if err := event.Publish(context.Background(), &pb.Message{
Say: "hello server!",
}); err != nil {
log.Panic("send msg", err)
}
log.Println("send msg success!")
}
注意点我们的客户端是放在微服务的目录下：
image.png
结果悲剧了：
D:\code\go\Mi_Onse\greeter>go run greeter_cli.go
2021-01-20 17:22:20.086552 I | call func{"id":"go.micro.client","code":500,"detail":"service go.micro.service.greeter: not found","status":"Internal Server Error"}
panic: call func{"id":"go.micro.client","code":500,"detail":"service go.micro.service.greeter: not found","status":"Internal Server Error"}
goroutine 1 [running]:
log.Panic(0xc0004b1f48, 0x2, 0x2)
D:/go1.14/go1.14.13/src/log/log.go:351 +0xb3
main.testCallFunc()
D:/code/go/Mi_Onse/greeter/greeter_cli.go:33 +0x18a
main.main()
D:/code/go/Mi_Onse/greeter/greeter_cli.go:15 +0x27
exit status 2
D:\code\go\Mi_Onse\greeter>
原因是我们的客户端调用的时候应该是需要去我们的Consul查询我们的服务，所以它找不到了！！！
这个地方也是找不到注册到consul的的服务：
D:\code\go\Mi_Onse>micro list services
D:\code\go\Mi_Onse>
我们切换我们的微服务注册到默认的MDNS
切换后，查看服务：
D:\code\go\Mi_Onse>micro list services
go.micro.service.greeter
micro.http.broker
- 从consul查看服务列表--方式1：
–registry_address=127.0.0.1:8500 用来指定服务发现的地址, 就是上面的 consul 的地址, consul 默认端口是 8500
这地方也不行？暂时不知道！！！备注一下 也获取不到！！！
D:\code\go\Mi_Onse>micro --registry_address=127.0.0.1:8500 list services
D:\code\go\Mi_Onse>
- 从consul查看服务列表--方式2：
这地方也不行？暂时不知道！！！备注一下 也获取不到！！！
D:\code\go\Mi_Onse>micro --registry consul --registry_address loaclhost:8500 list services
Registry consul not found
D:\code\go\Mi_Onse>
先切换回 使用默认的MDSN 启动微服务方式：
再调用我们的客户端代码：
D:\code\go\Mi_Onse\greeter>go run greeter_cli.go
2021-01-20 17:30:43.456834 I | call func success! Hello xiao xie
2021-01-20 17:30:43.558562 I | send msg success!
D:\code\go\Mi_Onse\greeter>
补充 ：其他命令学习
1 查看服务详情：
命令：
D:\code\go\Mi_Onse>micro get service go.micro.service.greeter
结果：
D:\code\go\Mi_Onse>micro get service go.micro.service.greeter
service go.micro.service.greeter
version latest
ID Address Metadata
go.micro.service.greeter-c344efa6-8a4f-4674-9fe1-f1679e667233 192.168.1.213:52927 broker=http,protocol=grpc,registry=mdns,server=grpc,transport=grpc
Endpoint: Greeter.Call
Request: {
message_state MessageState {
no_unkeyed_literals NoUnkeyedLiterals
do_not_compare DoNotCompare
do_not_copy DoNotCopy
message_info MessageInfo
}
int32 int32
unknown_fields []uint8
name string
}
Response: {
message_state MessageState {
no_unkeyed_literals NoUnkeyedLiterals
do_not_compare DoNotCompare
do_not_copy DoNotCopy
message_info MessageInfo
}
int32 int32
unknown_fields []uint8
msg string
}
Endpoint: Greeter.PingPong
Metadata: stream=true
Request: {}
Response: {}
Endpoint: Greeter.Stream
Metadata: stream=true
Request: {}
Response: {}
Endpoint: Greeter.Handle
Metadata: subscriber=true,topic=go.micro.service.greeter
Request: {
message_state MessageState {
no_unkeyed_literals NoUnkeyedLiterals
do_not_compare DoNotCompare
do_not_copy DoNotCopy
message_info MessageInfo
}
int32 int32
unknown_fields []uint8
say string
}
Response: {}
2 尝试调用服务：
- 估计这个是v1版本的形式：
D:\code\go\Mi_Onse>micro query go.micro.service.greeter greeter.call
无效参数
QUERY { PROCESS | SESSION | TERMSERVER | USER }
exit status 1
- V2版本的相识（当我们的把微服务注册到Consul的时候是找不到服务的）
D:\code\go\Mi_Onse>micro call go.micro.service.greeter greeter.call
error calling go.micro.service.greeter.greeter.call: {"id":"go.micro.client","code":500,"detail":"service go.micro.service.greeter: not found","status":"Internal Server Error"}
D:\code\go\Mi_Onse>
切换回默认注册到MDNS的之后【区分大小写：】
大写：
D:\code\go\Mi_Onse>micro call go.micro.service.greeter Greeter.Call
{
"msg": "Hello "
}
小写：
D:\code\go\Mi_Onse>micro call go.micro.service.greeter greeter.call
error calling go.micro.service.greeter.greeter.call: {"id":"go.micro.client","code":500,"detail":"unknown service greeter","status":"Internal Server Error"}
使用Mirco修改默认注册中心：
D:\code\go\Mi_Onse>set MICRO_REGISRY consul
MICRO_REGISRY=consul
D:\code\go\Mi_Onse>set MIRCO_REGISTRY_ADDRESS 127.0.0.1:8500
环境变量 MIRCO_REGISTRY_ADDRESS 127.0.0.1:8500 没有定义
D:\code\go\Mi_Onse>
cli命令：
D:\code\go\Mi_Onse>micro cli
micro> list
go.micro.service.greeter
micro.http.broker
micro> help
Commands:
call Call a service
deregister Deregister a service
exit Exit the CLI
get Get service info
health Get service health
help CLI usage
list List services, peers or routes
publish Publish a message to a topic
quit Exit the CLI
register Register a service
stats Get service stats
stream Stream a call to a service
micro>
尝试修改我们的mirco 默认的注册中心
D:\code\go\Mi_Onse>micro --registry consul --registry_address loaclhost:8500 list services
Registry consul not found
D:\code\go\Mi_Onse>micro --registry consul --registry_address loaclhost:8500 list services
Registry consul not found
D:\code\go\Mi_Onse>
V2 micro --help 命令大全：
D:\code\go\Mi_Onse>micro --help
NAME:
micro - A microservice runtime
Use `micro [command] --help` to see command specific help.
USAGE:
micro [global options] command [command options] [arguments...]
VERSION:
latest
COMMANDS:
server Run the micro server
new Create a service template
env Get/set micro cli environment
login Login using a token
run Run a service: micro run [source]
logs Get logs for a service
call Call a service e.g micro call greeter Say.Hello '{"name": "John"}
update Update a service: micro update [source]
kill Kill a service: micro kill [source]
store Run the micro store service
config Manage configuration values
auth Manage authentication related resources
status List runtime objects
stream Create a service stream
file Move files between your local machine and the server
list List items in registry or network
cli Run the interactive CLI
publish Publish a message to a topic
stats Query the stats of a service
bot Run the chatops bot
whoami Account information
api Run the api gateway
register Register an item in the registry
deregister Deregister an item in the registry
get Get item from registry
broker Run the message broker
health Check the health of a service
proxy Run the service proxy
router Run the micro network router
tunnel Run the micro network tunnel
network Run the micro network node
registry Run the service registry
debug Run the micro debug service
trace Get tracing info from a service
runtime Run the micro runtime
service Run a micro service
plugin Plugin commands
web Run the web dashboard
init Run the micro operator
help, h Shows a list of commands or help for one command
GLOBAL OPTIONS:
--client value Client for go-micro; rpc [%MICRO_CLIENT%]
--client_request_timeout value Sets the client request timeout. e.g 500ms, 5s, 1m. Default: 5s [%MICRO_CLIENT_REQUEST_TIMEOUT%]
--client_retries value Sets the client retries. Default: 1 (default: 1) [%MICRO_CLIENT_RETRIES%]
--client_pool_size value Sets the client connection pool size. Default: 1 (default: 0) [%MICRO_CLIENT_POOL_SIZE%]
--client_pool_ttl value Sets the client connection pool ttl. e.g 500ms, 5s, 1m. Default: 1m [%MICRO_CLIENT_POOL_TTL%]
--register_ttl value Register TTL in seconds (default: 60) [%MICRO_REGISTER_TTL%]
--register_interval value Register interval in seconds (default: 30) [%MICRO_REGISTER_INTERVAL%]
--server value Server for go-micro; rpc [%MICRO_SERVER%]
--server_name value Name of the server. go.micro.srv.example [%MICRO_SERVER_NAME%]
--server_version value Version of the server. 1.1.0 [%MICRO_SERVER_VERSION%]
--server_id value Id of the server. Auto-generated if not specified [%MICRO_SERVER_ID%]
--server_address value Bind address for the server. 127.0.0.1:8080 [%MICRO_SERVER_ADDRESS%]
--server_advertise value Used instead of the server_address when registering with discovery. 127.0.0.1:8080 [%MICRO_SERVER_ADVERTISE%]
--server_metadata value A list of key-value pairs defining metadata. version=1.0.0 [%MICRO_SERVER_METADATA%]
--broker value Broker for pub/sub. http, nats, rabbitmq [%MICRO_BROKER%]
--broker_address value Comma-separated list of broker addresses [%MICRO_BROKER_ADDRESS%]
--profile value Debug profiler for cpu and memory stats [%MICRO_DEBUG_PROFILE%]
--registry value Registry for discovery. etcd, mdns [%MICRO_REGISTRY%]
--registry_address value Comma-separated list of registry addresses [%MICRO_REGISTRY_ADDRESS%]
--runtime value Runtime for building and running services e.g local, kubernetes (default: "local") [%MICRO_RUNTIME%]
--runtime_source value Runtime source for building and running services e.g github.com/micro/service (default: "github.com/micro/services") [%MICRO_RUNTIME_SOURCE%]
--selector value Selector used to pick nodes for querying [%MICRO_SELECTOR%]
--store value Store used for key-value storage [%MICRO_STORE%]
--store_address value Comma-separated list of store addresses [%MICRO_STORE_ADDRESS%]
--store_database value Database option for the underlying store [%MICRO_STORE_DATABASE%]
--store_table value Table option for the underlying store [%MICRO_STORE_TABLE%]
--transport value Transport mechanism used; http [%MICRO_TRANSPORT%]
--transport_address value Comma-separated list of transport addresses [%MICRO_TRANSPORT_ADDRESS%]
--tracer value Tracer for distributed tracing, e.g. memory, jaeger [%MICRO_TRACER%]
--tracer_address value Comma-separated list of tracer addresses [%MICRO_TRACER_ADDRESS%]
--auth value Auth for role based access control, e.g. service [%MICRO_AUTH%]
--auth_id value Account ID used for client authentication [%MICRO_AUTH_ID%]
--auth_secret value Account secret used for client authentication [%MICRO_AUTH_SECRET%]
--auth_namespace value Namespace for the services auth account (default: "go.micro") [%MICRO_AUTH_NAMESPACE%]
--auth_public_key value Public key for JWT auth (base64 encoded PEM) [%MICRO_AUTH_PUBLIC_KEY%]
--auth_private_key value Private key for JWT auth (base64 encoded PEM) [%MICRO_AUTH_PRIVATE_KEY%]
--auth_provider value Auth provider used to login user [%MICRO_AUTH_PROVIDER%]
--auth_provider_client_id value The client id to be used for oauth [%MICRO_AUTH_PROVIDER_CLIENT_ID%]
--auth_provider_client_secret value The client secret to be used for oauth [%MICRO_AUTH_PROVIDER_CLIENT_SECRET%]
--auth_provider_endpoint value The enpoint to be used for oauth [%MICRO_AUTH_PROVIDER_ENDPOINT%]
--auth_provider_redirect value The redirect to be used for oauth [%MICRO_AUTH_PROVIDER_REDIRECT%]
--auth_provider_scope value The scope to be used for oauth [%MICRO_AUTH_PROVIDER_SCOPE%]
--config value The source of the config to be used to get configuration [%MICRO_CONFIG%]
--local Enable local only development: Defaults to true. (default: false)
--enable_acme Enables ACME support via Let's Encrypt. ACME hosts should also be specified. (default: false) [%MICRO_ENABLE_ACME%]
--acme_hosts value Comma separated list of hostnames to manage ACME certs for [%MICRO_ACME_HOSTS%]
--acme_provider value The provider that will be used to communicate with Let's Encrypt. Valid options: autocert, certmagic [%MICRO_ACME_PROVIDER%]
--enable_tls Enable TLS support. Expects cert and key file to be specified (default: false) [%MICRO_ENABLE_TLS%]
--tls_cert_file value Path to the TLS Certificate file [%MICRO_TLS_CERT_FILE%]
--tls_key_file value Path to the TLS Key file [%MICRO_TLS_KEY_FILE%]
--tls_client_ca_file value Path to the TLS CA file to verify clients against [%MICRO_TLS_CLIENT_CA_FILE%]
--api_address value Set the api address e.g 0.0.0.0:8080 [%MICRO_API_ADDRESS%]
--namespace value Set the micro service namespace (default: "micro") [%MICRO_NAMESPACE%]
--proxy_address value Proxy requests via the HTTP address specified [%MICRO_PROXY_ADDRESS%]
--web_address value Set the web UI address e.g 0.0.0.0:8082 [%MICRO_WEB_ADDRESS%]
--network value Set the micro network name: local, go.micro [%MICRO_NETWORK%]
--network_address value Set the micro network address e.g. :9093 [%MICRO_NETWORK_ADDRESS%]
--router_address value Set the micro router address e.g. :8084 [%MICRO_ROUTER_ADDRESS%]
--gateway_address value Set the micro default gateway address e.g. :9094 [%MICRO_GATEWAY_ADDRESS%]
--tunnel_address value Set the micro tunnel address e.g. :8083 [%MICRO_TUNNEL_ADDRESS%]
--api_handler value Specify the request handler to be used for mapping HTTP requests to services; {api, proxy, rpc} [%MICRO_API_HANDLER%]
--api_namespace value Set the namespace used by the API e.g. com.example.api [%MICRO_API_NAMESPACE%]
--web_namespace value Set the namespace used by the Web proxy e.g. com.example.web [%MICRO_WEB_NAMESPACE%]
--web_url value Set the host used for the web dashboard e.g web.example.com [%MICRO_WEB_HOST%]
--enable_stats Enable stats (default: false) [%MICRO_ENABLE_STATS%]
--auto_update Enable automatic updates (default: false) [%MICRO_AUTO_UPDATE%]
--update_url value Set the url to retrieve system updates from (default: "https://go.micro.mu/update") [%MICRO_UPDATE_URL%]
--report_usage Report usage statistics (default: true) [%MICRO_REPORT_USAGE%]
--env value, -e value Override environment [%MICRO_ENV%]
--plugin value Comma separated list of plugins e.g broker/rabbitmq, registry/etcd, micro/basic_auth, /path/to/plugin.so [%MICRO_PLUGIN%]
--help, -h show help (default: false)
--version print the version (default: false)
D:\code\go\Mi_Onse>
区别:
D:\code\go\Mi_Onse\greeter>micro register consulsdasda
D:\code\go\Mi_Onse\greeter>micro register consulsdasdaasdasd
D:\code\go\Mi_Onse>micro --registry consul --registry_address loaclhost:8500 list services
Registry consul not found
