org.apache.flink.shaded.netty4.io.netty.buffer.ByteBuf.readableBytes()方法的使用及代码示例

x33g5p2x  于2022-01-17 转载在 其他  
字(10.5k)|赞(0)|评价(0)|浏览(202)

本文整理了Java中org.apache.flink.shaded.netty4.io.netty.buffer.ByteBuf.readableBytes()方法的一些代码示例，展示了ByteBuf.readableBytes()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。ByteBuf.readableBytes()方法的具体详情如下：
包路径：org.apache.flink.shaded.netty4.io.netty.buffer.ByteBuf
类名称：ByteBuf
方法名：readableBytes

ByteBuf.readableBytes介绍

暂无

代码示例

代码示例来源：origin: apache/flink

private ByteBuf readChunk() {
  if (isClosed) {
    return null;
  } else if (buf.readableBytes() <= chunkSize) {
    isEndOfInput = true;
    // Don't retain as the consumer is responsible to release it
    return buf.slice();
  } else {
    // Return a chunk sized slice of the buffer. The ref count is
    // shared with the original buffer. That's why we need to retain
    // a reference here.
    return buf.readSlice(chunkSize).retain();
  }
}

代码示例来源：origin: apache/flink

/**
 * Serializes the failure message sent to the
 * {@link org.apache.flink.queryablestate.network.Client} in case of
 * server related errors.
 *
 * @param alloc            The {@link ByteBufAllocator} used to allocate the buffer to serialize the message into.
 * @param cause            The exception thrown at the server.
 * @return        The failure message.
 */
public static ByteBuf serializeServerFailure(
    final ByteBufAllocator alloc,
    final Throwable cause) throws IOException {
  final ByteBuf buf = alloc.ioBuffer();
  // Frame length is set at end
  buf.writeInt(0);
  writeHeader(buf, MessageType.SERVER_FAILURE);
  try (ByteBufOutputStream bbos = new ByteBufOutputStream(buf);
      ObjectOutput out = new ObjectOutputStream(bbos)) {
    out.writeObject(cause);
  }
  // Set frame length
  int frameLength = buf.readableBytes() - Integer.BYTES;
  buf.setInt(0, frameLength);
  return buf;
}

代码示例来源：origin: apache/flink

/**
 * Serializes the exception containing the failure message sent to the
 * {@link org.apache.flink.queryablestate.network.Client} in case of
 * protocol related errors.
 *
 * @param alloc            The {@link ByteBufAllocator} used to allocate the buffer to serialize the message into.
 * @param requestId        The id of the request to which the message refers to.
 * @param cause            The exception thrown at the server.
 * @return A {@link ByteBuf} containing the serialized message.
 */
public static ByteBuf serializeRequestFailure(
    final ByteBufAllocator alloc,
    final long requestId,
    final Throwable cause) throws IOException {
  final ByteBuf buf = alloc.ioBuffer();
  // Frame length is set at the end
  buf.writeInt(0);
  writeHeader(buf, MessageType.REQUEST_FAILURE);
  buf.writeLong(requestId);
  try (ByteBufOutputStream bbos = new ByteBufOutputStream(buf);
      ObjectOutput out = new ObjectOutputStream(bbos)) {
    out.writeObject(cause);
  }
  // Set frame length
  int frameLength = buf.readableBytes() - Integer.BYTES;
  buf.setInt(0, frameLength);
  return buf;
}

代码示例来源：origin: apache/flink

private void sendError(ChannelHandlerContext ctx, String error) {
    if (ctx.channel().isActive()) {
      DefaultFullHttpResponse response = new DefaultFullHttpResponse(HttpVersion.HTTP_1_1,
        HttpResponseStatus.INTERNAL_SERVER_ERROR,
        Unpooled.wrappedBuffer(error.getBytes(ConfigConstants.DEFAULT_CHARSET)));

      response.headers().set(HttpHeaders.Names.CONTENT_TYPE, "text/plain");
      response.headers().set(HttpHeaders.Names.CONTENT_LENGTH, response.content().readableBytes());

      ctx.writeAndFlush(response);
    }
  }
}

代码示例来源：origin: apache/flink

