MQ确认机制之事务机制，confirm串行

一：介绍

1.说明原理

　　A:生产者将信道设置成confirm模式，一旦信道进到confirm模式，所有该信道上发布的消息都会被指派一个唯一的ID（从1开始）。

　　一旦消息被投递到所有匹配的队列后，broker就会发送一个确认给生产者，并包括了唯一的ID，这样就使得生产者知道消息已经到达目的队列。

　　B:如果消息和消息队列是可持久化的，那么确认消息会将消息写入磁盘后发出，broker会回传给生产者的确认消息中deliver-tag域包含了确认消息的序列号，并且broker也可以设置basic.ack的multiple域。

　　用来表示这个序列号之前所有的消息已经得到处理。

二：程序（发送一条数据）

1.生产者

package com.mq.confirm;

import com.mq.utils.ConnectionUtil;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;

public class Send {
    private static final String QUEUE_NAME="test_queue_confirm";
    public static void main(String[] args)throws Exception{
        Connection connection= ConnectionUtil.getConnection();
        Channel channel=connection.createChannel();
        channel.queueDeclare(QUEUE_NAME,false,false,false,null);

        channel.confirmSelect();
        String msg="confirm msg";
        channel.basicPublish("",QUEUE_NAME,null,msg.getBytes());

        if (!channel.waitForConfirms()){
            System.out.println("message send failed");
        }else{
            System.out.println("message send success");
        }
    }
}

2.消费者

package com.mq.confirm;

import com.mq.utils.ConnectionUtil;
import com.rabbitmq.client.*;

import java.io.IOException;

public class Receive {
    private static final String QUEUE_NAME="test_queue_confirm";
    public static void main(String[] args)throws Exception {
        Connection connection = ConnectionUtil.getConnection();
        Channel channel = connection.createChannel();
        channel.queueDeclare(QUEUE_NAME, false, false, false, null);
        channel.basicConsume(QUEUE_NAME,true,new DefaultConsumer(channel){
            @Override
            public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {
                System.out.println(new String(body,"utf-8"));
            }
        });
    }
}

3.现象

　　发送成功后，在send端会返回发送成功、

　　在接收端会接受到信息。

　　

　　

三：程序（发送多条）

1.生产者

package com.mq.confirm;

import com.mq.utils.ConnectionUtil;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;

public class SendMultipleMessage {
    private static final String QUEUE_NAME="test_queue_confirm";
    public static void main(String[] args)throws Exception{
        Connection connection= ConnectionUtil.getConnection();
        Channel channel=connection.createChannel();
        channel.queueDeclare(QUEUE_NAME,false,false,false,null);

        channel.confirmSelect();
        String msg="confirm msg";

        //一次性发送多条数据
        for (int i=0;i<10;i++){
            channel.basicPublish("",QUEUE_NAME,null,msg.getBytes());
        }

        //确认一次
        if (!channel.waitForConfirms()){
            System.out.println("message send failed");
        }else{
            System.out.println("message send success");
        }
    }
}

2.原理‘

　　原理就是一次发送多条数据，然后一次返回判断。

　　缺点：如果丢失，就是全部丢失。

3.现象