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常见问答知识还有疑问，可以来我们这了解详情。
推荐阅读：