一、高可用集群 从ActiveMQ5.9开始,ActiveMQ的集群实现方式取消了传统的Master-Slave方式,增加了基于ZooKeeper+LevelDB的Master-Slave实现方式,其他两种方式目录共享和数据库共享方式依然存在. 1、文件共享(KahaDB) [html] view ...
分类:
其他好文 时间:
2017-11-13 21:32:04
阅读次数:
183
配置文件如下<!-- Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE file distributed with thi ...
分类:
数据库 时间:
2017-11-13 21:27:27
阅读次数:
193
Publisher的代码: Subscribe的代码: 先启动消费者(先订阅后消费),再启动发布者 ...
分类:
其他好文 时间:
2017-11-13 14:13:07
阅读次数:
235
生产者JMSProducer: 先启动消费者(订阅),再启动生产者(发布) ...
分类:
其他好文 时间:
2017-11-13 13:55:40
阅读次数:
271
一 、消息中间件的基本介绍 1.1 消息中间件 1.1.1 什么是消息中间件 消息中间件利用高效可靠的消息传递机制进行平台无关的数据交流,并基于数据通信来进行分布式系统的集成。通过提供消息传递和消息排队模型,它可以在分布式环境下扩展进程间的通信。对于消息中间件,常见的角色大致也就有Producer( ...
分类:
编程语言 时间:
2017-11-12 00:27:12
阅读次数:
306
先来个ActiveMQ介绍哈: MQ全称为Message Queue, 消息队列(MQ)是一种应用程序对应用程序的通信方法,是一个消息中间件。 应用场景:为了实现系统之间的通信,把系统之间的调用耦合度降低就可以使用MQ。 1) activeMQ 是Apache出品,最流行的,能力强劲的开源消息总线。 ...
分类:
编程语言 时间:
2017-11-11 15:22:50
阅读次数:
220
RocketMQ是一款分布式消息系统,最初是由阿里巴巴消息中间件团队研发并大规模应用于生产系统,满足线上海量堆积的需求,在去年捐赠给Apache开源基金会,并列为孵化项目,今年成功的正式成为了apache顶级项目;早期阿里曾经基于ActiveMQ研发的消息系统,随着业务消息的规模增大,瓶颈逐渐明显, ...
分类:
系统相关 时间:
2017-11-11 11:21:40
阅读次数:
176
1.1. 什么是ActiveMQ ActiveMQ 是Apache出品,最流行的,能力强劲的开源消息总线。ActiveMQ 是一个完全支持JMS1.1和J2EE 1.4规范的 JMS Provider实现,尽管JMS规范出台已经是很久的事情了,但是JMS在当今的J2EE应用中间仍然扮演着特殊的地位。 ...
分类:
其他好文 时间:
2017-11-10 23:02:17
阅读次数:
241
1、Bloom Filter 过滤器数据分片与路由 分区算法:一致性哈希算法 2、备份机制与一致性 3、CAP理论 4、幂等性:分布式系统状态管理基石 5、一致性模型:强、弱、最终一致。 6、备份机制:法7,Leader-Follower模式 7、共识协议:一致性协议。Paxos或者Raft 8、算 ...
分类:
其他好文 时间:
2017-11-08 23:27:24
阅读次数:
207
1. 点对点通信 点对点是一种一对一通信方式,更像是有一个队列,一个人往队列里放消息,另一个人从队列中取消息,其最大的特点是一个消息只会被消费一次,即使有多个消费者同时消费,他们消费的也是不同的消息。 2. 简单实现 添加依赖 添加Maven依赖: org.apache.activemq activ... ...
分类:
其他好文 时间:
2017-11-08 20:58:03
阅读次数:
215