JMS学习五(ActiveMQ的本地事务)

1、ActiveMQ的本地事务

在一个JMS客户端,可以使用本地事务来组合消息的发送和接收。JMS Session接口提供了commit和rollback方法。事务提交意味着生产的所有消息被发送,消费的所有消息被确认;事务回滚意味着生产的所有消息被销毁,消费的所有消息被恢复并重新提交,除非它们已经过期。 事务性的会话总是牵涉到事务处理中,commit或rollback方法一旦被调用,一个事务就结束了,而另一个事务被开始。关闭事务性会话将回滚其中的事务。 需要注意的是,如果使用请求/回复机制,即发送一个消息,同时希望在同一个事务中等待接收该消息的回复,那么程序将被挂起,因为直到事务提交,发送操作才会真正执行。 需要注意的还有一个,消息的生产和消费不能包含在同一个事务中。

在事务状态下进行发送操作,消息并未真正投递到中间件,而只有进行session.commit操作之后,消息才会发送到中间件,再转发到适当的消费者进行处理。如果是调用rollback操作,则表明,当前事务期间内所发送的消息都取消掉。

2、关于ActiveMQ本地事务的用法

public class Sender {  

    public static void main(String[] args) throws Exception {  

        // 1、建立ConnectionFactory工厂对象,需要填入用户名,密码,以及连接的地址
        // 仅使用默认。端口号为"tcp://localhost:61616"
        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(
                "zhangsan",// ActiveMQConnectionFactory.DEFAULT_USER,
                "123",// ActiveMQConnectionFactory.DEFAULT_PASSWORD,
                "tcp://localhost:61616");
        // 2、通过ConnectionFactory工厂对象创建一个Connection连接
        // 并且调用Connection的start方法开启连接,Connection默认是不开启的
        Connection connection = connectionFactory.createConnection();
        connection.start();  

        // 3、通过Connection对象创建Session会话(上下文环境对象),
        // 参数一,表示是否开启事务
        // 参数二,表示的是签收模式,一般使用的有自动签收和客户端自己确认签收  

        // 第一个参数设置为true,表示开启事务
        // 开启事务后,记得要手动提交事务  

        Session session = connection.createSession(Boolean.TRUE,
                Session.AUTO_ACKNOWLEDGE);  

        // 4、通过Session创建Destination对象,指的是一个客户端用来指定生产消息目标和消费消息来源的对象。
        // 在PTP模式中,Destination指的是Queue
        // 在发布订阅模式中,Destination指的是Topic
        Destination destination = session.createQueue("queue1");  

        // 5、使用Session来创建消息对象的生产者或者消费者
        MessageProducer messageProducer = session.createProducer(destination);
        // 6、如果是,生产者,使用MessageProducer的setDeliverMode方法设置,消息的持久化和非持久化
        messageProducer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
        // 7、最后使用JMS规范的TextMessage形式创建数据(通过Session对象)
        // 并利用MessageProducer的send方法发送数据
        for (int i = 0; i < 5; i++) {
            TextMessage textMessage = session.createTextMessage();
            textMessage.setText("我是消息" + i);
            messageProducer.send(textMessage);
        }  

        // 手动提交开启的事务
        session.commit();  

        // 释放连接
        if (connection != null) {
            connection.close();
        }
    }
}  

2.1   开启事务

// 3、通过Connection对象创建Session会话(上下文环境对象),
        // 参数一,表示是否开启事务
        // 参数二,表示的是签收模式,一般使用的有自动签收和客户端自己确认签收  

        // 第一个参数设置为true,表示开启事务
        // 开启事务后,记得要手动提交事务  

        Session session = connection.createSession(Boolean.TRUE,
                Session.AUTO_ACKNOWLEDGE);  

2.2    提交事务

// 7、最后使用JMS规范的TextMessage形式创建数据(通过Session对象)
        // 并利用MessageProducer的send方法发送数据
        for (int i = 0; i < 5; i++) {
            TextMessage textMessage = session.createTextMessage();
            textMessage.setText("我是消息" + i);
            messageProducer.send(textMessage);
        }  

        // 手动提交开启的事务
        session.commit();  

原文地址:https://www.cnblogs.com/alter888/p/8976100.html

时间: 2024-10-17 02:11:07

JMS学习五(ActiveMQ的本地事务)的相关文章

JMS学习(五)--ActiveMQ中的消息的持久化和非持久化 以及 持久订阅者 和 非持久订阅者之间的区别与联系

