1，mr代码如下package com.test.hadoop; import java.io.IOException; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.fs.Path; import org.apache.hadoop.io.NullWritable; import org.apache.hadoop.io.Text; import org.apache.hadoop.mapreduce.Job; import org.apache.hadoop.mapreduce.Mapper; import org.apache.hadoop.mapreduce.Reducer; import org.apache.hadoop.mapreduce.lib.input.FileInputFormat; import org.apache.hadoop.mapreduce.lib.output.FileOutputFormat; import org.apache.orc.TypeDescription; import org.apache.orc.mapred.OrcStruct; import org.apache.orc.mapreduce.OrcInputFormat; im ...继续阅读 (82)

1，下载svn co http://code.taobao.org/p/datax2，安装根据服务器安装软件情况可能需要安装下面软件yum install antyum install gcc-c++进入rpm目录编译cd datax/trunk/rpmrpmbuild --ba t_dp_datax_engine.specrpmbuild --ba  t_dp_datax_hdfsreader.specrpmbuild --ba  t_dp_datax_hdfswriter.specrpmbuild --ba  t_dp_datax_mysqlreader.specrpmbuild --ba  t_dp_datax_mysqlwriter.spec如果编译过程中有错误还需要修改下源码，修改如下内容，再编译成功后输出路径中有：..../root/rpmbuild/RPMS/noarch/t_dp_datax_mysqlreader-1.0.0-1.noarch.rpm依次安装编译好的rpm包....rpm -ivh /root/rpmbuild/RPMS/noarch/t_dp_datax_mysqlreader-1.0.0-1.noarch.rpm3,使用，安装好engine和要用到的插件后就可以使用了例如，从hdfs->mysql编 ...继续阅读 (66)

一．系统吞度量要素：  一个系统的吞度量（承压能力）与request对CPU的消耗、外部接口、IO等等紧密关联。单个reqeust 对CPU消耗越高，外部系统接口、IO影响速度越慢，系统吞吐能力越低，反之越高。系统吞吐量几个重要参数：QPS（TPS）、并发数、响应时间        QPS（TPS）：每秒钟request/事务 数量        并发数： 系统同时处理的request/事务数        响应时间： 一般取平均响应时间（很多人经常会把并发数和TPS理解混淆）理解了上面三个要素的意义之后，就能推算出它们之间的关系：QPS（TPS）= 并发数/平均响应时间        一个系统吞吐量通常由QPS（TPS）、并发数两个因素决定，每套系统这两个值都有一个相对极限值，在应用场景访问压力下，只要某一项达到系统最高值，系统的吞吐量就上不去了，如果压力继续增大，系统的吞吐量反而会下降，原因是系统超负荷工作，上下文切换、内存等等其它消耗导致系统 ...继续阅读 (10)

1，一行转多行      url列以分号分隔，将其一行转化为多行，借助自增长表help_topic 实现。select a.channel_id,channel_code,site_name,siteid,refer_channel,substring_index(substring_index(a.url,';',b.help_topic_id+1),';',-1) as urls from  t_channel_mapping a join mysql.help_topic b on (length(a.url) - length(replace(a.url,';',''))+1) > b.help_topic_id; 2，多行转一行     分组后汇总成一行，orderid以逗号分隔  select SiteID,group_concat(distinct cast(orderid as char(8))) as orderid from  site_order3，Mysql实现rownumber    mysql是不支持r ...继续阅读 (23)

1,选择两台服务器2,安装redis     wget http://download.redis.io/releases/redis-2.8.12.tar.gz     tar -xvf redis-2.8.12.tar.gz      cd  redis-2.8.12     make3，配置   vi redis.conf   主修改    daemonize yes    bind 192.168.1.1    requirepass 123456   slave节点修改    daemonize yes    bind 192.168.1.2  slaveof 192.168.1.1 6379  masterauth 1234564，启动主次节点  主次节点分别执行  src/redis-server redis.conf 5,验证 连接主节点  src/redis-cli -h ...继续阅读 (48)

   ORCfile format，它的全名是Optimized Row Columnar (ORC)  file format。使用ORC文件格式提升Hive读、写与处理数据的性能。    存储方式为数据按行分块，每块按照列存储     压缩快 快速列存取     效率比rcfile高,是rcfile的改良版本    具体可以参考官网：     https://cwiki.apache.org/confluence/display/Hive/LanguageManual+ORC ...继续阅读 (161)

