一、消息确认机制rabbitmq在发送消息后立即从内存中删除消息，因此如果消费者处理消息耗时较长，在处理过程中消费者被kill，则处理中的消息、以及其他发往该消费者的消息都将丢失。
为了保证消息不丢失，rabbitmq支持消息确认机制，消费者可以发送ack告诉rabbitm指定消息已经收到并处理，因此rabbitmq可以删除该消息。
如果消费者死掉（channel关闭、connection关闭、或者TCP connection丢失），导致rabbitmq没有收到ack，rabbitmq将把消息重入队列。
不存在消息超时，这意味着处理一个消息非常长的时间也是ok的。
消息确认机制默认是开启的，通过在channel.basic_consume中设置no_ack=True关闭。
注意消费者在处理消息后，不要忘记调用channel.basic_ac开发云主机域名k进行消息确认，否则rabbitmq将不断消耗内存把消息重入队列。
二、队列/消息持久化为了防止rabbitmq服务终止导致队列和消息丢失，需要将队列和消息标记为持久化的：
确保rabbitmq永远不丢失队列，需要将队列 声明为持久化的：
将消息声明为持久化的：注意：尽管已经很健壮了，但是仍然无法完全保证消息不会丢失，例如rabbitmq接收消息但是还没有保存到硬盘的情况。
三、exchange简单的说，exchange的一端接收消息，另一端把消息放进队列。在rabbitmq中生产者不会将请求直接发送给消费者，生产值只会把消息发给exchange，exchange收到消息后需要知道怎么做：添加到特定队列、添加到多个队列、还是丢弃。
exchange的类型包括direct,topic,headers,fanout
四、绑定exchange和queue之间的联系被称为绑定(binding)，可以简单的看：队列对于特定exchange上的消息感兴趣
此时’logs’ exchange将添加消息到指定queue
绑定可以使用一个额外的routing_key参数，例如：
对于fanout类型的exchange来说，routing_key参数是被忽略的
五、topic exchange发往topic exchange的消息不能携带任意的routing_key，必须是以点隔开的一串字符，最大255个字节
binding key也必须是相同的形式，注意binding key有两个重要的特殊情况：
* 可以替代一个单词
#可以替代零个或多个单词
例如，如果binding key是*.orange.*，则可以匹配所有
topic exchange非常强大，通过匹配routing_key可以表现的像存在多个exchange
六、RPC为了接收响应，客户端需要在发送请求时附加发送回调队列地址：
实现JSP通过Tomcat连接MySQL服务概述1、Tomcat是什么？Tomcat 服务器是一个免费的开放源代码的Web 应用服务器，属于轻量级应用服务器，在中小型系统和并发访问用户不是很多的场合下被普遍使用，是开发和调试JSP 程序的首选。Tomcat和I…
免责声明：本站发布的图片视频文字，以转载和分享为主，文章观点不代表本站立场，本站不承担相关法律责任；如果涉及侵权请联系邮箱：360163164@qq.com举报，并提供相关证据，经查实将立刻删除涉嫌侵权内容。
微信扫一扫 
