将事件发布到单个微服务实例

Question

我正在做一个项目，它有几个事件驱动的微服务，并且还使用Kubernetes进行负载平衡。所有的服务都是发布者和侦听者。当一个微服务发布一个事件时，所有的侦听器都在捕获该事件（如果它侦听了那个特定的事件）并完成它们的工作。在此之前,此流没有任何问题：

假设我有一个负责发送电子邮件的微服务。并且此服务由于负载高而被负载均衡器重复2次。现在我们有3个电子邮件服务实例。当发布“Sendmail”事件时，所有3个实例都会捕获该事件并为它们自己发送电子邮件。在一天结束时，正在发送3封电子邮件。

微服务:A、B、C

由负载均衡器复制：A1,A2,A3,B1...

案例1：我想为所有服务的实例发布一个事件。

applicationContext().publishEvent(
        new customEvent(
                this,  // Source
                busProperties().getId(),  // Origin Service
                null  // Destination Service (null: all)
        )
);

事件侦听器；

@Component
public class Listener implements ApplicationListener<CustomEvent> {
    @Override
    public void onApplicationEvent(CustomEvent event) {
        Foo();
    }
}

Answer 1

我现在更明白了，这里是我之前贴的图像链接。我肯定你已经知道这件事了。这是一个常见的问题，最好的方法是使用redis作为“阻塞”机制。由于消息队列异步地向所有使用者发送请求，我们将不知道谁在接收和处理请求，但我们可以通过使用阻塞来确保它不会被所有人处理。在执行任何操作之前，检查块，如果它不存在，则处理请求。