比方说我们用到了RabbitMQ和Kafka,由于这两个消息中间件的架构上的不同,像RabbitMQ有exchange,kafka有Topic和Partitions分区。
消息队列中间件是分布式系统中重要的组件,主要解决应用耦合、异步消息、流量削锋等问题。它可以实现高性能、高可用、可伸缩和最终一致性架构,是大型分布式系统不可缺少的中间件。...
应用程序通过inputs或者 outputs 来与Spring Cloud Stream中binder对象交互。
RabbitMQ的消息是默认放在内存的,如果不特别声明消息持久到磁盘,当节点关掉或者crash(碰撞)掉,消息就会丢失。
消息队列:多个生产者可以向同一个消息队列发送消息,但是一个消息只能被一个消费者消费。
Lambda表达式讲解 接口新特性 函数式接口 方法引用 Stream流 Optional工具类介绍 新的日期时间工具类介绍 注解的增强
4. 停掉集群B ,将 集群A 的 n1 n2 n3 的文件,分别拷贝到 集群B 的 n1 n2 n3 文件mnesia 目录下。
Spring Cloud Bus 配合Spring Cloud Config 使用可以实现配置的动态刷新。
https://www.rabbitmq.com/which-erlang.html
后面了解到包括Java单机版的DelayQueue以及RabbitMQ延时队列/延迟重试等相对更靠谱一些。