1:Storm作为一个实时处理的框架,产生的消息需要快速的进行处理,比如存在消息队列ZeroMQ里面。 由于消息队列ZeroMQ是C++写的,而我们的程序是运行在JVM虚拟机里面的。所以需要jzmq这个桥梁来黏合C++程序接口和Java程序接口。
ZeroMQ的官方网址:http://zeromq.org/
1:MetaQ(全称Metamorphosis)是一个高性能、高可用、可扩展的分布式消息中间件,思路起源于LinkedIn的Kafka,但并不是Kafka的一个Copy。MetaQ具有消息存储顺序写、吞吐量大和支持本地和XA事务等特性,适用于大吞吐量、顺序消息、广播和日志数据传输等场景,目前在淘宝和支付宝有着广泛的应用。
2:MetaQ概念
Producer (消息生产者)
Consumer (消息消费者)
Topic (消息的主题)
Partition (分区)
Message (消息)
Broker (就是meta的服务端)
Group (消费者分组)
Offset (消息偏移量)
3:下载地址 http://fnil.net
GitHub地址 https://github.com/killme2008/Metamorphosis
2:ZeroMQ的安装过程如下所示(首先将zeromq-2.1.7.tar.gz上传到自己的虚拟机里面,过程省略):
然后进行解压缩操作,如下所示:
[root@slaver1 package]# tar -zxvf zeromq-2.1..tar.gz -C /home/hadoop/soft/
解压缩以后,由于解压缩以后是源码,所以需要编译,编译以后再进行安装操作:
然后使用此命令对编译环境进行检测:
[root@slaver1 zeromq-2.1.]# ./configure
然后出现如下错误,没有找到C++编译器,所以现在安装C++编译器:
checking for a BSD-compatible install... /usr/bin/install -c
checking whether build environment is sane... yes
checking for a thread-safe mkdir -p... /bin/mkdir -p
checking for gawk... gawk
checking whether make sets $(MAKE)... yes
checking how to create a ustar tar archive... gnutar
checking for gcc... gcc
checking whether the C compiler works... yes
checking for C compiler default output file name... a.out
checking for suffix of executables...
checking whether we are cross compiling... no
checking for suffix of object files... o
checking whether we are using the GNU C compiler... yes
checking whether gcc accepts -g... yes
checking for gcc option to accept ISO C89... none needed
checking for style of include used by make... GNU
checking dependency style of gcc... gcc3
checking for gcc option to accept ISO C99... -std=gnu99
checking for g++... no
checking for c++... no
checking for gpp... no
checking for aCC... no
checking for CC... no
checking for cxx... no
checking for cc++... no
checking for cl.exe... no
checking for FCC... no
checking for KCC... no
checking for RCC... no
checking for xlC_r... no
checking for xlC... no
checking whether we are using the GNU C++ compiler... no
checking whether g++ accepts -g... no
checking dependency style of g++... none
checking whether gcc -std=gnu99 and cc understand -c and -o together... yes
checking for a sed that does not truncate output... /bin/sed
checking for gawk... (cached) gawk
checking for xmlto... no
checking for asciidoc... no
checking build system type... i686-pc-linux-gnu
checking host system type... i686-pc-linux-gnu
checking for a sed that does not truncate output... (cached) /bin/sed
checking for grep that handles long lines and -e... /bin/grep
checking for egrep... /bin/grep -E
checking for fgrep... /bin/grep -F
checking for ld used by gcc -std=gnu99... /usr/bin/ld
checking if the linker (/usr/bin/ld) is GNU ld... yes
checking for BSD- or MS-compatible name lister (nm)... /usr/bin/nm -B
checking the name lister (/usr/bin/nm -B) interface... BSD nm
checking whether ln -s works... yes
checking the maximum length of command line arguments...
checking whether the shell understands some XSI constructs... yes
checking whether the shell understands "+="... yes
checking for /usr/bin/ld option to reload object files... -r
checking for objdump... objdump
checking how to recognize dependent libraries... pass_all
checking for ar... ar
checking for strip... strip
checking for ranlib... ranlib
checking command to parse /usr/bin/nm -B output from gcc -std=gnu99 object... ok
checking how to run the C preprocessor... gcc -std=gnu99 -E
checking for ANSI C header files... yes
checking for sys/types.h... yes
checking for sys/stat.h... yes
checking for stdlib.h... yes
checking for string.h... yes
checking for memory.h... yes
checking for strings.h... yes
checking for inttypes.h... yes
checking for stdint.h... yes
checking for unistd.h... yes
checking for dlfcn.h... yes
checking whether we are using the GNU C++ compiler... (cached) no
checking whether g++ accepts -g... (cached) no
checking dependency style of g++... (cached) none
checking for objdir... .libs
checking if gcc -std=gnu99 supports -fno-rtti -fno-exceptions... no
checking for gcc -std=gnu99 option to produce PIC... -fPIC -DPIC
checking if gcc -std=gnu99 PIC flag -fPIC -DPIC works... yes
checking if gcc -std=gnu99 static flag -static works... no
checking if gcc -std=gnu99 supports -c -o file.o... yes
checking if gcc -std=gnu99 supports -c -o file.o... (cached) yes
checking whether the gcc -std=gnu99 linker (/usr/bin/ld) supports shared libraries... yes
checking whether -lc should be explicitly linked in... no
checking dynamic linker characteristics... GNU/Linux ld.so
checking how to hardcode library paths into programs... immediate
checking whether stripping libraries is possible... yes
checking if libtool supports shared libraries... yes
checking whether to build shared libraries... yes
checking whether to build static libraries... yes
checking whether the C compiler works... yes
checking whether we are using Intel C compiler... no
checking whether we are using Sun Studio C compiler... no
checking whether we are using clang C compiler... no
checking whether we are using gcc >= C compiler... yes
checking whether the C++ compiler works... no
configure: error: Unable to find a working C++ compiler
安装C++编译器,如果有网络的话,可以使用yum进行安装,如果没有网络需要提前下载好,由于前段时间重装系统了,所有都是从头开始,你懂的,然后我的网络又坏了,日了狗了,我的问题是,本机可以ping通虚拟机,但是虚拟机ping不通本地,很显然就是DNS出现问题了,那么说一下我是如何解决的:
然后呢,配置一下自己的虚拟机的网络编辑器,本机NET模式的DNS和虚拟机的NET模式的DNS要一致:
可以上网的情况下:
[root@slaver1 hadoop]# yum install gcc-c++
离线安装如下所示:
rpm -i libstdc++-devel-4.4.-.el6.x86_64.rpm
rpm -i gcc-c++-4.4.-.el6.x86_64.rpm
rpm -i libuuid-devel-2.17.-12.9.el6.x86_64.rpm
然后呢,再去zeroMQ目录下面对编译环境进行检测:
[root@slaver1 zeromq-2.1.]# ./configure
然后呢,出现如下所示的问题,最后一行如下所示的问题,这是需要一些依赖,所以接下来解决这个问题:
configure: error: cannot link with -luuid, install uuid-dev.
手动安装这个依赖,解决问题,解决完问题再去ZeroMQ目录下面检测环境正常即可:
[root@slaver1 rpms-]# rpm -ivh libuuid-devel-2.17.-12.9.el6.i686.rpm
Preparing... ########################################### [%]
:libuuid-devel ########################################### [%]
如果正常,最后一行如下所示:
config.status: executing libtool commands
然后开始进行编译操作,如下所示,在ZeroMQ目录下面输入make命令,进行编译操作:
[root@slaver1 zeromq-2.1.]# make
编译以后进行安装,如下所示,在ZeroMQ目录下面输入make install命令,进行安装操作:
[root@slaver1 zeromq-2.1.]# make install
至此ZeroMQ安装结束,接下来安装 jzmq(Java调用C++的桥梁),如下所示:
[root@slaver1 package]# unzip jzmq-master.zip -d /home/hadoop/soft/
然后生成configure命令。操作如下所示,会提示你缺少libtool这个包,然后现在安装一下这个包:
[root@slaver1 jzmq-master]# ./autogen.sh
autogen.sh: error: could not find libtool. libtool is required to run autogen.sh.
然后呢,安装libtool出现的问题以及解决方法如下所示:
[root@slaver1 rpms-]# rpm -ivh libtool-2.2.-15.5.el6.i686.rpm
error: Failed dependencies:
autoconf >= 2.58 is needed by libtool-2.2.-15.5.el6.i686
automake >= 1.4 is needed by libtool-2.2.-15.5.el6.i686
[root@slaver1 rpms-]# rpm -ivh autoconf-2.63-5.1.el6.noarch.rpm
Preparing... ########################################### [%]
:autoconf ########################################### [%]
[root@slaver1 rpms-]# rpm -ivh automake-1.11.-.el6.noarch.rpm
Preparing... ########################################### [%]
:automake ########################################### [%]
[root@slaver1 rpms-]# rpm -ivh libtool-2.2.-15.5.el6.i686.rpm
Preparing... ########################################### [%]
:libtool ########################################### [%]
[root@slaver1 rpms-]#
然后呢,再去jzmq目录下面运行如下脚本生成configure命令:
[root@slaver1 jzmq-master]# ./autogen.sh
然后使用configure命令对编译环境进行检测:
[root@slaver1 jzmq-master]# ./configure
然后进行编译操作,如下所示:
[root@slaver1 jzmq-master]# make
然后进行安装操作,如下所示:
[root@slaver1 jzmq-master]# make install
3:由于Storm的脚本是Python写的,所以需要安装一下Python这个运行环境,又因为Centos6.4版本已经安装了python,所以就不需要进行安装了哦:
[root@slaver1 jzmq-master]# which python
/usr/bin/python
查看python的版本,如下所示:
[root@slaver1 jzmq-master]# python -V
Python 2.6.
4:然后呢,开始安装Storm,由于之前写过了,这里就不再叙述了;
待续......