@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 。
|
writebind, close, connect, deregister, disconnect, flush, readensureNotSharable, exceptionCaught, handlerAdded, handlerRemoved, isSharableclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitexceptionCaught, handlerAdded, handlerRemovedprotected 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.