前面一篇实现了一个非常基础的日志系统，交换机将所有接收到的消息广播到它所知道的多个接受者。

这一节我们更进一步，实现订阅部分消息的功能。比如我只讲那些ERROR级别的消息写入日志文件， 同时将所有日志打印到控制台上面。

前面一篇介绍的任务队列是每个消息只能被一个工作者取走。这一篇讲解发布/订阅消息模式， 在这个模式里面，一个消息可以被发送给多个消费者。

这里我通过一个简单的日志系统来说明，消息生产者会将日志发送给队列，然后多个订阅者可以接收到这条日志显示到不同的地方， 比如可以打印到文件中，同时打印到控制台上面。

这里演示的官网通过python使用消息队列的教程：https://www.rabbitmq.com/getstarted.html

先演示最简单的一个入门级别的hello world例子， 发送者发送一个字符串，接受者接收到消息后打印出来。然后再介绍怎样实现任务队列

hello world

这里使用 python 的pika来演示，先安装pika:

最近又开始捣鼓RabbitMQ了，一个超好用的队列中间件，官网教程更新，自己也将有用的东东记录下来。

测试环境：消息服务器CentOS7.4、客户端Python3.6.1

RabbitMQ是一个出色的消息代理中间件（Message Broker）：接受和转发消息。你可以将它看作是一个邮局， 你把自己的信件写上收件人地址，然后放到邮筒里面就不用管了，由邮局负责将这个信件送到目的地。

ngrok是一个反向代理，它能够让你本地的web服务或tcp服务通过公共的端口和外部建立一个安全的通道， 使得外网可以访问本地的计算机服务。也就是说，我们提供的服务（比如web站点）无需搭建在外部服务器， 只要通过ngrok把站点映射出去，别人即可直接访问到我们的服务。

在Java 7发布的新的IO框架中，除了大家都熟知的 FileVisitor 接口外，还有个 WatchService 接口经常被人忽视掉。 这个类可以让你实时的监控操作系统中文件的变化，包括创建、更新和删除事件。

WatchService 用来观察被注册了的对象的变化和事件。它和Watchable两个接口的配合使用， WatchService类似于在观察者模式中的观察者，Watchable类似域观察者模式中的被观察者。