swaggyW's Blog

@Import(StringUtils.class)
@Configuration //标注该类是一个配置类
@SpringBootConfiguration // 和上面的作用一样，用于人区分，上面做公共配置
public class AppConfig {
    
}

public enum CreateMode {
    
    /**
     * 持久节点，客户端断开节点不会删除
     */
    PERSISTENT (0, false, false, false, false),
    /**
    * 持久节点，客户端断开节点不会删除，并且节点名称会有序增加
    */
    PERSISTENT_SEQUENTIAL (2, false, true, false, false),
    /**
     * 临时节点，客户端断开链接就会自动删除
     */
    EPHEMERAL (1, true, false, false, false),
    /**
     * 临时节点，客户端断开链接就会自动删除，并且节点名称会有序增加
     */
    EPHEMERAL_SEQUENTIAL (3, true, true, false, false),
    /**
     * 作为容器节点，作为选举时的leader节点或者锁之类的。如果子节点被删除也会自动被删除
     */
    CONTAINER (4, false, false, true, false),
    /**
     * 持久节点，如果没有在给定的ttl内修改节点，一旦没有子节点就会被删除
     */
    PERSISTENT_WITH_TTL(5, false, false, false, true),
    /**
     * 持久有序节点，如果没有在给定的ttl内修改节点，一旦没有子节点就会被删除
     */
    PERSISTENT_SEQUENTIAL_WITH_TTL(6, false, true, false, true);

import org.apache.zookeeper.CreateMode;
import org.apache.zookeeper.KeeperException;
import org.apache.zookeeper.ZooDefs;
import org.apache.zookeeper.ZooKeeper;
import org.apache.zookeeper.data.Stat;


public class InternalsDriver {
    public String createNode(ZooKeeper zkClient, String path, String basePath) {
        String createdPath = null;
        try {
          /** 判断根节点是否存在 没有则创建**/
            Stat exists = zkClient.exists(basePath, false);
            if (exists == null) {
                zkClient.create(basePath, null, ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
            }
            createdPath = zkClient.create("/locks/lock-", null, ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL_SEQUENTIAL);
        } catch (KeeperException e) {
            e.printStackTrace();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        return createdPath.substring(createdPath.lastIndexOf("/") + 1);
    }
}

private List<String> getSortedChildren() {
        List<String> sortedList = null;
        try {
            List<String> children = zkClient.getChildren(basePath, false);
            sortedList = new ArrayList<>(children);
            Collections.sort(sortedList, new Comparator<String>() {
                @Override
                public int compare(String lhs, String rhs) {
                    return getLockNumber(lhs, LOCK_NAME).compareTo(getLockNumber(rhs, LOCK_NAME));
                }
            });
        } catch (KeeperException | InterruptedException e) {
            e.printStackTrace();
        }
        return sortedList;
}

public static void main(String[] args) throws IOException {
        // 创建es客户端
        RestHighLevelClient client = new RestHighLevelClient(
                RestClient.builder(
                        new HttpHost("127.0.0.1", 9200, "http")));

        // 关闭客户端
        client.close();

}

// 创建索引
CreateIndexResponse order = client.indices().create(new CreateIndexRequest("order"), RequestOptions.DEFAULT);
// 创建结果
boolean acknowledged = order.isAcknowledged();

System.out.println("创建结果： " + (acknowledged ? "成功": "失败"));

// 查询索引
GetIndexResponse order = client.indices().get(new GetIndexRequest("order"), RequestOptions.DEFAULT);
// 打印相关信息; 索引的别名、结构、设置信息
System.out.println(order.getAliases());
System.out.println(order.getMappings());
System.out.println(order.getSettings());