一,消息的持久化和非持久化 ①DeliveryMode 这是传输模式.ActiveMQ支持两种传输模式:持久传输和非持久传输(persistent and non-persistent delivery),默认情况下使用的是持久传输. 可以通过MessageProducer 类的 setDeliveryMode方法设置传输模式: MessageProducer producer = ...; producer.setDeliveryMode(DeliveryMode.PERSISTENT); 持

JMS学习(七)-ActiveMQ消息的持久存储方式之KahaDB存储

一,介绍 自ActiveMQ5.4以来,KahaDB成为了ActiveMQ默认的持久化存储方式.相比于原来的AMQ存储方式,官方宣称KahaDB使用了更少的文件描述符,并且提供了更快的存储恢复机制. 二,KahaDB存储配置 在 conf/activemq.xml 中配置如下: <broker brokerName="broker" ... > <persistenceAdapter> <kahaDB directory="activemq-da

JMS学习(八)-ActiveMQ Consumer 使用 push 还是 pull 获取消息

ActiveMQ是一个消息中间件,对于消费者而言有两种方式从消息中间件获取消息: ①Push方式:由消息中间件主动地将消息推送给消费者:②Pull方式:由消费者主动向消息中间件拉取消息.看一段官网对Push方式的解释: To be able to achieve high performance it is important to stream messages to consumers as fast as possible so that the consumer always has a

JMS学习(六)-ActiveMQ的高可用性实现

一,ActiveMQ高可用性的架构 ActiveMQ的高可用性架构是基于Master/Slave 模型的.ActiveMQ总共提供了四种配置方案来配置HA,其中Shared Nothing Master/Slave 在5.8版本之后不再使用了,并在ActiveMQ5.9版本中引入了基于Zookeeper的Replicated LevelDB Store HA方案. 二,Master/Slave架构的配置解释 ①Shared Nothing Master/Slave   该架构最大的特点是: 1)

蜗牛—ORACLE基础之事务学习(五)

---------------事务---当执行到commit时 事务才算是完成,不然 会执行rollback操作. declare v_money acount.money%type:=1223; ex exception; begin update acount set money=money-v_money where id=1; raise ex; update acount set money=money+v_money where id=2; commit; exception whe

ActiveMQ的学习(三)(ActiveMQ的消息事务和消息的确认机制)

ActiveMQ的消息事务 消息事务,是保证消息传递原子性的一个重要特性,和JDBC的事务特征类似. 一个事务性发送,其中一组消息要么能够全部保证到达服务器,要么都不到达服务器.生产者,消费者与消息服务器都支持事务性.ActiveMQ得事务主要偏向在生产者得应用. ActiveMQ消息事务流程图: 原生jms事务发送(生产者的事务发送) 不加事务得情况:(程序没有错误,10条消息会到达mq中) 不加事务得情况:(程序有错误,结果是发送成功3条,其余不成功---因为没有加事务) 加事务得情况:(程

本地事务和分布式事务工作实践 【转】

一:从事务的历史说起 知已知彼,百战不败.想了解事务,我们从事务的历史说起. 在Windows平台上,事务的概念最开始出现在关系型数据库中,但是随着.net平台的发展,事务包括的的范围也越来越宽,先一睹为快, 在关系型数据库中的事务是通过begin transaction,rollback transaction, commit 等关键字来实现事务的. BEGIN TRANSACTION  UPDATE [dbo].[T_ACCOUNT] SET BALANCE = BALANCE + @amo

本地事务和分布式事务工作实践

一:从事务的历史说起 知已知彼,百战不败.想了解事务,我们从事务的历史说起. 在Windows平台上,事务的概念最开始出现在关系型数据库中,但是随着.net平台的发展,事务包括的的范围也越来越宽,先一睹为快, 在关系型数据库中的事务是通过begin transaction,rollback transaction, commit 等关键字来实现事务的. BEGIN TRANSACTION  UPDATE [dbo].[T_ACCOUNT] SET BALANCE = BALANCE + @amo

本地事务和分布式事务工作实践 [转]

一:从事务的历史说起 知已知彼,百战不败.想了解事务,我们从事务的历史说起. 在Windows平台上,事务的概念最开始出现在关系型数据库中,但是随着.net平台的发展,事务包括的的范围也越来越宽,先一睹为快, 在关系型数据库中的事务是通过begin transaction,rollback transaction, commit 等关键字来实现事务的. BEGIN TRANSACTION  UPDATE [dbo].[T_ACCOUNT] SET BALANCE = BALANCE + @amo