消息队列架构设计思路，消息队列的原理

「SpringCloud」(三十八)搭建ELK日志采集与分析系统

日志的采集灵活性是我们选择日志采集方案更看重的因素，所以logstash属于首先方案， 它可以兼顾多种不同系统和应用类型等因素的差异，从源头上进行一些初步的日志预处理。

Spring cloud是什么？相信大家在看到cloud这个单词时首先想到的便是“云”或“云计算”，其实这里并不是这个意思，Spring cloud是以Spring boot为基础的快速构建分布式系统的工具集。

Spring Cloud Sleuth可以应用在各种各样的单一Web应用中。我们可以使用这项技术轻松地为一个请求采集日志，即使请求跨越多个线程。

消息队列(三)kafka的一致性和失败处理策略

1、服务器处理消息需要是幂等的，消息的生产方和接收方都需要做到幂等性； 发送放需要添加一个定时器来遍历重推未处理的消息，避免消息丢失，造成的事务执行断裂。

2、生产者负载均衡 由于同一个Topic消息会被分区并将其分布在多个Broker上，因此，生产者需要将消息合理地发送到这些分布式的Broker上，那么如何实现生产者的负载均衡，Kafka支持传统的四层负载均衡，也支持Zookeeper方式实现负载均衡。

3、　高吞吐：Kafka拥有很高的吞吐量，即使是在单节点性能比较低下的商用集群中，也能保证单节点每秒10万条消息的传输。 　高容错：Kafka在设计上支持多分区、多副本的策略，拥有很强的容错性。

4、Kafka提供3种消息传输一致性语义：最多1次，最少1次，恰好1次。 最少1次：可能会重传数据，有可能出现数据被重复处理的情况； 最多1次：可能会出现数据丢失情况； 恰好1次：并不是指真正只传输1次，只不过有一个机制。

Java开发中消息队列和rpc框架都是做什么的?

1、Dubbo是一个分布式服务框架，致力于提供高性能和透明化的RPC(远程过程调用协议)远程服务调用方案，以及SOA服务治理方案。

2、SpringBoot：用于搞定其他框架的一个框架，主要是提供了各种启动器、简化了各种配置、方便和其他框架集成、开发者能够快速上手。

3、传统的webservice框架： Apache CXF、Apache Axisjava 自带的JAX-WS等等。webService框架大多基于标准的SOAP协议。新兴的微服务框架： Dubbo、 spring cloud、Apache Thrift等等。

RabbitMQ架构

为了保证数据不被丢失，RabbitMQ支持消息确认机制，为了保证数据能被正确处理而不仅仅是被Consumer收到，这就需要在处理完数据之后发送一个确认ack。

rabbitMQ是AMQP协议的一个开源实现。

rabbitMQ 架构为rabbitMQ + keepalived 镜像模式。

kafaka和rabbitmq的最主要区别在于数据的可靠性和吞吐量上；在实际场景中，需要按需求取舍。

ZeroMQ号称最快的消息队列系统，尤其针对大吞吐量的需求场景。 可用性 都可以实现高可用。RabbitMQ 都是基于主从架构实现高可用性。

松下显示hh是什么故障?

1、比如：网络原因闪断，ACK返回失败等等故障，确认信息没有传送到消息队列，导致消息队列不知道自己已经消费过该消息了，再次将该消息分发给其他的消费者。

2、松下洗衣机显示H后面是有数字交替显示的，如H再跳出09，一般显示H是一定有部件不良。只有知道了数字才知道是什么问题，只知道H是没作用的。建议你在保修期内，找售后予以解决，不要私自动手维修。

3、松下洗衣机出现H码有以下几种可能：H01码：水位开关异常。H02码：电机双向可控硅异常。H04码：电源继电器短路异常。H05码：记忆异常（芯片存储器异常）。H07码：运转传感器异常H08码：热敏电阻异常。

4、整机不工作 可能原因：停电，电源插头未插人电源插座或插人但接触不良，保险丝直径太细，容量不足，机门未关好，门控开关触头接触不良，程控器旋钮仍处于“关”(OFF)档。

关于消息队列架构设计思路和消息队列的原理的介绍到此就结束了，不知道你从中找到你需要的信息了吗 ？如果你还想了解更多这方面的信息，记得收藏关注本站。