对于非常健壮稳定的后台系统，我们必须得考虑到各种宕机的情况：物理宕机，应用自身出错崩溃等，而这个时候我们的应用需要做到重启后数据依旧不丢失，这个问题就是数据持久化，也就是说数据持久化到了磁盘。在RabbitMQ中，如果要保证消息发送到broker，我们首先

RabbitAdmin类可以很好的操作RabbitMQ，在Spring中直接进行注入即可。RabbitAdmin底层实现就是从Spring容器中获取Exchange、Binding、RoutingKey以及Queue的@Bean声明。然后使用RabbitT

生产者将消息通过交换器分发给所有在线的消费者。交换机没有消息存储的能力，只能向当前在线的消费者发送消息。因此未接收到消息的消费者，即使重新连接rabbitmq也无法获取到已发送的消息。[Java] 纯文本查看 复制代码?String message = &

本文主要讲解mall整合RabbitMQ实现延迟消息的过程，以发送延迟消息取消超时订单为例。RabbitMQ是一个被广泛使用的开源消息队列。它是轻量级且易于部署的，它能支持多种消息协议。RabbitMQ可以部署在分布式和联合配置中，以满足高规模、高可用性的

简介 RabbitMQ是实现AMQP的消息中间件的一种，用于在分布式系统中存储转发消息，在易用性、扩展性、高可用性等方面表现不俗

如果没有设置policy，在申明队列的时候使用x-ha-policy这个参数设置的镜像队列是无效的。

应用场景之前我们已经通过《Spring Cloud Stream消费失败后的处理策略（一）：自动重试》一文介绍了Spring Cloud Stream默认的消息重试功能。本文将介绍RabbitMQ的binder提供的另外一种重试功能：重新入队。}内容很简单

概述项目的部分功能重构计划引入消息中间件，现将安装RabbitMQ以及通过SpringBoot集成的过程进行记录。安装本人使用环境：CentOS71.erlang安装。sudo yum install erlang遇到的问题:Q1:从官网下载rpm包为es

在开发中做定时任务是一个非常常见的业务场景，在代码层面 Node.js 可以用 setTimeout、setInerval 这种基础语法或用 node-schedule 这些类似的库来达到部分目的，在第三方服务上可以用 Redis 的 Keyspace N

Erlang/OTP 19 [erts-8.1] [source-77fb4f8] [64-bit] [async-threads:10] [hipe] [kernel-. yum -y install socat-1.7.2.3-1.el6.x86_64

消息确认机制当把basic_consume的参数no_ack设置为true时，消息达到消费者时就立刻被标记为删除状态，如果这时一个worker的消息来不及执行完成就被中止掉，那么这条消息就会丢失，所以需要一个消息确认机制，当worker挂掉后，把消息重新分

假设三个业务节点分别使用50ms,串行方式使用时间150ms,并行使用时间100ms。当库存系统出现故障时,订单就会失败。在处理完数据之后发送ack,就是告诉RabbitMQ数据已经被接收,处理完成,RabbitMQ可以安全的删除它了.要持久化队列queu

本文涉及rabbitmq的基本安装，基本的集群配置。1）更新EPEL源#yum官方源无erlang；[root@rmq-node1 ~]# yum install foo2）添加erlang解决方案库#如果不添加erlang解决方案，yum安装的erlan

让我们展示如何使用Spring Cloud Stream来设计事件驱动的微服务。因为Spring AMPQ提供了访问AMPQ工件所需的一切。如果您不熟悉Spring AMPQ，请查看此repo，其中包含许多有用的示例。Spring Cloud Stream

import java.util.Date;private final static String QUEUE_NAME = "ftpAgent";private final static String userName = "