@ChannelHandler.Sharable public class StringDecoder extends OneToOneDecoder
ChannelBuffer into a String. Please
note that this decoder must be used with a proper FrameDecoder
such as DelimiterBasedFrameDecoder if you are using a stream-based
transport such as TCP/IP. A typical setup for a text-based line protocol
in a TCP/IP socket would be:
and then you can use aChannelPipelinepipeline = ...; // Decoders pipeline.addLast("frameDecoder", newDelimiterBasedFrameDecoder(80,Delimiters.lineDelimiter())); pipeline.addLast("stringDecoder", newStringDecoder(CharsetUtil.UTF_8)); // Encoder pipeline.addLast("stringEncoder", newStringEncoder(CharsetUtil.UTF_8));
String instead of a ChannelBuffer
as a message:
void messageReceived(ChannelHandlerContextctx,MessageEvente) { String msg = (String) e.getMessage(); ch.write("Did you say '" + msg + "'?\n"); }
ChannelHandler.Sharable| 构造器和说明 |
|---|
StringDecoder()
Creates a new instance with the current system character set.
|
StringDecoder(java.nio.charset.Charset charset)
Creates a new instance with the specified character set.
|
| 限定符和类型 | 方法和说明 |
|---|---|
protected java.lang.Object |
decode(ChannelHandlerContext ctx,
Channel channel,
java.lang.Object msg)
Transforms the specified received message into another message and return
the transformed message.
|
handleUpstreampublic StringDecoder()
public StringDecoder(java.nio.charset.Charset charset)
protected java.lang.Object decode(ChannelHandlerContext ctx, Channel channel, java.lang.Object msg) throws java.lang.Exception
OneToOneDecodernull if the received message
is supposed to be discarded.decode 在类中 OneToOneDecoderjava.lang.Exception