Spring Reactive 使用 ServerRequest 获取正文 JSONObject

Question

我是 Spring React 新手。

我正在尝试使用邮递员从服务器获取请求信息。

首先，postman使用post方法向服务器发送信息。其次，我们一直在服务器端编写相关代码并获取请求信息。

在下面的代码片段中

我想知道是否可以获取ServerRequest函数的JSONObject。

邮递员主体（应用程序/json）

{
    "name": "aaaa",
    "name_order": ["aa", "bb", "cc"],
    "type": "12",
    "query": ""
}

java（路由器功能）

import com.ntels.io.input.handler.RestInHandler;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.http.MediaType;
import org.springframework.web.reactive.config.EnableWebFlux;
import org.springframework.web.reactive.config.WebFluxConfigurer;
import org.springframework.web.reactive.function.server.*;

import static org.springframework.web.reactive.function.server.RequestPredicates.GET;
import static org.springframework.web.reactive.function.server.RequestPredicates.POST;
import static org.springframework.web.reactive.function.server.RequestPredicates.PUT;
import static org.springframework.web.reactive.function.server.RequestPredicates.DELETE;

@Configuration
@EnableWebFlux
public class RestConfig implements WebFluxConfigurer {

    @Bean
    public RouterFunction<ServerResponse> routes(RestInHandler restInHandler){
        return RouterFunctions.route(POST("/input/event").
        and(RequestPredicates.accept(MediaType.APPLICATION_JSON)), restInHandler::toRESTInVerticle);
    }
}

java（处理程序）

public Mono<ServerResponse> toRESTInVerticle(ServerRequest serverRequest) {
    String serverRequestUrl = serverRequest.uri().toString();

    System.out.println("RestInHandler test in");
    System.out.println(serverRequest.method());
    System.out.println(serverRequest.headers());
    System.out.println(serverRequest.uri().toString());

    // how can i get the jsonbody using serverrequest

    // testing..

    // Mono<JSONObject> jsonObjectMono = serverRequest.bodyToMono(JSONObject.class);
    // Flux<JSONObject> jsonObjectFlux = serverRequest.bodyToFlux(JSONObject.class);
-> MonoOnErrorResume

    return (Mono<ServerResponse>) ServerResponse.ok();
}

Answer 1

谢谢你。亚历山大捷列霍夫

您的回答对解决问题有很大帮助。

我的测试代码。

RouterFunction = 与现有代码相同。

处理程序

public Mono<ServerResponse> toRESTInVerticle(ServerRequest serverRequest) {
    String uri = serverRequest.uri().toString();
    String method = serverRequest.methodName();
    String contentType = serverRequest.headers().contentType().get().toString();
    String characterSet = serverRequest.headers().acceptCharset().get(0).toString();
    JSONObject bodyData = serverRequest.bodyToMono(JSONObject.class).toProcessor().peek();

    System.out.println("==========toRESTInVerticle Data Check==========");
    System.out.println(uri);
    System.out.println(method);
    System.out.println(contentType);
    System.out.println(characterSet);
    System.out.println(bodyData);
    System.out.println("======toRESTInVerticle Data Check Complete======");

    return Mono.empty();
}

控制台中的结果如下：-

==========toRESTInVerticle Data Check==========
http://localhost:8082/input/event/check
POST
application/json
UTF-8
{"event_type":"12","event_name_order":["aa","bb","cc"],"event_query":"","event_name":"aaaa","init_value":"","init_value_yn":"N","event_descp":"ddd"}
======toRESTInVerticle Data Check Complete======

祝您编码愉快，谢谢。

已更新。

谢谢。 @Zon 评论。 toProcessor 现已弃用 - 更喜欢使用 share() 来共享父订阅，或使用 Sinks https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Mono.html#toProcessor-- 请参阅此网址。

Answer 2

