golang-微服务micro初体验

什么是微服务？

一种软件体系结构模式，用于将大型单块应用程序分解为更小、可管理的独立服务，这些服务经过语言无关协议进行通讯，每一个服务的重点作好一件事

微服务的概念并不新鲜，这是对服务导向架构的从新构想，但其方法更总体地与unix进程和管道保持一致。

微服务架构的理念：

• 服务很小 - 细粒度做为单一的商业目的相似于unix哲学“作一件事，作得好”
• 组织文化应该包含部署和测试的自动化。这减轻了管理和运营的负担
• 文化和设计原则应该包含失败和错误，相似于反脆弱系统。

好处：

• 更容易扩展开发 - 团队围绕不一样的业务需求进行组织并管理本身的服务。
• 更容易理解 - 微服务要小得多，一般是1000 LOC或更低。
• 更容易部署新版本的服务 - 能够独立部署，扩展和管理服务。
• 改进的容错和隔离 - 关注点的分离能够最大限度地减小一个服务中的问题对另外一个服务的影响。
• 提升执行速度 - 团队经过独立开发，部署和管理微服务，更快地知足业务需求。
• 可重用的服务和快速原型 - 微服务中根深蒂固的unix哲学容许您重用现有服务并在更快的速度上构建全新的功能。

micro 与go-micro 的区别

micro

Micro解决了构建微服务系统的关键要求。它采用微服务架构模式并将其转换为一组工具，由如下功能组成：

• API网关：使用服务发现进行动态请求路由的单个入口点。API网关容许您在后端构建可扩展的微服务架构，并在前端整合服务公共API。micro api经过发现和可插拔处理程序提供强大的路由，以提供http，grpc，websockets，发布事件等。
• 交互式CLI：用于直接从终端描述，查询和与您的平台和服务进行交互的CLI。CLI为您提供了您但愿了解微服务发生状况的全部命令。它还包括一个交互模式。
• 服务代理：基于 go-micro 构建的透明代理。将服务发现，负载平衡，容错，消息编码，中间件，监控等卸载到单个位置。独立运行或与服务一块儿运行。
• 模板生成：建立新的服务模板以快速入门。Micro提供用于编写微服务的预约义模板。始终以相同的方式开始，构建相同的服务以提升工做效率。
• SlackOps Bot：在您的平台上运行的机器人，让您能够从Slack自己管理您的应用程序。微型机器人支持ChatOps，使您可以经过消息传递与团队一块儿完成全部工做。它还包括建立松弛命令做为动态发现的服务的能力。
• Web仪表板： Web仪表板容许您浏览服务，描述其端点，请求和响应格式，甚至能够直接查询它们。仪表板还为想要即时进入终端的开发人员提供了内置的CLI体验。
• Go Framework：利用强大的 go-micro 框架轻松快速地开发微服务。Go Micro抽象出分布式系统的复杂性，并提供更简单的抽象来构建高度可扩展的微服务。

go-micro

go-micro提供了分布式系统开发的核心要求，包括RPC和事件驱动的通讯。

主要功能。

• 服务发现 - 自动服务注册和名称解析。服务发现是微服务开发的核心。当服务A须要与服务B通话时，它须要该服务的位置。默认发现机制是多播DNS（mdns），一种零配置系统。您能够选择使用SWIM协议为p2p网络设置八卦，或者为弹性云原生设置设置consul。
• 负载平衡 - 基于服务发现构建的客户端负载平衡。一旦咱们得到了服务的任意数量实例的地址，咱们如今须要一种方法来决定要路由到哪一个节点。咱们使用随机散列负载平衡来提供跨服务的均匀分布，并在出现问题时重试不一样的节点。
• 消息编码 - 基于内容类型的动态消息编码。客户端和服务器将使用编解码器和内容类型为您无缝编码和解码Go类型。能够编码任何种类的消息并从不一样的客户端发送。客户端和服务器默认处理此问题。这包括默认的protobuf和json。
• 请求/响应 - 基于RPC的请求/响应，支持双向流。咱们提供了同步通讯的抽象。对服务的请求将自动解决，负载平衡，拨号和流式传输。启用tls时，默认传输为http / 1.1或http2。
• Async Messaging - PubSub是异步通讯和事件驱动架构的一流公民。事件通知是微服务开发的核心模式。启用tls时，默认消息传递是点对点http / 1.1或http2。
• 可插拔接口 - Go Micro为每一个分布式系统抽象使用Go接口。所以，这些接口是可插拔的，并容许Go Micro与运行时无关。您能够插入任何基础技术。在github.com/micro/go-plugins中找到插件 。

