FeignClient with Client Certificate and Docker

私は、私のマイクロサービスが双方向SSLを利用するための要件を持っています。各microserviceはで注釈春ブートアプリケーションである：各microserviceは、様々な機能のために、残りのAPIを公開コントローラを有するFeignClient with Client Certificate and Docker

eureka: 
    client: 
     service-url: 
      defaultZone: ${EUREKA_CLIENT_SERVICEURL_PROTOCOL:http}://${EUREKA_CLIENT_SERVICEURL_HOST:192.168.99.100}:${EUREKA_CLIENT_SERVICEURL_PORT:8761}/eureka/ 
    instance: 
     secure-virtual-host-name: ${spring.application.name} 
     prefer-ip-address: true 
     non-secure-port-enabled: ${EUREKA_NON_SECURE_PORT_ENABLED:false} 
     secure-port-enabled: ${EUREKA_SECURE_PORT_ENABLED:true} 
     secure-port: ${server.port} 
ribbon: 
    IsSecure: true 
    eureka: 
     enabled: true

：

@SpringBootApplication 
@EnableFeignClients 
@EnableDiscoveryClient 
@EnableZuulProxy 
public class Application { 
    public static void main(String[] args) { 
     SpringApplication.run(Application.class, args); 
    } 
}

各YMLユーレカ/リボンのための同様の構成を有しています。 1 microservicesは別のmicroserviceエンドポイントに要請する必要があるとき、私はそのmicroserviceにクライアント・インターフェースを作成することによって、そうしようとしている

：

@FeignClient(name = "user", configuration = FeignConfiguration.class, url = "https://user") 
public interface UserClient { 
    @RequestMapping(method = RequestMethod.GET, value = "/test") 
    String testUser(); 
}

はここFeignConfigurationです：

@Configuration 
public class FeignConfiguration { 

    @Bean 
    public Feign.Builder feignBuilder(){ 
     Client trustSSLSockets = new Client.Default(TrustingSSLSocketFactory.get(), null); 
     return Feign.builder().client(trustSSLSockets); 
    } 

    @Bean 
    Logger.Level feignLoggerLevel() { 
     return Logger.Level.FULL; 
    } 

    @Bean 
    public Contract feignContract() { 
     return new feign.Contract.Default(); 
    } 

}

TrustingSSLSocketFactoryクラスはhttps://github.com/Netflix/feign/blob/master/core/src/test/java/feign/client/TrustingSSLSocketFactory.javaからコピーされ、クライアントのcert/passwordで変更されました。

ユーザーmicroserviceは、セキュリティのように構成している他のコンフィグの中で、クライアントを呼び出すには

server: 
    port: ${DOCKER_SERVER_PORT:28443} 
     ssl: 
      key-store: ${KEYSTORE_FILE:classpath:keystore.p12} 
      key-store-password: ${KEYSTORE_PASSWORD:abc123} 
      key-store-type: ${KEYSTORE_TYPE:PKCS12} 
      trust-store: ${TRUSTSTORE_FILE:classpath:trust.jks} 
      trust-store-password: ${TRUSTSTORE_PASSWORD:abc123} 
      trust-store-type: ${TRUSTSTORE_TYPE:JKS} 
      client-auth: ${CLIENT_AUTH_REQUIRED:want}

、私は単純にクライアントを注入し、他のインターフェイスとしてそれを呼び出します。

@RestController 
public class MyController { 

@Autowired 
UserClient userClient; 

@RequestMapping(value = "/testUser", 
     method = RequestMethod.GET, 
     produces = MediaType.APPLICATION_JSON_VALUE) 
    public String testUser() { 
     return userClient.testUser(); 
    } 
}

ユーザマイクロサービスには、簡単な返信を返すテストエンドポイントがあります。

UserClientがユーザーホストとの接続を確立しようとするとUnknownHostExceptionが発生します。私はおそらくこれを正しく実装しておらず、いくつかの指針に感謝するでしょう。

