ActiveMQ向消息队列存入消息(点对点模式)

简介: 创建一个maven工程,引入ActiveMQ的依赖

创建一个maven工程,


引入ActiveMQ的依赖


<dependency>
      <groupId>org.apache.activemq</groupId>
      <artifactId>activemq-core</artifactId>
      <version>5.7.0</version>
    </dependency>

创建一个类


package com.vhukze.Producer;
import org.apache.activemq.ActiveMQConnectionFactory;
import javax.jms.*;
public class ProducerTest {
    //mq通讯地址
    private static String url = "tcp://127.0.0.1:61616";
    //队列名称
    private static String queueName = "my_queue";
    public static void main(String[] args) throws JMSException {
        //创建连接工厂
        ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory(url);
        //创建连接
        Connection connection = factory.createConnection();
        //启动连接
        connection.start();
        //创建会话,参数1,设置是否需要事务方式提交,参数2,消息方式  默认采用自动接收
        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        //创建目标(队列)
        Queue queue = session.createQueue(queueName);
        //创建生产者
        MessageProducer producer = session.createProducer(queue);
        for (int i = 0; i <= 10 ; i++) {
            //创建消息
            TextMessage textMessage = session.createTextMessage("消息内容" + i);
            //发送消息
            producer.send(textMessage);
        }
        connection.close();
    }
}


启动activeMQ服务



运行上面的代码


访问ActiveMQAdmin页面


localhost:8161/admin



可以看到有11条未消费的消息


相关文章
|
1月前
|
消息中间件 存储 Kafka
Kafka - 消息队列的两种模式
Kafka - 消息队列的两种模式
43 0
|
4月前
|
消息中间件 Java 数据安全/隐私保护
企业实战(12)消息队列之Docker安装部署ActiveMQ实战
企业实战(12)消息队列之Docker安装部署ActiveMQ实战
|
5月前
|
消息中间件 移动开发 运维
消息队列和应用工具产品体系-14-容量规划及不同模式的适用场景
消息队列和应用工具产品体系-14-容量规划及不同模式的适用场景
97 0
消息队列和应用工具产品体系-14-容量规划及不同模式的适用场景
|
6月前
|
消息中间件 Java API
可靠消息传递的选择:深入了解 Apache ActiveMQ 消息队列
在分布式系统中,可靠的消息传递是实现异步通信、解耦和数据同步的关键。Apache ActiveMQ,作为一款开源的消息队列系统,为开发者提供了一个强大的工具来实现可靠的消息传递。本文将为您详细介绍 Apache ActiveMQ 的核心概念、特性以及在分布式架构中的应用。
87 0
|
6月前
|
消息中间件 存储
消息队列之RabbitMQ之主题(Topics)模式
RabbitMQ是一个消息中间件,它接受并转发消息。它有6中工作模式,而主题模式是它的核心。在主题模式中,主要是通配符的添加与使用。
131 0
|
10月前
|
消息中间件 存储 JavaScript
消息队列原理和选型:Kafka、RocketMQ 、RabbitMQ 和 ActiveMQ
消息队列原理和选型:Kafka、RocketMQ 、RabbitMQ 和 ActiveMQ
消息队列原理和选型:Kafka、RocketMQ 、RabbitMQ 和 ActiveMQ
|
消息中间件 Linux 开发工具
消息队列:第二章:安装 ActiveMQ
消息队列:第二章:安装 ActiveMQ
101 0
消息队列:第二章:安装 ActiveMQ
|
消息中间件
springbooot整合ActiveMQ实现消息队列和主题
springbooot整合ActiveMQ实现消息队列和主题
150 0
|
消息中间件 存储 缓存
常用消息队列 Kafka、RabbitMQ、RocketMQ、ActiveMQ 综合对比(18个方面)
常用消息队列 Kafka、RabbitMQ、RocketMQ、ActiveMQ 综合对比(18个方面)
370 0
|
消息中间件 存储 监控
消息队列原理和选型:Kafka、RocketMQ 、RabbitMQ 和 ActiveMQ
常用的消息队列主要这 4 种,分别为 Kafka、RabbitMQ、RocketMQ 和 ActiveMQ,主要介绍前三,不BB,上思维导图!
1473 0
消息队列原理和选型:Kafka、RocketMQ 、RabbitMQ 和 ActiveMQ

相关产品

  • 云迁移中心