MQ确认机制之事务机制，tx

一：介绍

1.介绍

　　在前面的说的模式中会出现一个问题。

　　就是生产者将消息发送出去到底有没有到达rabbitMq，默认情况下是不知道。

　　有两种解决方式。

　　　　AMQP实现事务机制

　　　　Confirm机制。

　　这里先说明第一种实现方式。

2.事务机制

　　txSelect：用于将当前的channel设置成transation模式。

　　txCommit：用于提交事务

　　txRollback：回滚事务

3.缺点

　　很耗时，降低吞吐量。

二：程序

1.生产者

package com.mq.TxCommit;

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

import java.io.IOException;
import java.util.Map;
import java.util.concurrent.TimeoutException;

public class Send {
    private static final String QUEUE_NAME="test_queue_tx";
    public static void main(String[] args)throws Exception{
        Connection connection= ConnectionUtil.getConnection();
        Channel channel=connection.createChannel();
        channel.queueDeclare(QUEUE_NAME,false,false,false,null);
        String msg="tx msg";
        try {
            channel.txSelect();
            channel.basicPublish("",QUEUE_NAME,null,msg.getBytes());
            System.out.println("msg:"+msg);
            //营造一个可以回退的语句
            int a=1/0;
            channel.txCommit();
        }catch (Exception e){
            channel.txRollback();
        }
    }
}

2.消费者

package com.mq.TxCommit;

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

import java.io.IOException;

public class Receive {
    private static final String QUEUE_NAME="test_queue_tx";
    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.现象

　　就不粘图了，用文字说明一番。

　　如果没有粘贴可以造成异常的语句，就可以收到消息；如果有，就收不到消息。