spring - 偽のクライアントと hystrix で Oauth2 トークンを使用しようとしています

Question

「ServiceA」から「ServiceB」を呼び出そうとしています。どちらのサービスもリソースサーバーです。「Feign Client and OAuth2 toke」を介してこのサービス間呼び出しを行おうとしています。これは、Configuration クラスの以下の Bean 実装で正常に動作しています。 :

@Bean    
public RequestInterceptor requestTokenBearerInterceptor() {

    return new RequestInterceptor() {

        @Override
        public void apply(RequestTemplate requestTemplate) {

            OAuth2AuthenticationDetails details = (OAuth2AuthenticationDetails)

            SecurityContextHolder.getContext().getAuthentication()
                    .getDetails();

            requestTemplate.header("Authorization",
                    "bearer " + details.getTokenValue());

        }

    };

}

フォールバックで Feign クライアントを使用しようとしているとき、つまり OAuth トークンなしで Hystrix を使用しようとしているとき (つまり、どのサービスもリソースサーバーではないとき) も正常に動作しています。

しかし、これらのうちの 3 つ (つまり、Feignclient、Hystrix、および OAuth2) をすべて一緒に使用しようとしても、うまくいきません。すべてのサービスが稼働しているにもかかわらず、毎回フォールバック方式になります。

以下は私のコードです：

App.java

import org.json.simple.JSONObject;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.circuitbreaker.EnableCircuitBreaker;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
import org.springframework.cloud.netflix.feign.EnableFeignClients;
import org.springframework.context.annotation.Bean;
import org.springframework.security.core.context.SecurityContextHolder;
import        org.springframework.security.oauth2.provider.authentication.OAuth2AuthenticationDetails;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;

import feign.RequestInterceptor;
import feign.RequestTemplate;


@SpringBootApplication
@RestController
@EnableFeignClients
@EnableEurekaClient
@EnableCircuitBreaker
public class App 
{

/*@Autowired
@Qualifier("abc")
private GitHubClient gitHub;*/
@Autowired
private CallService callService;
public static void main( String[] args )
{
    SpringApplication.run(App.class, args);
}
    @RequestMapping(value="/feign",method=RequestMethod.POST,consumes="application/json")
public String contributors1(@RequestBody JSONObject payLoad) {
        String callservice2 = callService.callservice(payLoad);
        return callservice2;
}

@Bean
public RequestInterceptor requestTokenBearerInterceptor() {

    return new RequestInterceptor() {

        @Override
        public void apply(RequestTemplate requestTemplate) {

            OAuth2AuthenticationDetails details = (OAuth2AuthenticationDetails)

            SecurityContextHolder.getContext().getAuthentication()
                    .getDetails();

            requestTemplate.header("Authorization",
                    "bearer " + details.getTokenValue());

        }

    };

}



}

Callervice.java

import org.json.simple.JSONObject;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.stereotype.Service;

@Service
public class CallService {


@Autowired
@Qualifier("abc")
private GitHubClient gitHub;

public String callservice(JSONObject payLoad){
    String forObject =gitHub.contributors(payLoad);
    return forObject;
}

}

HystrixWrappedClient.java

import org.json.simple.JSONObject;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.stereotype.Component;

import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;

@Component("abc")
public class HystrixWrappedClient implements GitHubClient{

@Autowired
@Qualifier("gitHubClient")
private GitHubClient gitHub;

@Override
@HystrixCommand(fallbackMethod="failure")
public String contributors(JSONObject payLoad) {
    return gitHub.contributors(payLoad);
}

public String failure(JSONObject payLoad){
    System.out.println(payLoad);
    return "Failure";
}
}

GitHubClient.java

import org.json.simple.JSONObject;
import org.springframework.cloud.netflix.feign.FeignClient;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;

@FeignClient("MockRestService")
interface GitHubClient {


@RequestMapping(method = RequestMethod.POST, value =     "/test",consumes="application/json")
String contributors(@RequestBody JSONObject payLoad);

}

pom.xml

<parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>1.2.5.RELEASE</version>
</parent>


<dependencies>
    <dependency>
        <groupId>com.googlecode.json-simple</groupId>
        <artifactId>json-simple</artifactId>
        <version>1.1.1</version>
    </dependency>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-config-client</artifactId>
        <version>1.0.0.RELEASE</version>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-actuator</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-eureka</artifactId>
        <version>1.0.1.RELEASE</version>
    </dependency>
    <!-- For swagger documenation -->
    <dependency>
        <groupId>com.mangofactory</groupId>
        <artifactId>swagger-springmvc</artifactId>
        <version>1.0.2</version>
    </dependency>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-security</artifactId>
    </dependency>

    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-hystrix</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.security.oauth</groupId>
        <artifactId>spring-security-oauth2</artifactId>
    </dependency>

    <!-- NEW -->
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-feign</artifactId>
    </dependency>


</dependencies>
<dependencyManagement>
    <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-parent</artifactId>
            <version>1.0.1.RELEASE</version>
            <type>pom</type>
            <scope>import</scope>
        </dependency>
    </dependencies>
</dependencyManagement>

提案してください。Feignclient、OAuth2、および Hystrix をすべて一緒に使用しようとすると、常にフォールバックメソッドになります。

spring - 偽のクライアントと hystrix で Oauth2 トークンを使用しようとしています

2 に答える 2

Related

Reference