Solr 身份认证与授权更新异常解决方案

然后测试，也是正常执行，输出结果就不截图了，各位小伙伴可以亲自测试一下

关于下面的这段写法，来自: Preemptive Basic authentication with Apache HttpClient 4

上面的方式虽然可以让我们正确操作 solr 了，但是SystemDefaultHttpClient有一个删除注解，也就是说不建议再直接用它了，那就借鉴它的使用方式，来满足我们的需求，所以可以如下操作

@Value("${spring.data.solr.host}")
private String url;

@Data
public static class UrlDo {
    private String url;

    private String user;
    private String pwd;

    private String host;
    private int port;

    public static UrlDo parse(String url) throws MalformedURLException {
 // http://root:123@127.0.0.1:8983/solr
 URL u = new URL(url);
 UrlDo out = new UrlDo();
 out.setHost(u.getHost());
 out.setPort(u.getPort());

 String userInfo = u.getUserInfo();
 if (!StringUtils.isEmpty(userInfo)) {
     String[] users = org.apache.commons.lang3.StringUtils.split(userInfo, ":");
     out.setUser(users[0]);
     out.setPwd(users[1]);
 }
 out.setUrl(url);
 return out;
    }
}

public class SolrAuthInterceptor implements HttpRequestInterceptor {
    @Override
    public void process(final HttpRequest request, final HttpContext context) {
 AuthState authState = (AuthState) context.getAttribute(HttpClientContext.TARGET_AUTH_STATE);
 if (authState.getAuthScheme() == null) {
     CredentialsProvider credsProvider =
      (CredentialsProvider) context.getAttribute(HttpClientContext.CREDS_PROVIDER);
     HttpHost targetHost = (HttpHost) context.getAttribute(HttpCoreContext.HTTP_TARGET_HOST);
     AuthScope authScope = new AuthScope(targetHost.getHostName(), targetHost.getPort());
     Credentials creds = credsProvider.getCredentials(authScope);
     authState.update(new BasicScheme(), creds);
 }
    }
}

@Bean
public HttpSolrClient solrClient() throws MalformedURLException {
    UrlDo urlDo = UrlDo.parse(url);
    CredentialsProvider provider = new BasicCredentialsProvider();
    provider.setCredentials(new AuthScope(urlDo.getHost(), urlDo.getPort()),
     new UsernamePasswordCredentials(urlDo.getUser(), urlDo.getPwd()));

    HttpClientBuilder builder = HttpClientBuilder.create();
    // 请注意下面这一行，指定拦截器，用于设置认证信息
    builder.addInterceptorFirst(new SolrAuthInterceptor());
    builder.setDefaultCredentialsProvider(provider);
    CloseableHttpClient httpClient = builder.build();
    return new HttpSolrClient.Builder(url).withHttpClient(httpClient).build();
}

SolrInputdocument document = new SolrInputdocument();
document.addField("id", 999999);
document.addField("content_id", 3);
document.addField("title", "testAddByDoc!");
document.addField("content", "新增哒哒哒");
document.addField("type", 2);
document.addField("create_at", System.currentTimeMillis() / 1000);
document.addField("publish_at", System.currentTimeMillis() / 1000);

UpdateRequest updateRequest = new UpdateRequest();
updateRequest.setBasicAuthCredentials("root", "123");
updateRequest.add(document);
UpdateResponse response = updateRequest.process(solrClient, "yhh");
updateRequest.commit(solrClient, "yhh");