在此之前我们使用MySQL作为数据源，但发现这数据增长速度太快，并且由于种种原因，因此必须使用HBase，所以我们要把Mysql表里面的数据迁移到HBase中，在这里我就不讲解、不争论为什么要使用HBase，HBase是什么了，喜欢的就认真看下去，总有些地方是有用的。

我们要做的3大步骤：

  1. 新建HBase表格。

  2. 把MYSQL数据迁移到HBase中。

  3. 在Java Web项目中读取HBase的数据。

先介绍一下必要的一些环境：HBase的版本：0.98.8-hadoop2

所需的依赖包：

[html] view plaincopyprint?
  1. commons-codec-1.7.jar
  2. commons-collections-3.2.1.jar
  3. commons-configuration-1.6.jar
  4. commons-lang-2.6.jar
  5. commons-logging-1.1.3.jar
  6. guava-12.0.1.jar
  7. hadoop-auth-2.5.0.jar
  8. hadoop-common-2.5.0.jar
  9. hbase-client-0.98.8-hadoop2.jar
  10. hbase-common-0.98.8-hadoop2.jar
  11. hbase-protocol-0.98.8-hadoop2.jar
  12. htrace-core-2.04.jar
  13. jackson-core-asl-1.9.13.jar
  14. jackson-mapper-asl-1.9.13.jar
  15. log4j-1.2.17.jar
  16. mysql-connector-java-5.1.7-bin.jar
  17. netty-3.6.6.Final.jar
  18. protobuf-java-2.5.0.jar
  19. slf4j-api-1.7.5.jar
  20. slf4j-log4j12-1.7.5.jar
  21. zookeeper-3.4.6.jar
commons-codec-1.7.jar
commons-collections-3.2.1.jar
commons-configuration-1.6.jar
commons-lang-2.6.jar
commons-logging-1.1.3.jar
guava-12.0.1.jar
hadoop-auth-2.5.0.jar
hadoop-common-2.5.0.jar
hbase-client-0.98.8-hadoop2.jar
hbase-common-0.98.8-hadoop2.jar
hbase-protocol-0.98.8-hadoop2.jar
htrace-core-2.04.jar
jackson-core-asl-1.9.13.jar
jackson-mapper-asl-1.9.13.jar
log4j-1.2.17.jar
mysql-connector-java-5.1.7-bin.jar
netty-3.6.6.Final.jar
protobuf-java-2.5.0.jar
slf4j-api-1.7.5.jar
slf4j-log4j12-1.7.5.jar
zookeeper-3.4.6.jar

如果在你的web项目中有些包已经存在，保留其中一个就好了，免得报奇怪的错误就麻烦了。

步骤1：建表

在此之前，我在Mysql中的业务数据表一共有6个，其结构重复性太高了，首先看看我在HBase里面的表结构：

表名 kpi                              
key fid+tid+date                              
簇(family) base gpower userate consum time                      
                                 
描述 基础信息 发电量相关指标 可利用率 自耗电量 累计运行小时数 检修小时数 利用小时数                  
列(qualifier) fid tid date power windspeed unpower theory coup time power num cpower gpower runtime checktime usetime
描述 风场ID 风机号 日期 发电量 风速 弃风电量 理论电量 耦合度 故障时间 故障损失电量 故障台次 当天自耗电量 当天发电量 当天并网秒数 当天检修秒数 当天利用秒数

这个表中我们有5个family，其中base Family是对应6个mysql表中的key列， gpower、userate、consum分别对应一个表，time对应3个表。

这个kpi表的rowkey设计是base中的3个qualifier，分别从3个维度查询数据，这样的设计已经可以满足我们的需求了。

具体在HBase中如何建表如何搭建环境自己参考我写的【手把手教你配置HBase完全分布式环境】这篇文章吧。

步骤2：把MySQL数据迁移到HBase

这时我用gpower对应的mysql表来做演示吧，其他表的道理都一样。（这里可能有人会说为什么不用第三方插件直接数据库对数据库迁移，这里我统一回答一下，我不会，我也不需要。）

