出现的问题,原本4个操作,要么全部执行,要么全部不执行------->强一致性

但是现在分开了-----------最终一致性

强一致性：指在消息传递的过程中，系统会确保每个消息被精确地按照发送的顺序被传递，并且每个消息都会被正确地处理。强一致性保证了系统中的所有节点都具有相同的视图，即任何节点查询的数据都与其他节点查询的数据一致。在强一致性模型下，无论系统中发生了任何错误，所有节点在任何时候都能够看到完全相同的数据。

最终一致性：是指系统可以容忍在消息传递过程中的一定程度的不一致，但是最终会保证所有的节点都达到一致的状态。最终一致性不会保证在每个节点上看到的数据是相同的，但是当系统达到稳定状态时，每个节点的数据都会达到相同的状态。在最终一致性模型下，如果发生了某些错误，节点在一定时间内仍可能会看到不一致的数据，但是当系统达到一定时间后，所有节点上的数据将最终达到一致状态。

应用场景:

1.异步解耦,就是上面这张图

2.削峰填谷

3.消息分发

缺点:系统可用性降低,一旦MQ宕机,对业务造成影响,当然可以集群

系统复杂度提高

一致性问题

常用消息中间件

ActivitiMQ   RabbitMQ    RocketMQ   Kafka

 

 

RabbitMQ是使用Erlang语言开发的AMQP的开源实现.好比java中的JDBC,不同厂商都要来实现JDBC,AMQP就是不同厂商去实现AMQP,RabbitMQ就是具体实现

安装RabbitMQ前

要先下载安装Erlang

Erlang及RabbitMQ安装版本的选择

下载时一定要注意版本兼容性

版本兼容说明地址：RabbitMQ Erlang Version Requirements — RabbitMQ

我们选择的版本

Erlang官网下载:https://www.erlang.org/downloads

RabbitMQ官方下载地址:https://www.rabbitmq.com/download.html

工作模式总结

1、简单模式 HelloWorld

一个生产者、一个消费者，不需要设置交换机（使用默认的交换机）。

2、工作队列模式 Work Queue

一个生产者、多个消费者（竞争关系），不需要设置交换机（使用默认的交换机）。

3、发布订阅模式 Publish/subscribe

需要设置类型为 fanout 的交换机 ，并且交换机和队列进行绑定 ，当发送消息到交换机后，交换机会将消

息发送到绑定的队列。

4、路由模式 Routing

需要设置类型为 direct 的交换机 ，交换机和队列进行绑定 ， 并且指定 routing key，当发送消息到交换机 后 ，交换机会根据 routing key 将消息发送到对应的队列。

5、通配符模式 Topic

需要设置类型为 topic 的交换机 ，交换机和队列进行绑定 ，并且指定通配符方式的 routing key ，当发送消息到交换机后 ，交换机会根据 routing key 将消息发送到对应的队列。

关于Windows的Rabbit安装https://tiantian.blog.csdn.net/article/details/130452949?spm=1001.2014.3001.5502

注意 RabbitMQ中  队列持久化和消息持久化是两个概念

 

入门案例 简单模式 生产者代码

public static void main(String[] args) throws IOException, TimeoutException {
    //1 创建连接工厂
    ConnectionFactory connectionFactory=new ConnectionFactory();
    //2 设置rabbitmq  ip地址
    connectionFactory.setHost("localhost");
    //3 创建连接对象   Conection对象
    Connection connection=connectionFactory.newConnection();
    //4 创建管道  Chanel
    Channel channel=connection.createChannel();
    //5 设置队列属性
    /**
     * 第一个参数:队列的名称
     * 第二个参数:队列是否要持久化
     * 第三个参数:是否排他性(是否在同一个Connection,如果设置为true,不同的Connection是获得不到消息的)
     * 第四个参数:是否自动删除消息
     * 第五个参数:是否要设置一些额外的参数
     */
    channel.queueDeclare("01-hello",false,false,false,null);
    //6 发送消息
    /**
     * 第一个参数:交换机名称 没有交换机就设置""
     * 第二个参数:路由key
     * 第三个参数:消息属性
     * 第四个参数:消息内容
     */
    channel.basicPublish("","01-hello",null, "hello-rabbitMQ".getBytes(StandardCharsets.UTF_8));
    //7 关闭消息
    //channel.close();
    connection.close();
}

消费者  前面5步都是一样的  

注意消费者 需要持续监听,不要关闭

public static void main(String[] args) throws IOException, TimeoutException {
    //1 创建连接工厂
    ConnectionFactory connectionFactory=new ConnectionFactory();
    //2 设置rabbitmq  ip地址
    connectionFactory.setHost("localhost");
    //3 创建连接对象   Conection对象
    Connection connection=connectionFactory.newConnection();
    //4 创建管道  Chanel
    Channel channel=connection.createChannel();
    //5 设置队列属性
    /**
     * 第一个参数:队列的名称
     * 第二个参数:队列是否要持久化
     * 第三个参数:是否排他性(是否在同一个Connection,如果设置为true,不同的Connection是获得不到消息的)
     * 第四个参数:是否自动删除消息
     * 第五个参数:是否要设置一些额外的参数
     */
    channel.queueDeclare("01-hello",false,false,false,null);
    //6 使用chanel 去 rabbitmq 获取消息进行消费
    /**
     * 第一个参数:队列的名称
     * 第二个参数:是否自动签收
     * 第三个参数:消息属性
     * 第四个参数:消息内容
     */
    channel.basicConsume("01-hello", true,new DeliverCallback(){
        /**
         * 当消息从mq 中取出来了会回调这个方法
         * 消费者消费消息就在这个  handle中进行处理
         */
        @Override
        public void handle(String s, Delivery delivery) throws IOException {
            System.out.println("消息中的内容为:"+new String(delivery.getBody()));
        }
    },new CancelCallback(){
        /**
         * 当消息取消了会回调这个方法
         */
        @Override
        public void handle(String s) throws IOException {
            System.out.println(111);
        }
    });
    //7 关闭消息 

注意消费者 需要持续监听,不要关闭

    //channel.close();
    //connection.close();
}