网站制作在哪里找,番禺网站建设优化推广,wordpress下载慢,网站中的文章可以做排名吗本文介绍了三方平台接口对接方法#xff0c;一是基于OkHttp请求工具及dom4j报文封装解析xml的方法#xff0c;二是采用RestTemplate方法封装请求#xff0c;三是采用建立视图和从库数据源的方式查询。
一、OkHttp请求工具及dom4j报文封装解析
1、 依赖引入
!-- okhtt… 本文介绍了三方平台接口对接方法一是基于OkHttp请求工具及dom4j报文封装解析xml的方法二是采用RestTemplate方法封装请求三是采用建立视图和从库数据源的方式查询。
一、OkHttp请求工具及dom4j报文封装解析
1、 依赖引入
!-- okhttp3包 --dependencygroupIdcom.squareup.okhttp3/groupIdartifactIdokhttp/artifactIdversion4.9.3/versionscopecompile/scope/dependency
dependencygroupIdorg.dom4j/groupIdartifactIddom4j/artifactIdversion2.1.4/version/dependency
2、OkHttp请求工具类
package com.inspur.common.utils.okhttp;import okhttp3.*;import org.slf4j.Logger;import org.slf4j.LoggerFactory;import java.io.File;import java.io.IOException;import java.util.Map;import java.util.concurrent.TimeUnit;/*** OkHttp封装,调用示例OkHttpUtil.postJson(...)*/public class OkHttpUtil {private static final Logger logger LoggerFactory.getLogger(OkHttpUtil.class);private static final byte[] LOCKER new byte[0];private static volatile OkHttpClient okHttpClient;private static final MediaType JSON MediaType.parse(application/json; charsetutf-8);private static final MediaType XML MediaType.parse(application/xml; charsetutf-8);private OkHttpUtil() {}private static OkHttpClient getOkHttpClient() {if (okHttpClient null) {synchronized (LOCKER) {if (okHttpClient null) {OkHttpClient.Builder ClientBuilder new OkHttpClient.Builder();ClientBuilder.readTimeout(30, TimeUnit.SECONDS);//读取超时ClientBuilder.connectTimeout(30, TimeUnit.SECONDS);//连接超时ClientBuilder.writeTimeout(60, TimeUnit.SECONDS);//写入超时okHttpClient ClientBuilder.build();}}}return okHttpClient;}/*** 发送get请求** param url* param json* return* throws IOException*/public static ResultString get(String url) throws IOException {logger.debug(请求url:{}, url);Request request new Request.Builder().url(url).get().build();return execute(request);}/*** 发送get请求,带参数** param url* param json* return* throws IOException*/public static ResultString get(String url, MapString, String params) throws IOException {logger.debug(请求url:{}, url);HttpUrl.Builder urlBuilder HttpUrl.parse(url).newBuilder();for (Map.EntryString, String entry : params.entrySet()) {//追加表单信息urlBuilder.addQueryParameter(entry.getKey(), entry.getValue());}Request request new Request.Builder().url(urlBuilder.build()).build();return execute(request);}/*** 发送json请求** param url* param json* return* throws IOException*/public static ResultString postJson(String url, String json) throws IOException {logger.debug(请求url:{},请求体:{}, url, json);RequestBody requestBody RequestBody.create(json,JSON);Request request new Request.Builder().url(url).post(requestBody).build();return execute(request);}public static ResultString postXml(String url, String xml) throws IOException {RequestBody requestBody RequestBody.create(xml, XML);Request request new Request.Builder().url(url).post(requestBody).build();return execute(request);}/*** 发送form表单post请求** param url* param params* return* throws IOException*/public static ResultString post(String url, MapString, String params) throws IOException {logger.debug(请求地址:{};, url);//创建一个FormBody.BuilderFormBody.Builder builder new FormBody.Builder();for (Map.EntryString, String entry : params.entrySet()) {//追加表单信息builder.add(entry.getKey(), entry.getValue());}//生成表单实体对象RequestBody formBody builder.build();Request request new Request.Builder().url(url).post(formBody).build();return execute(request);}/*** 发送form表单post请求** param url* param params* return* throws IOException*/public static ResultString postWithHeader(String url, MapString, String params, String... headers) throws IOException {logger.debug(请求url:{};, url);//创建一个FormBody.BuilderFormBody.Builder builder new FormBody.Builder();for (Map.EntryString, String entry : params.entrySet()) {//追加表单信息builder.add(entry.getKey(), entry.getValue());}//生成表单实体对象RequestBody formBody builder.build();Request request new Request.Builder().url(url).headers(Headers.of(headers)).post(formBody).build();return execute(request);}/*** 发送form表单post请求** param url* param params* return* throws IOException*/public static ResultString postFile(String url, String fileName, File file, MapString, String params) throws IOException {logger.debug(请求url:{};, url);MultipartBody.Builder builder new MultipartBody.Builder();builder.addFormDataPart(fileName, fileName, RequestBody.create(MediaType.parse(application/octet-stream), file));if (params ! null) {for (Map.EntryString, String entry : params.entrySet()) {//追加表单信息builder.addFormDataPart(entry.getKey(), entry.getValue());}}MultipartBody multipartBody builder.build();Request request new Request.Builder().url(url).post(multipartBody).build();return execute(request);}private static ResultString execute(Request request) {ResultString result new Result();try (Response response OkHttpUtil.getOkHttpClient().newCall(request).execute()) {logger.debug({} 请求结果:{}, request.url().url(), response);if (response.isSuccessful()) {ResponseBody body response.body();if (body ! null) {result Result.ok(response.message(), body.string());}else {result Result.ok(response.message());}}else {result Result.fail(response.code(),response.message());}} catch (Exception e) {result Result.fail(e.getMessage());}return result;}}
3、基于dom4j解析和封装xml
1xml文件报文示例
/admin-module/src/main/resources/nc/classStudent.xml
?xml version1.0 encodingUTF-8?
ufinterface accounttpy63_wzx0731 billtype4D filename groupcode isexchangeY replaceY roottag sendergyhlw
classInfoschool市第一中学/schoolcity济南/citylocation2楼/location
/classInfo
studentsstudent namezhangsan age18/studentstudent namelisi age19/student
/students/ufinterface
2构建封装xml报文文件
public String buildXml(){// 创建saxReader对象SAXReader reader new SAXReader();try (InputStream classInfo new ClassPathResource(nc/classStudent.xml).getInputStream()) {// 通过read方法读取一个文件 转换成Document对象Document document reader.read(classInfo);// 获取根节点元素对象Element node document.getRootElement();// 根节点下的一级子节点Element classInfo node.element(classInfo); // 根节点下的子节点 classInfoElement students node.element(students); // 根节点下的子节点 students// 一级子节点classInfo 下属二级节点students.element(school).setText(市第一中学);students.element(city).setText(济南);students.element(location).setText(2楼);// 一级子节点students 下属二级节点// 以此添加成List并设置属性ListStudent st ArrayListT obj new ArrayListStudent() {{add(new Student(zhangsan,18));add(new Student(lisi,19));}};students.stream().forEach(student - {root.addElement(student).addAttribute(name, student.getName()).addAttribute(age, String.valueOf(student.getAge()))});// 生成xml对象String xml document.asXML();logger.info(生成XML\n{} , xml);}} 3okHttp三方接口请求
4xml报文读取解析
public Object handlerReturn() {try {/* 直接读取文件解析// 创建SAXReaderSAXReader saxReader SAXReader.createDefault();// 将xml解析为树Document document saxReader.read(xml/students.xml);*/String xml this.buildXml();// 三方接口请求地址String url http://110.10.1.11:8888/service/xxx// 1、请求发送ResultString result OkHttpUtil.postXml(url, xml);if (result.isOk()) {String resMess result.getData();logger.info(调用结果{}, resMess);// resMess实际为classStudent.xml文件格式内容Document respXml DocumentHelper.parseText(resMess);Element rootElement respXml.getRootElement();// 2、获取根节点下的一级子节点Element classInfo rootElement.element(classInfo); // 根节点下的子节点 classInfoElement students rootElement.element(students); // 根节点下的子节点 students// 3、获取一级子节点classInfo 下属二级节点属性String school classInfo.elementText(school);String city classInfo.elementText(city);String location classInfo.elementText(location);// 4、获取一级子节点students遍历下属二级节点student列表并获取属性值ListElement eles students.elements();ListStudent students new ArrayList();// 遍历子节点列表for(Element ele : eles){// 读取节点属性String name element.attributeValue(name);Interger age element.attributeValue(age);Student stu new Student(name,age);students.add(stu)}}} catch (DocumentException | IOException e) {logger.error(调用接口异常, e);}// 5、解析结果值构建对应实体类或mapHashMap resObj new HashMap();resObj.put(students,students);resObj.put(school,school);return resObj;} 二、RestTemplate
OutInterfaceDomain 实体类根据接口规范自行组装定义
1、依赖
dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-web/artifactId/dependency
2、使用
import org.springframework.http.HttpEntity;
import org.springframework.http.HttpHeaders;
import org.springframework.http.MediaType;import org.springframework.web.client.RestTemplate;public class OutInterfaceService {Autowired
private RestTemplate restTemplate;private String url http://110.1.1.129:8087/DataStandard/*****;HttpHeaders httpHeaders new HttpHeaders();
httpHeaders.setContentType(MediaType.APPLICATION_JSON_UTF8);// 要传递的业务内容MapString, Object columnMap new HashMap();columnMap.put(DEVICE_NO, factoryDevice.getDeviceNo());// 按接口规范组装OutInterfaceDomain outInterfaceDomain new OutInterfaceDomain();outInterfaceDomain.setColumns(columnMap);String contentJson JSON.toJSONString(outInterfaceDomain, SerializerFeature.WriteMapNullValue);
HttpEntityString httpEntity new HttpEntity(contentJson, httpHeaders);// 调用三方接口restTemplate.postForEntity(url, httpEntity, String.class);}
三、sql视图
在原表建立视图并创建新用户赋予只读权限。使用DataSource来切换数据库查询。
1、创建视图和用户并赋予权限
grant select on [view] to [username];//查询视图权限grant connect to [username];//连接数据库权限 # 创建设备视图create or replace view factory_device_view asselect * from factory_device;comment on table factory_device_view is 设备视图;SELECT * FROM all_tab_cols WHERE table_name FACTORY_DEVICE_VIEW;# 创建用户create user jtgViewer identified by password123$# 赋予权限GRANT SELECT ON jtg.factory_device_view TO jtgViewer; grant connect to jtgViewer
2、配置文件
# 从库数据源
slave:# 从数据源开关/默认关闭enabled: trueurl: jdbc:mysql://192.168.100.200:3306/esis_tjzg?useUnicodetruecharacterEncodingutf8zeroDateTimeBehaviorconvertToNulluseSSLtrueserverTimezoneGMT%2B8rewriteBatchedStatementstrueusername: rootpassword: Inspur2023
3、查询使用
DataSource(DataSourceType.SLAVE)public ListMapString,Object selectOutAmountByMaterial(TImMaterialrequestbill tImMaterialrequestbill);
