ActiveMQ入门案例-生产者代码实现

<–start–>
使用Java程序操作ActiveMQ生产消息，代码的复杂度较高，但也没有默写下来的必要。
开发ActiveMQ首先需要导入activemq-all.jar包，如果是maven项目，就需要在pom文件中导入坐标。本例中创建的是一个maven项目，所以在pom文件中引入坐标：

<dependency><groupId>org.apache.activemq</groupId><artifactId>activemq-all</artifactId><version>5.14.0</version>
</dependency>

要测试代码就需要引入juint坐标：

<dependency><groupId>junit</groupId><artifactId>junit</artifactId><version>4.12</version>
</dependency>

Java代码操作ActiveMQ生产消息:

public class ActiveMQProducer {@Testpublic void testProduceMQ() throws Exception {// 连接工厂// 使用默认用户名、密码、路径// 路径 tcp://host:61616ConnectionFactory connectionFactory = new ActiveMQConnectionFactory();// 获取一个连接Connection connection = connectionFactory.createConnection();// 建立会话Session session = connection.createSession(true,Session.AUTO_ACKNOWLEDGE);// 创建队列或者话题对象Queue queue = session.createQueue("HelloWorld");// 创建生产者 或者 消费者MessageProducer producer = session.createProducer(queue);// 发送消息for (int i = 0; i < 10; i++) {producer.send(session.createTextMessage("你好，activeMQ:" + i));}// 提交操作session.commit();}
}

<–end–>

ActiveMQ入门案例-生产者代码实现相关推荐

ActiveMQ入门系列二：入门代码实例（点对点模式）
在上一篇<ActiveMQ入门系列一:认识并安装ActiveMQ(Windows下)>中,大致介绍了ActiveMQ和一些概念,并下载.安装.启动他,还访问了他的控制台页面. 这篇,就用代 ...
b站黑马的Vue快速入门案例代码——【axios+Vue2】悦听player(音乐播放器)
目录本文中修改的原代码中的BUG: 修改方法: 本文案例代码仍有的BUG:(欢迎大家献计献策) 目标效果: 悦音player案例--效果展示视频: 更换的新接口/参数: 1.歌曲搜索接口:https ...
【Netty】Netty 入门案例分析 ( Netty 模型解析 | Netty 服务器端代码 | Netty 客户端代码 )
文章目录一. Netty 模型代码解析二. Netty 案例服务器端代码 1 . 服务器主程序 2 . 服务器自定义 Handler 处理者三. Netty 案例客户端代码 1 . 客户端主程序 ...
Netty框架入门案例,代码示例
Netty框架入门案例 pom文件 <?xml version="1.0" encoding="UTF-8"?> <project xmlns ...
ActiveMQ-01-MQ概述，安装，入门案例
文章目录 01.MQ概述 MQ的产品种类和对比 MQ的产生背景 MQ的主要作用 MQ的定义 MQ的特点 02.RPC架构什么是RPC架构? 常见的RPC架构 03.ActiveMQ安装 04.入门案 ...
消息队列入门案例-环境搭建
我们就来编写一个RabbitMQ的入门案例,首先第一步呢,先要去创建一个Project,那么至于Project的创建方式呢,我们都可以,比如用Spring官网创建的方式,创建项目也可以,你也可以在ID ...
05_RabbitMQ入门案例—fanout模式Direct模式Topic模式
RabbitMQ入门案例-fanout模式 package com.tian.rabbitmq.routing;import com.rabbitmq.client.Channel; import c ...
ActiveMQ入门-amq入门
ActiveMQ是什么 ActiveMQ是Apache出品,最流行的,能力强劲的开源消息总线. ActiveMQ是一个完全支持JMS1.1和J2EE1.4规范的JMS Provider实现,尽管JMS ...
RabbitMQ 服务异步通信 -- 入门案例（消息预存机制）、SpringAMQP、发布订阅模式（FanoutExchange、DirectExchange、TopicExchange）、消息转换器
文章目录 1. 入门案例 2. 完成官方Demo中的hello world案例 2.1 创建1个工程,2个模块 2.1.1 父工程的依赖,子工程不需要导入额外的依赖 2.1.2 配置子工程的配置文件( ...

ActiveMQ入门案例-生产者代码实现

ActiveMQ入门案例-生产者代码实现相关推荐

最新文章

热门文章