黔云通
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
Pu Zhibing
4 天以前 b219589d73f46bd98995bceb4caf16dadb56b869 
 ZuulQYTTravel/src/main/java/com/sinata/zuul/ZuulApplication.java


@@ -1,32 +1,17 @@


package com.sinata.zuul;




import com.sinata.zuul.util.applets.NettyServer0;


import com.sinata.zuul.util.echo.NettyServer;


import com.spring4all.swagger.EnableSwagger2Doc;


import org.apache.http.client.HttpClient;


import org.apache.http.config.SocketConfig;


import org.apache.http.impl.client.HttpClientBuilder;


import org.apache.http.impl.conn.PoolingHttpClientConnectionManager;


import org.springframework.boot.SpringApplication;


import org.springframework.boot.autoconfigure.SpringBootApplication;


import org.springframework.boot.builder.SpringApplicationBuilder;


import org.springframework.boot.web.servlet.support.SpringBootServletInitializer;


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


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


import org.springframework.cloud.netflix.zuul.EnableZuulProxy;


import org.springframework.context.annotation.Bean;


import org.springframework.context.annotation.Primary;


import org.springframework.http.client.HttpComponentsClientHttpRequestFactory;


import org.springframework.http.converter.StringHttpMessageConverter;


import org.springframework.stereotype.Component;


import org.springframework.web.client.RestTemplate;


import org.springframework.web.cors.CorsConfiguration;


import org.springframework.web.cors.UrlBasedCorsConfigurationSource;


import org.springframework.web.filter.CorsFilter;


import springfox.documentation.swagger.web.SwaggerResource;


import springfox.documentation.swagger.web.SwaggerResourcesProvider;




import java.nio.charset.StandardCharsets;


import java.util.ArrayList;


import java.util.List;




@@ -39,54 +24,9 @@




    public static void main(String[] args) {


        SpringApplication.run(ZuulApplication.class, args);


//        NettyServer nettyServer = new NettyServer();


//        nettyServer.bind();


//        NettyServer0 nettyServer0 = new NettyServer0();


//        nettyServer0.bind();


    }






    @Bean //SpringCloud内部服务质检使用服务名调用


    @LoadBalanced


    public RestTemplate internalRestTemplate() {


        PoolingHttpClientConnectionManager connectionManager = new PoolingHttpClientConnectionManager();


        connectionManager.setDefaultSocketConfig(SocketConfig.custom().setTcpNoDelay(true).build());


        connectionManager.setDefaultMaxPerRoute(100);//最大并发连接


        connectionManager.setMaxTotal(200); // 总的最大连接数


        HttpClient httpClient = HttpClientBuilder.create().setConnectionManager(connectionManager).build();


        HttpComponentsClientHttpRequestFactory httpRequestFactory = new HttpComponentsClientHttpRequestFactory(httpClient);


        httpRequestFactory.setConnectionRequestTimeout(30 * 1000);


        httpRequestFactory.setConnectTimeout(30 * 3000);


        httpRequestFactory.setReadTimeout(30 * 3000);


        RestTemplate restTemplate = new RestTemplate(httpRequestFactory);


        restTemplate.getMessageConverters().set(1, new StringHttpMessageConverter(StandardCharsets.UTF_8));


        return restTemplate;


    }








//    /**


//     * 向Spring容器中定义RestTemplate对象


//     * @return


//     */


//    @Bean //必须new 一个RestTemplate并放入spring容器当中,否则启动时报错


//    public RestTemplate restTemplate() {


//        PoolingHttpClientConnectionManager connectionManager = new PoolingHttpClientConnectionManager();


//        connectionManager.setDefaultSocketConfig(SocketConfig.custom().setTcpNoDelay(true).build());


//        connectionManager.setDefaultMaxPerRoute(100);//最大并发连接


//        connectionManager.setMaxTotal(200); // 总的最大连接数


//        HttpClient httpClient = HttpClientBuilder.create().setConnectionManager(connectionManager).build();


//        HttpComponentsClientHttpRequestFactory httpRequestFactory = new HttpComponentsClientHttpRequestFactory(httpClient);


//        httpRequestFactory.setConnectionRequestTimeout(30 * 1000);


//        httpRequestFactory.setConnectTimeout(30 * 3000);


//        httpRequestFactory.setReadTimeout(30 * 3000);


//        RestTemplate restTemplate = new RestTemplate(httpRequestFactory);


//        restTemplate.getMessageConverters().set(1, new StringHttpMessageConverter(StandardCharsets.UTF_8));


//        return restTemplate;


//    }








    


    /**


     * 配置Swagger


     */


@@ -97,9 +37,9 @@


        public List<SwaggerResource> get() {


            List resource=new ArrayList<>();


            //name可以随便写，location前缀要与zuul配置的path一致。zuul开了token验证,要加上token,否则不用加?token=1


            resource.add(swaggerResource("user","/user-server/v2/api-docs","1.0"));


            resource.add(swaggerResource("driver","/driver-server/v2/api-docs","1.0"));


            resource.add(swaggerResource("dispatch","/dispatch-server/v2/api-docs","1.0"));


//            resource.add(swaggerResource("user","/user-server/v2/api-docs","1.0"));


//            resource.add(swaggerResource("driver","/driver-server/v2/api-docs","1.0"));


//            resource.add(swaggerResource("dispatch","/dispatch-server/v2/api-docs","1.0"));


            return resource;


        }