技术栈：
- spring boot 2.x
- 腾讯
- java版本1.8
注意事项：
- 本文内的“**.**”需要自己替换为自己的路径。
- 常量内的“**”需要自己定义自己内容。
- 业务中认证图片，上传至阿里云oss上
话不多说，直接上代码
1、pom文件：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
|
<!-- apache httpclient组件 --> <dependency> <groupid>org.apache.httpcomponents</groupid> <artifactid>httpclient</artifactid> <version>4.5.6</version> </dependency> <!-- https://mvnrepository.com/artifact/com.aliyun.oss/aliyun-sdk-oss --> <dependency> <groupid>com.aliyun.oss</groupid> <artifactid>aliyun-sdk-oss</artifactid> <version>2.2.1</version> </dependency> |
2、人脸识别业务：facecontroller文件：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
|
package com.**.**.controller; import com.mb.initial.entity.test;import com.mb.initial.enums.resultenum;import com.mb.initial.result.result;import com.mb.initial.service.ifaceservice;import com.mb.initial.util.resultutils;import io.swagger.annotations.api;import io.swagger.annotations.apioperation;import io.swagger.annotations.apiresponse;import io.swagger.annotations.apiresponses;import org.slf4j.logger;import org.slf4j.loggerfactory;import org.springframework.beans.factory.annotation.autowired;import org.springframework.web.bind.annotation.requestmapping;import org.springframework.web.bind.annotation.requestmethod;import org.springframework.web.bind.annotation.requestparam;import org.springframework.web.bind.annotation.restcontroller; import javax.servlet.http.httpservletrequest;import javax.servlet.http.httpservletresponse; /** * 人脸识别业务 * @author: yanjianghua * @date: 2018/11/16 16:58 */ @api(value = "人脸识别业务",description = "人脸识别业务") @apiresponses(value = {@apiresponse(code = 200, message = "success",response = test.class)}) @requestmapping(value = "/1.0/face",method = {requestmethod.get, requestmethod.post}) @restcontrollerpublic class facecontroller { private logger log = loggerfactory.getlogger(facecontroller.class); @autowired private ifaceservice faceservice; @apioperation(value = "人脸对比信息接口", notes = "人脸对比信息接口") @requestmapping(value = "/getfacecompare") public result getfacecompare(@requestparam(value = "imagebaseauthentication", required = false) string imagebaseauthentication, @requestparam(value = "imagebase", required = false) string imagebase, httpservletresponse response, httpservletrequest request) throws exception{ if (imagebaseauthentication == null || imagebase == null || "".equals(imagebase) || "".equals(imagebaseauthentication)) { return resultutils.response(resultenum.parameter_null); } object result = faceservice.getfacecompare(imagebaseauthentication, imagebase); if(result == null){ return resultutils.response(resultenum.error); }else{ return resultutils.response(result); } } } |
3、ifaceservice文件：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
|
package com.**.**.service; /** * * @author: yanjianghua * @date: 2018/11/16 16:49 */public interface ifaceservice { /** * 人脸对比api接口 * @param imagebaseauthentication * @param imagebase * @return */ public object getfacecompare(string imagebaseauthentication, string imagebase); } |
4、逻辑实现类：ifaceserviceimpl
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
|
package com.**.**.service.impl; import com.alibaba.fastjson.json;import com.alibaba.fastjson.jsonobject;import com.**.**.constants.baseconstants;import com.**.**.exception.billingexception;import com.**.**.result.httpclientresult;import com.**.**.service.ifaceservice;import com.**.**.util.httpclientutils;import com.**.**.util.md5utils;import com.**.**.util.tencentaisignutils;import com.**.**.util.timeutils;import org.springframework.stereotype.service; import java.io.ioexception;import java.util.hashmap;import java.util.map; /** * * @author: yanjianghua * @date: 2018/11/16 16:50 */@servicepublic class ifaceserviceimpl implements ifaceservice { @override public object getfacecompare(string imagebaseauthentication, string imagebase){ httpclientresult result = null; map<string, string> params = new hashmap<string, string>(); params.put("app_id", string.valueof(baseconstants.app_id_ai_ocr)); params.put("time_stamp", string.valueof(system.currenttimemillis() / 1000 + "")); params.put("nonce_str", md5utils.getcharandnumr(10,3)); params.put("image_a", imagebaseauthentication); params.put("image_b", imagebase); params.put("sign", ""); //获取sign string sign = null; try { //post sign = tencentaisignutils.getsignature(params); if(sign == null) { throw new billingexception("sign错误") ; } params.put("sign", sign); result = httpclientutils.dopost(baseconstants.face_compare_url, params); if(result != null) { system.out.println("===facecompare===:" + result.getcontent()); jsonobject content = json.parseobject(result.getcontent()); jsonobject resdata = json.parseobject(content.getstring("data")); return resdata; } } catch (ioexception e) { e.printstacktrace(); } catch (exception e) { e.printstacktrace(); } return null; } } |
5、http工具类：httpclientutils
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
|
package com.**.**.util; import java.io.ioexception;import java.io.unsupportedencodingexception;import java.util.arraylist;import java.util.hashmap;import java.util.list;import java.util.map;import java.util.map.entry;import java.util.set;import java.io.bufferedreader;import java.io.bufferedwriter;import java.io.inputstream;import java.io.inputstreamreader;import java.io.outputstream;import java.io.outputstreamwriter;import java.net.httpurlconnection;import java.net.url; import org.apache.http.httpstatus;import org.apache.http.namevaluepair;import org.apache.http.client.config.requestconfig;import org.apache.http.client.entity.urlencodedformentity;import org.apache.http.client.methods.closeablehttpresponse;import org.apache.http.client.methods.httpdelete;import org.apache.http.client.methods.httpentityenclosingrequestbase;import org.apache.http.client.methods.httpget;import org.apache.http.client.methods.httppost;import org.apache.http.client.methods.httpput;import org.apache.http.client.methods.httprequestbase;import org.apache.http.client.utils.uribuilder;import org.apache.http.impl.client.closeablehttpclient;import org.apache.http.impl.client.httpclients;import org.apache.http.message.basicnamevaluepair;import org.apache.http.util.entityutils; import com.**.**.result.httpclientresult; /** * description: httpclient工具类 * * @author jourwon * @date created on 2018年11月30 日 */public class httpclientutils { //编码格式。发送编码格式统一用utf-8 private static final string encoding = "utf-8"; //设置连接超时时间，单位毫秒。 private static final int connect_timeout = 6000; //请求获取数据的超时时间(即响应时间)，单位毫秒。 private static final int socket_timeout = 6000; /** * 发送get请求；不带请求头和请求参数 * * @param url 请求地址 * @return * @throws exception */ public static httpclientresult doget(string url) throws exception { return doget(url, null, null); } /** * 发送get请求；带请求参数 * * @param url 请求地址 * @param params 请求参数集合 * @return * @throws exception */ public static httpclientresult doget(string url, map<string, string> params) throws exception { return doget(url, null, params); } /** * 发送get请求；带请求头和请求参数 * * @param url 请求地址 * @param headers 请求头集合 * @param params 请求参数集合 * @return * @throws exception */ public static httpclientresult doget(string url, map<string, string> headers, map<string, string> params) throws exception { // 创建httpclient对象 closeablehttpclient httpclient = httpclients.createdefault(); // 创建访问的地址 uribuilder uribuilder = new uribuilder(url); if (params != null) { set<entry<string, string>> entryset = params.entryset(); for (entry<string, string> entry : entryset) { uribuilder.setparameter(entry.getkey(), entry.getvalue()); } } // 创建http对象 httpget httpget = new httpget(uribuilder.build()); /** * setconnecttimeout：设置连接超时时间，单位毫秒。 * setconnectionrequesttimeout：设置从connect manager(连接池)获取connection * 超时时间，单位毫秒。这个属性是新加的属性，因为目前版本是可以共享连接池的。 * setsockettimeout：请求获取数据的超时时间(即响应时间)，单位毫秒。 如果访问一个接口，多少时间内无法返回数据，就直接放弃此次调用。 */ requestconfig requestconfig = requestconfig.custom().setconnecttimeout(connect_timeout).setsockettimeout(socket_timeout).build(); httpget.setconfig(requestconfig); // 设置请求头 packageheader(headers, httpget); // 创建httpresponse对象 closeablehttpresponse httpresponse = null; try { // 执行请求并获得响应结果 return gethttpclientresult(httpresponse, httpclient, httpget); } finally { // 释放资源 release(httpresponse, httpclient); } } /** * 发送post请求；不带请求头和请求参数 * * @param url 请求地址 * @return * @throws exception */ public static httpclientresult dopost(string url) throws exception { return dopost(url, null, null); } /** * 发送post请求；带请求参数 * * @param url 请求地址 * @param params 参数集合 * @return * @throws exception */ public static httpclientresult dopost(string url, map<string, string> params) throws exception { return dopost(url, null, params); } /** * 发送post请求；带请求头和请求参数 * * @param url 请求地址 * @param headers 请求头集合 * @param params 请求参数集合 * @return * @throws exception */ public static httpclientresult dopost(string url, map<string, string> headers, map<string, string> params) throws exception { // 创建httpclient对象 closeablehttpclient httpclient = httpclients.createdefault(); // 创建http对象 httppost httppost = new httppost(url); /** * setconnecttimeout：设置连接超时时间，单位毫秒。 * setconnectionrequesttimeout：设置从connect manager(连接池)获取connection * 超时时间，单位毫秒。这个属性是新加的属性，因为目前版本是可以共享连接池的。 * setsockettimeout：请求获取数据的超时时间(即响应时间)，单位毫秒。 如果访问一个接口，多少时间内无法返回数据，就直接放弃此次调用。 */ requestconfig requestconfig = requestconfig.custom().setconnecttimeout(connect_timeout).setsockettimeout(socket_timeout).build(); httppost.setconfig(requestconfig); httppost.setheader("content-type", "application/x-www-form-urlencoded"); // 设置请求头 /*httppost.setheader("cookie", ""); httppost.setheader("connection", "keep-alive"); httppost.setheader("accept", "application/json"); httppost.setheader("accept-language", "zh-cn,zh;q=0.9"); httppost.setheader("accept-encoding", "gzip, deflate, br"); httppost.setheader("user-agent", "mozilla/5.0 (windows nt 10.0; wow64) applewebkit/537.36 (khtml, like gecko) chrome/65.0.3325.181 safari/537.36");*/ packageheader(headers, httppost); // 封装请求参数 packageparam(params, httppost); // 创建httpresponse对象 closeablehttpresponse httpresponse = null; try { // 执行请求并获得响应结果 return gethttpclientresult(httpresponse, httpclient, httppost); } finally { // 释放资源 release(httpresponse, httpclient); } } /** * 发送put请求；不带请求参数 * * @param url 请求地址 * @return * @throws exception */ public static httpclientresult doput(string url) throws exception { return doput(url); } /** * 发送put请求；带请求参数 * * @param url 请求地址 * @param params 参数集合 * @return * @throws exception */ public static httpclientresult doput(string url, map<string, string> params) throws exception { closeablehttpclient httpclient = httpclients.createdefault(); httpput httpput = new httpput(url); requestconfig requestconfig = requestconfig.custom().setconnecttimeout(connect_timeout).setsockettimeout(socket_timeout).build(); httpput.setconfig(requestconfig); packageparam(params, httpput); closeablehttpresponse httpresponse = null; try { return gethttpclientresult(httpresponse, httpclient, httpput); } finally { release(httpresponse, httpclient); } } /** * 发送delete请求；不带请求参数 * * @param url 请求地址 * @return * @throws exception */ public static httpclientresult dodelete(string url) throws exception { closeablehttpclient httpclient = httpclients.createdefault(); httpdelete httpdelete = new httpdelete(url); requestconfig requestconfig = requestconfig.custom().setconnecttimeout(connect_timeout).setsockettimeout(socket_timeout).build(); httpdelete.setconfig(requestconfig); closeablehttpresponse httpresponse = null; try { return gethttpclientresult(httpresponse, httpclient, httpdelete); } finally { release(httpresponse, httpclient); } } /** * 发送delete请求；带请求参数 * * @param url 请求地址 * @param params 参数集合 * @return * @throws exception */ public static httpclientresult dodelete(string url, map<string, string> params) throws exception { if (params == null) { params = new hashmap<string, string>(); } params.put("_method", "delete"); return dopost(url, params); } /** * description: 封装请求头 * @param params * @param httpmethod */ public static void packageheader(map<string, string> params, httprequestbase httpmethod) { // 封装请求头 if (params != null) { set<entry<string, string>> entryset = params.entryset(); for (entry<string, string> entry : entryset) { // 设置到请求头到httprequestbase对象中 httpmethod.setheader(entry.getkey(), entry.getvalue()); } } } /** * description: 封装请求参数 * * @param params * @param httpmethod * @throws unsupportedencodingexception */ public static void packageparam(map<string, string> params, httpentityenclosingrequestbase httpmethod) throws unsupportedencodingexception { // 封装请求参数 if (params != null) { list<namevaluepair> nvps = new arraylist<namevaluepair>(); set<entry<string, string>> entryset = params.entryset(); for (entry<string, string> entry : entryset) { nvps.add(new basicnamevaluepair(entry.getkey(), entry.getvalue())); } // 设置到请求的http对象中 httpmethod.setentity(new urlencodedformentity(nvps, encoding)); } } /** * description: 获得响应结果 * * @param httpresponse * @param httpclient * @param httpmethod * @return * @throws exception */ public static httpclientresult gethttpclientresult(closeablehttpresponse httpresponse, closeablehttpclient httpclient, httprequestbase httpmethod) throws exception { // 执行请求 httpresponse = httpclient.execute(httpmethod); // 获取返回结果 if (httpresponse != null && httpresponse.getstatusline() != null) { string content = ""; if (httpresponse.getentity() != null) { content = entityutils.tostring(httpresponse.getentity(), encoding); } return new httpclientresult(httpresponse.getstatusline().getstatuscode(), content); } return new httpclientresult(httpstatus.sc_internal_server_error); } /** * description: 释放资源 * * @param httpresponse * @param httpclient * @throws ioexception */ public static void release(closeablehttpresponse httpresponse, closeablehttpclient httpclient) throws ioexception { // 释放资源 if (httpresponse != null) { httpresponse.close(); } if (httpclient != null) { httpclient.close(); } } } |
6、http响应类
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
|
package com.**.**.result; import java.io.serializable; /** * description: 封装httpclient响应结果 * @author: yanjianghua * @date: 2018/9/12 13:45 */public class httpclientresult implements serializable { private static final long serialversionuid = 2168152194164783950l; /** * 响应状态码 */ private int code; /** * 响应数据 */ private string content; public httpclientresult() { } public httpclientresult(int code) { this.code = code; } public httpclientresult(string content) { this.content = content; } public httpclientresult(int code, string content) { this.code = code; this.content = content; } public int getcode() { return code; } public void setcode(int code) { this.code = code; } public string getcontent() { return content; } public void setcontent(string content) { this.content = content; } @override public string tostring() { return "httpclientresult [code=" + code + ", content=" + content + "]"; } } |
7、常量类：baseconstants
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
|
package com.**.**.constants; /** * 常量类 */public class baseconstants { // 默认使用的redis的数据库 public static final integer assetcenter_default_flag = 0; // redis的数据库 1库 public static final integer assetcenter_busness_flag = 1; /** * 腾讯ai对外开放平台-app_id */ public static final int app_id_ai_ocr = *********; /** * 腾讯ai对外开放平台-app_key */ public static final string app_key_ai_ocr = "*********"; public static final string ocr_id_card_ocr_url = "https://api.ai.qq.com/fcgi-bin/ocr/ocr_idcardocr"; public static final string ocr_creditcard_ocr_url = "https://api.ai.qq.com/fcgi-bin/ocr/ocr_creditcardocr"; public static final string face_compare_url = "https://api.ai.qq.com/fcgi-bin/face/face_facecompare"; public static final string aliyun_oss_object_name_ocr = "idcardocr/"; public static final string aliyun_oss_object_creditcard_ocr = "creditcard/"; public static final string aliyun_oss_object_auth_dir = "authentication/"; } |
以上所述是小编给大家介绍的java腾讯ai人脸对比对接详解整合，希望对大家有所帮助，如果大家有任何疑问请给我留言，小编会及时回复大家的。在此也非常感谢大家对服务器之家网站的支持！
原文链接：https://blog.csdn.net/yjh44780791/article/details/84652282
