RedisBulkStringAggregator (Netty API Reference (4.1.22.Final))

java.lang.Object
- io.netty.channel.ChannelHandlerAdapter
- - io.netty.channel.ChannelInboundHandlerAdapter
  - - io.netty.handler.codec.MessageToMessageDecoder<I>
    - - io.netty.handler.codec.MessageAggregator<RedisMessage,BulkStringHeaderRedisMessage,BulkStringRedisContent,FullBulkStringRedisMessage>
      - io.netty.handler.codec.redis.RedisBulkStringAggregator

All Implemented Interfaces:

ChannelHandler ， ChannelInboundHandler
```
@UnstableApi
public final class RedisBulkStringAggregator
extends MessageAggregator<RedisMessage,BulkStringHeaderRedisMessage,BulkStringRedisContent,FullBulkStringRedisMessage>
```
ChannelHandler将BulkStringHeaderRedisMessage及其随后的BulkStringRedisContent合并为一个FullBulkStringRedisMessage ，但没有BulkStringRedisContent 。当你不想照顾传输编码被“分块”的RedisMessage时，它非常有用。在ChannelPipeline之后的RedisDecoder之后插入此处理程序：
```
  ChannelPipeline p = ...;
 ...
 p.addLast("encoder", new RedisEncoder());
 p.addLast("decoder", new RedisDecoder());
 p.addLast("aggregator", new RedisBulkStringAggregator());
 ...
 p.addLast("handler", new HttpRequestHandler()); 
```
请注意，您需要在ChannelPipeline的RedisBulkStringAggregator之前安装 RedisEncoder 。

Nested Class Summary
- Nested classes/interfaces inherited from interface io.netty.channel.ChannelHandler
  ChannelHandler.Sharable

构造方法摘要

构造方法
Constructor and Description
`RedisBulkStringAggregator()` 创建一个新的实例。

方法摘要

所有方法接口方法具体的方法
Modifier and Type	Method and Description
`protected FullBulkStringRedisMessage`	`beginAggregation(BulkStringHeaderRedisMessage start, ByteBuf content)` 根据指定的开始消息和指定的内容创建新的聚合消息。
`protected boolean`	`closeAfterContinueResponse(java.lang.Object msg)` 确定在写入 `MessageAggregator.newContinueResponse(Object, int, ChannelPipeline)`的结果后是否应该关闭通道。
`protected boolean`	`ignoreContentAfterContinueResponse(java.lang.Object msg)` 确定当前请求/响应的所有对象是否应该被忽略。
`protected boolean`	`isAggregated(RedisMessage msg)` 当且仅当指定的消息已被聚合时才返回 `true` 。
`protected boolean`	`isContentLengthInvalid(BulkStringHeaderRedisMessage start, int maxContentLength)` 确定消息 `start`的内容长度是否已知，并且是否大于 `maxContentLength` 。
`protected boolean`	`isContentMessage(RedisMessage msg)` 当且仅当指定的消息是内容消息时返回 `true` 。
`protected boolean`	`isLastContentMessage(BulkStringRedisContent msg)` 当且仅当指定的消息是最后一个内容消息时才返回 `true` 。
`protected boolean`	`isStartMessage(RedisMessage msg)` 当且仅当指定的消息是开始消息时返回 `true` 。
`protected java.lang.Object`	`newContinueResponse(BulkStringHeaderRedisMessage start, int maxContentLength, ChannelPipeline pipeline)` 如有必要，返回指定开始消息的'continue response'。

Methods inherited from class io.netty.handler.codec.MessageAggregator
acceptInboundMessage, aggregate, channelInactive, channelReadComplete, ctx, decode, finishAggregation, handleOversizedMessage, handlerAdded, handlerRemoved, isHandlingOversizedMessage, maxContentLength, maxCumulationBufferComponents, setMaxCumulationBufferComponents

Methods inherited from class io.netty.handler.codec.MessageToMessageDecoder
channelRead

Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter
channelActive, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught, userEventTriggered

Methods inherited from class io.netty.channel.ChannelHandlerAdapter
ensureNotSharable, isSharable

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- 构造方法详细信息
  - RedisBulkStringAggregator
```
public RedisBulkStringAggregator()
```
    创建一个新的实例。
- 方法详细信息
  - isStartMessage
```
protected boolean isStartMessage(RedisMessage msg)
                          throws java.lang.Exception
```
    从类复制的描述： MessageAggregator
    当且仅当指定的消息是开始消息时才返回true 。通常情况下，此方法作为return声明与instanceof ：
```
  return msg instanceof MyStartMessage; 
```
    Specified by:
    
    isStartMessage MessageAggregator<RedisMessage,BulkStringHeaderRedisMessage,BulkStringRedisContent,FullBulkStringRedisMessage>
    
    异常
    
    java.lang.Exception
  - isContentMessage
```
protected boolean isContentMessage(RedisMessage msg)
                            throws java.lang.Exception
```
    从类复制的描述： MessageAggregator
    当且仅当指定的消息是内容消息时才返回true 。通常情况下，此方法以return语句与instanceof ：
```
  return msg instanceof MyContentMessage; 
```
    Specified by:
    
    isContentMessage在课程 MessageAggregator<RedisMessage,BulkStringHeaderRedisMessage,BulkStringRedisContent,FullBulkStringRedisMessage>
    
    异常
    
    java.lang.Exception
  - isLastContentMessage
```
protected boolean isLastContentMessage(BulkStringRedisContent msg)
                                throws java.lang.Exception
```
    从类复制的描述： MessageAggregator
    当且仅当指定的消息是最后一个内容消息时才返回true 。通常情况下，此方法作为return单个return语句与instanceof ：
