Namesrv名称服务,是没有状态可集群横向扩展。 一:Namesrv功能: 二:Namesrv启动流程: 三: RouteInfoManager 路由信息RouteInfoManager类的管理 四:Namesrv与broker间的心跳: ...
分类:
其他好文 时间:
2016-11-11 19:33:58
阅读次数:
334
ELK是日志收益与分析的利器。 1、elasticsearch集群搭建 略 2、logstash日志收集 我这里的实现分如下2步,中间用redis队列做缓冲,可以有效的避免es压力过大: 1、n个agent对n个服务的log做日志收集(1对1的方式),从日志文件解析数据,存入broker,这里用的是 ...
分类:
其他好文 时间:
2016-11-11 14:08:34
阅读次数:
213
备注:1.如果您此前未接触过RocketMQ,请先阅读附录部分,以便了解RocketMQ的整体架构和相关术语2.文中的MQServer与Broker表示同一概念 分布式消息系统作为实现分布式系统可扩展、可伸缩性的关键组件,需要具有高吞吐量、高可用等特点。而谈到消息系统的设计,就回避不了两个问题: R ...
分类:
其他好文 时间:
2016-11-11 11:44:10
阅读次数:
161
Broker:消息协商器。消息队列的实体,它在TCP/IP等端口上监听AMQ消息 vHost:虚拟主机。功能上类似于web的虚拟主机,都是把数据按照功能或项目的不同划分为不同的虚拟主机;用户只被授予访问虚拟主机的权限,而没有其他比这高级的访问控制措施。客户端与Broker沟通需要先建立连接,这些连接 ...
分类:
其他好文 时间:
2016-11-02 20:57:44
阅读次数:
158
原文:http://blog.csdn.net/lifetragedy/article/details/51869032 ActiveMQ的集群 内嵌代理所引发的问题: 消息过载 管理混乱 如何解决这些问题——集群的两种方式: Master slave Broker clusters ActiveM ...
分类:
其他好文 时间:
2016-11-01 13:52:02
阅读次数:
249
原文地址:http://www.jianshu.com/p/dc4770fc34b6 zookeeper集群搭建 kafka是通过zookeeper来管理集群。kafka软件包内虽然包括了一个简版的zookeeper,但是感觉功能有限。在生产环境下,建议还是直接下载官方zookeeper软件。 下载 ...
分类:
其他好文 时间:
2016-10-28 09:45:44
阅读次数:
275
单机运行 一、环境准备 Flume 1.6.0 Hadoop 2.6.0 Spark 1.6.0 Java version 1.8.0_73 Kafka 2.11-0.9.0.1 zookeeper 3.4.6 二、配置 spark和hadoop配置见() kafka和zookeeper使用默认配置 ...
分类:
其他好文 时间:
2016-10-26 20:25:10
阅读次数:
295
把一个数据恢复至另一个服务器上,出现了一个异常: The SQL Server Service Broker for the current database is not enabled, and as a result query notifications are not supported. ...
分类:
数据库 时间:
2016-10-24 23:54:18
阅读次数:
468
基于RabbitMQ的direct任务驱动异步RPC程序实现: RPC_dispatcher指令分发器: 1 #!/usr/bin/env python 2 # -*- coding:utf-8 -*- 3 __Author__ = "Zhang Xuyao" 4 5 import pika 6 i ...
分类:
编程语言 时间:
2016-10-21 10:19:33
阅读次数:
271
摘要: 从为什么我们需要消息系统(MQ)讲起,贯穿kafka架构、Producer发布消息、broker存储消息、Consumer消费消息以及 kafka HA等关键知识点,并附上实践中遇到的问题及解决方案。持续更新中…… ...
分类:
其他好文 时间:
2016-10-13 02:31:13
阅读次数:
248