一：新建Maven项目，加入如下依赖
org.apache.activemq
activemq-all
5.11.1
二：
server
package com.lala.mq;
import java.util.concurrent.TimeUnit;
import org.apache.activemq.broker.BrokerService;
public clas...
分类：
其他好文 时间：
2015-08-02 21:46:24
阅读次数：
205
RocketMQ 源码分析RocketMQ 的设计思想来自于Kafka,在具体设计时体现了自己的选择和需求，具体差别可以看RocketMQ与Kafka对比（18项差异）。接下来记录下自己阅读源码的一些探索。
RocketMQ的整体架构如下，可以看到各个组件充当的角色，Name Server 负责维护一些全局的路由信息：当前有哪些broker，每个Topic在哪个broker上等; Broker具体处...
分类：
其他好文 时间：
2015-08-01 23:37:44
阅读次数：
754
logstash 配置使用redis做中间broker节点无法连接
分类：
其他好文 时间：
2015-07-26 22:27:36
阅读次数：
306
对于数据转发我们一般就两种模式，一种时推模式，一种时拉模式。下面我们简单介绍一下推模式和拉模式。 推模式 该模式下，一般是消息源直接推送给目标群体或推送给Broker，由Broker推送给目标群体。 这个模式下，...
分类：
其他好文 时间：
2015-07-17 12:20:13
阅读次数：
185
正在 .NET 中构建一个需要使用分布式对象的应用程序，并且分布式对象的生存期由客户端控制。您的要求包括能够按值或按引用来传递对象，无论这些对象驻留在同一台计算 机上，还是驻留在同一个局域网 (LAN) 中的不同计算机上，或者是驻留在广域网 (WAN) 中的不同计算机上。实现策略这 种模式为在 .N...
分类：
Web程序 时间：
2015-07-15 09:15:00
阅读次数：
126
正在使用 Microsoft? .NET Framework 构建一个需要使用分布式对象的应用程序。您的要求包括能够按值或按引用来传递对象，无论这些对象驻留在同一台计算机上，还是驻留在同一个局域网 (LAN) 中的不同计算机上，或者是驻留在广域网 (WAN) 中的不同计算机上。应用程序不需要您显式控...
分类：
Web程序 时间：
2015-07-14 09:47:26
阅读次数：
145
一.RocketMQ网络部署特点（1）NameServer是一个几乎无状态的节点，可集群部署，节点之间无任何信息同步（2）Broker部署相对复杂，Broker氛围Master与Slave，一个Master可以对应多个Slaver，但是一个Slaver只能对应一个Master，Master与Slaver的对应关系通过指定相同的BrokerNam..
分类：
其他好文 时间：
2015-07-12 15:53:52
阅读次数：
218
In order to exchange messages, producers and consumers (clients) need to connect tothe broker. This client-to-broker communication is performed throug...
分类：
其他好文 时间：
2015-07-10 13:02:38
阅读次数：
101
The main role of a JMS broker such as ActiveMQ is to provide a communicationinfrastructure for client applications. For that reason, ActiveMQ provides...
分类：
其他好文 时间：
2015-07-10 12:51:31
阅读次数：
142
许多复杂的软件系统运行在多个处理器或分布式计算机上。将软件分布在多台计算机上的原因有多种，例如：分布式系统可以利用多个 CPU 或一群低成本计算机的计算能力。某个软件可能仅在特定计算机上可用。出于安全考虑，软件的各部分可能必须运行在不同的网段上。一些服务可能是由业务合作伙伴提供的，并且只能通过 In...
分类：
其他好文 时间：
2015-07-10 09:18:04
阅读次数：
172
