From f9688cb059e76fd976a76d36f716a9ceb2044efb Mon Sep 17 00:00:00 2001
From: licc168 <liccwork@126.com>
Date: Thu, 4 Jan 2018 14:19:04 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E4=BA=86=20=E6=A0=B9?=
 =?UTF-8?q?=E6=8D=AE=E9=80=9A=E8=BF=87httpclint=E6=96=B9=E5=BC=8F=E6=A0=B9?=
 =?UTF-8?q?=E6=8D=AEip=E8=8E=B7=E5=8F=96=E7=8E=AF=E5=A2=83=E5=8A=9F?=
 =?UTF-8?q?=E8=83=BD?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 dove-config-admin/pom.xml                     |   2 +-
 .../licc/dove/security/UserDetailService.java |   8 +-
 .../dove/service/DoveConfigAppService.java    |  12 +-
 .../dove/service/DoveConfigEnvIpService.java  |  16 +-
 .../service/DoveConfigPropertiesService.java  |   9 +-
 .../com/licc/dove/service/MenuService.java    |   4 +-
 .../com/licc/dove/service/UserService.java    |   2 +-
 .../service/base/impl/BaseServiceImpl.java    |   3 +-
 .../licc/dove/vo/DoveConfigPropertiesVO.java  |   2 +-
 .../mapper/DoveConfigPropertiesMapper.xml     |   4 +-
 .../resources/public/js/config/properties.js  |   1 +
 .../thymeleaf/config/appPropertiesList.html   |   1 +
 .../java/com/licc/dove/ConfigProperties.java  |  33 ++
 .../licc/dove/SpringBootWebApplication.java   |   1 -
 .../licc/dove/config/service/ApiService.java  |  41 ++
 dove-spring-boot-starter/pom.xml              |  14 +-
 .../loader/CustomPropertySourceLocator.java   |  53 ++-
 .../licc/dove/loader/util/HttpClientUtil.java | 369 ++++++++++++++++++
 18 files changed, 522 insertions(+), 53 deletions(-)
 create mode 100644 dove-config-client/src/main/java/com/licc/dove/ConfigProperties.java
 create mode 100644 dove-config-server/src/main/java/com/licc/dove/config/service/ApiService.java
 create mode 100644 dove-spring-boot-starter/src/main/java/com/licc/dove/loader/util/HttpClientUtil.java

diff --git a/dove-config-admin/pom.xml b/dove-config-admin/pom.xml
index fa933fa..a2c6700 100644
--- a/dove-config-admin/pom.xml
+++ b/dove-config-admin/pom.xml
@@ -123,7 +123,7 @@
 		<dependency>
 			<groupId>org.springframework.boot</groupId>
 			<artifactId>spring-boot-starter-tomcat</artifactId>
-			<scope>provided</scope>
+			<scope>compile</scope>
 		</dependency>
 		<dependency>
 			<groupId>com.licc.dove</groupId>
diff --git a/dove-config-admin/src/main/java/com/licc/dove/security/UserDetailService.java b/dove-config-admin/src/main/java/com/licc/dove/security/UserDetailService.java
index 800859e..8783f50 100644
--- a/dove-config-admin/src/main/java/com/licc/dove/security/UserDetailService.java
+++ b/dove-config-admin/src/main/java/com/licc/dove/security/UserDetailService.java
@@ -1,11 +1,8 @@
 package com.licc.dove.security;
 
-import com.licc.dove.domain.User;
-import com.licc.dove.service.UserService;
-
-
 import java.util.ArrayList;
 import java.util.List;
+
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.security.authentication.BadCredentialsException;
 import org.springframework.security.core.GrantedAuthority;
@@ -15,6 +12,9 @@
 import org.springframework.security.core.userdetails.UsernameNotFoundException;
 import org.springframework.stereotype.Service;
 
