登录

在分布式环境中，故障是很常见的情况，可以随时发生。在Kafka环境中，消息代理可能会崩溃，网络故障，处理故障，发布消息时失败或无法使用消息等。这些不同的情况导致了不同类型的数据丢失和重复。 失... 详细

在多线程应用程序中，队列需要处理多个并发的生产者－消费者方案。正确选择并发队列对于在我们的算法中实现良好性能至关重要。  首先，我们将看到阻塞队列和非阻塞队列之间的一些重要区别。然后，我们将看一些实... 详细

大多数应用程序至少具有一个批处理任务，在后台执行特定的逻辑。编写批处理作业并不复杂，但是您需要了解一些基本规则，这里将列举一些我发现最重要的规则。 从输入类型的角度来看，处理项目可以通过轮询数据库来... 详细

消息传递模式的严重错误，导致巨大的耦合和极端的意外复杂性： 少而巨大的事件 多个服务都可以发布相同的事件 每个服务都会改变事件的一部分并重新发布 众说纷纭： 最后一个在基于文档的消息传递... 详细

在 排队理论 使我们能够预测队列长度和等待时间，这是最重要的容量规划。对于架构师来说，这是一个非常方便的工具，因为队列不仅仅是消息传递系统的工具。 为了避免系统过载，我们使用 节流阀 . 详细

vel0city：我已经在相当小的VM上运行RabbitMQ很长时间了。RabbitMQ不需要每条消息大量的资源，即使使用非常小的VM（512MB RAM，单个CPU），我也看到它每秒处理数千条消息... 详细

LinkedIn消息平台现在存储了价值17年的消息（使用17年的不同产品功能创建），并且发送的消息数量一直保持不变往上走。 最初，这些消息看起来很像电子邮件。现在，他们看起来更像是聊天，带有主题，群... 详细

Spring框架为Java程序使用各种接口提供了简单的方法。它的JMS组件包括一些类，这些类可帮助程序等待新消息，类似于消息驱动Bean。已知使用IBM MQ时，Spring实现的默认行为不是最佳的... 详细