主题模式
1.前置教程
请先按顺序阅读下面章节
说明：因为Golang RabbitMQ发布订阅章节，已经包含完整的代码样例，其他RabbitMQ模式，仅仅是交换机的定义和路由参数不一样，所以仅展示关键代码。
2.声明Topic交换机
err = ch.ExchangeDeclare(
"sreio_topic", // 交换机名字，需要唯一
"topic", // 交换机类型
true, // 是否持久化
false, // auto-deleted
false, // internal
false, // no-wait
nil, // arguments
)3.发送消息
// 消息内容
body := "Hello sreio.com!"
// 推送消息
err = ch.Publish(
"sreio_topic", // exchange（交换机名字)
"www.sreio.com", // 路由参数，关键参数，决定你的消息会发送到那个队列。
false, // mandatory
false, // immediate
amqp.Publishing {
ContentType: "text/plain", // 消息内容类型，这里是普通文本
Body: []byte(body), // 消息内容
})4.消费消息
4.1.绑定交换机
// 声明需要操作的队列
q, err := ch.QueueDeclare(
"", // 队列名字，不填则随机生成一个
false, // 是否持久化队列
false, // delete when unused
true, // exclusive
false, // no-wait
nil, // arguments
)
// 队列绑定指定的交换机
err = ch.QueueBind(
q.Name, // 队列名
"*.sreio.com", // 路由参数，关键参数，使用了通配符 * 星号，匹配一个单词，如果使用 # 井号可以匹配多个单词.
"sreio_topic", // 交换机名字，需要跟消息发送端定义的交换器保持一致
false,
nil)4.2.处理消息
// 创建消费者
msgs, err := ch.Consume(
q.Name, // 引用前面的队列名
"", // 消费者名字，不填自动生成一个
true, // 自动向队列确认消息已经处理
false, // exclusive
false, // no-local
false, // no-wait
nil, // args
)
// 循环消费队列中的消息
for d := range msgs {
log.Printf("接收消息=%s", d.Body)
}