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

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

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

ByteBuf.writeByte介绍

[英]Sets the specified byte at the current writerIndexand increases the writerIndex by 1 in this buffer. The 24 high-order bits of the specified value are ignored.
[中]

代码示例

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

  1. @Override
  2. public ByteBuf writeByte(int value) {
  3.   buf.writeByte(value);
  4.   return this;
  5. }

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

  1. @Override
  2.   public void encodeAsByteBuf(ByteBuf byteBuf) {
  3.     byteBuf.writeByte(SUBNEGOTIATION_VERSION.byteValue());
  4.     byteBuf.writeByte(username.length());
  5.     byteBuf.writeBytes(username.getBytes(CharsetUtil.US_ASCII));
  6.     byteBuf.writeByte(password.length());
  7.     byteBuf.writeBytes(password.getBytes(CharsetUtil.US_ASCII));
  8.   }
  9. }

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

  1. @Override
  2.   public void encodeAsByteBuf(ByteBuf byteBuf) {
  3.     byteBuf.writeByte(SUBNEGOTIATION_VERSION.byteValue());
  4.     byteBuf.writeByte(username.length());
  5.     byteBuf.writeBytes(username.getBytes(CharsetUtil.US_ASCII));
  6.     byteBuf.writeByte(password.length());
  7.     byteBuf.writeBytes(password.getBytes(CharsetUtil.US_ASCII));
  8.   }
  9. }

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

  1. @Override
  2. public ByteBuf writeByte(int value) {
  3.   buf.writeByte(value);
  4.   return this;
  5. }

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

  1. private static void writeUnencodedChunk(ByteBuf in, ByteBuf out, int dataLength) {
  2.   out.writeByte(1);
  3.   writeChunkLength(out, dataLength + 4);
  4.   calculateAndWriteChecksum(in, out);
  5.   out.writeBytes(in, dataLength);
  6. }

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

  1. private static void encodeCopyWithOffset(ByteBuf out, int offset, int length) {
  2.   if (length < 12 && offset < 2048) {
  3.     out.writeByte(COPY_1_BYTE_OFFSET | length - 4 << 2 | offset >> 8 << 5);
  4.     out.writeByte(offset & 0x0ff);
  5.   } else {
  6.     out.writeByte(COPY_2_BYTE_OFFSET | length - 1 << 2);
  7.     out.writeByte(offset & 0x0ff);
  8.     out.writeByte(offset >> 8 & 0x0ff);
  9.   }
  10. }

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

  1. private static void writeUnencodedChunk(ByteBuf in, ByteBuf out, int dataLength) {
  2.   out.writeByte(1);
  3.   writeChunkLength(out, dataLength + 4);
  4.   calculateAndWriteChecksum(in, out);
  5.   out.writeBytes(in, dataLength);
  6. }

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

  1. private static void encodeCopyWithOffset(ByteBuf out, int offset, int length) {
  2.   if (length < 12 && offset < 2048) {
  3.     out.writeByte(COPY_1_BYTE_OFFSET | length - 4 << 2 | offset >> 8 << 5);
  4.     out.writeByte(offset & 0x0ff);
  5.   } else {
  6.     out.writeByte(COPY_2_BYTE_OFFSET | length - 1 << 2);
  7.     out.writeByte(offset & 0x0ff);
  8.     out.writeByte(offset >> 8 & 0x0ff);
  9.   }
  10. }

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

  1. void encode(ByteBuf buf) {
  2.     if (bytes == null) {
  3.       HttpHeaders.encodeAscii0(String.valueOf(code()), buf);
  4.       buf.writeByte(SP);
  5.       HttpHeaders.encodeAscii0(String.valueOf(reasonPhrase()), buf);
  6.     } else {
  7.       buf.writeBytes(bytes);
  8.     }
  9.   }
  10. }

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

  1. @Override
  2.   public void encodeAsByteBuf(ByteBuf byteBuf) {
  3.     byteBuf.writeByte(SUBNEGOTIATION_VERSION.byteValue());
  4.     byteBuf.writeByte(authStatus.byteValue());
  5.   }
  6. }

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

  1. @Override
  2. protected void encodeInitialLine(ByteBuf buf, HttpResponse response) throws Exception {
  3.   response.getProtocolVersion().encode(buf);
  4.   buf.writeByte(SP);
  5.   response.getStatus().encode(buf);
  6.   buf.writeBytes(CRLF);
  7. }

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

  1. static void encodeAscii0(CharSequence seq, ByteBuf buf) {
  2.   int length = seq.length();
  3.   for (int i = 0 ; i < length; i++) {
  4.     buf.writeByte(c2b(seq.charAt(i)));
  5.   }
  6. }

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

  1. public ByteBuf encodeDataFrame(ByteBufAllocator allocator, int streamId, boolean last, ByteBuf data) {
  2.   byte flags = last ? SPDY_DATA_FLAG_FIN : 0;
  3.   int length = data.readableBytes();
  4.   ByteBuf frame = allocator.ioBuffer(SPDY_HEADER_SIZE + length).order(ByteOrder.BIG_ENDIAN);
  5.   frame.writeInt(streamId & 0x7FFFFFFF);
  6.   frame.writeByte(flags);
  7.   frame.writeMedium(length);
  8.   frame.writeBytes(data, data.readerIndex(), length);
  9.   return frame;
  10. }

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

  1. @Override
  2.   public void encodeAsByteBuf(ByteBuf byteBuf) {
  3.     byteBuf.writeByte(protocolVersion().byteValue());
  4.     byteBuf.writeByte(authSchemes.size());
  5.     for (SocksAuthScheme authScheme : authSchemes) {
  6.       byteBuf.writeByte(authScheme.byteValue());
  7.     }
  8.   }
  9. }

