联讯物业系统后台
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
chengf
2026-02-25 64b14b0549344f13b191e2c26ed199f62655c43f 
 springboot/src/main/java/com/java110/boot/BootApplicationStart.java


@@ -16,38 +16,38 @@


package com.java110.boot;




import com.java110.core.annotation.Java110CmdDiscovery;


import com.java110.core.annotation.Java110ListenerDiscovery;


import com.java110.core.client.OutRestTemplate;


import com.java110.core.client.RestTemplate;


import com.java110.core.context.Environment;


import com.java110.core.event.cmd.ServiceCmdEventPublishing;


import com.java110.core.event.service.api.ServiceDataFlowEventPublishing;


import com.java110.core.log.LoggerFactory;


import com.java110.core.trace.Java110FeignClientInterceptor;


import com.java110.core.trace.Java110RestTemplateInterceptor;


import com.java110.doc.annotation.Java110ApiDocDiscovery;


import com.java110.doc.annotation.Java110CmdDocDiscovery;


import com.java110.doc.registrar.ApiDocCmdPublishing;


import com.java110.doc.registrar.ApiDocPublishing;


import com.java110.intf.dev.ICacheV1InnerServiceSMO;


import com.java110.service.init.ServiceStartInit;


import io.swagger.annotations.ApiOperation;


import com.java110.utils.cache.MappingCache;


import com.java110.utils.constant.MappingConstant;


import com.java110.utils.factory.ApplicationContextFactory;


import com.java110.utils.util.StringUtil;


import okhttp3.ConnectionPool;


import org.slf4j.Logger;


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.autoconfigure.liquibase.LiquibaseAutoConfiguration;


import org.springframework.boot.web.client.RestTemplateBuilder;


import org.springframework.cloud.client.discovery.EnableDiscoveryClient;


import org.springframework.cloud.client.loadbalancer.LoadBalanced;


import org.springframework.cloud.openfeign.EnableFeignClients;


import org.springframework.context.ApplicationContext;


import org.springframework.context.annotation.Bean;


import org.springframework.http.client.HttpComponentsClientHttpRequestFactory;


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;


import springfox.documentation.service.ApiInfo;


import springfox.documentation.spi.DocumentationType;


import springfox.documentation.spring.web.plugins.Docket;


import springfox.documentation.swagger2.annotations.EnableSwagger2;


import org.springframework.scheduling.annotation.EnableScheduling;




import javax.annotation.Resource;


import java.nio.charset.Charset;


@@ -57,7 +57,7 @@


/**


 * 这个服务是将 系统部署为spring boot版


 * 如果是spring cloud 微服务部署 不用启动这个类


 *


 * <p>


 *


 * @version v0.1


 * @auther com.java110.wuxw


@@ -66,8 +66,8 @@


 * @tag


 */


@SpringBootApplication(scanBasePackages = {


        "com.java110.service.configuration",


        "com.java110.service.init",


        "com.java110.service",


        "com.java110.db",


        "com.java110.core",


        "com.java110.config.properties.code",


        "com.java110.acct",


@@ -81,7 +81,18 @@


        "com.java110.report",


        "com.java110.store",


        "com.java110.user",


})


        "com.java110.doc",


        "com.java110.scm",


        "com.java110.api",


        "com.java110.boot"


},


        exclude = {LiquibaseAutoConfiguration.class,


                org.activiti.spring.boot.SecurityAutoConfiguration.class,


                org.springframework.boot.autoconfigure.security.servlet.SecurityAutoConfiguration.class,


                com.github.pagehelper.autoconfigure.MapperAutoConfiguration.class


        }




)


@Java110CmdDiscovery(cmdPublishClass = ServiceCmdEventPublishing.class,


        basePackages = {


                "com.java110.acct.cmd",


@@ -94,11 +105,29 @@


                "com.java110.order.cmd",


                "com.java110.report.cmd",


                "com.java110.store.cmd",


                "com.java110.scm.cmd",


                "com.java110.user.cmd"


        })


@EnableDiscoveryClient


@EnableAutoConfiguration(exclude = {DataSourceAutoConfiguration.class})


@EnableScheduling


@EnableAsync


//文档


@Java110ApiDocDiscovery(basePackages = {"com.java110.boot.rest"}, apiDocClass = ApiDocPublishing.class)


@Java110CmdDocDiscovery(basePackages = {


        "com.java110.acct.cmd",


        "com.java110.acct.payment.business",


        "com.java110.common.cmd",


        "com.java110.community.cmd",


        "com.java110.dev.cmd",


        "com.java110.fee.cmd",


        "com.java110.job.cmd",


        "com.java110.oa.cmd",


        "com.java110.order.cmd",


        "com.java110.report.cmd",


        "com.java110.store.cmd",


        "com.java110.scm.cmd",


        "com.java110.user.cmd"


},


        cmdDocClass = ApiDocCmdPublishing.class)


public class BootApplicationStart {




    private static Logger logger = LoggerFactory.getLogger(BootApplicationStart.class);


@@ -112,21 +141,59 @@


     * @return restTemplate


