接口的使用
org.springframework.messaging.tcp.reactor.ReactorNettyCodec
使用ReactorNettyCodec的程序包 程序包 说明 org.springframework.messaging.simp.stomp Generic support for simple messaging protocols (like STOMP).org.springframework.messaging.tcp.reactor Contains support for TCP messaging based on Reactor.org.springframework.messaging.simp.stomp中ReactorNettyCodec的使用
实现ReactorNettyCodec的org.springframework.messaging.simp.stomp中的类 修饰符和类型 类 说明 class
StompReactorNettyCodec
Simple delegation to StompDecoder and StompEncoder.org.springframework.messaging.tcp.reactor中ReactorNettyCodec的使用
实现ReactorNettyCodec的org.springframework.messaging.tcp.reactor中的类 修饰符和类型 类 说明 class
AbstractNioBufferReactorNettyCodec<P>
Convenient base class forReactorNettyCodec
implementations that need to work with NIOByteBuffers
.参数类型为ReactorNettyCodec的org.springframework.messaging.tcp.reactor中的构造器 构造器 说明 ReactorNettyTcpClient(String host, int port, ReactorNettyCodec<P> codec)
Simple constructor with the host and port to use to connect to.ReactorNettyTcpClient(Function<reactor.netty.tcp.TcpClient,reactor.netty.tcp.TcpClient> clientConfigurer, ReactorNettyCodec<P> codec)
A variant ofReactorNettyTcpClient(String, int, ReactorNettyCodec)
that still manages the lifecycle of theTcpClient
and underlying resources, but allows for direct configuration of other properties of the client through aFunction<TcpClient, TcpClient>
.ReactorNettyTcpClient(reactor.netty.tcp.TcpClient tcpClient, ReactorNettyCodec<P> codec)
Constructor with an externally createdTcpClient
instance whose lifecycle is expected to be managed externally.ReactorNettyTcpConnection(reactor.netty.NettyInbound inbound, reactor.netty.NettyOutbound outbound, ReactorNettyCodec<P> codec, reactor.core.publisher.DirectProcessor<Void> closeProcessor)