通过 Micro Bot 与 Go Micro 微服务进行交互

上篇分享我们介绍了通过 Micro CLI 与 Go Micro 微服务进行交互，除此之外，Micro 生态还支持通过机器人与 Go Micro 进行交互，我们可以在 Slack、HipChat、XMPP 之类的协作工具中通过发送消息的方式查看或 Go Micro 提供的服务，就像是背后是个机器人一样。这里我们以 Slack 为例进行演示。

Micro Bot 的基本使用

首先我们在 hello 项目根目录下运行 micro bot 命令启动服务：

micro bot --inputs=slack --slack_token=SLACK_TOKEN

注：将 SLACK_TOKEN 替换成你自己的 token 值。

然后我们到自己的 Slack Workspace 输入指令即可与 Go Micro 微服务进行交互，首先通过 help 查看可以使用哪些指令：

这些指令和我们上篇分享介绍的 Micro CLI 差不多，我们可以简单测试下：

可以看到，我们在输入框输出指令后回车，就会从 Go Micro 微服务处返回对应的信息并显示在屏幕上。

Micro 还支持通过 HipChat 实现类似的功能，具体可以参考官方文档，我们可以在这些协作工具中通过发送消息的方式到 Go Micro 的注册中心注册/反注册服务，也可以查看或调用 Go Micro 对外提供的微服务接口，此时，Micro Bot 所承担的角色和 Micro CLI、Micro API、Micro Web 一样，只不过请求输入方式变成了消息而已。

注册新指令

除了使用系统内置的指令之外，还可以自己编写指令注册到 Micro Bot 中，在 src/github.com/micro/micro/main.go 中，可以这么定义一个 greeting 指令：

import "github.com/micro/go-micro/agent/command"

func Greeting() command.Command {
	usage := "greeting"         // 指令名
	desc := "Returns greetings"  // 指令说明

	// 定义这个指令并返回
	return command.NewCommand("greeting", usage, desc, func(args ...string) ([]byte, error) {
		return []byte("你好,主人"), nil
	})
}

然后在该文件中定义一个 init 方法注册 ping 指令（init 在 main 方法之前运行）：

func init()  {
    command.Commands["^greeting$"] = Greeting()
}

然后我们需要到 bin 目录下重构 micro 使新指令生效：

cd bin
go build -i -o micro ../src/github.com/micro/micro/main.go

然后重新启动 micro bot，到 Slack 中输入 help 就可以看到 greeting 指令了：

扩展 Micro Bot 支持的终端

此外，你还可以扩展系统支持的协作工具，这需要实现 Input 接口（位于 src/github.com/micro/go-micro/agent/input/input.go），你可以参考 Slack 的实现来构建通过微信与 Go Micro 微服务交互的消息输入终端：

// Input is an interface for sources which
// provide a way to communicate with the bot.
// Slack, HipChat, XMPP, etc.
type Input interface {
	// Provide cli flags
	Flags() []cli.Flag
	// Initialise input using cli context
	Init(*cli.Context) error
	// Stream events from the input
	Stream() (Conn, error)
	// Start the input
	Start() error
	// Stop the input
	Stop() error
	// name of the input
	String() string
}

然后在 src/github.com/micro/micro/main.go 的 init 方法中注册它：

import "github.com/micro/go-micro/agent/input"

func init() {
    ...
    input.Inputs["wechat"] = WeChat
}

最后和新增指令一样，需要重新构建 micro 二进制文件并启动 --input 选项值为 wechat 的 micro bot 命令来测试是否生效。

micro bot 命令的底层执行逻辑入口文件位于 src/github.com/micro/micro/bot/bot.go 中，感兴趣的同学可以去看看，其代码结构和之前介绍的 micro cli 和 micro api 一样，只是消息源处理有所不同而已。