我们在上一篇文章中提到的微观实际上是基于微观的微服务框架工具。核心是Go-Micro。Go Micro是一个分布式系统开发框架。MICROPhilosophy具有合理的默认值，可以插入并插入。该框架提供了默认设置，以帮助我们快速启动，但所有内容都可以轻松替换。在实际项目中，通常可以根据我们自己的需求更换组件。例如，注册中心可以使用ETCD，CONSUL.USE。使用KAFKA，NSQ和其他工具。
GO Micro摘要分布式系统的详细信息。以下是主要功能。
在下面，我们从经纪人组件开始，以学习如何一起使用Go-Micro。我们知道经纪人是Go-Micro用于获得异步新闻的模型。本质是pubsub。实现异步消息的系统。
该示例实际上非常简单，实现了发布者函数pub，该示例已发布到每个刻度中的指定主题。
同时，订户子订阅者从指定主题中获取消息并执行处理函数。处理功能的参数是事件接口。通过它，我们可以收到消息。该消息包含标题和身体信息。
这些是推荐的消息系统。如何使此消息系统运行？它的主要逻辑是主函数中的逻辑。让我们看一下上面的主要功能。首先调用cmd.init方法，该方法的作用是
DefaultCMD是具有默认值的CMD实例。
然后初始化经纪人，在这里，默认经纪人是HTTP经纪人。
如果未指定ADDR选项，则是默认值
然后调用HTTP代理的连接方法连接到服务器
连接服务器后，我们可以建立与监视处理的连接。DID您发现它实际上是HTTP服务器，监视服务请求，然后处理事件。
以及用于发行和订阅的相应代码逻辑，我们可以看到，在发行版的逻辑中，我们将首先将MSG，Sabemessage放在指定的主题上，然后处理消息异步，因此如何执行Savemessage以及如何执行SACEMESSAGE以及如何执行异步消息的异步消息，首先，首先，
保存消息的逻辑很简单，只需将数据保存到HTTP Broker的某些地图。
在Goroutine中，从主题中删除消息，然后根据服务名称从注册中心获取服务列表，然后在列表中找到合格的节点。找到Nodethe Post方法后，将错误处理发送到服务器，并根据返回结果进行错误处理。
订阅的逻辑是生产订户
然后致电HTTP经纪人的订阅方法来真正执行订阅操作。
这种逻辑非常简单。将服务注册到注册中心，然后将此订阅添加到订户地图中，以促进消息的通信。
看到这一点，您可能会怀疑。我看不到我的消息处理功能如何订阅以接收数据处理的消息。我们都知道，当我们使用NET/HTTP启动HTTP服务器的HTTP服务器时，它将通过处理程序。
当我们进入HTTP经纪人Connect时，启动服务器，正式传递给指定处理程序时，我们是
默认路径是H是我们的HTTP经纪人。可以将其作为处理程序传递到手柄方法中的原因，因为HTTP代理实现了该方法的处理方法。
在这里，您可以解码消息，获取消息正文并调用消息处理功能。
这是整个HTTP经纪人的处理过程。我相信您现在可以了解GO-Micro异步消息系统的默认实现。如果您想实现自己的经纪人，只要您在实施中实现经纪人界面，就可以在项目中进入项目。使用自定义的Brok.seam.seamseam Switch。
在这一点上，整个经纪人部分都结束了。在下一篇文章中，让我们看一下如何实现定制经纪人。