com.alibaba.fastjson2.support.spring.codec

Class Fastjson2Decoder

java.lang.Object

org.springframework.core.codec.AbstractDecoder<java.lang.Object>

com.alibaba.fastjson2.support.spring.codec.Fastjson2Decoder

All Implemented Interfaces:

org.springframework.core.codec.Decoder<java.lang.Object>

public final class Fastjson2Decoder
extends org.springframework.core.codec.AbstractDecoder<java.lang.Object>

spring message codec decoder for Fastjson2.

Since:

2025/8/6

Field Summary

Fields

Modifier and Type	Field and Description
private FastJsonConfig	config

Fields inherited from class org.springframework.core.codec.AbstractDecoder

logger

Constructor Summary

Constructors

Constructor and Description
Fastjson2Decoder() default constructor
Fastjson2Decoder(FastJsonConfig config, org.springframework.util.MimeType... mimeTypes) Constructor with custom configs

Method Summary

Modifier and Type	Method and Description
java.lang.Object	decode(org.springframework.core.io.buffer.DataBuffer buffer, org.springframework.core.ResolvableType targetType, org.springframework.util.MimeType mimeType, java.util.Map<java.lang.String,java.lang.Object> hints)
reactor.core.publisher.Flux<java.lang.Object>	decode(org.reactivestreams.Publisher<org.springframework.core.io.buffer.DataBuffer> inputStream, org.springframework.core.ResolvableType elementType, org.springframework.util.MimeType mimeType, java.util.Map<java.lang.String,java.lang.Object> hints)
reactor.core.publisher.Mono<java.lang.Object>	decodeToMono(org.reactivestreams.Publisher<org.springframework.core.io.buffer.DataBuffer> inputStream, org.springframework.core.ResolvableType elementType, org.springframework.util.MimeType mimeType, java.util.Map<java.lang.String,java.lang.Object> hints)
private void	logValue(java.lang.Object value, java.util.Map<java.lang.String,java.lang.Object> hints)

Methods inherited from class org.springframework.core.codec.AbstractDecoder

canDecode, getDecodableMimeTypes, getLogger, setLogger

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.springframework.core.codec.Decoder

getDecodableMimeTypes

Field Detail

config

private final FastJsonConfig config

Constructor Detail

Fastjson2Decoder

public Fastjson2Decoder()

default constructor

Fastjson2Decoder

public Fastjson2Decoder(FastJsonConfig config,
                        org.springframework.util.MimeType... mimeTypes)

Constructor with custom configs

Parameters:

config - FastJsonConfig

mimeTypes - the mime types to support

Method Detail

decode

@NonNull
public reactor.core.publisher.Flux<java.lang.Object> decode(@NonNull
                                                                     org.reactivestreams.Publisher<org.springframework.core.io.buffer.DataBuffer> inputStream,
                                                                     @NonNull
                                                                     org.springframework.core.ResolvableType elementType,
                                                                     @Nullable
                                                                     org.springframework.util.MimeType mimeType,
                                                                     @Nullable
                                                                     java.util.Map<java.lang.String,java.lang.Object> hints)

decode

@Nullable
public java.lang.Object decode(@NonNull
                                         org.springframework.core.io.buffer.DataBuffer buffer,
                                         @NonNull
                                         org.springframework.core.ResolvableType targetType,
                                         org.springframework.util.MimeType mimeType,
                                         java.util.Map<java.lang.String,java.lang.Object> hints)
                                  throws org.springframework.core.codec.DecodingException

Throws:

org.springframework.core.codec.DecodingException

decodeToMono

@NonNull
public reactor.core.publisher.Mono<java.lang.Object> decodeToMono(@NonNull
                                                                           org.reactivestreams.Publisher<org.springframework.core.io.buffer.DataBuffer> inputStream,
                                                                           @NonNull
                                                                           org.springframework.core.ResolvableType elementType,
                                                                           @Nullable
                                                                           org.springframework.util.MimeType mimeType,
                                                                           @Nullable
                                                                           java.util.Map<java.lang.String,java.lang.Object> hints)

Specified by:

decodeToMono in interface org.springframework.core.codec.Decoder<java.lang.Object>

Overrides:

decodeToMono in class org.springframework.core.codec.AbstractDecoder<java.lang.Object>

logValue

private void logValue(@Nullable
                      java.lang.Object value,
                      @Nullable
                      java.util.Map<java.lang.String,java.lang.Object> hints)