使用RabbitMQ发布/订阅微服务事件总线时如何对事件进行重复数据删除

我一直在阅读第58页的《本书》，以了解如何在微服务之间进行异步事件集成。

使用RabbitMQ和发布/订阅模式有助于将事件推送给订阅者。但是，考虑到微服务架构和docker的使用情况，我希望运行不止一次微服务“类型”实例。据我了解，所有实例都将订阅该事件，因此都将收到该事件。

本书没有明确说明如何确保只有一个实例可以处理请求。

我已经研究了复制部分，但是它描述了一种模式，该模式说明了如何在服务实例中进行重复数据删除，但不一定要针对它们进行重复...

每个微服务实例将使用类似于以下内容的订阅：

public void Subscribe<T, TH>()
        where T : IntegrationEvent
        where TH : IIntegrationEventHandler<T>
    {
        var eventName = _subsManager.GetEventKey<T>();

        var containsKey = _subsManager.HasSubscriptionsForEvent(eventName);
        if (!containsKey)
        {
            if (!_persistentConnection.IsConnected)
            {
                _persistentConnection.TryConnect();
            }

            using (var channel = _persistentConnection.CreateModel())
            {
                channel.QueueBind(queue: _queueName,
                                    exchange: BROKER_NAME,
                                    routingKey: eventName);
            }
        }

        _subsManager.AddSubscription<T, TH>();
    }

我需要了解如果服务在处理过程中发生故障，相同“类型”的微服务的多个微服务实例如何进行重复数据删除而不会丢失消息。