ActiveMQ:
Apache出品,最流行的、功能强大的即时通讯和集成模式的开源服务器。ActiveMQ 是一个完全支持JMS1.1和J2EE 1.4规范的 JMS Provider实现。提供客户端支持跨语言和协议,带有易于在充分支持JMS 1.1和1.4使用J2EE企业集成模式和许多先进的功能。
开发环境准备:
OS:Windows
JDK:1.6+
IDE:eclipse
apache ActiveMQ 5.8(下载地址:http://www.apache.org/dyn/closer.cgi?path=/activemq/apache-activemq/5.8.0/apache-activemq-5.8.0-bin.zip)
下载ActiveMQ的压缩包之后,解压到本地目录,可以进入bin目录,使用activemq.bat双击启动(windows用户可以选择系统位数)。
如果启动出现以下异常信息,表明端口被占用了:
Caused by: java.io.IOException: Failed to bind to server socket: tcp://0.0.0.0:61616?maximumConnections=1000&wireformat.maxFrameSize=104857600 due to: java.net.SocketException: Unrecognized Windows Sockets error: 0: JVM_Bind
此时需要将该端口的服务关闭,然后再次启动,启动成功结果如下:
ActiveMQ启动成功之后,就可以在console里进行配置操作了。
访问:http://localhost:8161/admin/ (默认用户名密码:admin/admin),进入控制台首页。
选择【Queue】栏,可以进行Queue的创建:输入queue名称,点击【create】按钮即可完成queue的创建。
ActiveMQ有以下3种形式来进行消息的发送和接收:
(1)、点对点方式(point-to-point)
点对点的消息发送方式主要建立在 Message Queue,Sender,reciever上,Message Queue 存贮消息,Sneder 发送消息,receive接收消息.具体点就是Sender Client发送Message Queue ,而 receiver Cliernt从Queue中接收消息和"发送消息已接受"到Quere,确认消息接收。消息发送客户端与接收客户端没有时间上的依赖,发送客户端可以在任何时刻发送信息到Queue,而不需要知道接收客户端是不是在运行。
(2)、发布/订阅 方式(publish/subscriber Messaging)
发布/订阅方式用于多接收客户端的方式.作为发布订阅的方式,可能存在多个接收客户端,并且接收端客户端与发送客户端存在时间上的依赖。一个接收端只能接收他创建以后发送客户端发送的信息。作为subscriber ,在接收消息时有两种方法,destination的receive方法,和实现message listener 接口的onMessage 方法。
ActiviteMQ接收和发送消息基本流程:
发送消息的基本步骤:
(1)、创建连接使用的工厂类JMS ConnectionFactory
(2)、使用管理对象JMS ConnectionFactory建立连接Connection,并启动
(3)、使用连接Connection 建立会话Session
(4)、使用会话Session和管理对象Destination创建消息生产者MessageSender
(5)、使用消息生产者MessageSender发送消息
消息接收者从JMS接受消息的步骤
(1)、创建连接使用的工厂类JMS ConnectionFactory
(2)、使用管理对象JMS ConnectionFactory建立连接Connection,并启动
(3)、使用连接Connection 建立会话Session
(4)、使用会话Session和管理对象Destination创建消息接收者MessageReceiver
(5)、使用消息接收者MessageReceiver接受消息,需要用setMessageListener将MessageListener接口绑定到MessageReceiver消息接收者必须实现了MessageListener接口,需要定义onMessage事件方法。
相关推荐
NULL 博文链接:https://shhyuhan.iteye.com/blog/1280477
ActiveMQ 集群中JDBC Master Slave + Broker Cluster的整合
ActiveMQ 入门实战(3)--SpringBoot 整合 ActiveMQ(csdn)————程序
ActiveMQ.pdf ActiveMQ in Action
window搭建activeMQ集群(linux系统搭建集群的方式和window的一样),还有自己写的搭建集群的文档和我自己亲手搭建的一个三个mq集群
深入掌握JMS——ActiveMQ 十一章pdf,收集整理
发布/订阅消息传递域的特点如下:(1)生产者将消息发布到topic中,每个消息可以有多个消费者,属于1:N关系(2)生产者和消费者之间有时间上的相关性,订阅某一个主题的消费者只能消费自它订阅之后发布的消息(3)...
ActiveMQ环境搭建及实例详解的源码 ActiveMQ环境搭建及实例详解的源码
该文档详细描述了linux环境下的 Activemq 持久化、集群环境的搭建步骤,以及测试步骤
本章我将通过spring jms和activemq实现单Web项目服务器间异步访问和多Web项目服务器间异步访问。 一. 简介 1. 什么是Apache ActiveMq Apache ActiveMq是最流行和最强大的开源消息和集成服务器。同时Apache ActiveMq...
windows搭建activemq单机版,里面包含有mq文件,只需按照压缩包文档的介绍进行操作即可。
ActiveMQ手册 - 开发文档 开发手册 ActiveMQ手册 - 开发文档 开发手册
ACTIVEMQ实战部分翻译,只翻译了第一章到第四章的第三节
message queue,也就是消息队列,也就是处理消息的,也就是处理JMS的,本文介绍了在Linux环境搭建activeMQ的过程。
activeMq in action 使用activeMq开发JMS的简单讲述,activeMq in action 使用activeMq开发JMS的简单讲述
用于Delphi的ActiveMq开发,开发有关队列的操作,入队、出队等队列操作
springboot整合 activeMq 生产者 发送消息 包含队列模式点对点发送消息 以及 主题模式一对多发送消息 这是生产者的demo producer; 需要配合消费者的demo consumer 使用
activeMq的一个小例子activeMq的一个小例子activeMq的一个小例子activeMq的一个小例子activeMq的一个小例子activeMq的一个小例子activeMq的一个小例子activeMq的一个小例子activeMq的一个小例子activeMq的一个小例子...
点对点的消息传递中,目的地被称为队列(Queue)点对点消息传递的特点如下:(1)每个消息只能有一个消费者,类似1对1的关系,好比个人快递自己领取自己的(2)消息的生产者和消费者之间没有时间上的相关性。...