actv:ActiveMQ入门-amq入门

ActiveMQ是什么

ActiveMQ是Apache出品,最流行的,能力强劲的开源消息总线。
ActiveMQ是一个完全支持JMS1.1和J2EE1.4规范的JMS Provider实现,尽管JMS规范出台已经是很久的事情了,但是JMS在当今的J2EE应用中任然扮演着特殊的地位。

JMS规范

Java消息服务(Java Message Service,即JMS)应用程序接口是一个Java平台中关于面向消息中间件(MOM)的api,用于在两个应用程序之间,或分布式系统中发送消息,进行异步通信。Java消息服务是一个与具体平台无关的api。

JMS的对象模型

ConnectionFactory连接工厂
Connection连接
Session会话
Destination目的
MessageProducer生产者
MessageConsumer消费者
Message消息
Broker消息中间件的实例(ActiveMQ)

JMS的消息模型

Point-to-Point (P2P)/点对点


Publish/Subscribe(Pub/Sub)/主题(发布订阅)

JMS的消息结构


消息头
关于一些消息的描述信息

JMSDestination消息的目的地,Topic或者是Queue
JMSDeliveryMode消息的发送模式
JMSTimeStamp消息发送给Broker的时间戳,它不是实际发送时间
JMSExpiration消息的有效期,在有效期内,消息消费者才可以消费这个消息
JMSPriority消息的优先级。0-4为正常的优先级,5-9为高优先级
JMSMessageID一个字符串用来唯一标示一个消息
JMSReplyTo有时消息生产者希望消费者回复一个消息,JMSReplyTo为一个Destination,标示需要回复的目的地
JMSCorrelationID通常用来关联多个Message
JMSType表示消息体的结构,和JMS提供者有关
JMSDeliveryMode消息的发送模式
JMSRedelivered如果这个值为true,表示消息是被重新发送了

*JMSDeliveryMode :比如说消息发送出去后,是否需要回执

消息属性
消息属性可以理解为消息的附加消息头,属性名可以自定义


消息体
消息体类型

BytesMessage用来传递字节信息
MapMessage用来传递键值对信息
ObjectMessage用来传递序列化对象
StreanmMessage用来传递文件等
TextMessage用来传递字符串

ActiveMQ的特性

支持多种编程语言
支持多种传输协议
有多种持久化方式

ActiveMQ如何安装

环境准备
Centos7、jdk1.8

下载ActiveMQ




ActiveMQ服务

如何创建ActveMQ




ActiveMQ如何使用

使用ActiveMQ的Web管理平台

ActiveMQ自带有管理平台,在浏览器访问http://服务IP:8161/admin即可进入

ActiveMQ的管理页面默认开启了身份校验

帐号:admin
密码:admin

Web管理配置




引入ActiveMQ

使用Jar包


Maven依赖


在Spring中使用ActiveMQ

Spring官方教程
http://spring.io/guides/gs/messaging-jms/
Maven依赖

ActiveMQ入门安装

入门安装

在Java代码中使用ActiveMQ

在Java代码中使用ActiveMQ

相关推荐

相关文章