更新时间:2019-08-06 10:16
package com.aliyun.opensearch;
import com.alibaba.fastjson.JSONArray;
import com.aliyun.opensearch.sdk.dependencies.com.google.common.collect.Lists;
import com.aliyun.opensearch.sdk.dependencies.org.json.JSONObject;
import com.aliyun.opensearch.sdk.generated.OpenSearch;
import com.aliyun.opensearch.sdk.generated.commons.OpenSearchClientException;
import com.aliyun.opensearch.sdk.generated.commons.OpenSearchException;
import com.aliyun.opensearch.sdk.generated.search.*;
import com.aliyun.opensearch.sdk.generated.search.general.SearchResult;
import com.aliyun.opensearch.search.SearchParamsBuilder;
import com.aliyun.opensearch.search.SearchResultDebug;
import java.nio.charset.Charset;
public class testSuggest {
private static String appName = "替换为opensearch应用名";
private static String accesskey = "替换accesskey";
private static String secret = "替换secret";
private static String host = "替换应用的API访问地址";
public static void main(String[] args) {
//查看文件和默认编码格式
System.out.println(String.format("file.encoding: %s", System.getProperty("file.encoding")));
System.out.println(String.format("defaultCharset: %s", Charset.defaultCharset().name()));
//创建并构造OpenSearch对象
OpenSearch openSearch = new OpenSearch(accesskey, secret, host);
//创建OpenSearchClient对象,并以OpenSearch对象作为构造参数
OpenSearchClient serviceClient = new OpenSearchClient(openSearch);
//创建SearcherClient对象,并以OpenSearchClient对象作为构造参数
SearcherClient searcherClient = new SearcherClient(serviceClient);
//定义Config对象,用于设定config子句参数,分页或数据返回格式,指定应用名等等
Config config = new Config(Lists.newArrayList(appName));
config.setStart(0);
config.setHits(5);
//设置返回格式为json,3.1.2 sdk只支持返回xml和json格式,暂不支持返回fulljson类型,3.1.3版本支持fulljson
config.setSearchFormat(SearchFormat.JSON);
// 创建参数对象
SearchParams searchParams = new SearchParams(config);
// 设置查询子句。若设置多个setQuery,后面的会替换前面的
Suggest sug = new Suggest();
sug.setSuggestName("suggest");
searchParams.setSuggest(sug);//searchParams对象添加下拉对象
searchParams.setQuery("nihao");
// SearchParams的工具类,提供了更为便捷的操作
SearchParamsBuilder paramsBuilder = SearchParamsBuilder.create(searchParams);
// 执行返回查询结果
SearchResult searchResult;
try {
searchResult = searcherClient.execute(paramsBuilder);
String result = searchResult.getResult();
JSONObject obj = new JSONObject(result);
//判断执行返回是否成功,如果报错执行下面代码,否者输出正确查询内容
if(obj.has("errors")){
JSONArray jsonarr = JSONArray.parseArray(obj.get("errors").toString());
System.out.println("error code:"+jsonarr.getJSONObject(0).get("code"));
System.out.println("error message:"+jsonarr.getJSONObject(0).get("message"));
}else{
// 输出查询结果
System.out.println("output:"+obj.toString());
//个别用户可能需要debug请求地址信息
SearchResultDebug srd = searcherClient.executeDebug(searchParams);
System.out.println(srd.getRequestUrl().toString());
}
} catch (OpenSearchException e) {
e.printStackTrace();
} catch (OpenSearchClientException e) {
e.printStackTrace();
}
}
}
在文档使用中是否遇到以下问题
更多建议
匿名提交