redis消息队列实现思路-redisson消息队列可靠吗(7-17-46)

Redis本文目录一览：

• 1、消息中间件(一)MQ详解及四大MQ比较
• 2、消息队列核心原理
• 3、消息队列基础
• 4、redis与rabbitmq做消息队列的区别
• 5、redis的消息队列和缓存的区别
• 6、消息队列为什么不需要同步

消息中间件(一)MQ详解及四大MQ比较

1、优势： 在性能方面kafka可以说是业界非常优秀的一款中间件，在常规的机器配置下，一台机器可以达到每秒几十万的QPS。

2、RocketMQ身出名门，但使用者不多，生态较小，毕竟消息量能达到这种体量的公司不多，你也可以直接去购买阿里云的消息服务。Kafka生态完善，其代码是用Scala语言写成，可靠性比RocketMQ低一些。

3、异步：同步接口调用导致响应时间长的问题，使用mq之后，将同步调用改成异步，能够显著减少系统响应时间。

消息队列核心原理

1、即消息的Ackownledge确认机制，为了保证消息不丢失，消息队列提供了消息Acknowledge机制，即ACK机制，当Consumer确认消息已经被消费处理，发送一个ACK给消息队列，此时消息队列便可以删除这个消息了。

2、ActiveMQ工作原理：首先来看本地通讯的情况，应用程序A和应用程序B运行于同一系统A，它们之间可以借助消息队列技术进行彼此的通讯：应用程序A向队列1发送一条信息，而当应用程序B需要时就可以得到该信息。

3、消息队列 （MQ）是一种应用程序对应用程序的通信方法。应用程序通过写和检索出入列队的针对应用程序的数据（消息）来通信，而无需专用连接来链接它们。

4、Redis实现消息队列原理，常用的消息队列有RabbitMQ，ActiveMQ，个人觉得这种消息队列太大太重，本文介绍下基于Redis的轻量级消息队列服务。

5、它的实现原理是：消息的发送者把自己想要发送的信息放入一个容器中（我们称之为Message），然后把它保存至一个系统公用空间的消息队列（Message Queue）中；本地或者是异地的消息接收程序再从该队列中取出发给它的消息进行处理。

消息队列基础

解耦： 如果使用多线程进行异步，这样会造成与下游系统耦合，每对接一个系统，会增加一个接口调用，然后重新发布系统。使用消息队列，将消息发布到消息队列中，下游系统直接监听审批过程消息来感知审批进度，达到解耦目的。

是生产者先将消息投递一个叫队列的容器中，然后再从这个容器中取出消息，最后再转发给消费者。

消息队列（MQ），是一种应用程序对应用程序的通信方法。应用程序通过写和检索出入列队的针对应用程序的数据（消息）来通信，而无需专用连接来链接它们。

例如，当程序调用SetWindowPos系统发送WM_WINDOWPOSCHANGED消息。一些函数也发送非队列消息，例如下面我们要谈到的函数。 消息的发送 了解了上面的这些基础理论之后，我们就可以进行一下简单的消息发送与接收。

通过消息作为整合，大数据的背景下，消息队列还与实时处理架构整合，为数据处理提供性能支持。

redis与rabbitmq做消息队列的区别

1、我们介绍了RabbitMQ，Kafka和Redis的一些特征。这三种动物都是它们的类别，但是如上所述，它们的运行方式大不相同。这是我们建议正确的消息代理根据不同用例使用的建议。

2、首先说RabbitMQ，RabbitMQ是使用Erlang编写的一个开源的消息队列，本身支持很多的协议：AMQP，XMPP， SMTP， STOMP，也正因如此，它非常重量级，更适合于企业级的开发。

3、redis只是提供一个高性能的、原子操作内存键值对，具有高速访问能力，可用做消息队列的存储，但是不具备消息队列的任何功能和逻辑，要作为消息队列来实现的话，功能和逻辑要通过上层应用自己实现。我们以RabbitMQ为例介绍。

4、消息队列 一般是采用一个独立的集群专门用于消息存储，可以存储在内存里 也可以直接存储在磁盘中。

5、Redis实现消息队列原理常用的消息队列有RabbitMQ，ActiveMQ，个人觉得这种消息队列太大太重，本文介绍下基于Redis的轻量级消息队列服务。 一般来说，消息队列有两种模式，一种是发布者订阅模式，另外一种是生产者和消费者模式。

6、消息队列已经逐渐成为企业IT系统内部通信的核心手段。它具有低耦合、可靠投递、广播、流量控制、最终一致性等一系列功能，成为异步RPC的主要手段之一。

redis的消息队列和缓存的区别

1、redis 消息推送（基于分布式 pub/sub）多用于实时性较高的消息推送，并不保证可靠。其他的mq和kafka保证可靠但有一些延迟（非实时系统没有保证延迟）。

2、消息队列系统：消息队列系统可以说是一个大型网站的必备基础组件，因为其具有业务 解耦、非实时业务削峰等特性。

3、数据库应用场景不同：Redis主要用于缓存、队列、计数器等，而关系型数据库主要用于存储关系型数据。数据库的处理方式不同：Redis可以对数据进行持久化，包括RDB快照和AOF日志两种方式，保证数据不丢失。

4、消息队列是在消息的传输过程中保存消息的容器。（redis教程）redis中的消息队列redis中可以使用自带的publish和subscribe命令完成“消息推送”和“消息拉取”功能，实现消息队列。

消息队列为什么不需要同步

1、共享内存的最大不足之处在于，由于多个进程对同一块内存区域有访问的权限，各个进程之间的同步问题显得尤为重要。必须控制同一时刻只有一个进程对共享内存区域写入数据，否则将造成数据的混乱。

2、个人认为消息队列的主要特点是异步处理，主要目的是减少请求响应时间和解耦。所以主要的使用场景就是将比较耗时而且不需要即时（同步）返回结果的操作作为消息放入消息队列。

3、消息队列的使用就是为了解决异步线程通信而引入的一种通信机制。当线程A和线程B之间需要通信，但是又不想因为各自处理性能的差异导致相互影响。这个时候引入消息队列，就很好的解决了这个问题。所以消息队列通信是异步通信。