From 05683f2b2bdbdbe21cf17ad523c21ab338bd1c54 Mon Sep 17 00:00:00 2001
From: wuxw <928255095@qq.com>
Date: 星期二, 19 七月 2022 21:49:55 +0800
Subject: [PATCH] 优化添加设备 功能
---
service-api/src/main/java/com/java110/api/ApiApplicationStart.java | 56 ++++++++++++++++++++++++++++++++++++++++++++++++--------
1 files changed, 48 insertions(+), 8 deletions(-)
diff --git a/service-api/src/main/java/com/java110/api/ApiApplicationStart.java b/service-api/src/main/java/com/java110/api/ApiApplicationStart.java
old mode 100644
new mode 100755
index c93e0c9..5e400aa
--- a/service-api/src/main/java/com/java110/api/ApiApplicationStart.java
+++ b/service-api/src/main/java/com/java110/api/ApiApplicationStart.java
@@ -1,16 +1,35 @@
-
+/*
+ * Copyright 2017-2020 鍚村鏂� and java110 team.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
package com.java110.api;
import com.java110.core.annotation.Java110ListenerDiscovery;
+import com.java110.core.trace.Java110FeignClientInterceptor;
+import com.java110.core.trace.Java110RestTemplateInterceptor;
import com.java110.core.client.RestTemplate;
import com.java110.core.event.service.api.ServiceDataFlowEventPublishing;
+import com.java110.core.log.LoggerFactory;
import com.java110.service.init.ServiceStartInit;
import io.swagger.annotations.ApiOperation;
+import okhttp3.ConnectionPool;
import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnBean;
import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration;
import org.springframework.boot.web.client.RestTemplateBuilder;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
@@ -19,7 +38,7 @@
import org.springframework.context.ApplicationContext;
import org.springframework.context.annotation.Bean;
import org.springframework.http.converter.StringHttpMessageConverter;
-
+import org.springframework.scheduling.annotation.EnableAsync;
import springfox.documentation.builders.ApiInfoBuilder;
import springfox.documentation.builders.PathSelectors;
import springfox.documentation.builders.RequestHandlerSelectors;
@@ -28,7 +47,9 @@
import springfox.documentation.spring.web.plugins.Docket;
import springfox.documentation.swagger2.annotations.EnableSwagger2;
+import javax.annotation.Resource;
import java.nio.charset.Charset;
+import java.util.concurrent.TimeUnit;
/**
@@ -46,7 +67,7 @@
"com.java110.api",
"com.java110.core",
"com.java110.config.properties.code",
- })
+})
@EnableDiscoveryClient
@Java110ListenerDiscovery(listenerPublishClass = ServiceDataFlowEventPublishing.class,
basePackages = {"com.java110.api.listener"})
@@ -54,9 +75,13 @@
//@EnableConfigurationProperties(EventProperties.class)
@EnableFeignClients(basePackages = {"com.java110.intf"})
@EnableAutoConfiguration(exclude = {DataSourceAutoConfiguration.class})
+@EnableAsync
public class ApiApplicationStart {
private static Logger logger = LoggerFactory.getLogger(ApiApplicationStart.class);
+
+ @Resource
+ private Java110RestTemplateInterceptor java110RestTemplateInterceptor;
/**
* 瀹炰緥鍖朢estTemplate锛岄�氳繃@LoadBalanced娉ㄨВ寮�鍚潎琛¤礋杞借兘鍔�.
@@ -68,6 +93,7 @@
public RestTemplate restTemplate() {
StringHttpMessageConverter m = new StringHttpMessageConverter(Charset.forName("UTF-8"));
RestTemplate restTemplate = new RestTemplateBuilder().additionalMessageConverters(m).build(RestTemplate.class);
+ restTemplate.getInterceptors().add(java110RestTemplateInterceptor);
return restTemplate;
}
@@ -97,6 +123,20 @@
.apis(RequestHandlerSelectors.withMethodAnnotation(ApiOperation.class)).build();
}
+
+ @Bean
+ @ConditionalOnBean(Java110FeignClientInterceptor.class)
+ public okhttp3.OkHttpClient okHttpClient(@Autowired
+ Java110FeignClientInterceptor okHttpLoggingInterceptor){
+ okhttp3.OkHttpClient.Builder ClientBuilder = new okhttp3.OkHttpClient.Builder()
+ .readTimeout(30, TimeUnit.SECONDS) //璇诲彇瓒呮椂
+ .connectTimeout(10, TimeUnit.SECONDS) //杩炴帴瓒呮椂
+ .writeTimeout(60, TimeUnit.SECONDS) //鍐欏叆瓒呮椂
+ .connectionPool(new ConnectionPool(10 /*maxIdleConnections*/, 3, TimeUnit.MINUTES))
+ .addInterceptor(okHttpLoggingInterceptor);
+ return ClientBuilder.build();
+ }
+
/**
* 鍒涘缓璇PI鐨勫熀鏈俊鎭紙杩欎簺鍩烘湰淇℃伅浼氬睍鐜板湪鏂囨。椤甸潰涓級
* 璁块棶鍦板潃锛歨ttp://椤圭洰瀹為檯鍦板潃/swagger-ui.html
@@ -115,13 +155,13 @@
public static void main(String[] args) throws Exception {
- try{
+ try {
+ ServiceStartInit.preInitSystemConfig();
ApplicationContext context = SpringApplication.run(ApiApplicationStart.class, args);
-
//鏈嶅姟鍚姩鍔犺浇
ServiceStartInit.initSystemConfig(context);
- }catch (Throwable e){
- logger.error("绯荤粺鍚姩澶辫触",e);
+ } catch (Throwable e) {
+ logger.error("绯荤粺鍚姩澶辫触", e);
}
}
--
Gitblit v1.8.0