+import com.licc.dove.domain.User;
+import com.licc.dove.service.UserService;
+
 
 /**
  * @author Jonsy
diff --git a/dove-config-admin/src/main/java/com/licc/dove/service/DoveConfigAppService.java b/dove-config-admin/src/main/java/com/licc/dove/service/DoveConfigAppService.java
index 53e1eaf..613c9e2 100644
--- a/dove-config-admin/src/main/java/com/licc/dove/service/DoveConfigAppService.java
+++ b/dove-config-admin/src/main/java/com/licc/dove/service/DoveConfigAppService.java
@@ -1,17 +1,17 @@
 package com.licc.dove.service;
 
+import java.util.List;
+
+import javax.annotation.Resource;
+
+import org.springframework.stereotype.Service;
+
 import com.licc.dove.dao.CommonDao;
 import com.licc.dove.dao.Page;
-import com.licc.dove.dao.ParamMap;
 import com.licc.dove.domain.DoveConfigApp;
 import com.licc.dove.param.DoveConfigAppParam;
-import com.licc.dove.param.PageParam;
 import com.licc.dove.service.base.impl.BaseServiceImpl;
 import com.licc.dove.util.BeanMapper;
-import com.licc.dove.vo.MenuVO;
-import java.util.List;
-import javax.annotation.Resource;
-import org.springframework.stereotype.Service;
 
 /**
  * @author  lichangchao
diff --git a/dove-config-admin/src/main/java/com/licc/dove/service/DoveConfigEnvIpService.java b/dove-config-admin/src/main/java/com/licc/dove/service/DoveConfigEnvIpService.java
index 6c1410f..0b01763 100644
--- a/dove-config-admin/src/main/java/com/licc/dove/service/DoveConfigEnvIpService.java
+++ b/dove-config-admin/src/main/java/com/licc/dove/service/DoveConfigEnvIpService.java
@@ -1,22 +1,16 @@
 package com.licc.dove.service;
 
-import com.licc.dove.dao.ParamMap;
-import com.licc.dove.domain.DoveConfigEnvIp;
-import com.licc.dove.param.DoveConfigEnvIpParam;
-import com.licc.dove.vo.DoveConfigEnvIpVO;
-import com.licc.dove.vo.DoveConfigPropertiesVO;
-import java.util.List;
-
 import javax.annotation.Resource;
 
 import org.springframework.stereotype.Service;
 
 import com.licc.dove.dao.CommonDao;
 import com.licc.dove.dao.Page;
-import com.licc.dove.domain.DoveConfigEnv;
-import com.licc.dove.param.DoveConfigEnvParam;
+import com.licc.dove.dao.ParamMap;
+import com.licc.dove.domain.DoveConfigEnvIp;
+import com.licc.dove.param.DoveConfigEnvIpParam;
 import com.licc.dove.service.base.impl.BaseServiceImpl;
-import com.licc.dove.util.BeanMapper;
+import com.licc.dove.vo.DoveConfigEnvIpVO;
 
 /**
  * @author  lichangchao
@@ -36,4 +30,6 @@ public Page<DoveConfigEnvIpVO> page(DoveConfigEnvIpParam param) {
   }
 
 
+
+
 }
diff --git a/dove-config-admin/src/main/java/com/licc/dove/service/DoveConfigPropertiesService.java b/dove-config-admin/src/main/java/com/licc/dove/service/DoveConfigPropertiesService.java
index 16b5dac..6336ca1 100644
--- a/dove-config-admin/src/main/java/com/licc/dove/service/DoveConfigPropertiesService.java
+++ b/dove-config-admin/src/main/java/com/licc/dove/service/DoveConfigPropertiesService.java
@@ -1,17 +1,16 @@
 package com.licc.dove.service;
 
+import javax.annotation.Resource;
+
+import org.springframework.stereotype.Service;
+
 import com.licc.dove.dao.CommonDao;
 import com.licc.dove.dao.Page;
 import com.licc.dove.dao.ParamMap;
-import com.licc.dove.domain.DoveConfigApp;
 import com.licc.dove.domain.DoveConfigPropertie;
-import com.licc.dove.param.DoveConfigAppParam;
 import com.licc.dove.param.DoveConfigPropertieParam;
 import com.licc.dove.service.base.impl.BaseServiceImpl;
-import com.licc.dove.util.BeanMapper;
 import com.licc.dove.vo.DoveConfigPropertiesVO;
-import javax.annotation.Resource;
-import org.springframework.stereotype.Service;
 
 /**
  * 配置中心-属性管理
diff --git a/dove-config-admin/src/main/java/com/licc/dove/service/MenuService.java b/dove-config-admin/src/main/java/com/licc/dove/service/MenuService.java
index 1bfd8dc..f7efb00 100644
--- a/dove-config-admin/src/main/java/com/licc/dove/service/MenuService.java
+++ b/dove-config-admin/src/main/java/com/licc/dove/service/MenuService.java
@@ -1,7 +1,5 @@
 package com.licc.dove.service;
 
-import com.licc.dove.dao.Order.Direction;
-import com.licc.dove.dao.ParamMap;
 import java.util.List;
 
 import javax.annotation.Resource;
@@ -12,7 +10,9 @@
 import com.google.common.collect.Lists;
 import com.licc.dove.dao.CommonDao;
 import com.licc.dove.dao.Order;
+import com.licc.dove.dao.Order.Direction;
 import com.licc.dove.dao.Page;
+import com.licc.dove.dao.ParamMap;
 import com.licc.dove.domain.Menu;
 import com.licc.dove.param.PageParam;
 import com.licc.dove.service.base.impl.BaseServiceImpl;
diff --git a/dove-config-admin/src/main/java/com/licc/dove/service/UserService.java b/dove-config-admin/src/main/java/com/licc/dove/service/UserService.java
index 786cb79..044a3af 100644
--- a/dove-config-admin/src/main/java/com/licc/dove/service/UserService.java
+++ b/dove-config-admin/src/main/java/com/licc/dove/service/UserService.java
@@ -1,7 +1,6 @@
 package com.licc.dove.service;
 
 
-import com.licc.dove.dao.CommonDao;
 import java.util.Date;
 import java.util.List;
 
@@ -12,6 +11,7 @@
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.util.CollectionUtils;
 
+import com.licc.dove.dao.CommonDao;
 import com.licc.dove.domain.User;
 import com.licc.dove.param.UserParam;
 import com.licc.dove.service.base.impl.BaseServiceImpl;
diff --git a/dove-config-admin/src/main/java/com/licc/dove/service/base/impl/BaseServiceImpl.java b/dove-config-admin/src/main/java/com/licc/dove/service/base/impl/BaseServiceImpl.java
index 513c6aa..b401aa7 100644
--- a/dove-config-admin/src/main/java/com/licc/dove/service/base/impl/BaseServiceImpl.java
+++ b/dove-config-admin/src/main/java/com/licc/dove/service/base/impl/BaseServiceImpl.java
@@ -21,7 +21,8 @@ public  class BaseServiceImpl<T> implements IBaseService<T>  {
   CommonDao commonDao;
   @Override
   public void deleteById(Long id) {
-    commonDao.delete(id);
+    T t = commonDao.get(DTOClass,id);
+    commonDao.delete(t);
   }
 
   @Override
diff --git a/dove-config-admin/src/main/java/com/licc/dove/vo/DoveConfigPropertiesVO.java b/dove-config-admin/src/main/java/com/licc/dove/vo/DoveConfigPropertiesVO.java
index 7fe6d5a..56cca06 100644
--- a/dove-config-admin/src/main/java/com/licc/dove/vo/DoveConfigPropertiesVO.java
+++ b/dove-config-admin/src/main/java/com/licc/dove/vo/DoveConfigPropertiesVO.java
@@ -23,5 +23,5 @@ public class DoveConfigPropertiesVO {
 
   String appName;
   String appProfile;
-
+  String appLable;
 }
diff --git a/dove-config-admin/src/main/resources/mybatis/mapper/DoveConfigPropertiesMapper.xml b/dove-config-admin/src/main/resources/mybatis/mapper/DoveConfigPropertiesMapper.xml
index b97740c..1d79837 100644
--- a/dove-config-admin/src/main/resources/mybatis/mapper/DoveConfigPropertiesMapper.xml
+++ b/dove-config-admin/src/main/resources/mybatis/mapper/DoveConfigPropertiesMapper.xml
@@ -9,6 +9,8 @@
     <result column="pro_value" property="proValue" jdbcType="VARCHAR"/>
     <result column="appName" property="appName" jdbcType="VARCHAR"/>
     <result column="appProfile" property="appProfile" jdbcType="VARCHAR"/>
+    <result column="appLable" property="appLable" jdbcType="VARCHAR"/>
+
   </resultMap>
   <sql id="Base_Column_List">
     t.id  ,  t.config_app_id  , t.pro_key, t.pro_value
@@ -17,7 +19,7 @@
   <select id="findList" parameterType="Object" resultMap="BaseResultMap">
     SELECT
     <include refid="Base_Column_List"/>
-    ,t1.application as appName,t1.profile as appProfile
+    ,t1.application as appName,t1.profile as appProfile,t1.lable as appLable
     from dove_config_propertie t,dove_config_app t1
     where t.delete_flag = 0 and t1.delete_flag = 0 and t.config_app_id = t1.id
     <if test="appName != null and appName != ''">
diff --git a/dove-config-admin/src/main/resources/public/js/config/properties.js b/dove-config-admin/src/main/resources/public/js/config/properties.js
index 15d246c..562e1ee 100644
--- a/dove-config-admin/src/main/resources/public/js/config/properties.js
+++ b/dove-config-admin/src/main/resources/public/js/config/properties.js
@@ -5,6 +5,7 @@ var options = {
   "aoColumns": [
     { data: 'appName' },
     { data: 'appProfile' },
+    { data: 'appLable' },
     { data: 'proKey' },
     { data: 'proValue' },
     { data: null,"bSortable": false, "mRender":function(data,type,full){
diff --git a/dove-config-admin/src/main/resources/public/thymeleaf/config/appPropertiesList.html b/dove-config-admin/src/main/resources/public/thymeleaf/config/appPropertiesList.html
index 7406e8f..d50994c 100644
--- a/dove-config-admin/src/main/resources/public/thymeleaf/config/appPropertiesList.html
+++ b/dove-config-admin/src/main/resources/public/thymeleaf/config/appPropertiesList.html
@@ -64,6 +64,7 @@ <h3 class="header smaller lighter blue"></h3>
                               <tr>
                                   <th>应用名称</th>
                                   <th>应用环境</th>
+                                  <th>标签</th>
                                   <th>属性名</th>
                                    <th>属性值</th>
                                    <th>操作</th>
diff --git a/dove-config-client/src/main/java/com/licc/dove/ConfigProperties.java b/dove-config-client/src/main/java/com/licc/dove/ConfigProperties.java
new file mode 100644
index 0000000..9e5c06f
--- /dev/null
+++ b/dove-config-client/src/main/java/com/licc/dove/ConfigProperties.java
@@ -0,0 +1,33 @@
+package com.licc.dove;
+
+import org.springframework.boot.context.properties.ConfigurationProperties;
+
+/**
+ * 自定义属性
+ * 
+ * @author lichangchao
+ * @version 1.0.0
+ * @date 2018/1/4 9:55
+ * @see
+ */
+@ConfigurationProperties(prefix = "config", ignoreUnknownFields = false)
+public class ConfigProperties {
+    private final Mail mail = new Mail();
+
+    public Mail getMail() {
+        return mail;
+    }
+
+    public static class Mail {
+
+        private String from = "tuxAdmin@localhost";
+
+        public String getFrom() {
+            return from;
+        }
+
+        public void setFrom(String from) {
+            this.from = from;
+        }
+    }
+}
diff --git a/dove-config-client/src/main/java/com/licc/dove/SpringBootWebApplication.java b/dove-config-client/src/main/java/com/licc/dove/SpringBootWebApplication.java
index 5b8073e..4718e51 100644
--- a/dove-config-client/src/main/java/com/licc/dove/SpringBootWebApplication.java
+++ b/dove-config-client/src/main/java/com/licc/dove/SpringBootWebApplication.java
@@ -4,7 +4,6 @@
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 
 @SpringBootApplication