代码示例来源：origin: couchbase/java-dcp-client

  1. public static void init(ByteBuf buffer, short vbid, long seqno) {
  2.   buffer.writeByte(MessageUtil.MAGIC_INT);
  3.   buffer.writeByte(MessageUtil.INTERNAL_ROLLBACK_OPCODE);
  4.   buffer.writeShort(vbid);
  5.   buffer.writeLong(seqno);
  6. }

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

  1. @Override
  2.   public void encodeAsByteBuf(ByteBuf byteBuf) {
  3.     byteBuf.writeByte(protocolVersion().byteValue());
  4.     byteBuf.writeByte(authScheme.byteValue());
  5.   }
  6. }

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

  1. private void writeControlFrameHeader(ByteBuf buffer, int type, byte flags, int length) {
  2.   buffer.writeShort(version | 0x8000);
  3.   buffer.writeShort(type);
  4.   buffer.writeByte(flags);
  5.   buffer.writeMedium(length);
  6. }

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

  1. @Override
  2. protected void encodeHeader(ByteBuf buf, BinaryMemcacheResponse msg) {
  3.   buf.writeByte(msg.getMagic());
  4.   buf.writeByte(msg.getOpcode());
  5.   buf.writeShort(msg.getKeyLength());
  6.   buf.writeByte(msg.getExtrasLength());
  7.   buf.writeByte(msg.getDataType());
  8.   buf.writeShort(msg.getStatus());
  9.   buf.writeInt(msg.getTotalBodyLength());
  10.   buf.writeInt(msg.getOpaque());
  11.   buf.writeLong(msg.getCAS());
  12. }

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

  1. @Override
  2. protected void encodeHeader(ByteBuf buf, BinaryMemcacheRequest msg) {
  3.   buf.writeByte(msg.getMagic());
  4.   buf.writeByte(msg.getOpcode());
  5.   buf.writeShort(msg.getKeyLength());
  6.   buf.writeByte(msg.getExtrasLength());
  7.   buf.writeByte(msg.getDataType());
  8.   buf.writeShort(msg.getReserved());
  9.   buf.writeInt(msg.getTotalBodyLength());
  10.   buf.writeInt(msg.getOpaque());
  11.   buf.writeLong(msg.getCAS());
  12. }

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

  1. @Override
  2. protected void encodeHeader(ByteBuf buf, BinaryMemcacheRequest msg) {
  3.   buf.writeByte(msg.getMagic());
  4.   buf.writeByte(msg.getOpcode());
  5.   buf.writeShort(msg.getKeyLength());
  6.   buf.writeByte(msg.getExtrasLength());
  7.   buf.writeByte(msg.getDataType());
  8.   buf.writeShort(msg.getReserved());
  9.   buf.writeInt(msg.getTotalBodyLength());
  10.   buf.writeInt(msg.getOpaque());
  11.   buf.writeLong(msg.getCAS());
  12. }

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

ByteBuf

相关文章

    查看更多

    热门标签

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

    最新文章

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