RPC即远程过程调用，通过网络从远程计算机程序上请求服务。也就是说两台服务器A，B，一个应用部署在A服务器上，想要调用B服务器上应用提供的函数/方法，由于不在一个内存空间，不能直接调用，需要通过网络来表达调用的语义和传达…

接上篇文章，本文主要分析一下一个ZK集群从刚启动到对外提供服务这段时间发生了什么 一、执行流程概述 首先在ZK集群中，不管是什么类型的节点，刚刚启动时都是LOOKING状态然后发起选举寻找Leader，只有确定Leade…

CDH中Zookeeper启动失败 解决： 1、查看/var/lib/zookeeper中是否有的myid 2、对该目录赋权，chown zookeeper:zookeeper /var/lib/zookeeper 另外…

安装ZooKeeper包 [CDH下载地址]（http://archive.cloudera.com/cdh5/cdh/5/） 1、将课程提供的zookeeper-3.4.5-cdh5.3.6.tar.gz使用WinSC…

随着互联网系统规模的不断扩大，大数据时代飞速到来，越来越多的分布式系统将ZooKeeper作为核心组件使用。接下来一起看一下ZooKeeper究竟可以做哪些工作。 1、数据发布/订阅 数据发布/订阅系统，就是将数据发布到…

http://www.jeecg.org/ 1、javascript视频教程 链接: http://pan.baidu.com/s/1gd57FVH 密码: d9ei 2、JPA视频教程 链接: http://pan.b…

Kafka是一种高吞吐量的分布式发布订阅消息系统，它可以处理消费者规模的网站中的所有动作流数据。Kafka的目的是通过Hadoop的并行加载机制来统一线上和离线的消息处理，也是为了通过集群机来提供实时的消费。下面介绍有关…

配置 集群配置 3个Node 3个节点； cpu: 40c memory: 256G 带宽: 4G JVM配置 -Xmx30G -Xms30G -XX:MaxPermSize=48m -server -XX:+UseG1…

[Toc] 如何在kafka中创建topic 在使用kafka发送消息和消费消息之前，必须先要创建topic，在kafka中创建topic的方式有以下3种： 如果kafka broker中的config/server.p…

SDN分布式集群 修改后记得 maven clean install 分布式事务之2PC和3PC storm – 可靠机制 kafka 分布式消息系统：Kafka Kafka剖析（一）：Kafka背景及架构介…

分布式锁，在高并发场景下，集群中各机器之间只能有一个线程处理某个操作，这样和java同一进程下的锁，就不能解决了。就用到了不同机器之间的分布式锁。 package com.test; import java.io.IOE…

一、zookeeper有三个端口（可以修改）及作用 1、2181：对cline端提供服务 2、3888：选举leader使用 3、2888：集群内机器通讯使用（Leader监听此端口） 二、部署时注意 1、单机单实例，只…