okay,首先我们来看看代码先吧：

[java] view plaincopyprint?
  1. import java.io.File;
  2. import java.sql.Connection;
  3. import java.sql.DriverManager;
  4. import java.sql.PreparedStatement;
  5. import java.sql.ResultSet;
  6. import java.text.SimpleDateFormat;
  7. import java.util.ArrayList;
  8. import java.util.List;
  9. import org.apache.hadoop.conf.Configuration;
  10. import org.apache.hadoop.hbase.HBaseConfiguration;
  11. import org.apache.hadoop.hbase.client.HBaseAdmin;
  12. import org.apache.hadoop.hbase.client.HTable;
  13. import org.apache.hadoop.hbase.client.Put;
  14. import org.apache.hadoop.hbase.util.Bytes;
  15. import org.apache.log4j.BasicConfigurator;
  16. import org.apache.log4j.Level;
  17. import org.apache.log4j.Logger;
  18. public class GpowerTransfer{
  19. private static final String QUOREM = "192.168.103.50,192.168.103.51,192.168.103.52,192.168.103.53,192.168.103.54,192.168.103.55,192.168.103.56,192.168.103.57,192.168.103.58,192.168.103.59,192.168.103.60";//这里是你HBase的分布式集群结点，用逗号分开。
  20. private static final String CLIENT_PORT = "2181";//端口
  21. private static Logger log = Logger.getLogger(GpowerTransfer.class);
  22. /**
  23. * @param args
  24. */
  25. public static void main(String[] args) {
  26. BasicConfigurator.configure();
  27. log.setLevel(Level.DEBUG);
  28. String tableName = "kpi";//HBase表名称
  29. Configuration conf = HBaseConfiguration.create();
  30. conf.set("hbase.zookeeper.quorum", QUOREM);
  31. conf.set("hbase.zookeeper.property.clientPort", CLIENT_PORT);
  32. try { File workaround = new File(".");
  33. System.getProperties().put("hadoop.home.dir", workaround.getAbsolutePath());
  34. new File("./bin").mkdirs();
  35. new File("./bin/winutils.exe").createNewFile();//这几段奇怪的代码在windows跑的时候不加有时候分报错，在web项目中可以不要,但单独的java程序还是加上去吧，知道什么原因的小伙伴可以告诉我一下，不胜感激。
  36. HBaseAdmin admin = new HBaseAdmin(conf);
  37. if(admin.tableExists(tableName)){
  38. Class.forName("com.mysql.jdbc.Driver");//首先将mysql中的数据读取出来，然后再插入到HBase中
  39. String url = "jdbc:mysql://192.168.***.***:3306/midb?useUnicode=true&characterEncoding=utf-8";
  40. String username = "********";
  41. String password = "********";
  42. Connection con = DriverManager.getConnection(url, username, password);
  43. PreparedStatement pstmt = con.prepareStatement("select * from kpi_gpower");
  44. ResultSet rs = pstmt.executeQuery();
  45. HTable table = new HTable(conf, tableName);
  46. log.debug(tableName + ":start copying data to hbase...");
  47. List<Put> list = new ArrayList<Put>();
  48. SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMdd");
  49. String base = "base";//family名称
  50. String gpower = "gpower";//family名称
  51. String[] qbase = {"fid","tid","date"};//qualifier名称
  52. String[] qgpower = {"power","windspeed","unpower","theory","coup"};//qualifier名称
  53. while(rs.next()){
  54. String rowKey = rs.getString("farmid") + ":" + (rs.getInt("turbineid")<10?("0"+rs.getInt("turbineid")):rs.getInt("turbineid")) + ":" + sdf.format(rs.getDate("vtime"));//拼接rowkey
  55. Put put = new Put(Bytes.toBytes(rowKey));//新建一条记录，然后下面对相应的列进行赋值
  56. put.add(base.getBytes(), qbase[0].getBytes(), Bytes.toBytes(rs.getString("farmid")));//base:fid
  57. put.add(base.getBytes(), qbase[1].getBytes(), Bytes.toBytes(rs.getInt("turbineid")+""));//base:tid
  58. put.add(base.getBytes(), qbase[2].getBytes(), Bytes.toBytes(rs.getDate("vtime")+""));//base:date
  59. put.add(gpower.getBytes(), qgpower[0].getBytes(), Bytes.toBytes(rs.getFloat("value")+""));//gpower:power
  60. put.add(gpower.getBytes(), qgpower[1].getBytes(), Bytes.toBytes(rs.getFloat("windspeed")+""));//gpower:windspeed
  61. put.add(gpower.getBytes(), qgpower[2].getBytes(), Bytes.toBytes(rs.getFloat("unvalue")+""));//gpower:unvalue
  62. put.add(gpower.getBytes(), qgpower[3].getBytes(), Bytes.toBytes(rs.getFloat("theory")+""));//gpower:theory
  63. put.add(gpower.getBytes(), qgpower[4].getBytes(), Bytes.toBytes(rs.getFloat("coup")+""));//gpower:coup
  64. list.add(put);
  65. }
  66. table.put(list);//这里真正对表进行插入操作
  67. log.debug(tableName + ":completed data copy!");
  68. table.close();//这里要非常注意一点，如果你频繁地对表进行打开跟关闭，性能将会直线下降，可能跟集群有关系。
  69. }else{
  70. admin.close();
  71. log.error("table '" + tableName + "' not exisit!");
  72. throw new IllegalArgumentException("table '" + tableName + "' not exisit!");
  73. }
  74. admin.close();
  75. } catch (Exception e) {
  76. e.printStackTrace();
  77. }
  78. }
  79. }