-
 public class SpringBootWebApplication {
 
 	public static void main(String[] args) throws Exception {
diff --git a/dove-config-server/src/main/java/com/licc/dove/config/service/ApiService.java b/dove-config-server/src/main/java/com/licc/dove/config/service/ApiService.java
new file mode 100644
index 0000000..6df6a35
--- /dev/null
+++ b/dove-config-server/src/main/java/com/licc/dove/config/service/ApiService.java
@@ -0,0 +1,41 @@
+package com.licc.dove.config.service;
+
+import com.licc.dove.config.domin.DoveConfigEnv;
+import com.licc.dove.config.domin.DoveConfigEnvIp;
+import com.licc.dove.dao.CommonDao;
+import java.util.List;
+import javax.annotation.Resource;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+import org.springframework.util.CollectionUtils;
+
+/**
+ *
+ * @author lichangchao
+ * @version 1.0.0
+ * @date 2018/1/4 13:45
+ * @see
+ */
+@Service
+@Transactional
+public class ApiService {
+  @Resource
+  CommonDao commonDao;
+  /**
+   * 通过IP获取当前环境
+   * @param ip
+   * @return
+   */
+  public  String getProfileByIp(String ip){
+    DoveConfigEnvIp env = new DoveConfigEnvIp();
+    env.setDeleteFlag(false);
+    env.setIp(ip);
+    List<DoveConfigEnvIp> list = commonDao.listByExample(env);
+    if(CollectionUtils.isEmpty(list))return "dev";
+    DoveConfigEnvIp envIp =  list.get(0);
+    Long envId = envIp.getConfigEnvId();
+    DoveConfigEnv doveConfigEnv = commonDao.get(DoveConfigEnv.class,envId);
+    if(doveConfigEnv==null) return "dev";
+    return doveConfigEnv.getProfile();
+  }
+}
diff --git a/dove-spring-boot-starter/pom.xml b/dove-spring-boot-starter/pom.xml
index 33cde16..db2e0fd 100644
--- a/dove-spring-boot-starter/pom.xml
+++ b/dove-spring-boot-starter/pom.xml
@@ -29,10 +29,7 @@
 			<groupId>org.springframework.boot</groupId>
 			<artifactId>spring-boot-starter</artifactId>
 		</dependency>
-		<dependency>
-			<groupId>org.springframework.boot</groupId>
-			<artifactId>spring-boot-starter-jdbc</artifactId>
-		</dependency>
+
 
 
 
@@ -48,6 +45,15 @@
 			<version>4.3.5.RELEASE</version>
 		</dependency>
 
+		<dependency>
+			<groupId>org.apache.httpcomponents</groupId>
+			<artifactId>httpclient</artifactId>
+		</dependency>
+		<dependency>
+			<groupId>org.apache.commons</groupId>
+			<artifactId>commons-lang3</artifactId>
+			<version>3.5</version>
+		</dependency>
 
 
 	</dependencies>
diff --git a/dove-spring-boot-starter/src/main/java/com/licc/dove/loader/CustomPropertySourceLocator.java b/dove-spring-boot-starter/src/main/java/com/licc/dove/loader/CustomPropertySourceLocator.java
index b55b32c..ef995eb 100644
--- a/dove-spring-boot-starter/src/main/java/com/licc/dove/loader/CustomPropertySourceLocator.java
+++ b/dove-spring-boot-starter/src/main/java/com/licc/dove/loader/CustomPropertySourceLocator.java
@@ -13,6 +13,8 @@
 import org.springframework.core.env.PropertySource;
 import org.springframework.web.context.support.StandardServletEnvironment;
 
+import com.licc.dove.loader.util.HttpClientUtil;
+
 /**
  * 通过当前机器的IP自动改变该项目的环境变量
  */
@@ -20,32 +22,51 @@
 @Order(-1)
 @ConditionalOnProperty("spring.cloud.config.custom")
 public class CustomPropertySourceLocator implements PropertySourceLocator {
-   private  final static String Cloud_Config = "spring.cloud.config.";
+    private final static String Cloud_Config = "spring.cloud.config.";
+
     @Override
     public PropertySource<?> locate(Environment environment) {
 
         MutablePropertySources propertySources = ((StandardServletEnvironment) environment).getPropertySources();
         updateBootstrap(propertySources);
-        Map<String,Object> customMap =  new HashMap<>();
-        return new MapPropertySource("custom",customMap);
+        Map<String, Object> customMap = new HashMap<>();
+        return new MapPropertySource("custom", customMap);
     }
 
     /**
-     * @author  lichangchao
-     * @time  2017-12-22
-     * 修改默认的cloud config配置
+     * 通过当前服务器IP获取环境
+     * 
+     * @param propertySources
+     * @return
      */
-    private void  updateBootstrap(MutablePropertySources propertySources){
-        PropertySource<?> bootstartp =  propertySources.get("applicationConfig: [classpath:/bootstrap.yml]");
-        propertySources.remove("applicationConfig: [classpath:/bootstrap.yml]");
-        Map<String, Object> source = new HashMap<>();
-        source.put(Cloud_Config+"profile", "test");
-        source.put(Cloud_Config+"name",bootstartp.getProperty(Cloud_Config+"name"));
-        source.put(Cloud_Config+"uri",bootstartp.getProperty(Cloud_Config+"uri"));
-        source.put(Cloud_Config+"label",bootstartp.getProperty(Cloud_Config+"label"));
-        propertySources.addLast(new MapPropertySource("applicationConfig: [classpath:/bootstrap.yml]",source));
-     }
+    private String getProfileByIp(MutablePropertySources propertySources, String serverUri) {
+        PropertySource<?> bootstartp = propertySources.get("springCloudClientHostInfo");
+        String ip = (String) bootstartp.getProperty("spring.cloud.client.ipAddress");
+        try {
+            Map<String, String> params = new HashMap<>();
+            params.put("ip", ip);
+            String profile = HttpClientUtil.get(serverUri + "/api/getProfileByIp", params);
+            return profile;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return "";
+        }
 
+    }
 
+    /**
+     * @author lichangchao
+     * @time 2017-12-22 修改默认的cloud config配置
+     */
+    private void updateBootstrap(MutablePropertySources propertySources) {
+        PropertySource<?> bootstartp = propertySources.get("applicationConfig: [classpath:/bootstrap.yml]");
+        propertySources.remove("applicationConfig: [classpath:/bootstrap.yml]");
+        Map<String, Object> source = new HashMap<>();
+        source.put(Cloud_Config + "name", bootstartp.getProperty(Cloud_Config + "name"));
+        source.put(Cloud_Config + "uri", bootstartp.getProperty(Cloud_Config + "uri"));
+        source.put(Cloud_Config + "label", bootstartp.getProperty(Cloud_Config + "label"));
+        source.put(Cloud_Config + "profile", getProfileByIp(propertySources, (String) bootstartp.getProperty(Cloud_Config + "uri")));
+        propertySources.addLast(new MapPropertySource("applicationConfig: [classpath:/bootstrap.yml]", source));
+    }
 
 }
\ No newline at end of file
diff --git a/dove-spring-boot-starter/src/main/java/com/licc/dove/loader/util/HttpClientUtil.java b/dove-spring-boot-starter/src/main/java/com/licc/dove/loader/util/HttpClientUtil.java
new file mode 100644
index 0000000..1bc3f0c
--- /dev/null
+++ b/dove-spring-boot-starter/src/main/java/com/licc/dove/loader/util/HttpClientUtil.java
@@ -0,0 +1,369 @@
+package com.licc.dove.loader.util;
+
+import java.io.IOException;
+import java.nio.charset.Charset;
+import java.security.cert.CertificateException;
+import java.security.cert.X509Certificate;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+
+import javax.net.ssl.HostnameVerifier;
+import javax.net.ssl.SSLContext;
+
+import org.apache.commons.lang3.StringUtils;
+import org.apache.http.HttpEntity;
+import org.apache.http.HttpHost;
+import org.apache.http.HttpResponse;
+import org.apache.http.NameValuePair;
+import org.apache.http.client.ClientProtocolException;
+import org.apache.http.client.ResponseHandler;
+import org.apache.http.client.ServiceUnavailableRetryStrategy;
+import org.apache.http.client.config.RequestConfig;
+import org.apache.http.client.entity.UrlEncodedFormEntity;
+import org.apache.http.client.methods.HttpGet;
+import org.apache.http.client.methods.HttpPost;
+import org.apache.http.client.methods.HttpUriRequest;
+import org.apache.http.client.utils.URLEncodedUtils;
+import org.apache.http.config.ConnectionConfig;
+import org.apache.http.config.Registry;
+import org.apache.http.config.RegistryBuilder;
+import org.apache.http.conn.HttpClientConnectionManager;
+import org.apache.http.conn.socket.ConnectionSocketFactory;
+import org.apache.http.conn.socket.LayeredConnectionSocketFactory;
+import org.apache.http.conn.socket.PlainConnectionSocketFactory;
+import org.apache.http.conn.ssl.NoopHostnameVerifier;
+import org.apache.http.conn.ssl.SSLConnectionSocketFactory;
+import org.apache.http.entity.ContentType;
+import org.apache.http.impl.client.CloseableHttpClient;
+import org.apache.http.impl.client.DefaultServiceUnavailableRetryStrategy;
+import org.apache.http.impl.client.HttpClientBuilder;
+import org.apache.http.impl.client.HttpClients;
+import org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
+import org.apache.http.message.BasicNameValuePair;
+import org.apache.http.ssl.SSLContexts;
+import org.apache.http.ssl.TrustStrategy;
+import org.apache.http.util.EntityUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+/**
+ * Apache Httpclient 工具包装类 <br>
+ * required httpclient-4.3
+ *
+ * @author jiucai
+ */
+public class HttpClientUtil {
+
+    public static final String CHARSET_UTF8 = "UTF-8";
+
+    protected static Logger logger = LoggerFactory.getLogger(HttpClientUtil.class);
+
+    // 使用ResponseHandler接口处理响应，HttpClient使用ResponseHandler会自动管理连接的释放，解决了对连接的释放管理
+    private static ResponseHandler<String> responseHandler = new ResponseHandler<String>() {
+        // 自定义响应处理
+        @Override
+        public String handleResponse(HttpResponse response)
+                throws ClientProtocolException, IOException {
+
+            int code = response.getStatusLine().getStatusCode();
+
+            // 如果不是200，则返回状态码
+            // if (HttpStatus.SC_OK <= code && code < 500) {
+
+            if (code < 200 || code >= 500) {
+                return String.valueOf(code);
+            }
+
+            HttpEntity entity = response.getEntity();
+            if (entity != null) {
+                Charset charset = ContentType.getOrDefault(entity).getCharset();
+                if (null != charset) {
+                    return new String(EntityUtils.toByteArray(entity), charset);
+                } else {
+                    return new String(EntityUtils.toByteArray(entity));
+                }
+
+            } else {
+                return null;
+            }
+        }
+    };
+
+    /**
+     * 释放HttpClient连接
+     *
+     * @param hrb
+     *            请求对象
+     * @param httpclient
+     *            对象
+     */
+    public static void abortConnection(final HttpUriRequest hrb,
+            final CloseableHttpClient httpclient) {
+        if (hrb != null) {
+            hrb.abort();
+        }
+        if (httpclient != null) {
+            // httpclient.getConnectionManager().shutdown();
+            try {
+                // logger.debug("closing httpclient ...");
+                httpclient.close();
+            } catch (IOException e) {
+                logger.error("failed to close httpclient", e);
+            }
+
+        }
+    }
+
+    /**
+     * Get方式提交,URL中包含查询参数
+     *
+     * @param url
+     *            提交地址
+     * @return 响应消息
+     */
+    public static String get(String url) {
+        return get(url, null, CHARSET_UTF8);
+    }
+
+    /**
+     * Get方式提交,URL中不包含查询参数
+     *
+     * @param url
+     *            提交地址
+     * @param params
+     *            查询参数集, 键/值对
+     * @return 响应消息
+     */
+    public static String get(String url, Map<String, String> params) {
+        return get(url, params, CHARSET_UTF8);
+    }
+
+    /**
+     * Get方式提交,URL中不包含查询参数
+     *
+     * @param url
+     *            提交地址
+     * @param params
+     *            查询参数集, 键/值对
+     * @param charset
+     *            参数提交编码集
+     * @return 响应消息
+     */
+    public static String get(String url, Map<String, String> params, String charset) {
+
+        return get(url, params, charset, getHttpClient(charset));
+    }
+
+    public static String get(String url, Map<String, String> params, String charset,
+            CloseableHttpClient client) {
+        if (url == null || StringUtils.isEmpty(url)) {
+            return null;
+        }
+        List<NameValuePair> qparams = getParamsList(params);
+        if (qparams != null && qparams.size() > 0) {
+            charset = (charset == null ? CHARSET_UTF8 : charset);
+            String formatParams = URLEncodedUtils.format(qparams, charset);
+            url = (url.indexOf("?")) < 0 ? (url + "?" + formatParams)
+                    : (url.substring(0, url.indexOf("?") + 1) + formatParams);
+        }
+        HttpGet hg = new HttpGet(url);
+        // 发送请求，得到响应
+        String responseStr = null;
+        try {
+            responseStr = client.execute(hg, responseHandler);
+        } catch (ClientProtocolException e) {
+            throw new RuntimeException("客户端连接协议错误", e);
+        } catch (IOException e) {
+            throw new RuntimeException("IO操作异常", e);
+        } finally {
+            abortConnection(hg, client);
+        }
+        return responseStr;
+    }
+
+    public static HttpClientConnectionManager getConnectionManager() {
+
+        // ConnectionSocketFactory plainsf = null;
+        LayeredConnectionSocketFactory sslsf = null;
+
+        RegistryBuilder<ConnectionSocketFactory> registryBuilder = RegistryBuilder.create();
+
+        PlainConnectionSocketFactory plainsf = PlainConnectionSocketFactory.getSocketFactory();
+        registryBuilder.register("http", plainsf);
+
+        try {
+
+            // Trust own CA and all self-signed certs
+            SSLContext sslcontext = SSLContexts.custom().loadTrustMaterial(new TrustStrategy() {
+                @Override
+                public boolean isTrusted(X509Certificate[] chain, String authType)
+                        throws CertificateException {
+                    return true;
+                }
+            }).build();
+
+            HostnameVerifier allowAllHostnameVerifier = NoopHostnameVerifier.INSTANCE;
+            sslsf = new SSLConnectionSocketFactory(sslcontext, allowAllHostnameVerifier);
+
+            registryBuilder.register("https", sslsf);
+
+        } catch (Throwable e) {
+
+            logger.error("https ssl init failed", e);
+        }
+
+        Registry<ConnectionSocketFactory> r = registryBuilder.build();
+
+        PoolingHttpClientConnectionManager connManager = new PoolingHttpClientConnectionManager(r);
+        connManager.setMaxTotal(100);// 连接池最大并发连接数
+        connManager.setDefaultMaxPerRoute(100);// 单路由最大并发数
+        return connManager;
+
+    }
+
+    /**
+     * 获取HttpClient实例
+     *
+     * @param charset
+     *            参数编码集, 可空
+     * @return HttpClient 对象
+     */
+    public static CloseableHttpClient getHttpClient(final String charset) {
+        return getHttpClientBuilder(charset, null, 0).build();
+
+    }
+
+    public static HttpClientBuilder getHttpClientBuilder(final String charset, String proxyIp,
+            int proxyPort) {
+
+        HttpClientBuilder builder = HttpClients.custom();
+
+        Charset chartset = charset == null ? Charset.forName(CHARSET_UTF8)
+                : Charset.forName(charset);
+        ConnectionConfig.Builder connBuilder = ConnectionConfig.custom().setCharset(chartset);
+
+        RequestConfig.Builder reqBuilder = RequestConfig.custom();
+        reqBuilder.setExpectContinueEnabled(false);
+        reqBuilder.setSocketTimeout(10 * 60 * 1000);
+        reqBuilder.setConnectTimeout(10 * 60 * 1000);
+        reqBuilder.setMaxRedirects(10);
+
+        if (StringUtils.isNotBlank(proxyIp) && proxyPort > 0) {
+            logger.info("using proxy {}:{} to request ", proxyIp, String.valueOf(proxyPort));
+            HttpHost proxy = new HttpHost(proxyIp, proxyPort);
+            reqBuilder.setProxy(proxy);
+        }
+
+        ServiceUnavailableRetryStrategy serviceUnavailableRetryStrategy = new DefaultServiceUnavailableRetryStrategy(
+                3, 3000);
+        builder.setServiceUnavailableRetryStrategy(serviceUnavailableRetryStrategy);
+        // 模拟浏览器，解决一些服务器程序只允许浏览器访问的问题
+        builder.setUserAgent(
+                "Mozilla/5.0 (Windows NT 10.0; Win64; x64; rv:50.0) Gecko/20100101 Firefox/50.0");
+
+        builder.setDefaultRequestConfig(reqBuilder.build());
+        builder.setDefaultConnectionConfig(connBuilder.build());
+        builder.setConnectionManager(getConnectionManager());
+
+        // HostnameVerifier allowAllHostnameVerifier =
+        // NoopHostnameVerifier.INSTANCE;
+        // builder.setSSLHostnameVerifier(allowAllHostnameVerifier);
+
+        return builder;
+
+    }
+
+    /**
+     * 将传入的键/值对参数转换为NameValuePair参数集
+     *
+     * @param paramsMap
+     *            参数集, 键/值对
+     * @return NameValuePair参数集
+     */
+    public static List<NameValuePair> getParamsList(Map<String, String> paramsMap) {
+        if (paramsMap == null || paramsMap.size() == 0) {
+            return null;
+        }
+        List<NameValuePair> params = new ArrayList<NameValuePair>();
+        for (Map.Entry<String, String> map : paramsMap.entrySet()) {
+            params.add(new BasicNameValuePair(map.getKey(), map.getValue()));
+        }
+        return params;
+    }
+
+    /**
+     * Post方式提交,URL中不包含提交参数
+     *
+     * @param url
+     *            提交地址
+     * @param params
+     *            提交参数集, 键/值对
+     * @return 响应消息
+     */
+    public static String post(String url, Map<String, String> params) {
+        return post(url, params, HttpClientUtil.CHARSET_UTF8);
+    }
+
+    /**
+     * Post方式提交,URL中不包含提交参数
+     *
+     * @param url
+     *            提交地址
+     * @param params
+     *            提交参数集, 键/值对
+     * @param charset
+     *            参数提交编码集
+     * @return 响应消息
+     */
+    public static String post(String url, Map<String, String> params, String charset) {
+        return post(url, params, charset, getHttpClient(charset));
+    }
+
+    public static String post(String url, Map<String, String> params, String charset,
+            boolean isSecure) {
+
+        return post(url, params, charset);
+
+    }
+
+    public static String post(String url, Map<String, String> params, String charset,
+            CloseableHttpClient client) {
+        if (url == null || StringUtils.isEmpty(url)) {
+            return null;
+        }
+        UrlEncodedFormEntity formEntity = null;
+        try {
+            if (charset == null || StringUtils.isEmpty(charset)) {
+                if (null != params && params.size() > 0) {
+                    formEntity = new UrlEncodedFormEntity(getParamsList(params));
+                }
+            } else {
+                if (null != params && params.size() > 0) {
+                    formEntity = new UrlEncodedFormEntity(getParamsList(params), charset);
+                }
+            }
+        } catch (Exception e) {
+            throw new RuntimeException("不支持的编码集", e);
+        }
+        HttpPost hp = new HttpPost(url);
+
+        if (null != formEntity) {
+            hp.setEntity(formEntity);
+        }
+
+        // 发送请求，得到响应
+        String responseStr = null;
+        try {
+            responseStr = client.execute(hp, responseHandler);
+        } catch (ClientProtocolException e) {
+            throw new RuntimeException("客户端连接协议错误", e);
+        } catch (IOException e) {
+            throw new RuntimeException("IO操作异常", e);
+        } finally {
+            abortConnection(hp, client);
+        }
+        return responseStr;
+    }
+
+}
\ No newline at end of file