activemq持久化机制该怎么实现?

TheDisguiser 2020-08-08 13:38:00 java常见问答 7748

activemq中,持久化是它核心特点之一,学习过它就要充分了解如何实现它的持久化机制,下面小编就带你熟悉熟悉。

保证消息不丢失的重要方式之一就是消息持久化,我们的ActiveMQ提供了三种消息存储方式,如下:

 1、 基于KahaDB的消息存储方式,是现在的默认存储方式。它提供了容量的提升和恢复能力。

2、 基于JDBC的消息存储方式-数据存储于数据库中。

3、 Memory 消息存储-基于内存的消息存储。

JMS中两种通讯模式:

发布订阅 一对多 topic 去过消费者集群的话 都会消费

消息队列 点对点 queue 去过消费者集群的话 均摊消费

实现:

package com.toov5.producer;
import javax.jms.Connection;
import javax.jms.DeliveryMode;
import javax.jms.JMSException;
import javax.jms.MessageProducer;
import javax.jms.Queue;
import javax.jms.Session;
import javax.jms.TextMessage;
import org.apache.activemq.ActiveMQConnectionFactory;
public class producerTest
{
    // mq通讯地址
    private static String url = "tcp://192.168.91.6:61616";
    // 队列名称
    private static String queueName = "toov5_queue";
    public static void main(String[] args) throws JMSException
    {
        // 先创建连接工厂 密码默认采用admin admin
        ActiveMQConnectionFactory activeMQConnectionFactory = new ActiveMQConnectionFactory(url);
        // 创建连接
        Connection connection = activeMQConnectionFactory.createConnection();
        // 启动连接
        connection.start();
        // 创建会话
        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); // 是否需要事务方式提交 消费方式默认自动签收
        // 拿到session 创建目标 创建队列
        Queue queue = session.createQueue(queueName);
        // 创建生产者
        MessageProducer producer = session.createProducer(queue); // 生产者生产的消息 是放在这个queue里面的
        producer.setDeliveryMode(DeliveryMode.PERSISTENT); //默认非持久化的 设置持久化
        for (int i = 1; i < 10; i++)
        {
            // 拿到队列 创建消息
            TextMessage textMessage = session.createTextMessage("消息内容" + i);
            // 发送消息
            producer.send(textMessage);
        }
        // 关闭连接
        connection.close();
        System.out.println("消息发送完毕");
    }
}

以上就是本篇文章的所有内容,如果对一些常见java常见问答知识还有疑问,可以来我们这了解详情。

推荐阅读:

面试题activemq的原理详解

springboot整合activemq要怎么搭建?需要哪些配置?