如何使用RabbitMQ处理应用程序崩溃

最近,我为几个用例实现了RabbitMQ。发送邮件是其中之一(这在实践中很常见)

我的问题陈述 :

一个web服务(比如服务A)需要在队列中发布1000条消息(这将由一些邮件发送引擎选择)。但不幸的是,在向队列发布500条消息后,我的应用程序崩溃了。

现在,如果我再次点击相同的服务,那么在第一次点击时已经推送的500条消息将再次推送。虽然邮件复制目前不是什么大问题,但绝对不是人们想要的。如何处理这个问题。有什么想法吗?

我想出的解决方案 :

1. 使用批处理功能-但AsyncRabbitTemplate不支持它,因此我不能使用它。

2. 使用数据库。但这肯定很麻烦。我也不会用这个。