Как я могу прочитать содержимое Flux<DataBuffer>?

Я хочу прочитать mulitpart/formdata, одна часть — это application/JSON. Я не могу заставить их Map<String,String>, есть ли способ разобрать Part на String?

private Map<String, String> getFormData(String path, MultiValueMap<String, Part> partMultiValueMap) {
    if (partMultiValueMap != null) {
        Map<String, String> formData = new HashMap<>();
        Map<String, Part> multiPartMap = partMultiValueMap.toSingleValueMap();
        for (Map.Entry<String, Part> partEntry : multiPartMap.entrySet()) {
            Part part = partEntry.getValue();
            if (part instanceof FormFieldPart) {
                formData.put(partEntry.getKey(), ((FormFieldPart) part).value());
            } else {
                String bodyString = bufferToStr(part.content());
                formData.put(partEntry.getKey(), bodyString);

            }
        }
        return formData;
    }
    return null;
}

дополнительный флюс

private String bufferToStr(Flux<DataBuffer> content){
    AtomicReference<String> res = new AtomicReference<>();
    content.subscribe(buffer -> {
        byte[] bytes = new byte[buffer.readableByteCount()];
        buffer.read(bytes);
        DataBufferUtils.release(buffer);
        res.set(new String(bytes, StandardCharsets.UTF_8));
    });
    return res.get();
}

Подписка является асинхронной; bufferToStr значение может быть нулевым?

Пользовательский скаляр GraphQL
Пользовательский скаляр GraphQL
Листовые узлы системы типов GraphQL называются скалярами. Достигнув скалярного типа, невозможно спуститься дальше по иерархии типов. Скалярный тип...
Поднятие тревоги для долго выполняющихся методов в Spring Boot
Поднятие тревоги для долго выполняющихся методов в Spring Boot
Приходилось ли вам сталкиваться с требованиями, в которых вас могли попросить поднять тревогу или выдать ошибку, когда метод Java занимает больше...
Версия Java на основе версии загрузки
Версия Java на основе версии загрузки
Если вы зайдете на официальный сайт Spring Boot , там представлен start.spring.io , который упрощает создание проектов Spring Boot, как показано ниже.
Документирование API с помощью Swagger на Springboot
Документирование API с помощью Swagger на Springboot
В предыдущей статье мы уже узнали, как создать Rest API с помощью Springboot и MySql .
0
0
112
1
Перейти к ответу Данный вопрос помечен как решенный

Ответы 1

Ответ принят как подходящий

Вы можете сделать это неблокирующим способом с помощью StringDecoder

По сути, вы можете написать свой код для возврата Mono<Map<>>

Примечание. Здесь я использую класс Pair, чтобы возвращать ключ-значение, а затем собирать их в Map.

Пара, которую я использую здесь, из упаковки org.springframework.data.util.Pair

public Mono<Map<String, String>> getFormData(MultiValueMap<String, Part> partMultiValueMap) {
    Map<String, Part> multiPartMap = partMultiValueMap.toSingleValueMap();

    return Flux.fromIterable(multiPartMap.entrySet())
            .flatMap(entry -> {
                Part part = entry.getValue();
                if (part instanceof FormFieldPart) {
                    return Mono.just(
                            Pair.of(entry.getKey(), ((FormFieldPart) part).value()) // return Pair
                    );
                } else {
                    return decodePartToString(part.content()) // decoding DataBuffers to string
                            .flatMap(decodedString ->
                                    Mono.just(Pair.of(entry.getKey(), decodedString))); // return Pair
                }
            })
            .collectMap(Pair::getFirst, Pair::getSecond); // map and collect pairs to Map<>
}

private Mono<String> decodePartToString(Flux<DataBuffer> dataBufferFlux) {
    StringDecoder stringDecoder = StringDecoder.textPlainOnly();

    return stringDecoder.decodeToMono(dataBufferFlux,
            ResolvableType.NONE,
            MimeTypeUtils.TEXT_PLAIN,
            Collections.emptyMap()
    );
}

большое спасибо, вы решили мою проблему...

tangyaya 31.01.2023 06:52

Другие вопросы по теме