这是关于消息中间件ActiveMQ的一个系列专题文章,将涵盖JMS、ActiveMQ的初步入门及API详细使用、两种经典的消息模式(PTP and Pub/Sub)、与Spring整合、ActiveMQ集群、监控与配置优化等。话不多说,我们来一起瞧一瞧!
分类:
其他好文 时间:
2020-04-20 23:33:03
阅读次数:
81
什么是消息中间件? 定义 其实并没有标准定义。一般认为,消息中间件属于分布式系统中一个子系统,关注于数据的发送和接收,利用高效可靠的异步消息传递机制对分布式系统中的其余各个子系统进行集成。 为什么要用消息中间件? 假设一个电商交易的场景,用户下单之后调用库存系统减库存,然后需要调用物流系统进行发货, ...
分类:
其他好文 时间:
2020-04-20 23:31:13
阅读次数:
85
消息队列 每当想到消息队列:我们都会想到RabbitMQ,ActiveMQ,RocketMQ,等等一些专业的消息中间件。但是如果我们做的事情比较简单,只有一个消息队列,要使用专业的消息中间件是非常麻烦的,因此我们可以使用Redis做消息队列。 如果对消息的可靠性没有较高的要求的话,那么就可以使用Re ...
分类:
其他好文 时间:
2020-04-19 16:19:09
阅读次数:
74
概述 场景 服务解耦 削峰填谷 异步化缓冲:最终一致性/柔性事务 MQ应用思考点 生产端可靠性投递 消费端幂等:消息只能消费一次 高可用、低延迟、可靠性 消息堆积能力 可扩展性 业界主流MQ ActiveMQ:适合传统需求,并发性差 RabbitMQ:扩展性差 RocketMQ:扩展性强 Kafka ...
分类:
编程语言 时间:
2020-04-15 00:32:15
阅读次数:
107
将JavaWeb系统分为Controller/Service/Dao等层次,已经是开发们的习惯了。在这种分层思想的指导下,系统内的包结构一般都是这样的:当然,有时候bean、dao会被命名为model、pojo或者mapper,虽然名称各异,但含义相近。如果分层较细,可能还会有business、jms或者task这样的包。在这种这种包结构中,某一项功能(如用户管理功能)的代码被拆分成Control
分类:
其他好文 时间:
2020-04-13 18:14:41
阅读次数:
138
做消息持久化 借助 jdbc, kahadb或 leveldb+zookeeper首先将将消息发送设置为持久化发送(mq自带的属性),然后再借助jdbc kahadb leveldb+zookeeper等做消息的存储来持久化。思想都是发送者(消息生产者)将消息发送出去后,消息中心首先将消息存储到本地 ...
分类:
其他好文 时间:
2020-04-10 22:48:34
阅读次数:
232
一、JMS规范 定义:Java Message Service,本质是API,Java平台消息中间件的规范,java应用程序之间进行消息交换。包含点对点(Ponit to Point)和发布/订阅(Publish/Subscribe)2种消息模型,提供可靠的消息传输、事务和消息过滤等机制。主要特点包 ...
分类:
其他好文 时间:
2020-04-10 09:14:03
阅读次数:
66
1.queue是点对点模式,一条消息对应一个消费者,topic是一对多模式,一条消息可能有一个或多个消费者 2.queue模式消息再发送后消费者可以在之后的任意时间消费,topic模式如果没有订阅者消息就是废消息,会被丢弃。 3.queue模式生产者与消费者之间没有时间相关性,topic模式下生产者 ...
分类:
其他好文 时间:
2020-04-08 22:28:23
阅读次数:
69
这些是当前版本。对于以前的版本,请参阅以前的版本页面。 ActiveMQ 5.15.12(2020年3月9日) 文献资料 视窗 apache-activemq-5.15.12-bin.zip SHA512 GPG签名 Unix / Linux / Cygwin apache-activemq-5.1 ...
分类:
其他好文 时间:
2020-04-07 18:28:17
阅读次数:
265
1、 kafka的介绍 kafka是linkedin公司开源捐献给apache的一个消息队列的框架,底层语言用的是scala kafka是一个分布式的消息队列,提供了类似于JMS的特性,不是标准的JMS的实现,也有生产者,消费者,topic等组件 2、 消息队列的作用 解耦,异步,并行 3、 kak ...
分类:
其他好文 时间:
2020-04-01 20:59:46
阅读次数:
93