开始

准备工做

安装go语言环境，并开启go module功能，能够设置 GOPROXY=https://goproxy.io 环境变量能够永久加速下载包。在环境变量path添加一行配置 %GOPATH%bin这样能够在 go get 的时候安装的软件能够直接使用，不须要切换路径，GOPATH:是工做空间目录

临时加速，只在当前控制台有效：

• win: set GOPROXY=https://goproxy.io
• linux + mac: GOPROXY=https://goproxy.io

1,下载proto,选择本身须要的版本解压放在 %GOPATH%bin下，方便管理:

https://github.com/protocolbuffers/protobuf/releases

2,安装protoc-gen-go：

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

3,安装micro:

go get github.com/micro/micro

建立项目

go mod init module名：用于建立go module项目

module名：建议和父文件夹的名字相同

在桌面新建文件夹 demo

自定义一个文件夹：打开cmd 进入桌面上的demo后，运行 go mod init demo,运行完后新建handler,proto/hello文件夹，以及main.go文件

目录结构定义为：

demo
-handler

-proto
--hello

main.go
go.mod

在proto/hello下新建 hello.proto文件，内容以下

syntax = "proto3"; // 定义protobuf版本

//定义接口
service Hello {
    rpc Say (SayRequest) returns (SayResponse); //定义接口方法
}

// SayRequest，SayResponse:能够为不一样接口定义输入输出参数
message SayRequest {
    string name = 1;
}

message SayResponse {
    string msg = 1;
}

打开cmd进入proto/hello下 编译proto文件：

protoc --micro_out=. --go_out=. hello/hello.proto

而后就会产生两个文件，hello.micro.go,hello.pb.go

在handler下，新建hello_handler.go文件

package handler

import (
    "context"
    pb "demo/proto/hello"//proto文件的路径
)

type hello struct{}

func NewHelloApi() pb.HelloHandler {
    return &hello{}
}

func (self *hello) Say(ctx context.Context, req *pb.SayRequest, resp *pb.SayResponse) error {
    resp.Msg = "hello   " + req.Name
    return nil
}

编写main：

package main

import (
    "fmt"
    "github.com/micro/go-micro"
    "log"
    "demo/handler"
    hello_api "demo/proto/hello"
)

const (
    ServiceName = "demo.api"
)

func main() {
    service := micro.NewService(
        micro.Name(ServiceName),
        micro.Version("1.0.0"),
    )

    service.Init()

    //挂载服务
    err := hello_api.RegisterHelloHandler(service.Server(), handler.NewHelloApi())
    if err != nil {
        fmt.Println(err)
    }

    // 启动api服务
    if err := service.Run(); err != nil {
        log.Fatal(err)
    }
}

更新依赖：

go mod tidy

运行：

go run main.go

测试

使用 micro提供的工具

micro call demo.api Hello.Say '{"name":"John"}'

使用 postman

运行 网关：

micro api --namespace=demo

测试接口

细节

运行网关的时候：添加namespace这个参数，该参数值( demo)和 ServiceName(demo.api)的前缀必需要一致，然后面的字符就是访问该服务的前缀 ，例如:api ,因此经过网关访问就是：http://127.0.0.1:8080/api/hello/say，

hello:是定义的接口，

say：是该接口提供的方法