ActiveMQ学习笔记

关键接口和类:

ConnectionFactory connectionFactory;//连接工厂
Connection connection;//连接
Session session;
Destination destination;//目的
MessageProducer messageProducer;//消息生产者
Message message;//消息
MessageConsumer messageConsumer;//消息消费者

1.发送消息

//ActiveMQ用户名、ActiveMQ密码、ActiveMQ地址
connectionFactory = new ActiveMQXAConnectionFactory("admin", "admin", "failover://tcp://localhost:61616");
//连接
connection = connectionFactory.createConnection();
//第一个参数是否使用事务,第二个参数消息的确认模式
session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);//指定消息提供者在每次收到消息时自动发送确认。消息只向目标发送一次
//目的地,ActiveMQ中已存在队列
destination = session.createQueue("SecondQueue");
//消息生产者[发送者]
messageProducer = session.createProducer(destination);
//持久性设置
messageProducer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
//消息
message = session.createTextMessage("发了一条消息给SecondQueue");
//发送
messageProducer.send(message);
session.close();
connection.close();

2.发送文件

关键:BlogMessage

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

ActiveMQ学习笔记的相关文章

ActiveMQ学习笔记(五)——使用Spring JMS收发消息

ActiveMQ学习笔记(四)http://my.oschina.net/xiaoxishan/blog/380446 中记录了如何使用原生的方式从ActiveMQ中收发消息.可以看出,每次收发消息都要写许多重复的代码,Spring 为我们提供了更为方便的方式,这就是Spring JMS.我们通过一个例子展开讲述.包括队列.主题消息的收发相关的Spring配置.代码.测试. 本例中,消息的收发都写在了一个工程里. 1.使用maven管理依赖包 <dependencies> <depend

ActiveMQ学习笔记(六)——JMS消息类型

1.前言 ActiveMQ学习笔记(四)--通过ActiveMQ收发消息http://my.oschina.net/xiaoxishan/blog/380446 和ActiveMQ学习笔记(五)--使用Spring JMS收发消息http://my.oschina.net/xiaoxishan/blog/381209   中,发送和接受的消息类型都是TextMessage,即文本消息(如下面的代码所示).显然消息类型只有文本类型是不能满足要求的. //发送文本消息  session.create

ActiveMQ学习笔记(一)--认识消息JMS

1.面向消息的中间件 1.1 什么是MOM 面向消息的中间件,Message Oriented Middleware,简称MOM,利用高效可靠的消息传递机制进行平台无关的数据交流,并基于数据通信来进行分布式系统的集成.一个MOM系统,通常会包括客户端(Client).消息(Message)和MOM,客户端是发送或者接收消息的应用程序,消息封装了要传递的内容,MOM可以存储和转发消息. 1.2 MOM的好处 降低系统间的通信复杂度.有了MOM,系统间通信可以跨编程语言.不用考虑复杂的网络编程,只需

ActiveMQ学习笔记(二)--安装ActiveMQ

一.Windows安装AMQ AMQ下载地址:https://archive.apache.org/dist/activemq/5.13.0/apache-activemq-5.13.0-bin.zip JDK1.7 步骤一:把apache-activemq-5.13.0-bin.zip解压到一个目录下,例如D:\MQ\apache-activemq\apache-activemq-5.13.0. 目录结构介绍如下. bin,放置启动.停止.注册服务等命令文件. conf,配置文件,包括brok

ActiveMQ学习笔记之异常

1.Consumer消费时:FileNotFoundException 结果:fileserver/WEB-IND/web.xml中RestFilter.DefaultServlet注释掉(治标不治本,请大神指点) 2.PUT was not successful: 404 Not Found 结果:ActiveMQConnectionFactory参数错误 3.PUT was not successful: 500 Server Error 结果: ActiveMQConnectionFact

vector 学习笔记

vector 使用练习: /**************************************** * File Name: vector.cpp * Author: sky0917 * Created Time: 2014年04月27日 11:07:33 ****************************************/ #include <iostream> #include <vector> using namespace std; int main

Caliburn.Micro学习笔记(一)----引导类和命名匹配规则

Caliburn.Micro学习笔记(一)----引导类和命名匹配规则 用了几天时间看了一下开源框架Caliburn.Micro 这是他源码的地址http://caliburnmicro.codeplex.com/ 文档也写的很详细,自己在看它的文档和代码时写了一些demo和笔记,还有它实现的原理记录一下 学习Caliburn.Micro要有MEF和MVVM的基础 先说一下他的命名规则和引导类 以后我会把Caliburn.Micro的 Actions IResult,IHandle ICondu

jQuery学习笔记(一):入门

jQuery学习笔记(一):入门 一.JQuery是什么 JQuery是什么?始终是萦绕在我心中的一个问题: 借鉴网上同学们的总结,可以从以下几个方面观察. 不使用JQuery时获取DOM文本的操作如下: 1 document.getElementById('info').value = 'Hello World!'; 使用JQuery时获取DOM文本操作如下: 1 $('#info').val('Hello World!'); 嗯,可以看出,使用JQuery的优势之一是可以使代码更加简练,使开

[原创]java WEB学习笔记93:Hibernate学习之路---Hibernate 缓存介绍,缓存级别,使用二级缓存的情况,二级缓存的架构集合缓存,二级缓存的并发策略,实现步骤,集合缓存,查询缓存,时间戳缓存

本博客的目的:①总结自己的学习过程,相当于学习笔记 ②将自己的经验分享给大家,相互学习,互相交流,不可商用 内容难免出现问题,欢迎指正,交流,探讨,可以留言,也可以通过以下方式联系. 本人互联网技术爱好者,互联网技术发烧友 微博:伊直都在0221 QQ:951226918 -----------------------------------------------------------------------------------------------------------------