细致解释RabbbitMQ的音讯队列和HelloWorld。
内置文档2022升级百度大牛带你结合实践重学C++无mi
download：
1.信息排队1.MQ的相关概念1.MQ是什么？MQ(音讯队列)，从字面上讲就是队列。FIFO是先进先出的，但是存储在队列中的内容只是音讯。它也是一种跨进程的通讯机制，用于上游和下游的音讯传送。
在互联网架构中，MQ是十分常见的上下游“逻辑解耦+物了解耦”的音讯通讯效劳。运用MQ后，音讯发送的上游只需求依赖MQ，不需求依赖其他效劳。
2.为什么要用MQ？1.流量峰值消弭例如，假如订单系统能够处置多达10，000个订单，那么这个处置才能关于正常时间的订单来说是绰绰有余的。在正常时间内，我们能够在订购后一秒钟返回结果。但在顶峰期，假如有2万单操作系统处置不了，只能限制在1万单以上才干下单。运用音讯队列作为缓冲，我们能够取消这种限制，将一秒钟内发出的订单分散到一段时间内停止处置。这时分有些用户可能在下单后十几秒才干收到下单胜利的操作，但总比不能下单的体验要好。
2.应用去耦。以电子商务应用为例。应用程序中有订单系统、库存系统、物流系统和支付系统。用户创立订单后，假如库存系统、物流系统、支付系统耦合调用，任何一个子系统呈现毛病，都会招致下单操作异常。当基于音讯队列的办法改动时，系统间调用的问题将会减少很多。比方物流系统由于毛病需求几分钟才干修复。在这几分钟内，物流系统要处置的内存缓存在音讯队列中，用户的下单操作能够正常完成。当物流系统恢复后，只需继续处置订单信息，让单个用户感受不到物流系统的毛病，从而进步系统的可用性。
3.异步处置一些效劳间调用是异步的。比方A调用B，执行时间很长，但是A需求晓得B什么时分能执行完。以前普通有两种方式:
a过一会儿调用B的查询api查询。A提供回调api，B调用api通知A效劳完成后。这两种办法都不太文雅。运用音讯总线能够便当地处理这个问题。在A调用B效劳后，它只需求监听B处置完成的音讯。当B处置完成时，它会向MQ发送一条音讯，MQ会将这条音讯转发给A效劳。这样，效劳a不需求循环调用b的查询api，也不需求提供回调api。同样，效劳B也不用做这些操作。效劳也能够及时得到异步处置胜利的音讯。
3.MQ的分类1、ActiveMQ优点:单机吞吐量万级，时效性ms级，高可用，基于主从架构完成高可用，数据丧失概率低，音讯牢靠。
缺陷:如今官方社区对ActiveMQ 5.x的维护越来越少，高通量的场景用的比拟少。
2、卡夫卡大数据的杀手，说到大数据范畴的音讯传送，绕不开卡夫卡。这种为大数据而生的音讯中间件以百万级的TPS吞吐量而出名，并疾速成为大数据范畴的宠儿，在数据的采集、传输和存储过程中发挥着无足轻重的作用。目前，它曾经被LinkedIn、优步、Twitter、网飞等大公司采用。
优点:性能优秀。单机写的TPS大约是每秒一百万。最大的优势就是吞吐量高。Ms级可用性很高，kafka是散布式的，一个数据有多个副本，几台机器宕机，数据不会丧失，不会形成不可用。消费者经过拉取的方式获取音讯，音讯是有序的，经过控制能够保证一切音讯只消费一次；有优秀的第三方Kafka Web管理界面Kafka-
Manager；；在日志范畴比拟成熟，被很多公司和开源项目运用；功用:功用比拟简单，主要支持简单的MQ功用。大数据范畴的实时计算和日志搜集应用普遍。
缺陷:Kafka单机超越64个队列/分区，负载会明显飙升。队列越多，负载越高，发送音讯的响应时间越长。采用短轮询方式，实时性能取决于轮询距离。消费失败不支持重试；支持音讯序列，但是当一个代理下线时，会形成音讯紊乱，社区更新慢；
3、RocketMQRocketMQ来自阿里巴巴的开源产品，用Java言语完成。它是参照卡夫卡设计的，本人也做了一些改良。阿里巴巴普遍应用于订单、买卖、充值、流计算、音讯推送、日志流处置、binglog分发等场景。
优点:单机吞吐量10万，十分高的可用性，散布式架构，音讯零丧失，MQ功用比拟全，扩展性好。支持10亿条音讯的积聚，不会招致性能降落。源代码是java。我们能够本人看源代码，定制我们公司的MQ。
缺陷:支持的客户端言语不多，目前是java和c++，其中c++不成熟；社区活泼度普通，MQ中心中没有完成JMS等接口。有些系统需求修正很多代码才干迁移。
RabbitMQ它发布于2007年，是一个基于AMQP(高级音讯队列协议)的可重用企业音讯系统，是目前最主流的音讯中间件之一。
优点:由于erlang言语的高并发性，性能不错；MQ吞吐量10000，功用比拟全，强健，稳定，易用，跨平台，支持Python，Ruby等多种言语。NET、Java、JMS、C、PHP、ActionScript、XMPP、STOMP等。，并有支持AJAX的完好文档。开源提供的管理界面优秀，易于运用，社区活泼度高；更新频率相当高。
4.MQ的选择在选择音讯队列技术时，您需求经过以下指标来权衡所选择的音讯队列能否能满足您的需求:
音讯次第:发送到队列的音讯能否能保证消费的次第，比方A先下单，B后下单。应该是A先扣存货，B后扣存货，次第不能颠倒。路由:依据路由规则，只订阅契合路由规则的音讯，比方同时契合A/B规则的音讯。消费者只能订阅音讯A，但不会消费音讯B。牢靠性:能否会有音讯丧失，比方A/B有两个音讯，最后只能耗费音讯B，音讯A丧失。
音讯定时:主要包括“音讯生存期”和“延迟/预定音讯”。“音讯生存期”是指消费者能够为音讯设置TTL，超越TTL，音讯会自动消逝；“延迟/预定音讯”指的是能够延迟或预订消费的音讯。比方音讯延迟5分钟，消费者就需求5分钟来消费。假如时间没到，就不能消费。音讯保存:音讯在胜利运用后能否会保存在音讯队列中。容错:当一个音讯消费失败时，有没有什么机制能够保证音讯能够消费胜利？例如，异步第三方退款音讯需求被消费，然后才干确认向用户退款。因而，必需保证胜利消费该音讯的精确性。
伸缩性:当音讯队列的性能呈现问题时，比方耗费慢，能否能快速支持存储容量；当消费队列太多，糜费系统资源时，能否支持容量缩减？吞吐量:支持的最大并发数。
1、卡夫卡卡夫卡的主要特性是基于拉形式处置音讯消费，追求高吞吐量。其最初目的是搜集和传输日志，适用于产生大量数据的互联网效劳的数据搜集业务。大公司倡议能够用。假如有日志搜集和实时计算的功用，kafka绝对是首选。
2、RocketMQ降生于金融互联网范畴，对牢靠性请求较高，特别是电子商务中的订单扣款，以及业务的削峰，大量买卖涌入时后端可能无法及时处置。RoketMQ在稳定性方面可能更值得信任。这些商业场景在阿里双11中曾经测试过屡次。假如你的业务有上述并发场景，倡议你能够选择RocketMQ。
3、兔子分离erlang言语自身的并发优势，具有良好的性能，微秒级的时效性，高社区活泼度，十分便当的管理界面。假如你的数据量没有那么大，中小公司更喜欢功用相对齐全的RabbitMQ。
2.音讯队列形式1.点对点形式一个特定的音讯只能由一个消费者运用，多个消费者能够将音讯发送到同一个音讯队列，但是当一个音讯由一个发送者处置时，该音讯将被锁定或从队列中删除，其他消费者无法处置该音讯。
应该留意的是，假如消费者未能处置音讯，音讯系统通常会将音讯放回队列中，以便其他消费者能够继续处置它。
2.发布/订阅形式多个用户能够同时获取和处置单个音讯。普通来说，有两品种型的
短期订阅:这种订阅只在消费者启动并运转时存在。一旦消费者退出，相应的订阅和未处置的音讯将会丧失。耐久订阅:这种订阅会不断存在，除非主动删除。消费者退出后，音讯系统会继续维护订阅，后续音讯能够处置。
3、兔子1.什么是RabbitMQ？RabbitMQ是一个音讯中间件:它承受和转发音讯。你能够把它想象成一个快递站。当你要寄包裹时，你把你的包裹放在快递站，快递员最终会把你的快递送到收件人手中。依照这个逻辑，RabbitMQ就是一个快递站，快递员会帮你送快件。RabbitMQ和express station的主要区别在于，它不处置快递邮件，而是接纳、存储和转发音讯数据。
2.四个中心概念1.消费者生成数据传输音讯的程序是消费者。
2.转换开关是RabbitMQ的一个十分重要的组件。一方面，它接纳来自消费者的信息；另一方面，它将音讯推送到队列中。交流机必需确切地晓得如何处置它接纳到的音讯，是将这些音讯推送到特定队列还是多个队列，还是丢弃这些音讯，这取决于交流机的类型。
3.长队Queue是RabbitMQ内部运用的数据构造。固然音讯流经RabbitMQ和应用程序，但它们只能存储在队列中。队列只受主机内存和磁盘限制的约束，实质上是一个大的音讯缓冲区。许多消费者能够向队列发送音讯，许多消费者能够尝试从队列接纳数据。这是我们运用队列的方式。
4.顾客它和接纳有类似的意义。大多数时分，消费者是一个等候接纳音讯的程序。请留意，消费者、消费者和音讯中间件通常不在同一台机器上。同一个应用程序能够既是消费者又是消费者。
3.根本概念提到RabbitMQ，就不得不提到AMQP协议。AMQP协议是一个具有现代特征的二进制协议。它是一个应用程序级的规范高级音讯队列协议，提供统一的音讯效劳。它是应用层协议的开放规范，是为面向音讯的中间件设计的。
让我们先理解一下AMQP协议中间的一些重要概念:
效劳器:接纳客户端的衔接，完成AMQP实体效劳。衔接:衔接，应用程序和效劳器之间的网络衔接，TCP衔接。通道:通道，在其中读取和写入音讯。客户端能够树立多个通道，每个通道代表一个会话任务。假如每次访问RabbitMQ都树立一个衔接，那么在音讯量很大的状况下树立TCP衔接的开支会很大，效率也会很低。信道是在衔接中树立的逻辑衔接。假如应用程序支持多线程，每个线程通常会创立一个单独的通讯通道。AMQP办法包含通道id来协助客户端和音讯代理辨认通道，因而通道是完整隔离的。
作为一个轻量级频道衔接大大减少了操作系统树立TCP衔接的开支。音讯:音讯，应用程序和效劳器之间传输的数据。音讯能够十分简单，也能够十分复杂。它由属性和主体组成。关于属性的外包装，您能够修正音讯，例如音讯的优先级和延迟。是正文音讯内容。虚拟主机:虚拟主机，用于逻辑隔离。一个虚拟主机能够有多个交流和队列，但是同一个虚拟主机不能有同名的交流或队列。交流:接纳邮件并依据路由规则将邮件路由到一个或多个队列的交流。假如路由不可用，要么将其返回给消费者，要么直接将其丢弃。