SpringBoot使用RabbitMQ看这几篇就够了(配置篇)!
上篇我们说到了消息队列RabbitMQ的模式概念，那么这里将会针对模式使用SpringBoot联合RabbitMQ做一个案例，实现消息的生产和消费。这一篇也是这个主题的最后一篇了，建议配合着看。助于理解。
spring-amqp： spring-rabbit： amqp-client： 个人理解就是，spring-amqp是spring整合的amqp，spring-rabbit是spring整合的rabbitmq(rabbitmq是amqp的一个实现，所以可能spring-rabbit也是类似关系)，amqp-client提供操作rabbitmq的java api。
该设置可用于RabbitMQ 0或更高版本。默认的配置为 mirroring_sync_batch_size = 4096(4k)。 例： 集群相关的配置，为了形成一个集群，新的(“空白”)节点需要能够发现他们的同伴。这可以使用各种机制(后端)来完成。
RabbitMQ是用Erlang语言编写的分布式消息中间件，常常用在大型网站中作为消息队列来使用，主要目的是各个子系统之间的解耦和异步处理。
目的主要是学习RabbitMQ的消息超时时间、队列消息超时时间，大概会简单介绍学习为主：毕竟还是要来演示Springboot整合RabbitMQ注解的方式来使用。
读取配置文件的RabbitMQ的组件信息，然后动态的去创建关系。
消息队列之RabbitMQ-分布式部署
RabbitMQ本身是基于Erlang编写，Erlang语言天生具备分布式特性(通过同步Erlang集群各节点的magic cookie来实现)。 因此，RabbitMQ天然支持Clustering。这使得RabbitMQ本身不需要像ActiveMQ、Kafka那样通过ZooKeeper分别来实现HA方案和保存集群的元数据。
不像其他软件的集群方案，RabbitMQ集群中节点之间没有主从节点之分。
RabbitMQ 是实现 AMQP(高级消息队列协议)的消息中间件的一种，最初起源于金融系统，用于在分布式系统中存储转发消息，在易用性、扩展性、高可用性等方面表现不俗。 RabbitMQ 主要是为了实现系统之间的双向解耦而实现的。
rabbitmq是建立在AMQP上的企业消息系统。以生产者消费者为模型而存在的一个消息队列.解耦 这是一个天然的解耦，实现了应用程序不再通过接口，你只需要调用消息队列的接口把结果存放在消息队列即可。
上图中每个节点有一个queue，生产者生产完毕数据后投递到指定交换机的队列，交换机的队列进行消息同步。
上篇我们说到了消息队列RabbitMQ的模式概念，那么这里将会针对模式使用SpringBoot联合RabbitMQ做一个案例，实现消息的生产和消费。这一篇也是这个主题的最后一篇了，建议配合着看。助于理解。
RabbitMQ详解1.安装及使用
1、以下是Centos 7 的配置：进入 /etc/systemd/system 或者/usr/lib/systemd/system，并创建rabbitmq-server.service 文件。注意：通过 yum 安装的，已经在 /usr/lib/systemd/system 目录下存在rabbitmq-server.service 文件。
2、安装完以后erlang需要手动设置ERLANG_HOME 的系统变量。
3、持久化消息 集群 当生产者写入消息到RabbitMQ后，消费服务接收消息期间，服务器宕机，导致消息丢失了，这个时候我们就应该使用RabbitMQ的消费端消息确认机制 自动确认 手动确认 消费者收到消息。消费者发送确认消息给rabbitmq期间。
消息队列之zeroMQ、rabbitMQ、kafka
有些特殊框架(如：redis、kafka、zeroMq等)根据自身需要未严格遵循MQ规范，而是基于TCP\IP自行封装了一套协议，通过网络socket接口进行传输，实现了MQ的功能。
目前在生产环境，使用较多的消息队列有ActiveMQ，RabbitMQ，ZeroMQ，Kafka，MetaMQ，RocketMQ等。 消息队列应用场景 以下介绍消息队列在实际应用中常用的使用场景。异步处理，应用解耦，流量削锋和消息通讯四个场景。
RabbitMq中，producer不是通过信道直接将消息发送给queue，而是先发送给Exchange。
优势： 在RocketMQ没有出现之前，好多公司都从ActiveMQ切换到了RabbitMQ，它的优势在于可以保证数据不丢失，也能保证高可用性，即使集群部署部分机器宕机也能运行，然后支持部分高级功能，比如死信队列，消息重试之类的。
关于c语言中消息队列发送的结构体?
1、在C语言中，结构体(struct)指的是一种数据结构，是C语言中聚合数据类型(aggregate data type)的一类。结构体可以被声明为变量、指针或数组等，用以实现较复杂的数据结构。
2、C语言结构体（Struct）从本质上讲是一种自定义的数据类型，只不过这种数据类型比较复杂，是由 int、char、float 等基本类型组成的。你可以认为结构体是一种聚合类型。
3、为了解决这一问题，C语言中给出了另一种构造数据类型——结构体（Struct）。它可以将同一对象的多个数据类型存储在一起。
RabbitMQ架构
1、为了保证数据不被丢失，RabbitMQ支持消息确认机制，为了保证数据能被正确处理而不仅仅是被Consumer收到，这就需要在处理完数据之后发送一个确认ack。
2、在进行消息的存储时，RabbitMQ会在ETS（Erlang TermStorage）表中记录消息在文件中的位置映射和文件的相关信息。 消息（包括消息头、消息体、属性）可以直接存储在index中，也可以存储在store中。
3、backup_orders 队列通过 shovel 插件与另外的 MQ 集群进行同步数据，把消息发到第二个 MQ 集群上。 这是 rabbitMQ 比较早期的架构模型了，现在很少使用了。
4、MQ全程为message queue，即消息队列。是一种跨进程、异步通信机制、用于上下游传递消息。
5、RabbitMQ架构 概念 RabbitMQ是一个分布式系统 broker：每个节点运行的服务程序，功能为维护该节点的队列的增删以及转发队列操作请求。master queue：每个队列都分为一个主队列和若干个镜像队列。
微信扫一扫 
支付宝扫一扫 
