com.couchbase.client.deps.io.netty.buffer.ByteBuf.readByte()方法的使用及代码示例

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

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

ByteBuf.readByte介绍

[英]Gets a byte at the current readerIndex and increases the readerIndex by 1 in this buffer.
[中]在当前readerIndex处获取一个字节，并在此缓冲区中将readerIndex增加1。

代码示例

代码示例来源：origin: com.couchbase.client/core-io

  1. @Override
  2. public byte readByte() {
  3.   return buf.readByte();
  4. }

代码示例来源：origin: com.couchbase.client/core-io

  1. @Override
  2. public byte readByte() {
  3.   return buf.readByte();
  4. }

代码示例来源：origin: couchbase/couchbase-jvm-core

  1. @Override
  2. public byte readByte() {
  3.   return buf.readByte();
  4. }

代码示例来源：origin: couchbase/couchbase-jvm-core

  1. @Override
  2. public byte readByte() {
  3.   return buf.readByte();
  4. }

代码示例来源：origin: com.couchbase.client/core-io

  1. @Override
  2. public int read() throws IOException {
  3.   if (buffer.isReadable()) {
  4.     return buffer.readByte() & 0xff;
  5.   }
  6.   return -1;
  7. }

代码示例来源：origin: com.couchbase.client/core-io

  1. @Override
  2. public byte readByte() throws IOException {
  3.   if (!buffer.isReadable()) {
  4.     throw new EOFException();
  5.   }
  6.   return buffer.readByte();
  7. }

代码示例来源：origin: com.couchbase.client/core-io

  1. @Override
  2. public int read() throws IOException {
  3.   if (!buffer.isReadable()) {
  4.     return -1;
  5.   }
  6.   return buffer.readByte() & 0xff;
  7. }

代码示例来源：origin: com.couchbase.client/core-io

  1. @Override
  2. public byte readByte() {
  3.   checkReadableBytes(1);
  4.   return buffer.readByte();
  5. }

代码示例来源：origin: couchbase/couchbase-jvm-core

  1. @Override
  2. public byte readByte() {
  3.   checkReadableBytes(1);
  4.   return buffer.readByte();
  5. }

代码示例来源：origin: couchbase/couchbase-jvm-core

  1. @Override
  2. public int read() throws IOException {
  3.   if (buffer.isReadable()) {
  4.     return buffer.readByte() & 0xff;
  5.   }
  6.   return -1;
  7. }

代码示例来源：origin: couchbase/couchbase-jvm-core

  1. @Override
  2. public int read() throws IOException {
  3.   if (!buffer.isReadable()) {
  4.     return -1;
  5.   }
  6.   return buffer.readByte() & 0xff;
  7. }

代码示例来源：origin: couchbase/couchbase-jvm-core

  1. @Override
  2. public byte readByte() throws IOException {
  3.   if (!buffer.isReadable()) {
  4.     throw new EOFException();
  5.   }
  6.   return buffer.readByte();
  7. }

代码示例来源：origin: com.couchbase.client/core-io

  1. @Override
  2. protected void decode(ChannelHandlerContext ctx, ByteBuf byteBuf, List<Object> out) throws Exception {
  3.   switch (state()) {
  4.     case CHECK_PROTOCOL_VERSION: {
  5.       if (byteBuf.readByte() != SocksProtocolVersion.SOCKS5.byteValue()) {
  6.         out.add(SocksCommonUtils.UNKNOWN_SOCKS_RESPONSE);
  7.         break;
  8.       }
  9.       checkpoint(State.READ_PREFERRED_AUTH_TYPE);
  10.     }
  11.     case READ_PREFERRED_AUTH_TYPE: {
  12.       SocksAuthScheme authScheme = SocksAuthScheme.valueOf(byteBuf.readByte());
  13.       out.add(new SocksInitResponse(authScheme));
  14.       break;
  15.     }
  16.     default: {
  17.       throw new Error();
  18.     }
  19.   }
  20.   ctx.pipeline().remove(this);
  21. }

代码示例来源：origin: com.couchbase.client/core-io

  1. @Override
  2. protected void decode(ChannelHandlerContext channelHandlerContext, ByteBuf byteBuf, List<Object> out)
  3.     throws Exception {
  4.   switch (state()) {
  5.     case CHECK_PROTOCOL_VERSION: {
  6.       if (byteBuf.readByte() != SocksSubnegotiationVersion.AUTH_PASSWORD.byteValue()) {
  7.         out.add(SocksCommonUtils.UNKNOWN_SOCKS_RESPONSE);
  8.         break;
  9.       }
  10.       checkpoint(State.READ_AUTH_RESPONSE);
  11.     }
  12.     case READ_AUTH_RESPONSE: {
  13.       SocksAuthStatus authStatus = SocksAuthStatus.valueOf(byteBuf.readByte());
  14.       out.add(new SocksAuthResponse(authStatus));
  15.       break;
  16.     }
  17.     default: {
  18.       throw new Error();
  19.     }
  20.   }
  21.   channelHandlerContext.pipeline().remove(this);
  22. }

