pom文件
1 <?xml version="1.0" encoding="UTF-8"?>
2 <project xmlns="http://maven.apache.org/POM/4.0.0"
3 xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
4 xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
5 <parent>
6 <groupId>io.guangsoft</groupId>
7 <artifactId>market</artifactId>
8 <version>1.0</version>
9 </parent>
10 <modelVersion>4.0.0</modelVersion>
11
12 <artifactId>market-utils</artifactId>
13 <packaging>jar</packaging>
14
15 <!-- 完成真正的jar包注入 -->
16 <dependencies>
17 <!-- Apache工具组件 -->
18 <dependency>
19 <groupId>commons-net</groupId>
20 <artifactId>commons-net</artifactId>
21 </dependency>
22 <!-- Json处理工具包 -->
23 <dependency>
24 <groupId>com.fasterxml.jackson.core</groupId>
25 <artifactId>jackson-databind</artifactId>
26 </dependency>
27 <dependency>
28 <groupId>com.alibaba</groupId>
29 <artifactId>fastjson</artifactId>
30 </dependency>
31 <!-- httpclient -->
32 <dependency>
33 <groupId>org.apache.httpcomponents</groupId>
34 <artifactId>httpclient</artifactId>
35 </dependency>
36 <!-- Servet api -->
37 <dependency>
38 <groupId>javax.servlet</groupId>
39 <artifactId>javax.servlet-api</artifactId>
40 <scope>provided</scope>
41 </dependency>
42 </dependencies>
43
44 </project>
GResult.java
1 package io.guangsoft.market.util.bean;
2
3 public class GResult {
4
5 //状态码
6 private Integer gCode;
7
8 //状态信息
9 private String gMsg;
10
11 //响应数据
12 private Object gData;
13
14 public GResult() {
15 }
16
17 public GResult(Integer gCode, String gMsg) {
18 this.gCode = gCode;
19 this.gMsg = gMsg;
20 }
21
22 public GResult(Integer gCode, String gMsg, Object gData) {
23 this.gCode = gCode;
24 this.gMsg = gMsg;
25 this.gData = gData;
26 }
27
28 public Integer getgCode() {
29 return gCode;
30 }
31
32 public void setgCode(Integer gCode) {
33 this.gCode = gCode;
34 }
35
36 public String getgMsg() {
37 return gMsg;
38 }
39
40 public void setgMsg(String gMsg) {
41 this.gMsg = gMsg;
42 }
43
44 public Object getgData() {
45 return gData;
46 }
47
48 public void setgData(Object gData) {
49 this.gData = gData;
50 }
51
52 }
GResultUtil.java
1 package io.guangsoft.market.util.utils;
2
3 import com.alibaba.fastjson.JSONObject;
4 import io.guangsoft.market.util.bean.GResult;
5
6 import java.beans.BeanInfo;
7 import java.beans.Introspector;
8 import java.beans.PropertyDescriptor;
9 import java.lang.reflect.Method;
10 import java.util.HashMap;
11 import java.util.Map;
12
13 public class GResultUtil {
14
15 public static GResult success() {
16 return new GResult(0, "操作成功！");
17 }
18
19 public static GResult fail() {
20 return new GResult(1, "操作失败！");
21 }
22
23 public static GResult fail(Integer gCode) {
24 return new GResult(gCode, "操作失败！");
25 }
26
27 public static GResult fail(Integer gCode, String gMsg) {
28 return new GResult(gCode, gMsg);
29 }
30
31 public static GResult build(Integer gCode, String gMsg, Object gData) {
32 return new GResult(gCode, gMsg, gData);
33 }
34
35 /**
36 * 得到JSON格式的结果集
37 */
38 public static JSONObject toJSONResult(GResult gResult) {
39 Map gResultMap = transBean2Map(gResult);
40 return new JSONObject(gResultMap);
41 }
42
43 /**
44 * 使用内省方式将bean转成map
45 */
46 public static Map<String, Object> transBean2Map(Object obj) {
47 if(obj == null){
48 return null;
49 }
50 Map<String, Object> map = new HashMap<String, Object>();
51 try {
52 BeanInfo beanInfo = Introspector.getBeanInfo(obj.getClass());
53 PropertyDescriptor[] propertyDescriptors = beanInfo.getPropertyDescriptors();
54 for (PropertyDescriptor property : propertyDescriptors) {
55 String key = property.getName();
56 // 过滤class属性
57 if (!key.equals("class")) {
58 // 得到property对应的getter方法
59 Method getter = property.getReadMethod();
60 Object value = getter.invoke(obj);
61 map.put(key, value);
62 }
63 }
64 } catch (Exception e) {
65 e.printStackTrace();
66 }
67 return map;
68 }
69 }
CookieUtil.java
1 package io.guangsoft.market.util.utils;
2
3
4 import java.net.URLDecoder;
5 import java.net.URLEncoder;
6
7 import javax.servlet.http.Cookie;
8 import javax.servlet.http.HttpServletRequest;
9 import javax.servlet.http.HttpServletResponse;
10
11 public class CookieUtil {
12
13 /**
14 * 得到Cookie的值, 不编码
15 */
16 public static String getCookieValue(HttpServletRequest request, String cookieName) {
17 return getCookieValue(request, cookieName, false);
18 }
19
20 /**
21 * 得到Cookie的值,
22 */
23 public static String getCookieValue(HttpServletRequest request, String cookieName, boolean isDecoder) {
24 Cookie[] cookieList = request.getCookies();
25 if (cookieList == null || cookieName == null) {
26 return null;
27 }
28 String retValue = null;
29 try {
30 for (int i = 0; i < cookieList.length; i++) {
31 if (cookieList[i].getName().equals(cookieName)) {
32 if (isDecoder) {
33 retValue = URLDecoder.decode(cookieList[i].getValue(), "UTF-8");
34 } else {
35 retValue = cookieList[i].getValue();
36 }
37 break;
38 }
39 }
40 } catch (Exception e) {
41 e.printStackTrace();
42 }
43 return retValue;
44 }
45
46 /**
47 * 得到Cookie的值,
48 */
49 public static String getCookieValue(HttpServletRequest request, String cookieName, String encodeString) {
50 Cookie[] cookieList = request.getCookies();
51 if (cookieList == null || cookieName == null) {
52 return null;
53 }
54 String retValue = null;
55 try {
56 for (int i = 0; i < cookieList.length; i++) {
57 if (cookieList[i].getName().equals(cookieName)) {
58 retValue = URLDecoder.decode(cookieList[i].getValue(), encodeString);
59 break;
60 }
61 }
62 } catch (Exception e) {
63 e.printStackTrace();
64 }
65 return retValue;
66 }
67
68 /**
69 * 设置Cookie的值 不设置生效时间默认浏览器关闭即失效,也不编码
70 */
71 public static void setCookie(HttpServletRequest request, HttpServletResponse response, String cookieName,
72 String cookieValue) {
73 setCookie(request, response, cookieName, cookieValue, -1);
74 }
75
76 /**
77 * 设置Cookie的值 在指定时间内生效,但不编码
78 */
79 public static void setCookie(HttpServletRequest request, HttpServletResponse response, String cookieName,
80 String cookieValue, int cookieMaxage) {
81 setCookie(request, response, cookieName, cookieValue, cookieMaxage, false);
82 }
83
84 /**
85 * 设置Cookie的值 不设置生效时间,但编码
86 */
87 public static void setCookie(HttpServletRequest request, HttpServletResponse response, String cookieName,
88 String cookieValue, boolean isEncode) {
89 setCookie(request, response, cookieName, cookieValue, -1, isEncode);
90 }
91
92 /**
93 * 设置Cookie的值 在指定时间内生效, 编码参数
94 */
95 public static void setCookie(HttpServletRequest request, HttpServletResponse response, String cookieName,
96 String cookieValue, int cookieMaxage, boolean isEncode) {
97 doSetCookie(request, response, cookieName, cookieValue, cookieMaxage, isEncode);
98 }
99
100 /**
101 * 设置Cookie的值 在指定时间内生效, 编码参数(指定编码)
102 */
103 public static void setCookie(HttpServletRequest request, HttpServletResponse response, String cookieName,
104 String cookieValue, int cookieMaxage, String encodeString) {
105 doSetCookie(request, response, cookieName, cookieValue, cookieMaxage, encodeString);
106 }
107
108 /**
109 * 删除Cookie带cookie域名
110 */
111 public static void deleteCookie(HttpServletRequest request, HttpServletResponse response,
112 String cookieName) {
113 doSetCookie(request, response, cookieName, "", -1, false);
114 }
115
116 /**
117 * 设置Cookie的值，并使其在指定时间内生效
118 *
119 * @param cookieMaxage cookie生效的最大秒数
120 */
121 private static final void doSetCookie(HttpServletRequest request, HttpServletResponse response,
122 String cookieName, String cookieValue, int cookieMaxage, boolean isEncode) {
123 try {
124 if (cookieValue == null) {
125 cookieValue = "";
126 } else if (isEncode) {
127 cookieValue = URLEncoder.encode(cookieValue, "utf-8");
128 }
129 Cookie cookie = new Cookie(cookieName, cookieValue);
130 if (cookieMaxage > 0) {
131 cookie.setMaxAge(cookieMaxage);
132 }
133 if (null != request) {// 设置域名的cookie
134 String domainName = getDomainName(request);
135 System.out.println(domainName);
136 if (!"localhost".equals(domainName) && !"127.0.0.1".equals(domainName)) {
137 cookie.setDomain(domainName);
138 }
139 }
140 cookie.setPath("/");
141 response.addCookie(cookie);
142 } catch (Exception e) {
143 e.printStackTrace();
144 }
145 }
146
147 /**
148 * 设置Cookie的值，并使其在指定时间内生效
149 * @param cookieMaxage cookie生效的最大秒数
150 */
151 private static final void doSetCookie(HttpServletRequest request, HttpServletResponse response,
152 String cookieName, String cookieValue, int cookieMaxage, String encodeString) {
153 try {
154 if (cookieValue == null) {
155 cookieValue = "";
156 } else {
157 cookieValue = URLEncoder.encode(cookieValue, encodeString);
158 }
159 Cookie cookie = new Cookie(cookieName, cookieValue);
160 if (cookieMaxage > 0) {
161 cookie.setMaxAge(cookieMaxage);
162 }
163 if (null != request) {// 设置域名的cookie
164 String domainName = getDomainName(request);
165 System.out.println(domainName);
166 if (!"localhost".equals(domainName)) {
167 cookie.setDomain(domainName);
168 }
169 }
170 cookie.setPath("/");
171 response.addCookie(cookie);
172 } catch (Exception e) {
173 e.printStackTrace();
174 }
175 }
176
177 /**
178 * 得到cookie的域名
179 */
180 private static final String getDomainName(HttpServletRequest request) {
181 String domainName = null;
182 String serverName = request.getRequestURL().toString();
183 if (serverName == null || serverName.equals("")) {
184 domainName = "";
185 } else {
186 //http://www.baidu.com/aaa
187 //www.baidu.com.cn/aaa/bb/ccc
188 serverName = serverName.toLowerCase();
189 serverName = serverName.substring(7);
190 final int end = serverName.indexOf("/");
191 serverName = serverName.substring(0, end);
192 final String[] domains = serverName.split("\.");
193 int len = domains.length;
194 if (len > 3) {
195 // www.xxx.com.cn
196 domainName = "." + domains[len - 3] + "." + domains[len - 2] + "." + domains[len - 1];
197 } else if (len <= 3 && len > 1) {
198 // xxx.com or xxx.cn
199 domainName = "." + domains[len - 2] + "." + domains[len - 1];
200 } else {
201 domainName = serverName;
202 }
203 }
204 if (domainName != null && domainName.indexOf(":") > 0) {
205 String[] ary = domainName.split("\:");
206 domainName = ary[0];
207 }
208 return domainName;
209 }
210 }
HttpClientUtil.java
1 package io.guangsoft.market.util.utils;
2
3 import java.io.IOException;
4 import java.io.InterruptedIOException;
5 import java.net.URI;
6 import java.net.UnknownHostException;
7 import java.util.ArrayList;
8 import java.util.List;
9 import java.util.Map.Entry;
10
11 import javax.net.ssl.SSLException;
12 import javax.net.ssl.SSLHandshakeException;
13
14 import org.apache.http.Consts;
15 import org.apache.http.HttpEntity;
16 import org.apache.http.HttpEntityEnclosingRequest;
17 import org.apache.http.HttpRequest;
18 import org.apache.http.HttpResponse;
19 import org.apache.http.NameValuePair;
20 import org.apache.http.NoHttpResponseException;
21 import org.apache.http.client.HttpClient;
22 import org.apache.http.client.HttpRequestRetryHandler;
23 import org.apache.http.client.config.RequestConfig;
24 import org.apache.http.client.entity.UrlEncodedFormEntity;
25 import org.apache.http.client.methods.HttpPost;
26 import org.apache.http.client.protocol.HttpClientContext;
27 import org.apache.http.config.Registry;
28 import org.apache.http.config.RegistryBuilder;
29 import org.apache.http.conn.ConnectTimeoutException;
30 import org.apache.http.conn.socket.ConnectionSocketFactory;
31 import org.apache.http.conn.socket.LayeredConnectionSocketFactory;
32 import org.apache.http.conn.socket.PlainConnectionSocketFactory;
33 import org.apache.http.conn.ssl.SSLConnectionSocketFactory;
34 import org.apache.http.impl.client.CloseableHttpClient;
35 import org.apache.http.impl.client.HttpClients;
36 import org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
37 import org.apache.http.message.BasicNameValuePair;
38 import org.apache.http.protocol.HttpContext;
39 import org.apache.http.util.EntityUtils;
40
41 import com.alibaba.fastjson.JSONObject;
42
43 public class HttpClientUtil {
44
45 private static CloseableHttpClient httpClient = null;
46 static final int maxTotal = 5000;//最大并发数
47 static final int defaultMaxPerRoute = 1000;//每路最大并发数
48 static final int connectionRequestTimeout = 5000;// ms毫秒,从池中获取链接超时时间
49 static final int connectTimeout = 5000;// ms毫秒,建立链接超时时间
50 static final int socketTimeout = 30000;// ms毫秒,读取超时时间
51
52 private static CloseableHttpClient initHttpClient() {
53 ConnectionSocketFactory plainFactory = PlainConnectionSocketFactory.getSocketFactory();
54 LayeredConnectionSocketFactory sslFactory = SSLConnectionSocketFactory.getSocketFactory();
55 Registry<ConnectionSocketFactory> registry = RegistryBuilder.<ConnectionSocketFactory>create().
56 register("http", plainFactory).register("https", sslFactory).build();
57 PoolingHttpClientConnectionManager poolManager = new PoolingHttpClientConnectionManager(registry);
58 poolManager.setMaxTotal(maxTotal);
59 poolManager.setDefaultMaxPerRoute(defaultMaxPerRoute);
60 HttpRequestRetryHandler httpRetryHandler = new HttpRequestRetryHandler() {
61 @Override
62 public boolean retryRequest(IOException exception, int executionCount, HttpContext context) {
63 if(executionCount >= 2) {
64 return false;
65 }
66 if(exception instanceof NoHttpResponseException) {
67 return false;
68 }
69 if(exception instanceof SSLHandshakeException) {
70 return false;
71 }
72 if(exception instanceof InterruptedIOException) {
73 return false;
74 }
75 if(exception instanceof UnknownHostException) {
76 return false;
77 }
78 if(exception instanceof ConnectTimeoutException) {
79 return false;
80 }
81 if(exception instanceof SSLException) {
82 return false;
83 }
84 HttpClientContext clientContext = HttpClientContext.adapt(context);
85 HttpRequest request = clientContext.getRequest();
86 if(!(request instanceof HttpEntityEnclosingRequest)) {
87 return true;
88 }
89 return false;
90 }
91 };
92 RequestConfig requestConfig = RequestConfig.custom().setConnectionRequestTimeout(connectionRequestTimeout).
93 setConnectTimeout(connectTimeout).setSocketTimeout(socketTimeout).build();
94 CloseableHttpClient closeableHttpClient = HttpClients.custom().setConnectionManager(poolManager).setDefaultRequestConfig(requestConfig).
95 setRetryHandler(httpRetryHandler).build();
96 return closeableHttpClient;
97 }
98
99 public static CloseableHttpClient getHttpClient() {
100 if(httpClient == null) {
101 synchronized (HttpClientUtil.class) {
102 if(httpClient == null) {
103 httpClient = initHttpClient();
104 }
105 }
106 }
107 return httpClient;
108 }
109
110 public static JSONObject sendPost(JSONObject requestData) {
111 JSONObject result = new JSONObject();
112 String url = requestData.getString("url");
113 JSONObject parameter = requestData.getJSONObject("parameter");
114 try {
115 HttpClient httpClient = HttpClientUtil.getHttpClient();
116 HttpPost httpPost = new HttpPost();
117 httpPost.setURI(new URI(url));
118 List<NameValuePair> param = new ArrayList<NameValuePair>();
119 for(Entry<String, Object> entry : parameter.entrySet()) {
120 param.add(new BasicNameValuePair(entry.getKey(), entry.getValue().toString()));
121 }
122 httpPost.setEntity(new UrlEncodedFormEntity(param, Consts.UTF_8));
123 HttpResponse response = httpClient.execute(httpPost);
124 HttpEntity entity = response.getEntity();
125 String responseBody = EntityUtils.toString(entity);
126 int code = response.getStatusLine().getStatusCode();
127 result.put("CODE", code);
128 try {
129 JSONObject responseJson = JSONObject.parseObject(responseBody);
130 result.put("DATA", responseJson);
131 } catch(Exception e) {
132 result.put("DATA", responseBody);
133 }
134 httpPost.abort();
135 httpPost.releaseConnection();
136 } catch (Exception e) {
137 e.printStackTrace();
138 }
139 return result;
140 }
141
142 }