@UnstableApi public abstract class AbstractMemcacheObjectEncoder<M extends MemcacheMessage> extends MessageToMessageEncoder<java.lang.Object>
MemcacheMessage
的通用AbstractMemcacheObjectEncoder
。
请注意,此类旨在进行扩展,特别是因为二进制和ASCII协议都需要对它们的消息进行不同的处理。 由于两者的内容块写入相同,因此编码器会立即提取。
ChannelHandler.Sharable
Constructor and Description |
---|
AbstractMemcacheObjectEncoder() |
Modifier and Type | Method and Description |
---|---|
boolean |
acceptOutboundMessage(java.lang.Object msg)
如果给定的消息应该被处理,则返回
true 。
|
protected void |
encode(ChannelHandlerContext ctx, java.lang.Object msg, java.util.List<java.lang.Object> out)
从一条消息编码到另一条消息。
|
protected abstract ByteBuf |
encodeMessage(ChannelHandlerContext ctx, M msg)
取给定的 MemcacheMessage 并将其编码为可写ByteBuf 。
|
write
bind, close, connect, deregister, disconnect, flush, read
ensureNotSharable, exceptionCaught, handlerAdded, handlerRemoved, isSharable
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
exceptionCaught, handlerAdded, handlerRemoved
protected void encode(ChannelHandlerContext ctx, java.lang.Object msg, java.util.List<java.lang.Object> out) throws java.lang.Exception
MessageToMessageEncoder
encode
在课程
MessageToMessageEncoder<java.lang.Object>
ctx
- MessageToMessageEncoder
属于的ChannelHandlerContext
msg
- 要编码到另一个的消息
out
- 应该添加编码味精的
List
需要做某种聚合
java.lang.Exception
- 发生错误时抛出
public boolean acceptOutboundMessage(java.lang.Object msg) throws java.lang.Exception
MessageToMessageEncoder
true
。
如果false
它将被传递到ChannelPipeline
中的下一个ChannelOutboundHandler
。
acceptOutboundMessage
在课程
MessageToMessageEncoder<java.lang.Object>
java.lang.Exception
protected abstract ByteBuf encodeMessage(ChannelHandlerContext ctx, M msg)
MemcacheMessage
并将其编码为可写ByteBuf
。
ctx
- 通道处理程序上下文。
msg
- 要编码的消息。
ByteBuf
表示。
Copyright © 2008–2018 The Netty Project. All rights reserved.