我认为你可以尝试用下面的方式注册一种“回调”：

        return request.bodyToMono(JSONObject.class)
                  .doOnNext(jsonObject -> // testing..)
                  .then(ServerResponse.ok().build());

此外，我注意到您正在将

ServerResponse.ok()

投射到

Mono<ServerResponse>

。我认为它不会投。使用

ServerResponse.ok().build()

来制作

Mono<ServerResponse>

。

Answer 3

@oddeveloper 我发现

Mono.toProcessor()

已被弃用。

最简单的方法就是拥有这样的 POJO

import java.util.List;
import java.util.Objects;
import java.util.logging.Logger;

public class Person {
    
    private String name;
    
    private List<String> nameOrder;
    
    private String type;
    
    private String query;

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public List<String> getNameOrder() {
        return nameOrder;
    }

    public void setNameOrder(List<String> nameOrder) {
        this.nameOrder = nameOrder;
    }

    public String getType() {
        return type;
    }

    public void setType(String type) {
        this.type = type;
    }

    public String getQuery() {
        return query;
    }

    public void setQuery(String query) {
        this.query = query;
    }
    
    
    @Override
    public String toString() {
        return "Person{" + "name=" + name + ", nameOrder=" + nameOrder + ", type=" + type + ", query=" + query + '}';
    }
}

然后提取

Person person = serverRequest.bodyToMono(Person.class).toFuture().get()

。

get()函数

如有必要，等待此 future 完成，然后返回其结果。

@terekhov你的解决方案对我不起作用我不知道为什么

如果这对你不起作用，并且你必须有一个 JSONObject，那么创建一个像这样的 JSONObjectBodyExtractor

import java.nio.charset.StandardCharsets;
import org.json.JSONObject;
import org.reactivestreams.Subscriber;
import org.reactivestreams.Subscription;
import org.springframework.http.ReactiveHttpInputMessage;
import org.springframework.web.reactive.function.BodyExtractor;
import java.util.logging.Level;
import java.util.logging.Logger;
import org.springframework.core.io.buffer.DataBuffer;
import reactor.core.publisher.Mono;

/**
 *
 * @author timot
 * @param <T>
 * @param <M>
 */
public class JSONObjectBodyExtractor<T extends Mono<JSONObject>, M extends ReactiveHttpInputMessage> implements BodyExtractor {

    private static final Logger LOG = Logger.getLogger(JSONObjectBodyExtractor.class.getName());

    @Override
    public Mono<JSONObject> extract(ReactiveHttpInputMessage inputMessage, Context context) {

        return Mono.<JSONObject>create(sink -> {
            inputMessage.getBody().subscribe(new Subscriber() {

                @Override
                public void onSubscribe(Subscription s) {
                    s.request(1);
                }

                @Override
                public void onNext(Object t) {
                    
                    DataBuffer dataBuffer=(DataBuffer) t;
                    
                    sink.success(new JSONObject(dataBuffer.toString(StandardCharsets.UTF_8)));
                }

                @Override
                public void onError(Throwable thrwbl) {
                    LOG.log(Level.SEVERE, "jsonobjectbodyextractor onerror", thrwbl);
                }

                @Override
                public void onComplete() {
                    LOG.log(Level.INFO, "jsonobjectbodyextractor oncomplete");
                }

            });
        });
    }

}

然后在你的反应处理程序中像这样提取

    Mono<JSONObject> jsonObjectMono = (Mono<JSONObject>) request.body(jsonObjectBodyExtractor);
JSONObject jsonObject=jsonObjectMono.toFuture().get();

Answer 4

可以非阻塞的方式提取body请求的json数据：

使用
Mono<String>
```
 将请求转换为 
```
bodyToMono
.
然后使用
```
JSONObject
```
将字符串映射到
```
map
```
。
因为
```
bodyToMono
```
位于异步返回中，所以我们还需要将异步操作与
```
flatMap
```
链接起来。
在
```
flatMap
```
中，我们可以使用
```
getString
```
访问数据。

    public Mono<ServerResponse> toRESTInVerticle(ServerRequest request) {
        return request.bodyToMono(String.class)
                .map(JSONObject::new)
                .flatMap(bodyData -> {
                    System.out.println(bodyData.toString());
                    String name = bodyData.getString("name");
                    String name_order = bodyData.getString("name_order");
                    String type = bodyData.getString("type");
                    String query = bodyData.getString("query");
                    Mono<String> response = service.testingMethod(name, query);
                    return ServerResponse.ok()
                                    .contentType(MediaType.APPLICATION_JSON)
                                    .body(response, String.class);
                });
    }

注意：如果可能且实用，更喜欢直接映射到 POJO（普通旧 Java 对象），而不是使用 JSONObject。

Spring Reactive 使用 ServerRequest 获取正文 JSONObject

问题描述投票：0回答：4

4个回答

最新问题

Spring Reactive 使用 ServerRequest 获取正文 JSONObject

问题描述 投票：0回答：4

4个回答

最新问题

问题描述投票：0回答：4