文章目录
[+]
最近在做一个别系，个中须要用到行列步队。选来选去就选择了activeMQ，最开始在网上搜了一下go在activeMQ的用法，根据网上的代码实现之后。创造了几个问题：
1：当没有入队或者出队的时候，5分钟之后，生产者和消费者都会断开连接，5分钟之后，再发送到行列步队，会涌现连接超时（connect timeout），读取消息也会涌现读取超时（read timeout）。
2：消费者读取消息处理完之后，行列步队中的条数并没有减少。
（图片来自网络侵删）
为理解决这个两个问题，看了下官方文档 :github.com/go-stomp/stomp。
1：办理超时问题，在链接activeMQ的时候，须要设置读写链接超时限定；如果没有这个设置这两项，默认超时时间是5分钟。
2：当消费者获取到之后，须要发送一个应答给行列步队；不然还是会存在行列步队中。
针对上面的情形，我将代码贴出来，不说多了废话。