import java.io.File;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.List;import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.client.HBaseAdmin;
import org.apache.hadoop.hbase.client.HTable;
import org.apache.hadoop.hbase.client.Put;
import org.apache.hadoop.hbase.util.Bytes;
import org.apache.log4j.BasicConfigurator;
import org.apache.log4j.Level;
import org.apache.log4j.Logger;public class GpowerTransfer{private static final String QUOREM = "192.168.103.50,192.168.103.51,192.168.103.52,192.168.103.53,192.168.103.54,192.168.103.55,192.168.103.56,192.168.103.57,192.168.103.58,192.168.103.59,192.168.103.60";//这里是你HBase的分布式集群结点，用逗号分开。private static final String CLIENT_PORT = "2181";//端口private static Logger log = Logger.getLogger(GpowerTransfer.class);/*** @param args*/public static void main(String[] args) {BasicConfigurator.configure();log.setLevel(Level.DEBUG);String tableName = "kpi";//HBase表名称Configuration conf = HBaseConfiguration.create();conf.set("hbase.zookeeper.quorum", QUOREM);   conf.set("hbase.zookeeper.property.clientPort", CLIENT_PORT);try { File workaround = new File(".");System.getProperties().put("hadoop.home.dir", workaround.getAbsolutePath());new File("./bin").mkdirs();new File("./bin/winutils.exe").createNewFile();//这几段奇怪的代码在windows跑的时候不加有时候分报错，在web项目中可以不要,但单独的java程序还是加上去吧，知道什么原因的小伙伴可以告诉我一下，不胜感激。HBaseAdmin admin = new HBaseAdmin(conf);if(admin.tableExists(tableName)){Class.forName("com.mysql.jdbc.Driver");//首先将mysql中的数据读取出来，然后再插入到HBase中String url = "jdbc:mysql://192.168.***.***:3306/midb?useUnicode=true&characterEncoding=utf-8";String username = "********";String password = "********";Connection con = DriverManager.getConnection(url, username, password);PreparedStatement pstmt = con.prepareStatement("select * from kpi_gpower");ResultSet rs = pstmt.executeQuery();HTable table = new HTable(conf, tableName);log.debug(tableName + ":start copying data to hbase...");List<Put> list = new ArrayList<Put>();SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMdd");String base = "base";//family名称String gpower = "gpower";//family名称String[] qbase = {"fid","tid","date"};//qualifier名称String[] qgpower = {"power","windspeed","unpower","theory","coup"};//qualifier名称while(rs.next()){String rowKey = rs.getString("farmid") + ":" + (rs.getInt("turbineid")<10?("0"+rs.getInt("turbineid")):rs.getInt("turbineid")) + ":" + sdf.format(rs.getDate("vtime"));//拼接rowkeyPut put = new Put(Bytes.toBytes(rowKey));//新建一条记录，然后下面对相应的列进行赋值put.add(base.getBytes(), qbase[0].getBytes(), Bytes.toBytes(rs.getString("farmid")));//base:fidput.add(base.getBytes(), qbase[1].getBytes(), Bytes.toBytes(rs.getInt("turbineid")+""));//base:tidput.add(base.getBytes(), qbase[2].getBytes(), Bytes.toBytes(rs.getDate("vtime")+""));//base:dateput.add(gpower.getBytes(), qgpower[0].getBytes(), Bytes.toBytes(rs.getFloat("value")+""));//gpower:powerput.add(gpower.getBytes(), qgpower[1].getBytes(), Bytes.toBytes(rs.getFloat("windspeed")+""));//gpower:windspeedput.add(gpower.getBytes(), qgpower[2].getBytes(), Bytes.toBytes(rs.getFloat("unvalue")+""));//gpower:unvalueput.add(gpower.getBytes(), qgpower[3].getBytes(), Bytes.toBytes(rs.getFloat("theory")+""));//gpower:theoryput.add(gpower.getBytes(), qgpower[4].getBytes(), Bytes.toBytes(rs.getFloat("coup")+""));//gpower:couplist.add(put);}table.put(list);//这里真正对表进行插入操作log.debug(tableName + ":completed data copy!");table.close();//这里要非常注意一点，如果你频繁地对表进行打开跟关闭，性能将会直线下降，可能跟集群有关系。}else{admin.close();log.error("table '" + tableName + "' not exisit!");throw new IllegalArgumentException("table '" + tableName + "' not exisit!");}admin.close();} catch (Exception e) {e.printStackTrace();} }
}