1，R语言支持很多画图功能，现对饼状图尝试一下，可以定义一个pie.R文件内容如下ShowPie <- function(){x=c(1,2,4)pie(x, labels=c('a','b','c'),col = c('blue','red','green'),main='蛋糕分配')}命令行模式下调用2 当然也可以通过丰富的外部包来画图，例如venneuler安装venneuler包install.packages("venneuler")选择china镜像#载入venneuler包library(venneuler)vd <- venneuler(c(A=0.3, B=0.3, C=1.1, "A&B"=0.1, "A&C"=0.2, "B&C"=0.1 ,"A&B&C"=0.1)) plot(vd)# same as c(A=1, `A&B&C`=1, C=1) m <- data.frame(elements=c("1","2","2","2","3"), sets=c("A",&q ...继续阅读 (8)

R拥有许多用于存储数据的对象类型，包括标量、向量、矩阵、数组、数据框和列表1 标量标量是只含一个元素的向量，例如a<- 3、b <- "US"和c <- TRUE。它们用于保存常量2 向量R中的向量可以理解为一维的数组，每个元素的mode必须相同.函数c，是组合函数,可以用创建数组，如x <- c(10:19)b <- c("one", "two", "three")x[2] 访问数组中第2个元素。这里没有下标，从 1 开始计算距离x[c(2:4)] 访问数组中第2到4个元素x[c(2,4)] 访问数组中第2个和第4个元素3 矩阵  可以理解为二维数组，每一个元素必须要有相同的mode，使用matrix进行创建，matrix的形式为：matrix(data = NA, nrow = 1, ncol = 1, byrow = FALSE, dimnames = NULL)该函数中，vector中为矩阵的元素，nrow表示行数，ncol表示列数，byrow为一个布尔向量表示是否按照行为主进行填充，默认按照列为主，dimnames为可选的制定行和列的名称。mdat <- matrix(c(1,2,3, 11,12,13), nro ...继续阅读 (6)

1 R是一种统计绘图语言，也指实现该语言的软件2根据平台下载安装R 环境https://www.r-project.org/3 安装完成后，在安装目录的bin目录下运行Rgui.exe4 常用命令  install.pacakages("程序包") 安装某程序包  help("函数")   ?(函数) 获得帮助页面  y<- c(1,3,5,7,9) 定义一个向量  <-赋值，也可用=代替 ls() 显示内存中的所有对象 rm(对象) 删除内存中的对象1:4     #冒号是一种运算符，可以产生序列。[1] 1 2 3 4":"(1, 4)    #与1:4是等价的，用引号引起来，是一种函数名5:1 #结果：[1] 5 4 3 2 1创建矩阵x<-1:12dim(x)=c(3,4)mean(x)求x均值mode(x)返回x对象类型sort()排序 sum()求和 max()最大...5 基本的演练过程 ...继续阅读 (43)

      ImageMagick是一个免费的创建、编辑、合成图片的软件。它可以读取、转换、写入多种格式的图片。图片切割、颜色替换、各种效果的应用，图片的旋转、组合，文本，直线，多边形，椭圆，曲线，附加到图片伸展旋转官网描述 http://www.imagemagick.org/script/index.php        ImageMagick® is a software suite to create, edit, compose, or convert bitmap images. It can read and write images in a variety of formats (over 200) including PNG, JPEG, JPEG-2000, GIF, TIFF,DPX, EXR, WebP, Postscript, PDF, and SVG. Use ImageMagick to resize, flip, mirror, rotate, distort, shear and transform images, adjust image colors, apply various special effects, o ...继续阅读 (44)

1 选择两个服务器，分别作为主备数据库2 登陆到服务器， yum install mysql ; yum install mysql-server;3 启动服务器 service  mysqld start4 分别root登陆mysql 执行如下命令，增加复制用户并授权（主备都在192.168.119.*网段，为了方便主备切换，两边都建立）GRANT  REPLICATION SLAVE,REPLICATION CLIENT on *.* to repl@'192.168.119.%' identified by '1234';5 配置/etc/my.cnf第一服务器（主）log_bin=mysql_binserver_id=1第二个服务器（备）log_bin=mysql_binserver_id=2read_only=16 登陆主（root）执行show master status\G;显示File: mysql-bin.000001 Position: 106登陆备(root) 执行测试 mysql -urepl -h192.168.119.128 -p1234 是否能连接到主库，不能需要检查防火墙或者/etc/my.cnf是否有访问限制，修改配置mysql -uroot登陆本地库执行：CHANGE MASTER TO ...继续阅读 (49)

jama是一个基本的线性代数java包，它提供了实数非稀疏矩阵类，程序员可构造操控这些类。对于经常使用到矩阵运算的码农来说，即使不精通线性代数也没有关系，因为jama包提供的功能已经够用，调用方便，使用自然，而且易于理解。 JAMA功能汇总Jama.Matrix 对象操作 构造函数 set 方法 set(int i, int j, double s) get 方法 get(int i, int j) getArray() 拷贝方法 copy() 克隆方法 clone()矩阵元素级别的操作 矩阵加法 plus(Matrix B) 矩阵减法 minus(Matrix B) 矩阵乘法 times(Matrix B) 放大缩小 元素乘法 arrayTimesEquals(Matrix B) 元素除法 arrayLeftDivide(Matrix B) 求反 uminus() 倒置 transpose() 范式 norm()矩阵分解 Cholesky chol() LU lu() ...继续阅读 (52)

ALTER TABLE table1 DROP PARTITION (day='2015-07-14');ALTER TABLE table1 ADD COLUMNS (visit int); reflect("java.net.URLDecoder", "decode", url,"UTF-8")CASE WHEN b.user_account is null then 0 else b.user_account end ...继续阅读 (26)

Tornado是FriendFeed使用的可扩展的非阻塞式 web 服务器及其相关工具的开源版本。http://www.tornadoweb.cn/Fabric是一个Python库，可以通过SSH在多个host上批量执行任务。你可以编写任务脚本，然后通过Fabric在本地就可以使用SSH在大量远程服务器上自动运行。这些功能非常适合应用的自动化部署，或者执行系统管理任务。http://www.fabfile.org/ ...继续阅读 (51)

高性能web架构，动静分离，静态缓存。使用LVS实现4层负载均衡，使用KeepAlived实现LVS的HA和其他服务的HA，使用Nginx实现7层负载均衡，使用Squid实现caching proxy。nginx和squid作为服务，可以在前接嵌入lvs和keepalived。这是一个可嵌套的结构，只要你服务器足够，业务也有这个必要。高性能web架构，高性能缓存，squid不仅缓存静态资源还可以缓存动态请求，nginx实现负载均衡或者web服务：具体还需要根据业务规模特性的需要调整结构，具体配置需要google,配置好后可以通过webbench工具测试性能。webbench -c 500 -t 30http://127.0.0.1/test.jpg参数说明：-c表示并发数，-t表示时间(秒) ...继续阅读 (24)

一．系统吞度量要素：一个系统的吞度量（承压能力）与request对CPU的消耗、外部接口、IO等等紧密关联。单个reqeust 对CPU消耗越高，外部系统接口、IO影响速度越慢，系统吞吐能力越低，反之越高。系统吞吐量几个重要参数：QPS（TPS）、并发数、响应时间QPS（TPS）：每秒钟request/事务 数量并发数：系统同时处理的request/事务数响应时间：一般取平均响应时间（很多人经常会把并发数和TPS理解混淆）理解了上面三个要素的意义之后，就能推算出它们之间的关系：QPS（TPS）= 并发数/平均响应时间一个系统吞吐量通常由QPS（TPS）、并发数两个因素决定，每套系统这两个值都有一个相对极限值，在应用场景访问压力下，只要某一项达到系统最高值，系统的吞吐量就上不去了，如果压力继续增大，系统的吞吐量反而会下降，原因是系统超负荷工作，上下文切换、内存等等其它消耗导致系统性能下降。决定系统响应时间要素我们做项目要排计划，可以多人同时并发做多项任务，也可以一个人或者多个人串行工作，始终会有一条关键路径，这条路径就是项目的工期。系统一次调用的响应时间跟项目计划一样，也有一条关键路径，这个关键路径是就是系统影响时间；关键路径是有CPU运算、IO、外部系统响应等等组成。二．系统吞吐量评估：我们在做系统设计的时候就需要考虑CPU运算、IO、外部系统响应因素造成的影响以及对系统性能的初步 ...继续阅读 (34)

判断一个二维坐标点是否在一个多边形范围框内，首先给出范围框各顶点的坐标（按顺时针方向给出），分别放到两个数组中再比较大小范围从而判定点是否在多边形返回框中code如下：public class RangePoint { double[] x_points; double[] y_points; public RangePoint(){} public RangePoint(double[] x_points,double[] y_points) { this.x_points = x_points; this.y_points = y_points; } public boolean RangeMatch(double x, double y) { int j = x_points.length - 1; boolean odd_nodes = false; for (int i = 0; i < x_points.length; i++){ if (((y_points[i] < y && y_points[j] >= y) || (y_points[j] < y && y_points[i] >= y)) && (x_points[i] <= x || x_p ...继续阅读 (26)

权重随机算法在抽奖，资源调度等系统中应用还是比较广泛的，一个简单的按照权重来随机的实现，权重为几个随机对象(分类)的命中的比例，权重设置越高命中越容易，之和可以不等于100；简单实现代码如下：import java.util.ArrayList; import java.util.List; import java.util.Random; public class WeightRandom { static Listcategorys = new ArrayList(); private static Random random = new Random(); public static void initData() { WeightCategory wc1 = new WeightCategory("A",60); WeightCategory wc2 = new WeightCategory("B",20); WeightCategory wc3 = new WeightCategory("C",20); categorys.add(wc1); categorys.add(wc2); categorys.add(wc3); } public static void main(String[] args) { initData ...继续阅读 (28)

下面将讲解进程间通信的另一种方式，使用共享内存。一、什么是共享内存顾名思义，共享内存就是允许两个不相关的进程访问同一个逻辑内存。共享内存是在两个正在运行的进程之间共享和传递数据的一种非常有效的方式。不同进程之间共享的内存通常安排为同一段物理内存。进程可以将同一段共享内存连接到它们自己的地址空间中，所有进程都可以访问共享内存中的地址，就好像它们是由用C语言函数malloc分配的内存一样。而如果某个进程向共享内存写入数据，所做的改动将立即影响到可以访问同一段共享内存的任何其他进程。特别提醒：共享内存并未提供同步机制，也就是说，在第一个进程结束对共享内存的写操作之前，并无自动机制可以阻止第二个进程开始对它进行读取。所以我们通常需要用其他的机制来同步对共享内存的访问，例如前面说到的信号量。有关信号量的更多内容，可以查阅我的另一篇文章：Linux进程间通信——使用信号量二、共享内存的使得与信号量一样，在Linux中也提供了一组函数接口用于使用共享内存，而且使用共享共存的接口还与信号量的非常相似，而且比使用信号量的接口来得简单。它们声明在头文件 sys/shm.h中。1、shmget函数该函数用来创建共享内存，它的原型为：[cpp]view plaincopyprint?intshmget(key_t key,size_tsize,intshmflg);第一个参数，与信号量的semget函数一 ...继续阅读 (24)

转自：http://www.cnblogs.com/tommyli/p/3201047.htmlext3，ext4，xfs和btrfs文件系统性能对比应为原文：http://www.ilsistemista.net/index.php/linux-a-unix/6-linux-filesystems-benchmarked-ext3-vs-ext4-vs-xfs-vs-btrfs.html?start=1还有一篇相关介绍：http://www.phoronix.com/scan.php?page=article&item;=ext4_benchmarks#=2另一篇：http://tetralet.luna.com.tw/index.php?op=ViewArticle&articleId;=214&blogId;=1我这里只摘抄核心的图例哈。1：单字节写入性能对比A：由于硬盘式块设备所以对于这种测试硬盘式不擅长的B：btrfs系统只有200K/SEC,xfs表现的性能比较平衡。2：块写入性能对比（由于硬盘是块设备这种对比来的更有意义）A：性能上差不多，但是效率上（CPU占用率上）来说最好的是xfs接下来依次是EXT4，EXT3，BTRFS3：直接块顺序读写（关掉任何的系统和文件缓存）A：绕过系统和文件缓冲的话（例如：视频录制，一些虚拟机软件，ECC），EXT3/ 4是最好 ...继续阅读 (78)

lsof（list open files）是一个列出当前系统打开文件的工具。 lsof -i 4 #列举出IP V4 lsof -i tcp 列出所有TCP网络连接 lsof -i 列出所有网络连接 lsof -i:80 #查看一下80端口的进程 lsof -i udp:53 #查看 一下udp,53端口 lsof -u zhangy 列出某个用户打开的所有文件 lsof /usr/sbin/httpd 找出谁在使用某个文件 lsof -p 3738 列出所有由某个PID对应的进程打开的文件 ps -ef #显示所有进程的UID,PPIP,C与STIME栏位ps -Lef 查看线程 ps aux #不区分终端，显示所有用户的所有进程 ps -u hadoop #显示hadoop用户的所有进程 uname -a #显示系统信息 uname -m #显示系统类型，一般情况下，i386,i686是32位系统，X86，X86_64是64位系统 uname -s, --kernel-name 输出内核名称 hostname #显示主机名 hostname apple #设置主机名称 编辑/etc/sysconfig/network永久设置主机名 mount /dev/sda1 /media/u ...继续阅读 (33)

互联网行业瞬息万变，产品层出不穷，在移动互联网盛行的今天，一款互联网产品诞生变得更加容易。一款互联网产品到底是以快制胜还是精品制胜呢？每个人的理解不同，答案也不尽相同，市场运营人员可能更关注市场占有率，所以出产品一定要快，一个产品的孵化过程太长，很可能失去占领市场的机会，而被其他公司先打入市场，错失互联网行业先入为主的优势。技术产品人员可能更关注产品的细节，能不能做出一个精品往往是他们更加关注的问题，他们不希望自己辛苦打造的产品上线后只是昙花一现。公司领导决策层可能关注这个产品的意义，这个产品对公司的发展有什么推动作用，能带来用户吸引流量？提高公司品牌？还是能直接带来商机。其实仅仅站在各种人的角色上考虑这个问题貌似有点局限和狭隘。站在行业的角度上，看看互联网最近比较火的产品脸萌，2048..，貌似又该说有好的创意产品就能成功。这样说貌似也有些片面,在这两款产品之前类似产品某某头像，Threes等产品也没有火起来，貌似以快制胜也不一定能成功。我很赞同一句话，好的创意并一定使一款产品成功，真正使一款产品成功的是对产品创意的执行力和对市场的理解力。没有一款产品是长生不老，尤其在产品快速迭代的互联网行业，要想让产品或企业成为常青树，你要做的不仅仅是让树儿快快长大，更重要是修剪，浇水，施肥。 ...继续阅读 (21)

public class EvilTransform { final static double pi = 3.14159265358979324; // // // a = 6378245.0, 1/f = 298.3 // b = a * (1 - f) // ee = (a^2 - b^2) / a^2; final static double a = 6378245.0; final static double ee = 0.00669342162296594323; // // World Geodetic System ==> Mars Geodetic System public static double[] transform(double wgLat, double wgLon) { double mgLat=0; double mgLon=0; if (outOfChina(wgLat, wgLon)) { mgLat = wgLat; mgLon = wgLon; }else{ double dLat = tran ...继续阅读 (34)

什么是FastCGI，google吧，测试一个用C++实现的FastCGI程序。1, Nginx 安装，http://nginx.org/en/download.html.下载解压，configure,make ,make install.安装过程中确实包，需要先下载安装依赖包2，安装lighttpd的spawn-fastcgi下载http://www.lighttpd.net/download/lighttpd-1.4.19.tar.gz./configuremakemake installcp ./src/spawn-fcgi /usr/local/nginx/sbin3,安装fastcgi库下载http://www.fastcgi.com/dist/fcgi.tar.gz./configuremakemake install安装过程中缺少库，需要现在安装依赖库4，Helloworld.cpp#include#includeusing namespace std;int main(){int count = 0;while (FCGI_Accept() >= 0){FCGI_printf("Content-type: text/*\r\n\r\n");FCGI_printf("FastCGI Hello! Request number %d \n",++count);}}5,编 ...继续阅读 (13)

代码如下：其中s（x_point_s,y_point_s）,e(x_point_e,y_point_e)为两点魔卡托坐标：def calc_angle(x_point_s,y_point_s,x_point_e,y_point_e):angle=0y_se= y_point_e-y_point_s;x_se= x_point_e-x_point_s;if x_se==0 and y_se>0:angle = 360if x_se==0 and y_se<0:angle = 180if y_se==0 and x_se>0:angle = 90if y_se==0 and x_se<0:angle = 270if x_se>0 and y_se>0:angle = math.atan(x_se/y_se)*180/math.pielif x_se<0 and y_se>0:angle = 360 + math.atan(x_se/y_se)*180/math.pielif x_se<0 and y_se<0:angle = 180 + math.atan(x_se/y_se)*180/math.pielif x_se>0 and y_se<0:angle = 180 + math.atan(x_se/y_se)*180/math.pireturn angle ...继续阅读 (22)

1.ll /dev/sd* 查看硬盘设备看到/dev/sdb12,例如挂载/data1盘，根目录下创建/data1目录编辑/etc/fstab追加如下/dev/sdb1 /data1 ext3 noatime,acl,user_xattr 1 23,执行mount -a4，df -h 或者cat /proc/mounts查看挂载情况格式化mkfs -t ext3 -c /dev/sdg挂载单个磁盘mount -t ext3 /dev/sdg /data6卸载umount -v /dev/sdg通过设备名卸载umount -v /data6 通过挂载点卸载umount -l /data6 强制卸载 ...继续阅读 (19)

添加运行时共享库目录运行使用共享库的程序需要加载共享库（不同于G++ 编译时指定的链接库），添加共享库的步骤：修改文件 /etc/ld.so.conf 添加共享库目录运行 ldconfig 同步更新一下如：1gedit /etc/ld.so.conf2#添加 /root/dreamlove/lib3ldconfig添加include，lib的搜寻路径对所有用户有效修改/etc/profile对个人有效则修改~/.bashrc#在PATH中找到可执行文件程序的路径。 export PATH =$PATH:$HOME/bin#gcc找到头文件的路径 C_INCLUDE_PATH=/usr/include/libxml2:/MyLib export C_INCLUDE_PATH#g++找到头文件的路径 CPLUS_INCLUDE_PATH=$CPLUS_INCLUDE_PATH:/usr/include/libxml2:/MyLib export CPLUS_INCLUDE_PATH#找到动态链接库的路径 LD_LIBRARY_PATH=$LD_LIBRARY_PATH:/MyLib export LD_LIBRARY_PATH#找到静态库的路径 LIBRARY_PATH=$LIBRARY_PATH:/MyLib export LIBRARY_PATH使用source，加载这些定义使其立 ...继续阅读 (26)

1，下载0.9.0.1 http://storm.incubator.apache.org/downloads.html2，安装就jdk,python,zookeeper 在服务器 "192.168.1.1" "192.168.1.1""192.168.1.2"上3，解压，修改conf下的storm.yamlstorm.zookeeper.servers: - "192.168.1.1" - "192.168.1.2" - "192.168.1.3" nimbus.host: "192.168.1.10" storm.local.dir: "/data/storm/work" supervisor.slots.ports: - 6700 - 6701 - 6702 - 6703 storm.messaging.transport: "backtype.storm.messaging.netty.Context" storm.messaging.netty.buffer_size: 209715200 storm.messaging.netty.max_retries: 100 storm.messaging.netty.max_wait_ms: 1000 storm.messagin ...继续阅读 (30)

Storm 0.9的源码接口解释：IBoltpackage backtype.storm.task;public interface IBolt extends Serializable接收tuple作为输入，输出tuple，可以用来作过滤，连结，聚合等。IBolt提交到Nimbus后，Nimbus将作业发送到worker后，每个task初始化时都会调用prepare。TopologyContextpackage backtype.storm.task;public class TopologyContext extends WorkerTopologyContext implements IMetricsContextTopologyContext向bolts 和spouts 提供”prepare” and ”open” 方法。 TopologyContext提供了组件的各种信息，流的信息，task的信息等。ShellSpout/ShellBoltpackage backtype.storm.task;public class ShellSpout implements ISpoutpackage backtype.storm.spout;public class ShellBolt implements IBoltStorm可以用其它语言来实现Spout和Bolt的功能，如Py ...继续阅读 (493)

1，ZooKeeper集群安装，自己搜索安装2，下载https://github.com/killme2008/Metamorphosis/tree/metamorphosis-all-1.4.6.2，如果不想自己编译可以直接下载http://fnil.net/downloads/index.html，我这里选择自己编译，主要是以后如果出现问题自己可以修改其源码，重新编译3，maven编译,maven环境自己搜索配置好，下载all项目后需要编译其子项目metamorphosis-server-wrapper。dos环境进入其目录下mvn eclipse:eclipse，完成后导入到eclipse,用eclipse插件编译。或者直接dos该目录下执行mvn clean install-Dmaven.test.skip=true。完成后target目录下生产其jar包；可以在工程创建lib文件夹，输入以下命令：mvn dependency:copy-dependencies -DoutputDirectory=lib （不加DoutputDirectory会默认输出到targed/dependency下）。再把install的jar包也copy到lib下。4，完成编译后上传到服务器需要修改conf/server.ini文件[system]brokerId=2numPartitions= ...继续阅读 (193)