Spring Reactive получить тело JSONObject с помощью ServerRequest - PullRequest
Новая
       7

Spring Reactive получить тело JSONObject с помощью ServerRequest

0 голосов
/ 18 октября 2018

Я новичок реагирующего на весну.

Я пытаюсь использовать почтальон для получения информации о запросах от сервера.

Сначала почтальон отправляет информацию на сервер, используя метод post.Во-вторых, мы работаем на стороне сервера с соответствующим кодом и получаем информацию для запроса.

В следующем фрагменте кода

Интересно, смогу ли я получить JSONObject функции ServerRequest.

тело почтальона (application / json) 

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

Java (RouterFunction) 

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();
}

Ответы [ 2 ]

0 голосов
/ 19 октября 2018

спасибо. Александр Терехов

Ваш ответ очень помог в решении проблемы.

Мой тестовый код.

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======

Счастливое кодирование Спасибо.

0 голосов
/ 18 октября 2018

Я думаю, вы можете попытаться зарегистрировать своего рода «обратный вызов» следующим образом: 

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

Также я заметил, что вы переводите ServerResponse.ok() на Mono<ServerResponse>.Я думаю, что это не бросит.Используйте ServerResponse.ok().build(), чтобы сделать Mono<ServerResponse>.

...