elasticsearch httpclient认证机制
轉載自http://www.cnblogs.com/youran-he/p/7562870.html
最近公司單位搬遷,所有的服務都停止了,我負責的elasticsearch不知道怎么回事,一直不能運行呢,因此,我一直在負責調試工作。經過兩天的調試工作,我發現新的服務器增加了httpclient認證機制,經過幾次研究,發現服務器的新增了如下內容:
?http.basic.log: false
?http.basic.user: "hett"
?http.basic.password: "****"
因此,每次在進行ik拆分詞的時候會有提示信息就是:http沒有認證,因此,在加載http鏈接之間加入提前認證機制,在初始化bean的時候就開始認證,代碼做如下修改:
public class ElasticsearchServiceImpl implements IElasticsearchService , InitializingBean
改類繼承初始化bean的認證
實現父類的方法:
?? ? @Override
?? ?public void afterPropertiesSet() throws Exception {
?? ??? ?try {
?? ??? ??? ?Properties props = PropertiesLoaderUtils
?? ??? ??? ??? ??? ?.loadAllProperties("********");
?? ??? ??? ?String authUser = StringUtil
?? ??? ??? ??? ??? ?.null2Str(props.getProperty("username"));
?? ??? ??? ?String authPwd = StringUtil.null2Str(props.getProperty("password"));
?? ??? ??? ?credentialContext = HttpClientContext.create();
?? ??? ??? ?// 認證提供者
?? ??? ??? ?CredentialsProvider credsProvider = new BasicCredentialsProvider();
?? ??? ??? ?credsProvider.setCredentials(AuthScope.ANY,
?? ??? ??? ??? ??? ?new UsernamePasswordCredentials(authUser, authPwd));
?? ??? ??? ?AuthCache authCache = new BasicAuthCache();
?? ??? ??? ?// 提前填充認證信息緩存到上下文中,這樣,以這個上下文執行的方法,就會使用搶先認證。可能會出錯
?? ??? ??? ?credentialContext.setAuthCache(authCache);
?? ??? ??? ?credentialContext.setCredentialsProvider(credsProvider);
?? ??? ?} catch (Exception ex) {
?? ??? ??? ?logger.warn("read elasticsearch credential error", ex);
?? ??? ?}
?? ?}
再次訪問的時候提示如下:
?
debug拋出的信息是認證通過
經過幾天的折騰終于完成了搜索標簽的之類的服務啦?
總結
以上是生活随笔為你收集整理的elasticsearch httpclient认证机制的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: BTrace使用小结
- 下一篇: 使用JestClient操作Elasti