在put语句进行add的时候要特别注意：对于int、float、Date等等非String类型的数据，要记得将其转换成String类型，这里我直接用+""解决了，否则在你读取数据的时候就会遇到麻烦了。

步骤3：Java Web项目读取HBase里面的数据

ok,我们成功地把数据迁移到HBase，我们剩下的任务就是在Web应用中读取数据了。

首先我们要确保Web项目中已经把必要的Jar包添加到ClassPath了，下面我对一些HBase的连接做了小封装：

[java] view plaincopyprint?
  1. import org.apache.hadoop.conf.Configuration;
  2. import org.apache.hadoop.hbase.HBaseConfiguration;
  3. import org.apache.hadoop.hbase.client.HBaseAdmin;
  4. /**
  5. * @author a01513
  6. *
  7. */
  8. public class HBaseConnector {
  9. private static final String QUOREM = "192.168.103.50,192.168.103.51,192.168.103.52,192.168.103.53,192.168.103.54,192.168.103.55,192.168.103.56,192.168.103.57,192.168.103.58,192.168.103.59,192.168.103.60";
  10. private static final String CLIENT_PORT = "2181";
  11. private HBaseAdmin admin;
  12. private Configuration conf;
  13. public HBaseAdmin getHBaseAdmin(){
  14. getConfiguration();
  15. try {
  16. admin = new HBaseAdmin(conf);
  17. } catch (Exception e) {
  18. e.printStackTrace();
  19. }
  20. return admin;
  21. }
  22. public Configuration getConfiguration(){
  23. if(conf == null){
  24. conf = HBaseConfiguration.create();
  25. conf.set("hbase.zookeeper.quorum", QUOREM);
  26. conf.set("hbase.zookeeper.property.clientPort", CLIENT_PORT);
  27. }
  28. return conf;
  29. }
  30. }
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.client.HBaseAdmin;/*** @author a01513**/
public class HBaseConnector {private static final String QUOREM = "192.168.103.50,192.168.103.51,192.168.103.52,192.168.103.53,192.168.103.54,192.168.103.55,192.168.103.56,192.168.103.57,192.168.103.58,192.168.103.59,192.168.103.60";private static final String CLIENT_PORT = "2181";private HBaseAdmin admin;private Configuration conf;public HBaseAdmin getHBaseAdmin(){getConfiguration();try {admin = new HBaseAdmin(conf);} catch (Exception e) {e.printStackTrace();}return admin; }public Configuration getConfiguration(){if(conf == null){conf = HBaseConfiguration.create();conf.set("hbase.zookeeper.quorum", QUOREM);   conf.set("hbase.zookeeper.property.clientPort", CLIENT_PORT);   }return conf;}
}

