`
文章列表
      今天尝试自己写了一个map-reduce程序,感觉不错.程序完成的是wordcount的功能,代码贴出来纪念一下: package com.wjy.hadoop; import java.io.IOException; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.conf.Configured; import org.apache.hadoop.fs.Path; import org.apache.hadoop.io.IntWritable; import org. ...
      最近在看ZK(ZooKeeper)的源码,发现源码中用到了Properties类加载配置信息,所以小研究一下:       .properties文件是一行一行以等号分割的键值对,允许有多余的空格(所以经常取出来要用String的trim方法去除首尾多余的空格)。        下面看个例子就行了,Properties类的使用很简单: InputStream inStream; try { inStream = new FileInputStream(new File("./file/test.properties")); Pr ...
        我们来看看,利用ZK实现分布式锁和实现实时更新server列表的功能的例子,转自:                      http://coolxing.iteye.com/blog/1871630                      http://coolxing.iteye.com/blog/1871520 **************************************以下为转载******************************** 分布式锁: 场景描述      在分布式应用, 往往存在多个进程提供同一服务. 这些进程有可能 ...
      最近在大量看有关ZooKeeper的博客,有关Zookeeper配置和Java的Api的博客发现了两篇,特此转载于此。向原作者致敬。        转自:                        http://coolxing.iteye.com/blog/1871009                        http://coolxing.iteye.com/blog/1871347 ZK的安装和配置:     Zookeeper的安装和配置十分简单, 既可以配置成单机模式, 也可以配置成集群模式. 下面将分别进行介绍. 单机模式 点击这里下载zoo ...
     下面列举一些,ZooKeeper的命令操作实例:   连接server bin/zkCli.sh -server 10.1.39.43:4180   列出指定node的子node [zk: 10.1.39.43:4180(CONNECTED) 9] ls /   [hello, filesync, zookeeper, xing, server, 
    Watch的注意事项:   1.Watches通知是一次性的,必须重复注册. 2.同一个ZK客户端,反复对同一个ZK节点(znode)注册相同的watcher,是无效的,最终只会有一个生效。 3.发生CONNECTIONLOSS之后,只要在session_timeout之内再次连接上 ...
      我想了想,还是决定将那篇讲ZAB协议的文章转载过来,ZK中提交事务采用的就是ZAB协议。       转自:http://blog.csdn.net/m_vptr/article/details/9325405 建议还是看原文,我转载到这里利于我查看。向原作者致敬。 ps:个人感觉原博客的一张图画错了,就是那张Leader和Follower的通信图。个人感觉Commit应该是从Leader指向Follower的。   ******************************原文如下************************************     ...
     今天发现了一篇超级好的入门zookeeper的博客,是超级好。讲的很清晰,导致我忍不住想把它转过来收藏起来。       这篇博客是IBM Developer Works社区上的,属于ZK的入门帖子。但是讲的很清晰,看来学计算机英语好是很重要的,英语好的话可以多阅读一些apache的官方文档,对ZK的理解也会更深刻。下来我把这篇博客转载过来,原博客地址: http://www.ibm.com/developerworks/cn/opensource/os-cn-zookeeper/ 原文如下: (建议还是看原文,我转载到我这里方便我查看,向原作者致敬)   //*** ...
    最近在看Zookeeper的源码,发现有很多包名中有“jute”的字符,查了一下,原来是这样的:  1. 在看ZooKeepr的实现是,发现了有几个包缺失了(e.g. data, proto)。以为是code下载错了,后来发现,其实这些包的code都是由Jute ...
声明:用到的所有安装包,我回上传到网盘,博客尾部给出下载地址.   1.首先,我们应该在ubutun上安装jdk: Step1: # 将解压好的jdk1.8.0_05文件夹用最高权限复制到/usr/lib/jvm目录里 sudo cp -r ~/jdk1.8.0_05/ /usr/lib/jvm/jdk1.8.0_05 Step2: # 配置环境变量 sudo gedit ~/.profile 在末尾加上: export JAVA_HOME=/usr/lib/jvm/jdk1.8.0_05 然后保存关闭,使用source更新下 $ source ~/.prof ...
       最近在写《Java解惑》的读后感,本来想写在一篇博客里,发现内容太多写不下了,所以分了一个上下部分。 上部分:http://wjy320.iteye.com/blog/2069408        此内容也是持续更新,我看一点写一点:
       最近因为某种需要,正在学习JavaScript。选了一本书是O'REILLY出的叫<<JavaScript学习指南>>。感觉书很不错,看书过程中有些小问题我会记下来,所以这篇博客会持续更新。         1.  var strValue="4"+3+1;       //结果是“431”,+操作符也被重载了。            var strValueTwo=4+3+"1";     //结果为“71”,和java一样,先执行了+。    var firstResult="35" ...
      最近在看《JAVA解惑》,看到移位操作符这一块感觉比较陌生,特意写一篇博客记录一下。        由于int型数值占4个字节,所以它是2的32次方。由于32是2的5次方。而对于long型数值占8个字节,所以是2的64次方。由于64 ...
      转自:http://blog.csdn.net/allanking666/article/details/5020864                     第1个异常是java.net.BindException:Address already in use: JVM_Bind。该异常发生在服务器端进行new ServerSocket(port)(port是一个0,65536的整型值)操作时。异常的原因是以为与port一样的一个端口已经被启动,并进行监听。此时用netstat –an命令,可以看到一个Listending状态的端口。只需要找一个没有被占用的端口就能解决这 ...
String.length() 返回字符串的字符个数,一个中文算一个字符; String.getBytes().length 返回字符串的字节长度,一个中文两个字节; String的getBytes()方法是得到一个字串的字节数组,这是众所周知的。但特别要注意的是,本方法将返回该操作系统默认的编码格式的字节数组。如果你在使用这个方法时不考虑到这一点,你会发现在一个平台上运行良好的系统,放到另外一台机器后会产生意想不到的问题。比如下面的程序: class TestCharset {     public static void main(String[] args)     {    ...
Global site tag (gtag.js) - Google Analytics