指引网

当前位置: 主页 > 编程开发 > C >

处理xml或者json格式返回数据之EasyNet.Solr

来源:网络 作者:佚名 点击: 时间:2017-07-19 23:06
[摘要] 

处理xml或者json格式返回数据之easynet.solr
在easynet.solr中,有两个接口最重要,一个是编解码器接口icodec,一个是solr输出结果解析器接口isolrresponseparser<st, dt>。
easynet.solr内置了两个编解码器实现:javabincodec,textcodec。javabincodec对应solr中基于javabin协议,textcodec对应solr中的xml、json等基于文本的协议。相应定义了binarycodecfactory,用于创建javabincodec,textcodecfactory用于创建textcodec。在solrconnection中有个codecfactory的属性,这是
public class example
2     {
3         public string id { get; set; }
4         public string name { get; set; }
5         public ilist<string> features { get; set; }
6         public datetime modifieddatetime { get; set; }
7     }
定义exampleobjectdeserialize用于反序列化:

view code
 1   public class exampleobjectdeserialize : iobjectdeserialize<example>
 2     {
 3         public ienumerable<example> deserialize(solrdocumentlist result)
 4         {
 5             var examples = new list<example>();
 6
 7             foreach (solrdocument doc in result)
 8             {
 9                 examples.add(new example()
10                 {
11                     id = doc["id"].tostring(),
12                     name = doc["name"].tostring(),
13                     modifieddatetime = convert.todatetime(doc["last_modified"]),
14                     features = (ilist<string>)doc["features"]
15                 });
16             }
17
18             return examples;
19         }
20     }
 处理xml格式返回数据:

view code
 1             var codefactory = new textcodecfactory();
 2             var con = new solrconnection<string>("http://localhost:8088/solr") { codecfactory = codefactory };
 3             var objectdeserialize = new exampleobjectdeserialize();
 4             var qop = new solrqueryoperations<string>(con);
 5             var options = new namevaluecollection();
 6
 7             options.add(commonparams.start, "0");
 8             options.add(commonparams.rows, "10");
 9             options.add(highlightparams.highlight, "true");
10             options.add(highlightparams.fields, "name");
11             options.add(commonparams.wt, "xml");
12
13             var response = qop.query(new solrquery("name:terry"), options);
14
15             //解析返回头信息
16             var xmlresponseheaderparser = new xmlresponseheaderparser();
17
18             var responseheader = xmlresponseheaderparser.parser(response);
19
20             //解析高亮
21             var xmlhighlightingparser = new xmlhighlightingparser();
22
23             var highlighting = xmlhighlightingparser.parser(response);
24
25             //解析查询结果
26             var xmlqueryresultsparser = new xmlqueryresultsparser<example>(objectdeserialize);
27
28             var examples = xmlqueryresultsparser.parser(response);
 处理json格式返回数据:

view code
 1             var codefactory = new textcodecfactory();
 2             var con = new solrconnection<string>("http://localhost:8088/solr") { codecfactory = codefactory };
 3             var objectdeserialize = new exampleobjectdeserialize();
 4             var qop = new solrqueryoperations<string>(con);
 5             var options = new namevaluecollection();
 6
 7             options.add(commonparams.start, "0");
 8             options.add(commonparams.rows, "10");
 9             options.add(highlightparams.highlight, "true");
10             options.add(highlightparams.fields, "name");
11             options.add(commonparams.wt, "json");
12
13             var response = qop.query(new solrquery("name:terry"), options);
14
15             //解析头信息
16             var jsonresponseheaderparser = new jsonresponseheaderparser();
17
18             var responseheader = jsonresponseheaderparser.parser(response);
19
20             //解析高亮
21             var jsonhighlightingparser = new jsonhighlightingparser();
22
23             var highlighting = jsonhighlightingparser.parser(response);
24
25             //解析查询结果
26             var jsonqueryresultsparser = new jsonqueryresultsparser<example>(objectdeserialize);
27
28             var examples = jsonqueryresultsparser.parser(response);

上面的实例处理过程是

1.定义icodecfactory,由于xml、json都是基于文本的,所以我们使用textcodecfactory。

2.创建指定icodecfactory的solr连接isolrconnection。

3. 创建isolrqueryoperations<t>用于solr查询,t为返回结构数据类型,此处应该为string类型。


4.预先定义好的iobjectdeserialize<t>,对象反序列化接口实现。t为要反序列化为的对象数据类型。

5.构造查询字符串及查询选项。

6.进行查询,返回结果。

7.对于查询结果,可以用各种实现isolrresponseparser<st, dt>接口的解析器进行解析。st为原数据类型,此处为stirng类型,dt为解析结果的数据类型。 

 

------分隔线----------------------------