这里的代码基本上跟迁移的那部分代码一样，由于我在其他地方都要重用这些代码，就装在一个地方免得重复写了。

我在Service层做了一下测试，下面看看具体的读取过程：

[java] view plaincopyprint?
  1. private final String tableName = "kpi";
  2. @Override
  3. public List<GenPowerEntity> getGenPower(String farmid,int ltb,int htb,String start,String end) {
  4. List<GenPowerEntity> list = new ArrayList<GenPowerEntity>();
  5. HBaseConnector hbaseConn = new HBaseConnector();
  6. HBaseAdmin admin = hbaseConn.getHBaseAdmin();
  7. try {
  8. if(admin.tableExists(tableName)){
  9. HTable table = new HTable(hbaseConn.getConfiguration(), tableName);
  10. Scan scan = new Scan();
  11. scan.addFamily(Bytes.toBytes("base"));
  12. scan.addFamily(Bytes.toBytes("gpower"));
  13. scan.addFamily(Bytes.toBytes("userate"));
  14. String startRowKey = new String();
  15. String stopRowKey = new String();
  16. if("".equals(start) && !"".equals(end)){
  17. stopRowKey = farmid + ":" + Tools.addZero(htb) + ":" + end;
  18. scan.setStopRow(Bytes.toBytes(stopRowKey));
  19. }else if(!"".equals(start) && "".equals(end)){
  20. startRowKey = farmid + ":" + Tools.addZero(ltb) + ":" + start;
  21. scan.setStartRow(Bytes.toBytes(startRowKey));
  22. }else if(!"".equals(start) && !"".equals(end)){
  23. startRowKey = farmid + ":" + Tools.addZero(ltb) + ":" + start;
  24. stopRowKey = farmid + ":" + Tools.addZero(htb) + ":" + end;
  25. scan.setStartRow(Bytes.toBytes(startRowKey));
  26. scan.setStopRow(Bytes.toBytes(stopRowKey));
  27. }else{
  28. table.close();
  29. admin.close();
  30. return null;
  31. }
  32. ResultScanner rsc = table.getScanner(scan);
  33. Iterator<Result> it = rsc.iterator();
  34. List<GenPowerEntity> slist = new ArrayList<GenPowerEntity>();
  35. List<UseRateEntity> ulist = new ArrayList<UseRateEntity>();
  36. String tempRowKey = "";//这个临时rowkey是用来判断一行数据是否已经读取完了的。
  37. GenPowerEntity gpower = new GenPowerEntity();
  38. UseRateEntity userate = new UseRateEntity();
  39. while(it.hasNext()){
  40. for(Cell cell: it.next().rawCells()){
  41. String rowKey = new String(cell.getRowArray(),cell.getRowOffset(),cell.getRowLength(),"UTF-8");
  42. String family = new String(cell.getFamilyArray(),cell.getFamilyOffset(),cell.getFamilyLength(),"UTF-8");
  43. String qualifier = new String(cell.getQualifierArray(),cell.getQualifierOffset(),cell.getQualifierLength(),"UTF-8");
  44. String value = new String(cell.getValueArray(),cell.getValueOffset(),cell.getValueLength(),"UTF-8");//假如我们当时插入HBase的时候没有把int、float等类型的数据转换成String，这里就会乱码了，并且用Bytes.toInt()这个方法还原也没有用，哈哈
  45. System.out.println("RowKey=>"+rowKey+"->"+family+":"+qualifier+"="+value);
  46. if("".equals(tempRowKey))
  47. tempRowKey = rowKey;
  48. if(!rowKey.equals(tempRowKey)){
  49. slist.add(gpower);
  50. ulist.add(userate);
  51. gpower = null;
  52. userate = null;
  53. gpower = new GenPowerEntity();
  54. userate = new UseRateEntity();
  55. tempRowKey = rowKey;
  56. }
  57. switch(family){
  58. case "base":
  59. switch(qualifier){
  60. case "fid":
  61. gpower.setFarmid(value);
  62. userate.setFarmid(value);
  63. break;
  64. case "tid":
  65. gpower.setTurbineid(Integer.parseInt(value));
  66. userate.setTurbineid(Integer.parseInt(value));
  67. break;
  68. case "date":
  69. SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
  70. Date date = null;
  71. try {
  72. date = sdf.parse(value);
  73. } catch (ParseException e) {
  74. e.printStackTrace();
  75. }
  76. gpower.setVtime(date);
  77. userate.setVtime(date);
  78. break;
  79. }
  80. break;
  81. case "gpower":
  82. switch(qualifier){
  83. case "power":
  84. gpower.setValue(Float.parseFloat(value));
  85. break;
  86. case "windspeed":
  87. gpower.setWindspeed(Float.parseFloat(value));
  88. break;
  89. case "unpower":
  90. gpower.setUnvalue(Float.parseFloat(value));
  91. break;
  92. case "theory":
  93. gpower.setTvalue(Float.parseFloat(value));
  94. break;
  95. case "coup":
  96. gpower.setCoup(Float.parseFloat(value));
  97. break;
  98. }
  99. break;
  100. case "userate":
  101. switch(qualifier){
  102. case "num":
  103. userate.setFnum(Integer.parseInt(value));
  104. break;
  105. case "power":
  106. userate.setFpower(Float.parseFloat(value));
  107. break;
  108. case "time":
  109. userate.setFvalue(Float.parseFloat(value));
  110. break;
  111. }
  112. break;
  113. }
  114. }
  115. }
  116. rsc.close();
  117. table.close();
  118. admin.close();
  119. ......
  120. }
  121. } catch (IOException e) {
  122. e.printStackTrace();
  123. }
  124. return list;
  125. }
