消息重复的原因有两个：1.生产时消息重复，2.消费时消息重复。由于生产者发送消息给MQ，在MQ确认的时候出现了网络波动，生产者没有收到确认，实际上MQ已经接收到了消息。生产者中如果消息未被确认，或确认失败，我们可以使用定时任务+来进行消息重试。@Sched

AMQP，即 AMQP，一个提供统一消息服务的应用层标准高级消息队列协议，是应用层协议的一个开发标准，为面向消息的中间件设计。基于此协议的客户端与消息中间件可传递消息，并不受客户端中间件不同产品，不同的开发语言等条件的限制，Erlang 中的实现有 Rab

　　生产者将数据发送到rabbitmq的时候，可能因为网络问题导致数据就在半路给搞丢了。但是问题是，开始rabbitmq事务机制，基本上吞吐量会下来，因为太耗性能。如果rabbitmq没能处理这个消息，会回调你一个nack接口，告诉你这个消息接收失败，你可

‘queueName‘ => ‘test_cache_queue‘."_".$time,‘routeKey‘ => ‘test_cache_route‘."_".$time,‘host‘ => ‘1

1） 对于数据量大或者处理耗时长的操作，我们可以引入 MQ 实现异步通信，减少客户端的等待，提升响应速度。2） 对于改动影响大的系统之间，可以引入 MQ 实现解耦，减少系统之间的直接依赖。1）系统可用性降低：原来是两个节点的通信，现在还需要独立运行一个服务

然后执行‘start mqnamesrv.cmd’，启动NAMESERVER。成功后会弹出提示框，此框勿关闭。#set it false if you don‘t want use dashboard.default true. #set the mess

众所周知，消息队列是应用系统中重要的组件，主要解决应用解耦，异步消息，流量削锋等问题，实现高性能，高可用，可伸缩和最终一致性架构。目前使用较多的消息队列有 ActiveMQ，RabbitMQ，ZeroMQ，Kafka，MetaMQ，RocketMQ.但是如

Kafka追求高吞吐量和性能，但是不支持事务，以及对消息的重复和丢失没有严格要求，一开始主要用于日志收集和传输，适合大量数据收集。RabbitMQ使用Erlang语言开发，基于AMQP协议实现，AMQP主要特征是面向消息、队列、可靠性、安全。

将不需要同步处理的并且耗时长的操作由消息队列通知消息接收方进行异步处理。

消费端实现幂等性，就意味着，我们的消息永远不会被消费多次，即时收到多条一样的消息。幂等性，通俗点说，就一个数据，或者一个请求，给你重复来多次，你得确保对应的数据是不会改变的，不能出错。生产者进行接收应该，用来确定这条消息是否正常的发送到broker，这种方

使用MQ的三大作用：1、同步变异步2、流量削峰3、解耦降低服务间的耦合性要不要使用MQ，需不需要使用MQ依据项目的需要做选择。监控应用中抛出的异常，邮件通知管理员。也就是增加监控功能，且一个消息服务可以监控无数个应用。例如，微信的抢红包，淘宝的订单，铁道部

我们使用Elasticsearch索引文档时，最理想的情况是文档JSON结构是确定的，数据源源不断地灌进来即可，但实际情况中，没人能够阻拦需求的变更，在项目的某个版本，可能会对原有的文档结构造成冲击，增加新的字段还好，如果要修改原有的字段，只能重建索引了。

MQ全称为Message Queue: 消息队列是应用程序之间的通信.应用程序解耦合: MQ相当于一个中介, 生产方通过MQ与消费方交互, 它将应用程序解耦合.JMS定义了统一的接口, 来对消息操作统一, 而AMQP通过规定协议来统一数据交互格式.JMS只

核心架构：Spring Cloud、Spring Boot、Mybatis、Redis、Rabbit MQ、微服务、分布式、电子商务核心思想：产品微服务、模块化、原子化、持续集成、分布式、集群部署开发模式：代码生成工具、驱动式开发模式、提高开发效率源码可加

最近的PHP项目中有使用AMQP，解耦一些业务性的功能模块。因为工作使用的是线上Linux搭建，为了方便测试所以我决定本地搭建一个MQ服务。MQ全称为Message Queue, 消息队列是一种应用程序对应用程序的通信方法。RabbitMQ是一个在AMQP

上一篇已经讲了Rabbitmq如何在Windows平台安装，还不了解如何安装的朋友，请看我前面几篇文章：RabbitMQ学习系列一：windows下安装RabbitMQ服务， 今天就来聊聊C# 实际开发的过程中，怎么调用 用RabbitMQ。　　　　Eas

上一篇，简单介绍了RabbitMQ的情况还有一些相关的概念，这一篇，会讲讲RabbitMQ安装与配置。　　　　Rabbit MQ 是建立在强大的Erlang OTP平台上，因此安装RabbitMQ之前要先安装Erlang。　　　　　　1.现在先别装最新的

最大努力通知的目标是发起通知方通过一定机制，最大努力将业务处理结果通知到接收方。接收通知方监听MQ。接收通知方接收消息，业务处理完成回应ack。MQ会按照间隔1分钟，5分钟，10分钟，30分钟，1h,2h,5h,10h的方式，逐步拉大通知间隔，直到达到通知

JVM有哪些回收算法，对应的收集器有哪些？jvm g1的内存模型讲一下，G1和CMS收集器的区别？以及G1收集器对CMS的改进？java线程同步都有哪几种方式，synchonized和reteenlock的区别。cas的原理，变量要用哪个关键字修饰，vol

当业务量上升后，由于mysql对全文检索或模糊查询支持的能力不强，在系统中查询的地方，往往会出现慢sql等，拖累系统其他模块，造成性能低下。随着ES使用普及率的升高，ES是mysql的一个有效补充。我们可以将数据发送到搜索引擎（如ES）上，由搜索引擎来提供