fablefe 发表于 2017-12-17 23:49:34

Hadoop技巧(04):简易处理solr date 时区问题


一:编写程序
  编写模拟插入程序。为了容易查看,只插入2条数据。
  这里我们使用的solr版本为4.10.3。

  

    private void insert() throws SolrServerException, IOException,  
ParseException {
  
String zhHost
= "master1/solr";  

  
CloudSolrServer cloudSolrServer
= new CloudSolrServer(zhHost);  

  
cloudSolrServer.setDefaultCollection(
"date_demo");  


  
String>= UUID.randomUUID().toString().replaceAll("-", "")  
.toUpperCase();
  
String name_1
= "1点前+8";  
Date createDate_1
= sdfDate.parse("2016-12-30 00:11:12");  
String day_1
= sdfDay.format(createDate_1);  


  
String>= UUID.randomUUID().toString().replaceAll("-", "")  
.toUpperCase();
  
String name_2
= "1点后+8";  
Date createDate_2
= sdfDate.parse("2016-12-30 10:13:14");  
String day_2
= sdfDay.format(createDate_2);  

  
SolrInputDocument solrInputDocument1
= create(id_1, name_1, day_1,  
createDate_1);
  
SolrInputDocument solrInputDocument2
= create(id_2, name_2, day_2,  
createDate_2);
  

  
cloudSolrServer.add(solrInputDocument1);
  
cloudSolrServer.add(solrInputDocument2);
  
cloudSolrServer.commit();
  

  
System.out.println(
"success");  
}
  


View Code
二:运行程序
  可以看到我们已经插入2条数据。


三:程序查询
  在程序查询的结果如下。

  可以看到solr自己的查询界面使用的时间格式是UTC的,会有时差,我们这里是8小时。
  CREATEDAY和CREATEDATE有时候不一致。

四:处理
  所以为了3方的统一,要么自己改solr界面查询的。要么自己改下时差,使得3方结果一致,方便使用。
  这里我们采用自己修改时差来同步。
  但工具量挺大,得在solr插入的时候转换下时间格式程utc。还的在每次查询的时候转换回来。
  所以这里就自己恶心下自己,改下solr源码,在源码中找到对应的位置,固定的修改成自己这里的时差。
  这样就间接的使3方同步了。
  找到solr相关的处理代码类
  

org.apache.solr.common.util.JavaBinCodec.java  

  在readVal下
  

return new Date(dis.readLong()-28800000l);//因为存储的时候solr的时间格式是utc的,所以这里减掉当前时区的值  

  在writePrimitive下
  

daos.writeLong(((Date) val).getTime()+28800000l);//存入的时候为了同day string同步 加8小时  

  这样就可以了。
  我们查看效果。
  为了对比 将数据的名称加备注+8

  solr查询页面

  --------------------------------------------------------------------
  到此,本章节的内容讲述完毕。

页: [1]
查看完整版本: Hadoop技巧(04):简易处理solr date 时区问题