【队列状态】1、直接网页查看：http://127.0.0.1:8161/admin/queues.jsp2、curl（QueueSizewithSTOMP）curl-uadmin:adminhttp://127.0.0.1:8161/api/jolokia/read/org.apache.activemq:type=Broker,brokerName=localhost,destinationType=Queue,destinationName=QueueName3、Ap..
分类：
其他好文 时间：
2017-09-21 09:45:57
阅读次数：
128
一、镜像模式集群简介如果RabbitMQ集群只有一个broker节点，那么该节点的失效将导致整个服务临时性的不可用，并且可能会导致message的丢失（尤其是在非持久化message存储于非持久化queue中的时候）。当然可以将所有的publish的message都设置为持久化的，并且使用持久化的queue..
分类：
其他好文 时间：
2017-09-19 23:03:12
阅读次数：
348
LevelDB这种文件系统是从ActiveMQ5.8之后引进的，它和KahaDB非常相似，也是基于文件的本地数据库储存形式，但是它提供比KahaDB更快的持久性。与KahaDB不同的是，它不是使用传统的B-树来实现对日志数据的提前写，而是使用基于索引的LevelDB。<brokerbrokerName="broker"...&g..
分类：
数据库 时间：
2017-09-19 11:05:44
阅读次数：
1037
JDBC可以将消息存储到数据库中，例如：Mysql、SQLServer、Oracle、DB2。使用JDBC持久化方式，数据库会创建3个表：activemq_msgs，activemq_acks和activemq_lock。一、配置方式（Oracle）：conf/acticvemq.xml<beans>
<brokerbrokerName="test-broker"persistent="true..
分类：
数据库 时间：
2017-09-16 11:36:41
阅读次数：
157
1. 简介-两个程序通信，除了socket就是文件了，但是通过磁盘效率太低了，之前的RabbitMQ只是实现了消息的传递，现在要是实现数据的共享(一份数据，可供多人查阅)，可以通过缓存实现，一个中间商broker。 可是程序之间是无法访问对方的内存地址的。所以其他程序和中间商的之间的通信是通过soc ...
分类：
其他好文 时间：
2017-09-15 18:39:23
阅读次数：
103
目标：sparkStreaming每2s中读取一次kafka中的数据，进行单词计数。 topic:topic1 broker list:192.168.1.126:9092,192.168.1.127:9092,192.168.1.128:9092 1、首先往一个topic中实时生产数据。 代码如下 ...
分类：
其他好文 时间：
2017-09-13 09:51:50
阅读次数：
271
每个 Master 配置一个 Slave，有多对Master-Slave，HA采用同步双写方式，主备都写成功，向应用返回成功。 优点：数据与服务都无单点，Master宕机情况下，消息无延迟，服务可用性与数据可用性都非常高。缺点：性能比异步复制模式略低，大约低10%左右，发送单个消息的RT会略高。目前 ...
分类：
其他好文 时间：
2017-09-12 17:43:39
阅读次数：
491
分布式消息Kafka 摘要: Kafka将消息以topic为单位进行归纳。 将向Kafka topic发布消息的程序成为producers. 将预订topics并消费消息的程序成为consumer. Kafka以集群的方式运行，可以由一个或多个服务组成，每个服务叫做一个broker. 介绍Kafk... ...
分类：
其他好文 时间：
2017-09-11 12:25:16
阅读次数：
173
activemq的consumer端也有窗口机制，通过prefetchSize就可以设置窗口大小。加入窗口是为了批量获取数据，同时可以设置optimizeAcknowledge来优化确认回复，优化确认一方面可以减轻client负担（不需要频繁的确认消息）、减少通信开销，另一方面由于延迟了确认（默认a ...
分类：
其他好文 时间：
2017-09-05 15:44:51
阅读次数：
181
RabbitMQRabbitMQ是使用Erlang编写的一个开源的消息队列，本身支持很多的协议：AMQP，XMPP, SMTP, STOMP，也正因如此，它非常重量级，更适合于企业级的开发。同时实现了Broker构架，这意味着消息在发送给客户端时先在中心队列排队。对路由，负载均衡或者数据持久化都有很 ...
分类：
其他好文 时间：
2017-09-04 20:40:59
阅读次数：
189