if (serialResp.readableBytes() <= highWatermark) {
  write = ctx.writeAndFlush(serialResp);
} else {

代码示例来源：origin: apache/flink

response.headers().set(HttpHeaders.Names.CONTENT_LENGTH, response.content().readableBytes());

代码示例来源：origin: org.apache.flink/flink-queryable-state-client-java_2.11

private ByteBuf readChunk() {
  if (isClosed) {
    return null;
  } else if (buf.readableBytes() <= chunkSize) {
    isEndOfInput = true;
    // Don't retain as the consumer is responsible to release it
    return buf.slice();
  } else {
    // Return a chunk sized slice of the buffer. The ref count is
    // shared with the original buffer. That's why we need to retain
    // a reference here.
    return buf.readSlice(chunkSize).retain();
  }
}

代码示例来源：origin: com.alibaba.blink/flink-queryable-state-client-java

@Override
public ByteBuf readChunk(ChannelHandlerContext ctx) throws Exception {
  if (isClosed) {
    return null;
  } else if (buf.readableBytes() <= chunkSize) {
    isEndOfInput = true;
    // Don't retain as the consumer is responsible to release it
    return buf.slice();
  } else {
    // Return a chunk sized slice of the buffer. The ref count is
    // shared with the original buffer. That's why we need to retain
    // a reference here.
    return buf.readSlice(chunkSize).retain();
  }
}

代码示例来源：origin: com.alibaba.blink/flink-runtime

/**
 * Copies bytes from the src to dest, but do not exceed the capacity of the dest buffer.
 *
 * @param src The ByteBuf to copy bytes from.
 * @param dest The ByteBuf to copy bytes to.
 * @param maxCopySize Maximum size of bytes to copy.
 * @return The length of actually copied bytes.
 */
private int copyToTargetBuffer(ByteBuf src, ByteBuf dest, int maxCopySize) {
  int copyLength = Math.min(src.readableBytes(), maxCopySize);
  checkState(dest.writableBytes() >= copyLength,
    "There is not enough space to copy " + copyLength + " bytes, writable = " + dest.writableBytes());
  dest.writeBytes(src, copyLength);
  return copyLength;
}

代码示例来源：origin: com.alibaba.blink/flink-runtime

public static HttpResponse getResponse(HttpResponseStatus status, @Nullable String message) {
  ByteBuf messageByteBuf = message == null ? Unpooled.buffer(0)
    : Unpooled.wrappedBuffer(message.getBytes(ENCODING));
  FullHttpResponse response = new DefaultFullHttpResponse(HttpVersion.HTTP_1_1, status, messageByteBuf);
  response.headers().set(HttpHeaders.Names.CONTENT_TYPE, "text/plain; charset=" + ENCODING.name());
  response.headers().set(HttpHeaders.Names.CONTENT_LENGTH, response.content().readableBytes());
  return response;
}

代码示例来源：origin: org.apache.flink/flink-runtime_2.11

public static HttpResponse getResponse(HttpResponseStatus status, @Nullable String message) {
  ByteBuf messageByteBuf = message == null ? Unpooled.buffer(0)
    : Unpooled.wrappedBuffer(message.getBytes(ENCODING));
  FullHttpResponse response = new DefaultFullHttpResponse(HttpVersion.HTTP_1_1, status, messageByteBuf);
  response.headers().set(HttpHeaders.Names.CONTENT_TYPE, "text/plain; charset=" + ENCODING.name());
  response.headers().set(HttpHeaders.Names.CONTENT_LENGTH, response.content().readableBytes());
  return response;
}

代码示例来源：origin: org.apache.flink/flink-runtime

public static HttpResponse getResponse(HttpResponseStatus status, @Nullable String message) {
  ByteBuf messageByteBuf = message == null ? Unpooled.buffer(0)
    : Unpooled.wrappedBuffer(message.getBytes(ENCODING));
  FullHttpResponse response = new DefaultFullHttpResponse(HttpVersion.HTTP_1_1, status, messageByteBuf);
  response.headers().set(HttpHeaders.Names.CONTENT_TYPE, "text/plain; charset=" + ENCODING.name());
  response.headers().set(HttpHeaders.Names.CONTENT_LENGTH, response.content().readableBytes());
  return response;
}

代码示例来源：origin: com.alibaba.blink/flink-runtime

public static HttpResponse getErrorResponse(Throwable throwable, HttpResponseStatus status) {
    byte[] bytes = ExceptionUtils.stringifyException(throwable).getBytes(ENCODING);
    FullHttpResponse response = new DefaultFullHttpResponse(
      HttpVersion.HTTP_1_1,
      status,
      Unpooled.wrappedBuffer(bytes));

    response.headers().set(HttpHeaders.Names.CONTENT_TYPE, "text/plain; charset=" + ENCODING.name());
    response.headers().set(HttpHeaders.Names.CONTENT_LENGTH, response.content().readableBytes());

    return response;
  }
}

代码示例来源：origin: org.apache.flink/flink-runtime_2.11

public static HttpResponse getErrorResponse(Throwable throwable, HttpResponseStatus status) {
    byte[] bytes = ExceptionUtils.stringifyException(throwable).getBytes(ENCODING);
    FullHttpResponse response = new DefaultFullHttpResponse(
      HttpVersion.HTTP_1_1,
      status,
      Unpooled.wrappedBuffer(bytes));

    response.headers().set(HttpHeaders.Names.CONTENT_TYPE, "text/plain; charset=" + ENCODING.name());
    response.headers().set(HttpHeaders.Names.CONTENT_LENGTH, response.content().readableBytes());

    return response;
  }
}

