actv:ActiveMQ入门-amq入门 2024-04-29 21:31:25 0 0 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或者是QueueJMSDeliveryMode消息的发送模式JMSTimeStamp消息发送给Broker的时间戳,它不是实际发送时间JMSExpiration消息的有效期,在有效期内,消息消费者才可以消费这个消息JMSPriority消息的优先级。0-4为正常的优先级,5-9为高优先级JMSMessageID一个字符串用来唯一标示一个消息JMSReplyTo有时消息生产者希望消费者回复一个消息,JMSReplyTo为一个Destination,标示需要回复的目的地JMSCorrelationID通常用来关联多个MessageJMSType表示消息体的结构,和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 收藏(0)