private final String tableName = "kpi";
@Overridepublic List<GenPowerEntity> getGenPower(String farmid,int ltb,int htb,String start,String end) {List<GenPowerEntity> list = new ArrayList<GenPowerEntity>();HBaseConnector hbaseConn = new HBaseConnector();HBaseAdmin admin = hbaseConn.getHBaseAdmin();try {if(admin.tableExists(tableName)){HTable table = new HTable(hbaseConn.getConfiguration(), tableName);Scan scan = new Scan();scan.addFamily(Bytes.toBytes("base"));scan.addFamily(Bytes.toBytes("gpower"));scan.addFamily(Bytes.toBytes("userate"));String startRowKey = new String();String stopRowKey = new String();if("".equals(start) && !"".equals(end)){stopRowKey = farmid + ":" + Tools.addZero(htb) + ":" + end;scan.setStopRow(Bytes.toBytes(stopRowKey));}else if(!"".equals(start) && "".equals(end)){startRowKey = farmid + ":" + Tools.addZero(ltb) + ":" + start;scan.setStartRow(Bytes.toBytes(startRowKey));}else if(!"".equals(start) && !"".equals(end)){startRowKey = farmid + ":" + Tools.addZero(ltb) + ":" + start;stopRowKey = farmid + ":" + Tools.addZero(htb) + ":" + end;scan.setStartRow(Bytes.toBytes(startRowKey));scan.setStopRow(Bytes.toBytes(stopRowKey));}else{table.close();admin.close();return null;}ResultScanner rsc = table.getScanner(scan);Iterator<Result> it = rsc.iterator();List<GenPowerEntity> slist = new ArrayList<GenPowerEntity>();List<UseRateEntity> ulist = new ArrayList<UseRateEntity>();String tempRowKey = "";//这个临时rowkey是用来判断一行数据是否已经读取完了的。GenPowerEntity gpower = new GenPowerEntity();UseRateEntity userate = new UseRateEntity();while(it.hasNext()){for(Cell cell: it.next().rawCells()){String rowKey = new String(cell.getRowArray(),cell.getRowOffset(),cell.getRowLength(),"UTF-8");String family = new String(cell.getFamilyArray(),cell.getFamilyOffset(),cell.getFamilyLength(),"UTF-8");String qualifier = new String(cell.getQualifierArray(),cell.getQualifierOffset(),cell.getQualifierLength(),"UTF-8");String value = new String(cell.getValueArray(),cell.getValueOffset(),cell.getValueLength(),"UTF-8");//假如我们当时插入HBase的时候没有把int、float等类型的数据转换成String，这里就会乱码了，并且用Bytes.toInt()这个方法还原也没有用，哈哈System.out.println("RowKey=>"+rowKey+"->"+family+":"+qualifier+"="+value);if("".equals(tempRowKey))tempRowKey = rowKey;if(!rowKey.equals(tempRowKey)){slist.add(gpower);ulist.add(userate);gpower = null;userate = null;gpower = new GenPowerEntity();userate = new UseRateEntity();tempRowKey = rowKey;}switch(family){case "base":switch(qualifier){case "fid":gpower.setFarmid(value);userate.setFarmid(value);break;case "tid":gpower.setTurbineid(Integer.parseInt(value));userate.setTurbineid(Integer.parseInt(value));break;case "date":SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");Date date = null;try {date = sdf.parse(value);} catch (ParseException e) {e.printStackTrace();}gpower.setVtime(date);userate.setVtime(date);break;}break;case "gpower":switch(qualifier){case "power":gpower.setValue(Float.parseFloat(value));break;case "windspeed":gpower.setWindspeed(Float.parseFloat(value));break;case "unpower":gpower.setUnvalue(Float.parseFloat(value));break;case "theory":gpower.setTvalue(Float.parseFloat(value));break;case "coup":gpower.setCoup(Float.parseFloat(value));break;}break;case "userate":switch(qualifier){case "num":userate.setFnum(Integer.parseInt(value));break;case "power":userate.setFpower(Float.parseFloat(value));break;case "time":userate.setFvalue(Float.parseFloat(value));break;}break;}}}rsc.close();table.close();admin.close();......}} catch (IOException e) {e.printStackTrace();}return list;}

这是我在Service层中用作测试的一个方法，业务逻辑代码可以直接无视（已经用.....代替了，哈哈），至此我们的所有工作完成，对于更深入的应用，还要靠自己去认真挖掘学习了。

实战：在Java Web项目中使用HBase相关推荐

  1. JAVA Web项目中所出现错误及解决方式合集（不断更新中）

    JAVA Web项目中所出现错误及解决方式合集 前言 一.几个或许会用到的软件下载官网 二.Eclipse的[preferences]下没有[sever]选项 三.Tomcat的安装路径找不到 四.T ...

  2. 在java web项目中编写自己的代码生成器

    在java web项目中编写自己的代码生成器 转载于:https://www.cnblogs.com/punisher/p/5909943.html

  3. Java / Web项目中的NPM模块Browser-Sync

    Browser-Sync是一个方便的基于Node.js的NPM模块,可用于更快的Web开发. 浏览器同步可在许多设备之间同步文件更改和交互. 最重要的功能是实时重新加载. 我们也可以在Java / W ...

  4. java web项目中的根路径踩坑

    以下总结来自于颜群老师课堂笔记. java web项目中的"/"怎样区分? 项目根目录: WebContent \ src(所有的构建目录) 如果WebContent中有一个文件i ...

  5. Java Web项目中缺少Java EE 6 Libraries怎么添加

    Java Web项目中缺少Java EE 6 Libraries怎么添加 具体步骤如下: 1.项目名称上点击鼠标右键,选择"Build Path-->Configure Build P ...

  6. Java Web项目中使用Freemarker生成Word文档

    Web项目中生成Word文档的操作屡见不鲜,基于Java的解决方案也是很多的,包括使用Jacob.Apache POI.Java2Word.iText等各种方式,其实在从Office 2003开始,就 ...

  7. Java Web项目中HTML文件中的汉字在浏览器中显示乱码的解决方案

    今天在做一个Java Web项目的时候,html中的汉字在浏览器中显示为乱码,分析其可能原因有: (1)html文件属性中有默认的编码方式,如果它的设置与html文档中content charset属 ...

  8. 在java web项目中实现随项目启动的额外操作

    前言 在web项目中经常会遇到在项目启动初始,会要求做一些逻辑的实现,比如实现一个消息推送服务,实现不同类型数据同步的回调操作初始化,或则通知其他客户服务器本项目即将启动,等等.对于这种要求,目前个人 ...

  9. java访问错误404_如何解决 Java web 项目中的 404 错误

    在使用 Tomcat 进行 Java Web 开发的时候,经常会遇到以下 HTTP 404 错误: 错误代码为 HTTP 404(未找到),描述信息是: "The origin server ...

最新文章

  1. 32单片机编程简单吗？单片机程序与桌面编程哪个难？
  2. 基于SSM的汽车销售管理系统
  3. mysql创建函数1418_Mysql中创建函数报“ERROR 1418 ”的解决方法
  4. python 3.6.0新语法_详解Python3.6正式版新特性
  5. oracle替代变量输出,【Oracle】替代变量
  6. Spark入门（二）多主standalone安装
  7. Java调试器和超时
  8. linux udp 端口 抓包,tcpdump之UDP抓包
  9. iPhone最让人头疼的问题有望解决了，2020年将使用高通基带
  10. vue可视化拖拽生成工具_GitHub - 1260215278/dragUI: 基于vuedraggable.js + uni 的可视化拖拽编程，自动生成项目，自动生成代码，自行导入第三方组件...
  11. Ayoa：让思维导图更简单，在线使用 无需安装客户端
  12. 实验7 OpenGL光照
  13. 一次debug过程描述
  14. Python源码剖析专栏总览
  15. Web Server 配置及上传文件
  16. sfm点云代码_三维重建的方法SFM
  17. 知富柜台系统服务器,商业银行柜面无纸化安全解决方案
  18. xp系统如何开启ftp服务器,xp系统怎么开ftp服务器
  19. 走进大数据丨 一条让我虎躯一震的SQL
  20. 安装glib2.6x

热门文章

  1. Java 1090 危险品装箱
  2. unity 抛物线运动计算｜【高楼抛物】｜自动计算加速度，空中移动时间
  3. 机器学习-多元线性回归（multiple linear regression）
  4. Linux Caffe train.txt,python脚本生成caffe train_list.txt的方法
  5. Xshell远程操作liunx图形化桌面创建oracle数据库实例
  6. 一生要做的99件事 一生要看的50部经典电影
  7. CentOS7 如何注册系统服务
  8. dhcp服务器连接状态,DHCP设置不当故障的解决方法
  9. 关于零食的火爆文案(适合卖零食的推广语)
  10. 金庸的小说人生（2）