我有一个spring引导微服务应用程序,我正在使用spring云流绑定程序-兔子-我所有的rabbiqMq配置都运行良好,但是如果rabbitMq下降,消费者会一直试图无限期地获取连接,增加服务启动时间。当rabbitMq上升时,它需要<30秒,当rabbitMQis下降时,大约需要270秒,有什么方法可以在特定时间后停止寻找连接吗?
这也会导致我的应用程序瘫痪,影响到与rabbitMQ无关的所有API。我试着寻找我可以在application.properties中添加的属性来克服这个问题,但是找不到。
@EnableBinding({HelperMQChannel.class})
p
我需要读取一个有数千行的日志文件,并将每一行写入一个Mongo数据库。我正在使用节点流读取文件。我使用“拆分”npm包将文件拆分为“行”。由于网络方面的考虑,MongoDB写入将花费比读取日志文件更长的时间。
我的核心代码如下所示:
var readableStream = fs.createReadStream(filename);
readableStream
.pipe(split()) // This splits the data into 'lines'
.on('da