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
今天的文章activemq amqp_ActiveMQ[通俗易懂]分享到此就结束了,感谢您的阅读。
版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。
如需转载请保留出处:https://bianchenghao.cn/77818.html