摘要：前言公司的最近需要全部進(jìn)行升級(jí)，目的是方便維護(hù)和統(tǒng)一管理。以前的版本不統(tǒng)一，這次準(zhǔn)備統(tǒng)一升級(jí)到一個(gè)固定的版本。帶來的問題就是我這邊的程序得改了，目前用的是來操作。升級(jí)完之后又有坑了。下載地址以上就是這次升級(jí)過程中踩過的坑，分享給大家。

公司的ES最近需要全部進(jìn)行升級(jí)，目的是方便維護(hù)和統(tǒng)一管理。以前的版本不統(tǒng)一，這次準(zhǔn)備統(tǒng)一升級(jí)到一個(gè)固定的版本。

同時(shí)還會(huì)給ES加上權(quán)限控制，雖然都是部署在內(nèi)網(wǎng)，為了防止誤操作，加上權(quán)限還是有必要的。

帶來的問題就是我這邊的程序得改了，目前用的是Spring Data Elasticsearch來操作ES。

首先版本從5.x升級(jí)到6.4.0，我這邊用的Spring Boot是2.0.1版本，這塊是兼容的，沒有影響。唯一導(dǎo)致我這邊要改動(dòng)的就是權(quán)限這塊。

在Spring Boot的文檔中，提供了三種操作ES的框架，有兩種是走Http協(xié)議的，也就是操作9200端口，是可以直接支持用戶名和密碼配置的。

elasticsearch-rest-client：

spring.elasticsearch.rest.uris=http://search.example.com:9200
spring.elasticsearch.rest.username=user
spring.elasticsearch.rest.password=secret

JestClient:

spring.elasticsearch.jest.uris=http://search.example.com:9200
spring.elasticsearch.jest.read-timeout=10000
spring.elasticsearch.jest.username=user
spring.elasticsearch.jest.password=secret

偏偏我用的是第三種Spring Data Elasticsearch，沒有認(rèn)證信息的配置，但是有一個(gè)擴(kuò)展屬性properties

@ConfigurationProperties(prefix = "spring.data.elasticsearch")
public class ElasticsearchProperties {

    /**
     * Elasticsearch cluster name.
     */
    private String clusterName = "elasticsearch";

    /**
     * Comma-separated list of cluster node addresses.
     */
    private String clusterNodes;

    /**
     * Additional properties used to configure the client.
     */
    private Map properties = new HashMap<>();
}

在TransportClientFactoryBean中初始化Settings的時(shí)候，會(huì)取properties中值

private Settings settings() {
    if (properties != null) {
            Settings.Builder builder = Settings.builder();

            properties.forEach((key, value) -> {
                builder.put(key.toString(), value.toString());
            });

            return builder.build();
    }
    return Settings.builder()
            .put("cluster.name", clusterName)
            .put("client.transport.sniff", clientTransportSniff)
            .put("client.transport.ignore_cluster_name", clientIgnoreClusterName)
            .put("client.transport.ping_timeout", clientPingTimeout)
            .put("client.transport.nodes_sampler_interval", clientNodesSamplerInterval)
            .build();
}

于是我在properties 中加上認(rèn)證信息的配置發(fā)現(xiàn)還是不行，因?yàn)檫@個(gè)全新認(rèn)證是擴(kuò)展的，需要增加x-pack-transport才行。

      org.elasticsearch.client
      x-pack-transport
      6.4.2

惡心的是中央倉庫沒有，還得指定倉庫：

      
      
         elasticsearch-releases
         https://artifacts.elastic.co/maven
         
            true
         
         
            false
         
      

當(dāng)你加入這些依賴之后你會(huì)發(fā)現(xiàn)，還是不能采用spring.data.elasticsearch.xxx這種方式直接配置認(rèn)證信息，因?yàn)榈讓硬皇怯玫膞pack擴(kuò)展的client構(gòu)造的， 用的是PreBuiltTransportClient，看下代碼：

protected void buildClient() throws Exception {

    client = new PreBuiltTransportClient(settings());
        
    clusterNodes.stream() //
            .peek(it -> logger.info("Adding transport node : " + it.toString())) //
            .forEach(client::addTransportAddress);
        
    client.connectedNodes();
}

最終還是放棄了自動(dòng)配置的方式，自己手動(dòng)配置定義Client來支持權(quán)限認(rèn)證。

@Bean
public Client client() {
    try {
        Settings.Builder builder = Settings.builder()
                .put("client.transport.ping_timeout", pingTimeout)
                .put("cluster.name", clusterName)
                .put("xpack.security.user", username + ":" + password)
                .put("xpack.security.transport.ssl.enabled", "true")
                .put("xpack.security.transport.ssl.truststore.path", keystorePath)
                .put("xpack.security.transport.ssl.keystore.path", keystorePath)
                .put("xpack.security.transport.ssl.verification_mode", "certificate");
        Settings settings = builder.build();
        String[] nodes = clusterNodes.split(",");
        TransportAddress[] addressArray = new TransportAddress[nodes.length];
        for (int i = 0; i < nodes.length; i++) {
            String[] nodeArray = nodes[i].split(":");
            addressArray[i] = new TransportAddress(InetAddress.getByName(nodeArray[0]), Integer.parseInt(nodeArray[1]));
        }
        return new PreBuiltXPackTransportClient(settings).addTransportAddresses(addressArray);
    } catch (Exception e) {
        logger.error("初始化ESClient異常", e);
    }
    return null;
}

username:用戶名

password:密碼

keystorePath:證書地址，會(huì)有一個(gè).p12的證書

不知大家發(fā)現(xiàn)沒有，看上去我們自定義的代碼也沒什么特別，關(guān)鍵點(diǎn)在于PreBuiltXPackTransportClient，框架中用的是PreBuiltTransportClient，所以我們才需要自定義。

配置完了你會(huì)發(fā)現(xiàn)還是不行，各種jar沖突，Spring Boot的版本還需要升級(jí)，于是只能升到目前最新的2.1.0版本。升級(jí)完之后又有坑了。

升級(jí)之前Data中的注解，要指定類型，keyword變成了Keyword

@Field(type=FieldType.Keyword)

ES的這個(gè)Field注解沒有別名映射的屬性，就是我es中存的u_name, 實(shí)體類中寫的是username,這個(gè)確實(shí)不太方便，像data mongodb中都有這樣的功能，有知道怎么解決的要給我留言哈，學(xué)習(xí)下。

然后就是security的一個(gè)坑了，升級(jí)之后security版本也升級(jí)了，下載下來的jar包用不了，錯(cuò)誤如下：

一開始以為是網(wǎng)絡(luò)原因，沒下載完，然后重新刪了再下，試了5次還是不行，最后沒辦法，我手動(dòng)下載了spring-security-config這個(gè)包，替換了本地倉庫的jar。

下載地址：https://mvnrepository.com/art...

以上就是這次升級(jí)過程中踩過的坑，分享給大家。這次只是客戶端這塊的改變，至于ES是怎么開啟權(quán)限認(rèn)證的我這邊就不做講解了，因?yàn)檫@塊不是我弄的，所以我也不熟悉，等后面有機(jī)會(huì)我也去研究研究可以給大家分享，反正是基于xpack搞的。