代码示例来源：origin: org.apache.flink/flink-runtime

public static HttpResponse getErrorResponse(Throwable throwable, HttpResponseStatus status) {
    byte[] bytes = ExceptionUtils.stringifyException(throwable).getBytes(ENCODING);
    FullHttpResponse response = new DefaultFullHttpResponse(
      HttpVersion.HTTP_1_1,
      status,
      Unpooled.wrappedBuffer(bytes));

    response.headers().set(HttpHeaders.Names.CONTENT_TYPE, "text/plain; charset=" + ENCODING.name());
    response.headers().set(HttpHeaders.Names.CONTENT_LENGTH, response.content().readableBytes());

    return response;
  }
}

代码示例来源：origin: com.alibaba.blink/flink-runtime

@Override
public CompletableFuture<FullHttpResponse> handleRequest(Map<String, String> pathParams, Map<String, String> queryParams, JobManagerGateway jobManagerGateway) {
  CompletableFuture<String> resultFuture = handleJsonRequest(pathParams, queryParams, jobManagerGateway);
  return resultFuture.thenApplyAsync(
    (String result) -> {
      byte[] bytes = result.getBytes(ENCODING);
      DefaultFullHttpResponse response = new DefaultFullHttpResponse(
        HttpVersion.HTTP_1_1, HttpResponseStatus.OK, Unpooled.wrappedBuffer(bytes));
      response.headers().set(HttpHeaders.Names.CONTENT_TYPE, "application/json; charset=" + ENCODING.name());
      response.headers().set(HttpHeaders.Names.CONTENT_LENGTH, response.content().readableBytes());
      return response;
    });
}

代码示例来源：origin: org.apache.flink/flink-runtime-web_2.11

private void sendError(ChannelHandlerContext ctx, String error) {
    if (ctx.channel().isActive()) {
      DefaultFullHttpResponse response = new DefaultFullHttpResponse(HttpVersion.HTTP_1_1,
        HttpResponseStatus.INTERNAL_SERVER_ERROR,
        Unpooled.wrappedBuffer(error.getBytes(ConfigConstants.DEFAULT_CHARSET)));

      response.headers().set(HttpHeaders.Names.CONTENT_TYPE, "text/plain");
      response.headers().set(HttpHeaders.Names.CONTENT_LENGTH, response.content().readableBytes());

      ctx.writeAndFlush(response);
    }
  }
}

代码示例来源：origin: org.apache.flink/flink-runtime-web

private void sendError(ChannelHandlerContext ctx, String error) {
    if (ctx.channel().isActive()) {
      DefaultFullHttpResponse response = new DefaultFullHttpResponse(HttpVersion.HTTP_1_1,
        HttpResponseStatus.INTERNAL_SERVER_ERROR,
        Unpooled.wrappedBuffer(error.getBytes(ConfigConstants.DEFAULT_CHARSET)));

      response.headers().set(HttpHeaders.Names.CONTENT_TYPE, "text/plain");
      response.headers().set(HttpHeaders.Names.CONTENT_LENGTH, response.content().readableBytes());

      ctx.writeAndFlush(response);
    }
  }
}

代码示例来源：origin: org.apache.flink/flink-runtime_2.11

@Override
protected void decode(ChannelHandlerContext context, ByteBuf in, List<Object> out) {
  if (in.readableBytes() >= SSL_RECORD_HEADER_LENGTH && SslHandler.isEncrypted(in)) {
    handleSsl(context);
  } else {
    context.pipeline().replace(this, HTTP_CODEC_HANDLER_NAME, new HttpServerCodec());
    context.pipeline().addAfter(HTTP_CODEC_HANDLER_NAME, NON_SSL_HANDLER_NAME, new NonSslHandler());
  }
}

代码示例来源：origin: org.apache.flink/flink-runtime

@Override
protected void decode(ChannelHandlerContext context, ByteBuf in, List<Object> out) {
  if (in.readableBytes() >= SSL_RECORD_HEADER_LENGTH && SslHandler.isEncrypted(in)) {
    handleSsl(context);
  } else {
    context.pipeline().replace(this, HTTP_CODEC_HANDLER_NAME, new HttpServerCodec());
    context.pipeline().addAfter(HTTP_CODEC_HANDLER_NAME, NON_SSL_HANDLER_NAME, new NonSslHandler());
  }
}

内容来源于网络，如有侵权，请联系作者删除！

ByteBuf

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备2022004421号-2 NULL123 https://www.null123.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com