0

我有一个简单的基于 Micronaut 的“hello world”服务，它内置了一个简单的安全性（为了测试和说明 Micronaut 的安全性）。服务中实现 hello 服务的控制器代码如下：

@Controller("/hello")
public class HelloController
{
   public HelloController()
   {
      // Might put some stuff in in the future
   }

    @Get("/")
    @Produces(MediaType.TEXT_PLAIN)
    public String index()
    {
       return("Hello to the World of Micronaut!!!");
    }
}

为了测试安全机制，我按照 Micronaut 教程的说明创建了一个安全服务类：

@Singleton
public class SecurityService
{
    public SecurityService()
    {
       // Might put in some stuff in the future
    }

    Flowable<Boolean> checkAuthorization(HttpRequest<?> theReq)
    {
        Flowable<Boolean> flow = Flowable.fromCallable(()->{
           System.out.println("Security Engaged!");
           return(false);    <== The tutorial says return true
        }).subscribeOn(Schedulers.io());

        return(flow);
    }

}

应该注意的是，与本教程不同的是，flowable.fromCallable() lambda 返回 false。在本教程中，它返回 true。我曾假设如果返回 false，安全检查将失败，并且失败会导致 hello 服务无法响应。

根据教程，为了开始使用 Security 对象，必须有一个过滤器。我创建的过滤器如下所示：

@Filter("/**")
public class HelloFilter implements HttpServerFilter
{
   private final SecurityService secService;

   public HelloFilter(SecurityService aSec)
   {
      System.out.println("Filter Created!");
      secService = aSec;
   }

   @Override
   public Publisher<MutableHttpResponse<?>> doFilter(HttpRequest<?> theReq, ServerFilterChain theChain)
   {
      System.out.println("Filtering!");
      Publisher<MutableHttpResponse<?>> resp = secService.checkAuthorization(theReq)
                                                         .doOnNext(res->{
                                                            System.out.println("Responding!");
                                                         });

      return(resp);
   }
}

当我运行微服务并访问 Helo 世界 URL 时，会出现问题。( http://localhost:8080/hello ) 我不能导致对服务的访问失败。过滤器捕获所有请求，并且启用了安全对象，但它似乎并没有阻止对 hello 服务的访问。我不知道如何使访问失败。

有人可以帮助解决这个问题吗？谢谢你。

4

1 回答 1

2

当您无法像往常一样访问资源或处理请求时，您需要更改过滤器中的请求。您的 HelloFilter 如下所示：

@Override
public Publisher<MutableHttpResponse<?>> doFilter(HttpRequest<?> theReq, ServerFilterChain theChain) {
    System.out.println("Filtering!");
    Publisher<MutableHttpResponse<?>> resp = secService.checkAuthorization(theReq)
            .switchMap((authResult) -> { // authResult - is you result from SecurityService
                if (!authResult) {
                    return Publishers.just(HttpResponse.status(HttpStatus.FORBIDDEN)); // reject request
                } else {
                    return theChain.proceed(theReq); // process request as usual
                }
            })
            .doOnNext(res -> {
                System.out.println("Responding!");
            });

    return (resp);
}

最后 - micronaut 有带有 SecurityFilter 的安全模块，您可以使用 @Secured 注释或在配置文件中编写访问规则更多示例在文档中

于 2018-09-04T06:14:09.573 回答