~~~
queue, err := r.channel.QueueDeclare(
"", //随机生产队列名称
false,
false,
false, // 排他
false,
nil,
)
~~~
这样设置消息就可以重复消费
~~~
_, e := r.channel.QueueDeclare(
r.QueueName, // 队列名称
false, // 消息是否持久化 false不
false, // 是否自动删除 没有消息就删除次队列
false, // 是否具有排他性 (true只有自己可以访问,连接端口会自动删除)
false, // 是否阻塞 (设置为true时就像没有bufio的channel)
nil, // 额外的属性
)
~~~
消息是否持久化 false不 这样没有消费照样会消失