代码示例来源：origin: couchbase/couchbase-jvm-core

  1. @Override
  2. protected BinaryMemcacheResponse decodeHeader(ByteBuf in) {
  3.   BinaryMemcacheResponse header = new DefaultBinaryMemcacheResponse();
  4.   header.setMagic(in.readByte());
  5.   header.setOpcode(in.readByte());
  6.   if (header.getMagic() == FRAMING_MAGIC) {
  7.     header.setFramingExtrasLength(in.readByte());
  8.     header.setKeyLength(in.readByte());
  9.   } else {
  10.     header.setKeyLength(in.readShort());
  11.   }
  12.   header.setExtrasLength(in.readByte());
  13.   header.setDataType(in.readByte());
  14.   header.setStatus(in.readShort());
  15.   header.setTotalBodyLength(in.readInt());
  16.   header.setOpaque(in.readInt());
  17.   header.setCAS(in.readLong());
  18.   return header;
  19. }

代码示例来源：origin: com.couchbase.client/core-io

  1. @Override
  2. protected BinaryMemcacheResponse decodeHeader(ByteBuf in) {
  3.   BinaryMemcacheResponse header = new DefaultBinaryMemcacheResponse();
  4.   header.setMagic(in.readByte());
  5.   header.setOpcode(in.readByte());
  6.   if (header.getMagic() == FRAMING_MAGIC) {
  7.     header.setFramingExtrasLength(in.readByte());
  8.     header.setKeyLength(in.readByte());
  9.   } else {
  10.     header.setKeyLength(in.readShort());
  11.   }
  12.   header.setExtrasLength(in.readByte());
  13.   header.setDataType(in.readByte());
  14.   header.setStatus(in.readShort());
  15.   header.setTotalBodyLength(in.readInt());
  16.   header.setOpaque(in.readInt());
  17.   header.setCAS(in.readLong());
  18.   return header;
  19. }

代码示例来源：origin: couchbase/couchbase-jvm-core

  1. @Override
  2. protected BinaryMemcacheRequest decodeHeader(ByteBuf in) {
  3.   BinaryMemcacheRequest header = new DefaultBinaryMemcacheRequest();
  4.   header.setMagic(in.readByte());
  5.   header.setOpcode(in.readByte());
  6.   header.setKeyLength(in.readShort());
  7.   header.setExtrasLength(in.readByte());
  8.   header.setDataType(in.readByte());
  9.   header.setReserved(in.readShort());
  10.   header.setTotalBodyLength(in.readInt());
  11.   header.setOpaque(in.readInt());
  12.   header.setCAS(in.readLong());
  13.   return header;
  14. }

代码示例来源：origin: com.couchbase.client/core-io

  1. @Override
  2. protected BinaryMemcacheRequest decodeHeader(ByteBuf in) {
  3.   BinaryMemcacheRequest header = new DefaultBinaryMemcacheRequest();
  4.   header.setMagic(in.readByte());
  5.   header.setOpcode(in.readByte());
  6.   header.setKeyLength(in.readShort());
  7.   header.setExtrasLength(in.readByte());
  8.   header.setDataType(in.readByte());
  9.   header.setReserved(in.readShort());
  10.   header.setTotalBodyLength(in.readInt());
  11.   header.setOpaque(in.readInt());
  12.   header.setCAS(in.readLong());
  13.   return header;
  14. }

代码示例来源：origin: com.couchbase.client/core-io

  1. /**
  2.  * Reads the next character into {@link #currentChar}.
  3.  *
  4.  * @param level the current level of nesting.
  5.  * @throws EOFException if more input is needed.
  6.  */
  7. private void readNextChar(final JsonLevel level) throws EOFException {
  8.   int readerIndex = content.readerIndex();
  9.   int lastWsIndex = content.forEachByte(wsProcessor);
  10.   if (lastWsIndex == -1 && level != null) {
  11.     throw NEED_MORE_DATA;
  12.   }
  13.   if (lastWsIndex > readerIndex) {
  14.     this.content.skipBytes(lastWsIndex - readerIndex);
  15.     this.content.discardReadBytes();
  16.   }
  17.   this.currentChar = this.content.readByte();
  18. }

代码示例来源：origin: couchbase/couchbase-jvm-core

  1. /**
  2.  * Reads the next character into {@link #currentChar}.
  3.  *
  4.  * @param level the current level of nesting.
  5.  * @throws EOFException if more input is needed.
  6.  */
  7. private void readNextChar(final JsonLevel level) throws EOFException {
  8.   int readerIndex = content.readerIndex();
  9.   int lastWsIndex = content.forEachByte(wsProcessor);
  10.   if (lastWsIndex == -1 && level != null) {
  11.     throw NEED_MORE_DATA;
  12.   }
  13.   if (lastWsIndex > readerIndex) {
  14.     this.content.skipBytes(lastWsIndex - readerIndex);
  15.     this.content.discardReadBytes();
  16.   }
  17.   this.currentChar = this.content.readByte();
  18. }

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

ByteBuf

相关文章

    查看更多

    热门标签

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

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com