javautil工具类大全

package com.ast.util; import java.io.IOException; import java.net.InetAddress; import java.net.UnknownHostException; import java.util.ArrayList; import java.util.List; import java.util.Map; import java.util.concurrent.ExecutionException; import net.sf.json.JSONObject; import org.apache.commons.lang.StringUtils; import org.elasticsearch.action.admin.indices.delete.DeleteIndexRequest; import org.elasticsearch.action.admin.indices.delete.DeleteIndexResponse; import org.elasticsearch.action.admin.indices.exists.indices.IndicesExistsRequest; import org.elasticsearch.action.admin.indices.exists.indices.IndicesExistsResponse; import org.elasticsearch.action.admin.indices.exists.types.TypesExistsRequest; import org.elasticsearch.action.admin.indices.exists.types.TypesExistsResponse; import org.elasticsearch.action.admin.indices.mapping.put.PutMappingRequest; import org.elasticsearch.action.admin.indices.mapping.put.PutMappingResponse; import org.elasticsearch.action.bulk.BulkRequestBuilder; import org.elasticsearch.action.bulk.BulkResponse; import org.elasticsearch.action.delete.DeleteResponse; import org.elasticsearch.action.deletebyquery.DeleteByQueryAction; import org.elasticsearch.action.deletebyquery.DeleteByQueryRequestBuilder; import org.elasticsearch.action.get.GetResponse; import org.elasticsearch.action.index.IndexRequestBuilder; import org.elasticsearch.action.search.SearchResponse; import org.elasticsearch.action.search.SearchType; import org.elasticsearch.action.update.UpdateRequest; import org.elasticsearch.client.IndicesAdminClient; import org.elasticsearch.client.Requests; import org.elasticsearch.client.transport.TransportClient; import org.elasticsearch.common.settings.Settings; import org.elasticsearch.common.text.Text; import org.elasticsearch.common.transport.InetSocketTransportAddress; import org.elasticsearch.common.xcontent.XContentBuilder; import org.elasticsearch.common.xcontent.XContentFactory; import org.elasticsearch.index.query.QueryBuilder; import org.elasticsearch.index.query.QueryBuilders; import org.elasticsearch.index.query.QueryStringQueryBuilder; import org.elasticsearch.plugin.deletebyquery.DeleteByQueryPlugin; import org.elasticsearch.search.SearchHit; import org.elasticsearch.search.SearchHits; import org.elasticsearch.search.highlight.HighlightField; import com.ast.controller.ElasticSearchHandler; import com.ast.model.Blog; /** * 该类使用原则： try { ESUtil.openClient(); }finally{ ESUtil.closeClient(); } * */ @SuppressWarnings(value = { "unchecked", "rawtypes" }) public class ESUtil { private static final int Return_NotExist = -1;// 不存在 private static final int Return_Failure = 0;// 失败 private static final int Return_Success = 1;// 成功 private static String clusterName = "elasticsearch"; private static final String[] ips = { "192.168.159.128", "192.168.159.129", "192.168.159.131" }; private static final int[] ports = { 9300, 9300, 9300 }; private static boolean clientTransportSniff = true; private static TransportClient client; private static IndicesAdminClient adminClient; /** 取得实例 */ public static synchronized TransportClient getTransportClient() { return client; } /** 打开客户端 */ public static void openClient() throws UnknownHostException { if (client == null) { synchronized (ElasticSearchHandler.class) { if (client == null) { Settings settings = Settings .settingsBuilder() .put("cluster.name", clusterName) .put("client.transport.sniff", clientTransportSniff) .build(); client = TransportClient.builder().settings(settings) .addPlugin(DeleteByQueryPlugin.class)// 批量删除 .build(); for (int i = 0; i < ips.length; i++) { addNode(ips[i], ports[i]); } adminClient = client.admin().indices(); } } } } /** 关闭客户端 */ public static synchronized void closeClient() { if (client != null) { client.close(); } } /** 为集群添加新的节点 */ public static synchronized void addNode(String ip, int port) throws UnknownHostException { client.addTransportAddress(new InetSocketTransportAddress(InetAddress .getByName(ip), port)); } /** 删除集群中的某个节点 */ public static synchronized void removeNode(String ip, int port) throws UnknownHostException { client.removeTransportAddress(new InetSocketTransportAddress( InetAddress.getByName(ip), port)); } /** 创建索引，是否需要覆盖原索引 */ public static synchronized void createIndex(String index, boolean overried) { if (index != null) { boolean exits = adminClient.prepareExists(index).execute() .actionGet().isExists(); if (exits && !overried) { return; } if (exits) { DeleteIndexRequest request = new DeleteIndexRequest(index); adminClient.delete(request).actionGet(); } adminClient.prepareCreate(index).execute().actionGet(); } } // 判断索引是否存在 传入参数为索引库名称 public static synchronized boolean isExistIndex(String index) { boolean bl = false; if (index != null) { IndicesExistsResponse response = adminClient.exists( new IndicesExistsRequest().indices(new String[] { index })) .actionGet(); bl = response.isExists(); } return bl; } /** * 判断指定的索引的类型是否存在 只有同一个 index 的中的 type 都有类似的映射 (mapping) 时，才应该使用 type */ public static synchronized boolean isExistType(String index, String type) { boolean bl = false; if (index != null && type != null) { TypesExistsResponse response = adminClient.typesExists( new TypesExistsRequest(new String[] { index }, type)) .actionGet(); bl = response.isExists(); } return bl; } /** * 没有index则创建;添加数据到Elasticsearch */ public static synchronized boolean saveDocument(String index, String type, String idName, JSONObject json) { List list = new ArrayList(); list.add(json); return saveDocuments(index, type, idName, list); } /** * 没有index则创建 没有指定idName那就让Elasticsearch自动生成id值 * */ public static synchronized boolean saveDocuments(String index, String type, String idName, List listData) { boolean bl = false; if (index != null && type != null && listData != null && listData.size() > 0) { BulkRequestBuilder bulkRequest = client.prepareBulk().setRefresh( true); for (Object object : listData) { JSONObject json = JSONObject.fromObject(object); IndexRequestBuilder lrb = null; if (StringUtils.isBlank(idName)) { lrb = client.prepareIndex(index, type).setSource(json); } else { String idValue = json.optString(idName); lrb = client.prepareIndex(index, type, idValue).setSource( json); } bulkRequest.add(lrb); } BulkResponse bulkResponse = bulkRequest.execute().actionGet(); if (!bulkResponse.hasFailures()) {// 保存成功 bulkRequest = client.prepareBulk(); bl = true; } } return bl; } /** * 创建mapping 访问:http://192.168.159.128:9200/blog/blog/_mapping */ public static synchronized int createMapping(String index, String type, XContentBuilder getMapping) { int i = Return_Failure; if (isExistIndex(index)) {// 必须存在索引库，可以不存在类型 PutMappingRequest mapping = Requests.putMappingRequest(index) .type(type).source(getMapping); PutMappingResponse response = adminClient.putMapping(mapping) .actionGet(); if (response.isAcknowledged()) i = Return_Success; } else { i = Return_NotExist; } return i; } /** * 指定域、类型、分词器 */ public static synchronized XContentBuilder getMapping(String index) throws IOExc