Master-Slave： 读写分离，save复制master的数据。同步复制：保证了强一致性但是会影响高可用性，因为写入的时候要保证slave都写入了才能返回告诉生产者数据写入成功，如果slave过多就是时间过长。异步复制：数据写入master之后不要求所有的slave都写入就返回生产者写入成功，... ...
分类：
其他好文 时间：
2018-01-21 17:31:37
阅读次数：
146
1，简介 RabbitMQ（Rabbit Message Queue）是流行的开源消息队列系统，用erlang语言开发。 1.1关键词说明： Broker：消息队列服务器实体。Exchange：消息交换机，它指定消息按什么规则，路由到哪个队列。Queue：消息队列载体，每个消息都会被投入到一个或多个 ...
分类：
编程语言 时间：
2018-01-21 00:09:12
阅读次数：
185
kafka架构： 生产者，消费者，Broker（接收生产者消息，给消费者订阅，），ZooKeeper（不是kafka的一部分，只是要使用ZooKeeper）。 Broker和ZooKeeper作为后台服务，生产者,消费者作为sdk，可以通过生产者的sdk发送数据给Broker，通过消费者的sdk从B... ...
分类：
其他好文 时间：
2018-01-19 21:29:44
阅读次数：
133
OffsetManager主要提供对offset的保存和读取，每个broker都有一个OffsetManager实例，kafka管理topic的偏移量有2种方式： 1、ZookeeperOffsetManager：调用zookeeper来存储和接收offset Consumer offset:/co ...
分类：
其他好文 时间：
2018-01-18 19:33:44
阅读次数：
410
架构： celery:分布式异步消息任务队列，一般使用rabbitmq或者redis做broker,分发任务 mongoDB:存储任务信息，存储测量结果.可视化链接工具 robo3t. RabbitMQ:消息队列 SQLite:持久化定时任务 tornado:异步，非阻塞web框架。 ...
分类：
其他好文 时间：
2018-01-17 00:25:55
阅读次数：
154
需求：? 阿里云ECS服务器上部署了Kafka伪集群，要求内网其他机器访问时broker走内网网卡，外部用户访问均走公网网卡IP：? 内网：10.130.10.10? ? ? ? ? ?外网：12.12.12.12解决方法：? ? ???
??&nb
分类：
其他好文 时间：
2018-01-16 18:01:39
阅读次数：
241
测试环境：系统:CentOS6.5x86_64JDK:javaversion1.8.0_121kafka:kafka_2.11-1.0.0.tgzzookeeper:3.4.5ip:192.168.49.161（我这里在一台机上部署整套环境）kafka名词解析：Broker:Kafka集群包含一个或多个服务器，这种服务器被称为brokerTopic:每条发布到Kafka集群的消息都有一个类别，这个
分类：
其他好文 时间：
2018-01-15 16:41:10
阅读次数：
1179
历史介绍部分： 远程调用大致经过了corba、webservice、二进制跟restful四个阶段 corba时代，corba(Common Object Request Broker Architecture，通用对象请求代理架构)算是公认的所有远程调用的鼻祖，是由OMG(object mange ...
分类：
其他好文 时间：
2018-01-13 20:58:40
阅读次数：
176
apollo 10.110.20.16 root XnlzeNP2 /var/lib/apache-apollo-1.7.1 1 创建broker 进入 bin 创建 broker /bin/apollo create apollo 2 启动server 进入 mybroker/bin/apollo ...
分类：
其他好文 时间：
2018-01-13 11:13:36
阅读次数：
143
1.定义： Celery是一个异步的任务队列（也叫做分布式任务队列） 2.工作结构 Celery分为3个部分 （1）worker部分负责任务的处理，即工作进程（我的理解工作进程就是你写的python代码，当然还包括python调用系统工具功能） （2）broker部分负责任务消息的分发以及任务结果的 ...
分类：
其他好文 时间：
2018-01-07 00:40:32
阅读次数：
252
