在做开发或者debug的时候，如果能看到进入到message broker的消息以及message broker分发的消息的话会很有帮助， rabbitmq 本身提供这样的一个叫做firehose(消防管道)的feature。 除此之外，rabbitmq还有一个叫做rabbitmq_tracing ...
分类：
其他好文 时间：
2018-02-14 11:45:05
阅读次数：
202
Kafka进阶知识 消息概念 消息指的是通信的基本单位。由消息生产者（producer）发布关于某个话题（topic）的消息。简单来说：消息以一种物理方式被发送给了作为代理（broker）的服务器（可能是另外一台机器）。若干的消息使用者（consumer）订阅（subscribe）某个话题，然后生产 ...
分类：
其他好文 时间：
2018-02-12 21:01:26
阅读次数：
176
经常有人问的一个问题就是：Kafka broker到底是不是无状态的？网上有这样的说法： 正常情况下consumer会在消费完一条消息后线性增加这个offset。当然，consumer也可将offset设成一个较小的值，重新消费一些消息。因为offet由consumer控制，所以Kafka brok ...
分类：
Web程序 时间：
2018-02-11 12:41:04
阅读次数：
323
RabbitMQ（一） ——简介 （转载请附上本文链接——linhxx） 一、概述 RabbitMQ是一种消息的传输者（broker），除了消息持久化，不对消息内容本身做任何的处理。其类似于邮局，可以将邮件发送给他，也可以去邮局取邮件。RabbitMQ相似，用户可以将消息发到其中，也可以去取消息。 ...
分类：
其他好文 时间：
2018-02-09 14:56:45
阅读次数：
145
1. KAFKA下载地址：http://kafka.apache.org/downloads KAFKA-快速上手-官方网站：http://kafka.apache.org/quickstart 2. 下载完成后解压，修改config目录下的配置文件：server.properties 、zooke ...
分类：
其他好文 时间：
2018-02-08 13:42:07
阅读次数：
216
一、搭建RocketMQ集群 我搭建的是2-master no slave模式，所以在${rocketmq}/conf/2m-noslave/下的 brokder-*.properties 中添加 filterServerNums=1 二、依次启动namesrv和broker 在broker-*.p ...
分类：
其他好文 时间：
2018-02-06 20:26:51
阅读次数：
129
1、RPC概述 RPC(Remote Procedure Call)即远程过程调用，允许一台计算机调用另一台计算机上的程序得到结果，而代码中不需要做额外的编程，就像在本地调用一样。主要是为了应对当前互联网项目量级越来越大而出现的。 2、Broker模式介绍 3、RPC结构拆解 4、RPC客户端组件与 ...
分类：
其他好文 时间：
2018-02-02 11:41:06
阅读次数：
178
Kafka基于高吞吐率和效率考虑，并没有使用第三方网络框架，而且自己基于java nio封装的，总体网络模型如下： Broker的内部按照SEDA模型处理网络请求，处理过程如下： Accept Thread负责与客户端建立连接链路，然后把Socket轮转交给Process Thread Proces ...
分类：
其他好文 时间：
2018-02-01 20:34:54
阅读次数：
260
一.topic中partition存储分布 在本地的kafka中，我们只启动一个broker，创建两个topic：single-todo和single-todo-vip ，每个topic有两个partition，在${KAFKA_HOME}conf/server.properties中log.dir ...
分类：
其他好文 时间：
2018-02-01 17:19:54
阅读次数：
183
副本分配算法如下： 将所有N Broker和待分配的i个Partition排序. 将第i个Partition分配到第(i mod n)个Broker上. 将第i个Partition的第j个副本分配到第((i + j) mod n)个Broker上. 将所有N Broker和待分配的i个Partiti ...
分类：
编程语言 时间：
2018-02-01 13:22:19
阅读次数：
159