gateway-ms_1 | 2016-05-09 16:22:19.294 DEBUG 1 --- [qtp351251459-24]  c.n.zuul.http.HttpServletRequestWrapper : Path = null 
gateway-ms_1 | 2016-05-09 16:22:19.294 DEBUG 1 --- [qtp351251459-24] c.n.zuul.http.HttpServletRequestWrapper : Transfer-Encoding = null 
gateway-ms_1 | 2016-05-09 16:22:19.294 DEBUG 1 --- [qtp351251459-24] c.n.zuul.http.HttpServletRequestWrapper : Content-Encoding = null 
gateway-ms_1 | 2016-05-09 16:22:19.295 DEBUG 1 --- [qtp351251459-24] c.n.zuul.http.HttpServletRequestWrapper : Content-Length header = -1 
gateway-ms_1 | 2016-05-09 16:22:19.297 DEBUG 1 --- [qtp351251459-24] c.n.loadbalancer.ZoneAwareLoadBalancer : Zone aware logic disabled or there is only one zone 
gateway-ms_1 | 2016-05-09 16:22:19.298 DEBUG 1 --- [qtp351251459-24] c.n.loadbalancer.LoadBalancerContext  : register using LB returned Server: 172.17.0.4:28443 for request /testUser 
gateway-ms_1 | 2016-05-09 16:22:19.298 DEBUG 1 --- [qtp351251459-24] com.netflix.niws.client.http.RestClient : RestClient sending new Request(GET:) https://172.17.0.4:28443/testUser 
gateway-ms_1 | 2016-05-09 16:22:19.300 DEBUG 1 --- [qtp351251459-24] c.n.http4.MonitoredConnectionManager  : Get connection: {s}->https://172.17.0.4:28443, timeout = 3000 
gateway-ms_1 | 2016-05-09 16:22:19.300 DEBUG 1 --- [qtp351251459-24] com.netflix.http4.NamedConnectionPool : [{s}->https://172.17.0.4:28443] total kept alive: 1, total issued: 0, total allocated: 1 out of 200 
gateway-ms_1 | 2016-05-09 16:22:19.300 DEBUG 1 --- [qtp351251459-24] com.netflix.http4.NamedConnectionPool : Getting free connection [{s}->https://172.17.0.4:28443][null] 
gateway-ms_1 | 2016-05-09 16:22:19.300 DEBUG 1 --- [qtp351251459-24] com.netflix.http4.NFHttpClient   : Stale connection check 
gateway-ms_1 | 2016-05-09 16:22:19.305 DEBUG 1 --- [qtp351251459-24] com.netflix.http4.NFHttpClient   : Attempt 1 to execute request 
register-ms_1 | 2016-05-09 16:22:19.312 DEBUG 1 --- [qtp376795121-24] com.jdh.register.clients.UserClient  : [UserClient#testUser] ---> GET https://user/test HTTP/1.1 
register-ms_1 | 2016-05-09 16:22:19.313 DEBUG 1 --- [qtp376795121-24] com.jdh.register.clients.UserClient  : [UserClient#testUser] ---> END HTTP (0-byte body) 
register-ms_1 | 2016-05-09 16:22:19.422 DEBUG 1 --- [qtp376795121-24] com.jdh.register.clients.UserClient  : [UserClient#testUser] <--- ERROR UnknownHostException: user (109ms) 
register-ms_1 | 2016-05-09 16:22:19.426 DEBUG 1 --- [qtp376795121-24] com.jdh.register.clients.UserClient  : [UserClient#testUser] java.net.UnknownHostException: user 
register-ms_1 | at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:184) 
register-ms_1 | at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392) 
register-ms_1 | at java.net.Socket.connect(Socket.java:589) 
register-ms_1 | at sun.net.NetworkClient.doConnect(NetworkClient.java:175) 
register-ms_1 | at sun.net.www.http.HttpClient.openServer(HttpClient.java:432) 
register-ms_1 | at sun.net.www.http.HttpClient.openServer(HttpClient.java:527) 
register-ms_1 | at sun.net.www.protocol.https.HttpsClient.<init>(HttpsClient.java:275) 
register-ms_1 | at sun.net.www.protocol.https.HttpsClient.New(HttpsClient.java:371) 
register-ms_1 | at sun.net.www.protocol.https.AbstractDelegateHttpsURLConnection.getNewHttpClient(AbstractDelegateHttpsURLConnection.java:191) 
register-ms_1 | at sun.net.www.protocol.http.HttpURLConnection.plainConnect0(HttpURLConnection.java:1104) 
register-ms_1 | at sun.net.www.protocol.http.HttpURLConnection.plainConnect(HttpURLConnection.java:998) 
register-ms_1 | at sun.net.www.protocol.https.AbstractDelegateHttpsURLConnection.connect(AbstractDelegateHttpsURLConnection.java:177) 
register-ms_1 | at sun.net.www.protocol.http.HttpURLConnection.getInputStream0(HttpURLConnection.java:1512) 
evice-ms_1 |  at sun.net.www.protocol.http.HttpURLConnection.getInputStream(HttpURLConnection.java:1440)

出典

2016-05-09 Hank

feign Clientは、リボンが注入される場所です。独自のクライアントを作成すると、リボンからオプトアウトされたため、http://user/...はリボンで解決されません。

これはの注釈を装うためにあなたが@RequestMappingと、デフォルトのように、Spring MVCの注釈を使用してのオプトアウトfeign.Contract.Default()を使用することによって、我々はロードバランサのクライアントも

@Bean 
@ConditionalOnMissingBean 
public Client feignClient(CachingSpringLoadBalancerFactory cachingFactory, 
     SpringClientFactory clientFactory) { 
    return new LoadBalancerFeignClient(new Client.Default(null, null), 
      cachingFactory, clientFactory); 
}

を作成する方法です。

出典

2016-05-10 00:21:39 spencergibb

FeignClient with Client Certificate and Docker

答えて

関連する問題