     */


    @Bean


    public RestTemplate outRestTemplate() {


    public OutRestTemplate outRestTemplate() {


        StringHttpMessageConverter m = new StringHttpMessageConverter(Charset.forName("UTF-8"));


        m.setWriteAcceptCharset(false);


        OutRestTemplate restTemplate = new RestTemplateBuilder().additionalMessageConverters(m).build(OutRestTemplate.class);


        restTemplate.getInterceptors().add(java110RestTemplateInterceptor);




        //设置超时时间


        HttpComponentsClientHttpRequestFactory httpRequestFactory = new HttpComponentsClientHttpRequestFactory();


        httpRequestFactory.setConnectionRequestTimeout(10000);


        httpRequestFactory.setConnectTimeout(10000);


        httpRequestFactory.setReadTimeout(10000);


        restTemplate.setRequestFactory(httpRequestFactory);


        return restTemplate;


    }




    @Bean


    //@LoadBalanced


    public RestTemplate formRestTemplate() {


        RestTemplate restTemplate = new RestTemplate();


        restTemplate.getMessageConverters().add(new StringHttpMessageConverter(Charset.forName("UTF-8")));


        return restTemplate;


    }




    /**


     * 实例化RestTemplate，通过@LoadBalanced注解开启均衡负载能力.


     *


     * @return restTemplate


     */


    @Bean


    @LoadBalanced


    public RestTemplate restTemplate() {


        StringHttpMessageConverter m = new StringHttpMessageConverter(Charset.forName("UTF-8"));


        m.setWriteAcceptCharset(false);


        RestTemplate restTemplate = new RestTemplateBuilder().additionalMessageConverters(m).build(RestTemplate.class);


        restTemplate.getInterceptors().add(java110RestTemplateInterceptor);


        //设置超时时间


        HttpComponentsClientHttpRequestFactory httpRequestFactory = new HttpComponentsClientHttpRequestFactory();


        httpRequestFactory.setConnectionRequestTimeout(20000);


        httpRequestFactory.setConnectTimeout(20000);


        httpRequestFactory.setReadTimeout(20000);


        restTemplate.setRequestFactory(httpRequestFactory);


        return restTemplate;


    }




    @Bean


    @ConditionalOnBean(Java110FeignClientInterceptor.class)


    public okhttp3.OkHttpClient okHttpClient(@Autowired


                                                     Java110FeignClientInterceptor okHttpLoggingInterceptor){


                                             Java110FeignClientInterceptor okHttpLoggingInterceptor) {


        okhttp3.OkHttpClient.Builder ClientBuilder = new okhttp3.OkHttpClient.Builder()


                .readTimeout(30, TimeUnit.SECONDS) //读取超时


                .connectTimeout(10, TimeUnit.SECONDS) //连接超时


                .connectTimeout(20, TimeUnit.SECONDS) //连接超时


                .writeTimeout(60, TimeUnit.SECONDS) //写入超时


                .connectionPool(new ConnectionPool(10 /*maxIdleConnections*/, 3, TimeUnit.MINUTES))


                .connectionPool(new ConnectionPool(20 /*maxIdleConnections*/, 3, TimeUnit.MINUTES))


                .addInterceptor(okHttpLoggingInterceptor);


        return ClientBuilder.build();


    }


@@ -137,9 +204,51 @@


            ApplicationContext context = SpringApplication.run(BootApplicationStart.class, args);


            //服务启动加载


            ServiceStartInit.initSystemConfig(context);




            Environment.setSystemStartWay(Environment.SPRING_BOOT);




            //刷新缓存


            flushMainCache(args);




            //服务启动完成


            ServiceStartInit.printStartSuccessInfo();






        } catch (Throwable e) {


            logger.error("系统启动失败", e);


        }


    }








    /**


     * 刷新主要的缓存


     *


     * @param args


     */


    private static void flushMainCache(String[] args) {




        logger.debug("判断是否需要刷新日志，参数 args 为 {}", args);




        //因为好多朋友启动时 不加 参数-Dcache 所以启动时检测 redis 中是否存在 java110_hc_version


        //String mapping = MappingCache.getValue(MappingConstant.ENV_DOMAIN,"java110_hc_version");


        String mapping = "";


        if (StringUtil.isEmpty(mapping)) {


            ICacheV1InnerServiceSMO devServiceCacheSMOImpl = (ICacheV1InnerServiceSMO) ApplicationContextFactory.getBean(ICacheV1InnerServiceSMO.class);


            devServiceCacheSMOImpl.startFlush();


            return;


        }




        if (args == null || args.length == 0) {


            return;


        }


        for (int i = 0; i < args.length; i++) {


            if (args[i].equalsIgnoreCase("-Dcache")) {


                logger.debug("开始刷新日志，入参为：{}", args[i]);


                ICacheV1InnerServiceSMO devServiceCacheSMOImpl = (ICacheV1InnerServiceSMO) ApplicationContextFactory.getBean(ICacheV1InnerServiceSMO.class);


                devServiceCacheSMOImpl.startFlush();


            }


        }


    }




}