```
  return msg instanceof MyLastContentMessage; 
```
    或用instanceof和布尔型字段检查：
```
  return msg instanceof MyContentMessage && msg.isLastFragment(); 
```
    Specified by:
    
    isLastContentMessage在课程 MessageAggregator<RedisMessage,BulkStringHeaderRedisMessage,BulkStringRedisContent,FullBulkStringRedisMessage>
    
    异常
    
    java.lang.Exception
  - isAggregated
```
protected boolean isAggregated(RedisMessage msg)
                        throws java.lang.Exception
```
    从类复制的描述： MessageAggregator
    
    当且仅当指定的消息已经被聚合时返回true 。如果此方法返回true ，则此处理程序将仅将消息按true转发给下一个处理程序。
    
    Specified by:
    
    isAggregated在课程 MessageAggregator<RedisMessage,BulkStringHeaderRedisMessage,BulkStringRedisContent,FullBulkStringRedisMessage>
    
    异常
    
    java.lang.Exception
  - isContentLengthInvalid
```
protected boolean isContentLengthInvalid(BulkStringHeaderRedisMessage start,
                                         int maxContentLength)
                                  throws java.lang.Exception
```
    从类复制的描述： MessageAggregator
    
    确定消息 start的内容长度是否已知，并且是否大于 maxContentLength 。
    
    Specified by:
    
    isContentLengthInvalid在课程 MessageAggregator<RedisMessage,BulkStringHeaderRedisMessage,BulkStringRedisContent,FullBulkStringRedisMessage>
    
    参数
    
    start - 可能指示内容长度的消息。
    
    maxContentLength - 允许的最大内容长度。
    
    结果
    
    true如果消息start的内容长度已知，并且它大于maxContentLength 。否则为false 。
    
    异常
    
    java.lang.Exception
  - newContinueResponse
```
protected java.lang.Object newContinueResponse(BulkStringHeaderRedisMessage start,
                                               int maxContentLength,
                                               ChannelPipeline pipeline)
                                        throws java.lang.Exception
```
    从类复制的描述： MessageAggregator
    
    如有必要，返回指定开始消息的'continue response'。例如，这个方法对于处理一个HTTP 100-continue头是很有用的。
    
    Specified by:
    
    newContinueResponse在课程 MessageAggregator<RedisMessage,BulkStringHeaderRedisMessage,BulkStringRedisContent,FullBulkStringRedisMessage>
    
    结果
    
    '继续回复'，或者 null如果没有消息要发送
    
    异常
    
    java.lang.Exception
  - closeAfterContinueResponse
```
protected boolean closeAfterContinueResponse(java.lang.Object msg)
                                      throws java.lang.Exception
```
    从类复制的描述： MessageAggregator
    
    在写入 MessageAggregator.newContinueResponse(Object, int, ChannelPipeline)的结果后，确定通道是否应该关闭。
    
    Specified by:
    
    closeAfterContinueResponse在课程 MessageAggregator<RedisMessage,BulkStringHeaderRedisMessage,BulkStringRedisContent,FullBulkStringRedisMessage>
    
    参数
    
    msg - 来自 MessageAggregator.newContinueResponse(Object, int, ChannelPipeline)的返回值。
    
    结果
    
    true如果在写入MessageAggregator.newContinueResponse(Object, int, ChannelPipeline)的结果后关闭通道。否则为false 。
    
    异常
    
    java.lang.Exception
  - ignoreContentAfterContinueResponse
```
protected boolean ignoreContentAfterContinueResponse(java.lang.Object msg)
                                              throws java.lang.Exception
```
    从类复制的描述： MessageAggregator
    
    确定当前请求/响应的所有对象是否应该被忽略。下次MessageAggregator.isContentMessage(Object)返回true时，消息将不再被忽略。
    
    Specified by:
    
    ignoreContentAfterContinueResponse在课程 MessageAggregator<RedisMessage,BulkStringHeaderRedisMessage,BulkStringRedisContent,FullBulkStringRedisMessage>
    
    参数
    
    msg -从返回值 MessageAggregator.newContinueResponse(Object, int, ChannelPipeline) 。
    
    结果
    
    true如果当前请求/响应的所有对象都应该被忽略。否则为false 。
    
    异常
    
    java.lang.Exception
  - beginAggregation
```
protected FullBulkStringRedisMessage beginAggregation(BulkStringHeaderRedisMessage start,
                                                      ByteBuf content)
                                               throws java.lang.Exception
```
    从类复制的描述： MessageAggregator
    
    根据指定的开始消息和指定的内容创建新的聚合消息。如果启动消息实现ByteBufHolder ，则其内容将附加到指定的content 。此聚合器将继续将收到的内容追加到指定的content 。
    
    Specified by:
    
    beginAggregation在课程 MessageAggregator<RedisMessage,BulkStringHeaderRedisMessage,BulkStringRedisContent,FullBulkStringRedisMessage>
    
    异常
    
    java.lang.Exception

Class RedisBulkStringAggregator

Nested Class Summary

Nested classes/interfaces inherited from interface io.netty.channel.ChannelHandler

构造方法摘要

方法摘要

Methods inherited from class io.netty.handler.codec.MessageAggregator

Methods inherited from class io.netty.handler.codec.MessageToMessageDecoder

Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter

Methods inherited from class io.netty.channel.ChannelHandlerAdapter

Methods inherited from class java.lang.Object

构造方法详细信息

RedisBulkStringAggregator

方法详细信息

isStartMessage

isContentMessage

isLastContentMessage

isAggregated

isContentLengthInvalid

newContinueResponse

closeAfterContinueResponse

ignoreContentAfterContinueResponse

beginAggregation