{"id":3785,"date":"2022-10-18T15:29:04","date_gmt":"2022-10-18T07:29:04","guid":{"rendered":"https:\/\/nj.transwarp.cn:8180\/?p=3785"},"modified":"2022-10-18T15:29:04","modified_gmt":"2022-10-18T07:29:04","slug":"java%e8%bf%9e%e6%8e%a5%e5%bc%80%e5%90%af%e5%ae%89%e5%85%a8%e7%9a%84search%e7%bb%84%e4%bb%b6demo","status":"publish","type":"post","link":"https:\/\/kbwp.transwarp.cn\/?p=3785","title":{"rendered":"java\u8fde\u63a5\u5f00\u542f\u5b89\u5168\u7684search\u7ec4\u4ef6demo"},"content":{"rendered":"

\u6982\u8981\u63cf\u8ff0<\/h3>\n
\n

\u4f7f\u7528\u987b\u77e5\uff1a<\/p>\n

    \n
  1. \u672c\u5b9e\u9a8c\u9488\u5bf9TDH6.2.1<\/strong>\u4ee5\u4e0a\u7248\u672c\uff0c\u53ea\u67096.2.1\u4ee5\u4e0a\u7684\u7248\u672c\u624d\u53ef\u4ee5\u5f00\u542fsearch\u7ec4\u4ef6\u5b89\u5168<\/li>\n
  2. \u6b64\u65b9\u5f0f\u662f\u8fde\u63a5\u7684Search\u76849300<\/strong>\u7aef\u53e3<\/li>\n<\/ol>\n

    \u4ee5\u4e0b\u5f00\u53d1\u73af\u5883\u4ee5IDEA + Windows10 + jdk1.8 + Maven3.6.1\u4e3a\u4f8b
    \n\u8bf7\u5b89\u88c5\u597d\u4ee5\u4e0a\u5f00\u53d1\u5de5\u5177<\/p>\n

    \u8be6\u7ec6\u8bf4\u660e<\/h3>\n
    \n

    \u51c6\u5907TDH6.2.1\u7684sdk<\/h4>\n

    \u8bf7\u4e0b\u8f7d\u661f\u73af\u63d0\u4f9b\u7684\u5bf9\u5e94\u7248\u672c\u7684SDK\uff0c\u5e76\u89e3\u538b(\u8054\u7cfb\u661f\u73af\u6280\u672f\u652f\u6301\u83b7\u53d6)
    \n\"file\"<\/p>\n

    \u914d\u7f6eIDEA Maven\u4ed3\u5e93<\/h4>\n

    \u3010File->Settings->Build,Execution,Deployment->Build Tools->Maven\u3011<\/p>\n

    \"file\"<\/p>\n

    \u5c06Local repository\u7684\u5730\u5740\u66f4\u6539\u4e3aSDK\u89e3\u538b\u7684\u4f4d\u7f6e\uff0c\u7136\u540e\u9009\u62e9Apply -> OK<\/p>\n

    pom.xml\u6587\u4ef6\u53c2\u8003\u5982\u4e0b<\/h4>\n

    \"file\"<\/p>\n

    \u6ce8\u610f<\/strong>\uff1a\u5728\u914d\u7f6emaven\u7684\u8fc7\u7a0b\u4e2d\uff0c\u53ef\u80fd\u4f1a\u6709jar\u5305\u4e0d\u5b58\u5728\u7684\u95ee\u9898\uff0c\u6bd4\u5982dnw\u548cnetty-all\u7b49\u5305\uff0c\u8fd9\u4e9b\u5305\u7528\u4e0d\u5230\uff0c\u53ef\u4ee5\u53bb\u9664\u6389
    \n\"file\"<\/p>\n

    demo\u53c2\u8003\u5982\u4e0b<\/h4>\n
    package io.transwarp;\nimport com.alibaba.fastjson.JSON;\nimport io.transwarp.plugin.doorkeeper.client.DoorKeeperClientPlugin;\nimport org.apache.hadoop.conf.Configuration;\nimport org.apache.hadoop.fs.CommonConfigurationKeys;\nimport org.apache.hadoop.security.UserGroupInformation;\nimport transwarp.org.elasticsearch.action.index.IndexResponse;\nimport transwarp.org.elasticsearch.client.Client;\nimport transwarp.org.elasticsearch.client.transport.TransportClient;\nimport transwarp.org.elasticsearch.common.settings.Settings;\nimport transwarp.org.elasticsearch.common.transport.InetSocketTransportAddress;\nimport transwarp.org.elasticsearch.common.xcontent.XContentType;\nimport transwarp.org.elasticsearch.plugins.Plugin;\nimport transwarp.org.elasticsearch.transport.client.PreBuiltTransportClient;\nimport javax.security.auth.login.LoginException;\nimport java.io.IOException;\nimport java.net.InetSocketAddress;\nimport java.util.Collections;\nimport java.util.HashMap;\nimport java.util.Map;\npublic class estest {\n    private static String principal = \"admin\/@TDH\";\n    private static String keytabPath = \"D:\\\\work\\\\idea_home\\\\SecuritySearch\\\\admin.keytab\";\n    private static String indexName = \"my_store\";\n    private static String type = \"products\";\n    public static void main(String[] args) throws IOException, LoginException {\n        initSecurityContext(principal,keytabPath);\n        Client client = buildTransportClient();\n        Map data = new HashMap();\n        \/\/data.put(\"id\", \"5\");\n        data.put(\"price\", \"200\");\n        data.put(\"productID\", \"MMMM-M-3333-#### \");\n        IndexResponse indexResponse = client.prepareIndex(indexName, type, null).setSource(JSON.toJSONString(data), XContentType.JSON).get();\n        System.out.println(indexResponse.toString());\n    }\n    \/**\n     * \u5ba2\u6237\u7aef\u521d\u59cb\u5316\n     * @param principal\n     * @param keytabPath\n     * @throws IOException\n     *\/\n    private static void initSecurityContext(String principal, String keytabPath)\n            throws IOException {\n        System.setProperty(\"java.security.krb5.conf\", \"D:\\\\work\\\\idea_home\\\\SecuritySearch\\\\krb5.conf\");\n        Configuration cnf = new Configuration();\n        cnf.set(CommonConfigurationKeys.HADOOP_SECURITY_AUTHENTICATION, \"kerberos\");\n        UserGroupInformation.setConfiguration(cnf);\n        UserGroupInformation.loginUserFromKeytab(principal, keytabPath);\n    }\n    \/**\n     * \u6784\u5efaTransportClient\n     * @return\n     *\/\n    private static Client buildTransportClient() {\n        Settings settings = Settings.builder()\n                .put(\"cluster.name\", \"cluster\")\n                .put(\"security.enable\", true)\n                .put(\"transport.type\", \"security-netty3\")\n                .build();\n        TransportClient client = new PreBuiltTransportClient(settings, Collections.>singletonList(DoorKeeperClientPlugin.class));\n        String[] hosts = {\"172.22.33.1\", \"172.22.33.2\", \"172.22.33.3\"};\n        for (String host : hosts) {\n            client.addTransportAddress(new InetSocketTransportAddress(new\n                    InetSocketAddress(host, 9300)));\n        }\n        return client;\n    }\n}<\/code><\/pre>\n
    \u6ce8\u610f<\/strong>\uff1a<\/p>\n
      \n
    1. \u66ff\u6362demo\u4e2d\u7684keytab\u6587\u4ef6\u4e3a\u5b9e\u9645\u8def\u5f84<\/li>\n
    2. \u66ff\u6362demo\u4e2d\u7684krb5\u6587\u4ef6\u4e3a\u5b9e\u9645\u8def\u5f84<\/li>\n
    3. \u914d\u7f6e\u5b9e\u9645\u7684host\u4fe1\u606f<\/li>\n<\/ol>\n
      \u66ff\u6362\u5b8c\u6bd5\u4e4b\u540e\uff0c\u53ef\u4ee5\u770b\u5230search\u4e2d\u5df2\u7ecf\u63d2\u5165\u4e86\u6570\u636e\uff1a
      \n\"file\"<\/p>\n","protected":false},"excerpt":{"rendered":"
      \u6982\u8981\u63cf\u8ff0 \u4f7f\u7528\u987b\u77e5\uff1a \u672c\u5b9e\u9a8c\u9488\u5bf9TDH6.2.1\u4ee5\u4e0a\u7248\u672c\uff0c\u53ea\u67096.2.1\u4ee5\u4e0a\u7684\u7248\u672c\u624d\u53ef\u4ee5\u5f00\u542fsearch\u7ec4\u4ef6\u5b89 ..<\/p>\n
      <\/div>\n
      Read more<\/a><\/p>\n","protected":false},"author":14,"featured_media":0,"comment_status":"closed","ping_status":"closed","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[42],"tags":[],"class_list":["post-3785","post","type-post","status-publish","format-standard","hentry","category-api"],"acf":[],"_links":{"self":[{"href":"https:\/\/kbwp.transwarp.cn\/index.php?rest_route=\/wp\/v2\/posts\/3785","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/kbwp.transwarp.cn\/index.php?rest_route=\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/kbwp.transwarp.cn\/index.php?rest_route=\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/kbwp.transwarp.cn\/index.php?rest_route=\/wp\/v2\/users\/14"}],"replies":[{"embeddable":true,"href":"https:\/\/kbwp.transwarp.cn\/index.php?rest_route=%2Fwp%2Fv2%2Fcomments&post=3785"}],"version-history":[{"count":2,"href":"https:\/\/kbwp.transwarp.cn\/index.php?rest_route=\/wp\/v2\/posts\/3785\/revisions"}],"predecessor-version":[{"id":8865,"href":"https:\/\/kbwp.transwarp.cn\/index.php?rest_route=\/wp\/v2\/posts\/3785\/revisions\/8865"}],"wp:attachment":[{"href":"https:\/\/kbwp.transwarp.cn\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=3785"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/kbwp.transwarp.cn\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=3785"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/kbwp.transwarp.cn\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=3785"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}