建立传感器项目

在 GOPATH src 下建立文件夹 sensors，使用 go mod init 初始化，并创建 main.go。

同时别忘了安装 amqp 的包：go get -u github.com/streadway/amqp

我们要生成一些模拟数据，生成数据有一定的范围（位于一个最大值和最小值之间），如下图：

因此，我们需要这样几个配置参数：

设置命令行参数并读取

在这个项目里，我们需要通过命令行参数来传递配置，并在 Go 程序里面进行解析和读取。我们可以使用 os.Args 来搞这些命令行参数，但是更好的办法是使用 flag 这个包（其内部实现使用的也是 os.Args）。

我们先看代码：

我们测试一下，命令行输入 go run . --help，其结果如下：

要生成模拟传感器的数据，需要使用到 math/rand 和 time 这两个包。

先看代码：

第 17 行，我们需要一个 *rand.Rand 类型来生成随机数，它又需要一个源，这里使用 time.Now().UnixNano() 生成源，这样做的好处是因为这个时间纳秒数永远不会重复。
第 19 行，声明 value，它表示传感器的数值，在这先生成一个初始值。
第 20 行，是额定值，在这里也就是最大值最小值的中间平均值。
第 25 行，把更新频率（每秒更新的次数）转化为了两次更新之间的时间间隔（毫秒），并解析成 time.Duration 这个类型。
第 26 行，time.Tick 函数会返回一个 time 的 Channel，该函数会按照提供的时间间隔不断触发，并向这个 Channel 发送当前时间。
第 28 行，使用 for range 来处理 signal 这个 Channel，每次 Channel 中有数据传递过来，我们就使用 calcValue 这个函数来生成新的模拟数据。
第 29 行，把生成的最新数据打印一下即可。

生成模拟数据的逻辑是如果数据偏离额定值，那么尽量让下次生成的值向额定值靠拢。

这部分可根据自己的特定需求来实现，不必和我的相同。

先看代码：

使用 go run . 运行，命令行参数使用默认值即可：

一切正常的话，它就会每秒钟生成 5 次数据。

生产环境中，通常会接收来自多个传感器的数据。

这里，我们让每个传感器都设置自己的路由 Key，所以 RabbitMQ 将会为每个 Key 创建一个 Queue：

但是这也会引起问题，就是之前章节里面的那个协调程序如何发现这些传感器呢？

首先，我们可以让每个传感器使用路由 Key 向一个所有传感器和协调程序都知晓的路径中发送一个消息。但这只能解决问题的一半，另一半我们以后再说。

这里会使用到 encoding/gob 包。

看代码：

在 sensors 包中创建 model 包，并建立 models.go 文件。
在 models.go 的第 12 行，建立 SensorMessage 作为传感器传递消息的类型，里面包含三个字段分别是传感器名称、数值和时间戳。
很显然我们不能把 Go 的 struct 类型直接扔到 RabbitMQ 里面，但我们项目中的各种客户端只涉及到 Go 语言，所以在这里我使用 Go 语言的 gob 来对消息进行编码，这样会更高效一些。如果这个项目是跨语言的我可能会使用 JSON 或 Protocol Buffers。
在 model 包的 init 函数里面，需要使用 gob 包的 Register 函数把将要编码的类型进行注册，这样依赖于这个包的其它 Go 程序就可以把 SensorMessage 这个类型的消息对象发送过去了

建立 tools 包，并建立 queuetools.go 文件，其内容如下：

代码内容与之前的项目类似，就不解释了。

这里还会使用到 bytes 包。

回到 main.go，修改代码：

前面添加了获取 Channel 和 Queue 的代码。其中第 37 行比较重要，因为我们不能保证在程序运行时，使用 Queue 名称作为路由 Key 的 Queue 存在，而使用 GetQueue 函数，就可以保证这个 Queue 会被正确的设置，并准备好被我们使用了。
第 42 行，使用 bytes 包创建了一个 *bytes.Buffer，它用来来承载编码后的数据，这个 Buffer 可以重复利用，所以实在 for range 的外部声明的。
1. 但是每次使用 Buffer 都需要进行重置，也就是第 53 行的作用，这样以前的数据就会被移除，Buffer 的指针会回到初始位置。
第 43 行，使用 gob 和 Buffer 来创建编码器。
第 54 行，使用编码器的 Encode 方法对消息进行编码。
第 56 行，创建要发送给 RabbitMQ 的消息（amqp.Publishing 类型），这里只需要填写 Body 字段即可，其它的字段根据自己的需求选填即可。
第 60 行，使用 Channel 来发布消息，这里使用的是默认的 Exchange，路由 key 就是 Queue 的名字，最后一个参数就是发布的消息。