• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    迪恩网络公众号

Java Buffer类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了Java中org.glassfish.grizzly.Buffer的典型用法代码示例。如果您正苦于以下问题:Java Buffer类的具体用法?Java Buffer怎么用?Java Buffer使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。



Buffer类属于org.glassfish.grizzly包,在下文中一共展示了Buffer类的19个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: handleWrite

import org.glassfish.grizzly.Buffer; //导入依赖的package包/类
@Override
public NextAction handleWrite(FilterChainContext context) throws IOException {
    Connection<?> connection = context.getConnection();
    GrizzlyChannel channel = GrizzlyChannel.getOrAddChannel(connection, url, handler);
    try {
        ChannelBuffer channelBuffer = ChannelBuffers.dynamicBuffer(1024); // 不需要关闭
        
        Object msg = context.getMessage();
        codec.encode(channel, channelBuffer, msg);
        
        GrizzlyChannel.removeChannelIfDisconnectd(connection);
        Buffer buffer = connection.getTransport().getMemoryManager().allocate(channelBuffer.readableBytes());
        buffer.put(channelBuffer.toByteBuffer());
        buffer.flip();
        buffer.allowBufferDispose(true);
        context.setMessage(buffer);
    } finally {
        GrizzlyChannel.removeChannelIfDisconnectd(connection);
    }
    return context.getInvokeAction();
}
 
开发者ID:dachengxi,项目名称:EatDubbo,代码行数:22,代码来源:GrizzlyCodecAdapter.java


示例2: handleWrite

import org.glassfish.grizzly.Buffer; //导入依赖的package包/类
@Override
public NextAction handleWrite(FilterChainContext context) throws IOException {
    Connection<?> connection = context.getConnection();
    GrizzlyChannel channel = GrizzlyChannel.getOrAddChannel(connection, url, handler);
    try {
        ChannelBuffer channelBuffer = ChannelBuffers.dynamicBuffer(1024); // 不需要关闭

        Object msg = context.getMessage();
        codec.encode(channel, channelBuffer, msg);

        GrizzlyChannel.removeChannelIfDisconnectd(connection);
        Buffer buffer = connection.getTransport().getMemoryManager().allocate(channelBuffer.readableBytes());
        buffer.put(channelBuffer.toByteBuffer());
        buffer.flip();
        buffer.allowBufferDispose(true);
        context.setMessage(buffer);
    } finally {
        GrizzlyChannel.removeChannelIfDisconnectd(connection);
    }
    return context.getInvokeAction();
}
 
开发者ID:hufeng,项目名称:dubbo2.js,代码行数:22,代码来源:GrizzlyCodecAdapter.java


示例3: transformImpl

import org.glassfish.grizzly.Buffer; //导入依赖的package包/类
/** {@inheritDoc} */
@Override
protected final TransformationResult<MessageLite, Buffer> transformImpl(
        final AttributeStorage storage, final @NonNull MessageLite input)
        throws TransformationException {
    final MemoryManager memoryManager = obtainMemoryManager(storage);
    final BufferOutputStream outputStream = new BufferOutputStream(memoryManager);

    final byte[] encodedMessage = input.toByteArray();
    try {
        writeHeader(outputStream, encodedMessage.length);

        outputStream.write(encodedMessage);
        outputStream.close();
    } catch (final IOException e) {
        final String msg = "Error writing protobuf message to output stream.";
        log.warn(msg, e);
        return createErrorResult(IO_WRITE_ERROR, msg);
    }

    return createCompletedResult(outputStream.getBuffer().flip(), null);
}
 
开发者ID:novabyte,项目名称:grizzly-protobuf,代码行数:23,代码来源:AbstractProtobufEncoder.java


示例4: transformImpl

import org.glassfish.grizzly.Buffer; //导入依赖的package包/类
@Override
protected TransformationResult<Request, Buffer> transformImpl(AttributeStorage storage, Request request) throws TransformationException {
    byte ver = request.getHeader().getSerializeVersion() ;
    int pLen = request.getPayload() == null ? 0 : request.getPayload().length;
    byte[] header = request.getHeader().toByte();
    // encoding length , and check the max value of integer, should be 2GB
    int totalLen = OFFSET + header.length + pLen + R_SIZE + H_SIZE;
    if ( totalLen > Integer.MAX_VALUE ) {
        throw new TransformationException( totalLen +" exceeding Integer.MAX_VALUE");
    }
    //logger.info("total "+totalLen+" hd "+header.length+" payload "+pLen);
    // Retrieve the memory manager
    //final MemoryManager memoryManager = ctx.getConnection().getTransport().getMemoryManager();

    // allocate the buffer of required size
    final Buffer bout = obtainMemoryManager(storage).allocate(totalLen);
    // Instruct the FilterChain to call the next filter
    bout.put(SIGNATURE);
    bout.put(ver);
    bout.putInt(totalLen);
    bout.putShort((short) header.length);
    bout.put(header);
    // request type
    bout.put((byte) request.getType().ordinal());
    bout.put( request.getPayload());

    bout.flip();
    bout.allowBufferDispose(true);

    return TransformationResult.createCompletedResult(bout, null);
}
 
开发者ID:viant,项目名称:CacheStore,代码行数:32,代码来源:RequestEncoder.java


示例5: transformImpl

import org.glassfish.grizzly.Buffer; //导入依赖的package包/类
@Override
protected TransformationResult<Buffer, Request> transformImpl(AttributeStorage storage, Buffer input) throws TransformationException {
    //Integer packSize = lengthAttribute.get(storage);
    VersionLength versionLength = lengthAttribute.get(storage);
    if (versionLength == null) {
        if (input.remaining() < OFFSET) {
            return TransformationResult.createIncompletedResult(input);
        }
        byte signature = input.get();
        byte ver = input.get();
        int packSize = input.getInt();
        if (signature != SIGNATURE  ) {
            //channel.close();
            throw new TransformationException("expect "+SIGNATURE+" but get "+signature+" "+" "+input.toString());
        }
        if ( packSize < 0 || packSize > MAX_LEN ) {
            //channel.close();
            throw new TransformationException(packSize+" Exceed Integer.MAX_VALUE or MAX_LEN");
        }
        //use versionlength
        versionLength = new VersionLength(packSize, ver);
        //lengthAttribute.set(storage, packSize);
        lengthAttribute.set(storage, versionLength);
    }

    if (input.remaining() < (versionLength.getLength() -OFFSET) ) {
        //logger.info("packSize "+versionLength.getLength() + " remaining "+input.remaining() );
        return TransformationResult.createIncompletedResult(input);
    }
    int tmpLimit = input.limit();
    input.limit(input.position() + (versionLength.getLength() -OFFSET) );
    Request request= doDecode(input, versionLength.getLength(), versionLength.getVersion()  );
    input.position(input.limit());
    input.limit(tmpLimit);
    return TransformationResult.createCompletedResult(
            request, input);
}
 
开发者ID:viant,项目名称:CacheStore,代码行数:38,代码来源:RequestDecoder.java


示例6: doDecode

import org.glassfish.grizzly.Buffer; //导入依赖的package包/类
protected Request doDecode(Buffer buffer, int len, byte ver) {
    //read all byte from buffer first, in case exception during de serialize
    short headLen = buffer.getShort();
    byte[] bytes = new byte[ (int) headLen];
    buffer.get( bytes);
    //read request type before payload
    byte type = buffer.get();
    byte[] payload = new byte[ len - headLen - OFFSET - R_SIZE - H_SIZE ];
    buffer.get( payload);
    Header header = Header.toHeader( bytes);
    // assign serializeVersion
    header.setSerializeVersion( ver);
    return new Request( header, payload, getRequestType( type));
}
 
开发者ID:viant,项目名称:CacheStore,代码行数:15,代码来源:RequestDecoder.java


示例7: handleWrite

import org.glassfish.grizzly.Buffer; //导入依赖的package包/类
/**
 * Method is called, when we write a data to the Connection.
 *
 * We override this method to perform GIOPMessage -> Buffer transformation.
 *
 * @param ctx Context of {@link FilterChainContext} processing
 * @return the next action
 * @throws java.io.IOException
 */
@Override
public NextAction handleWrite(final FilterChainContext ctx) throws IOException {
    final Request request = ctx.getMessage();

    byte ver = version;
    int pLen = request.getPayload() == null ? 0 : request.getPayload().length;
    byte[] header = request.getHeader().toByte();
    // encoding length , and check the max value of integer, should be 2GB
    int totalLen = TOTAL + header.length + pLen + R_SIZE;
    if ( totalLen > Integer.MAX_VALUE ) {
        throw new IOException( totalLen +" exceeding Integer.MAX_VALUE");
    }
    logger.info("total "+totalLen+" hd "+header.length+" payload "+pLen);
    // Retrieve the memory manager
    final MemoryManager memoryManager =
            ctx.getConnection().getTransport().getMemoryManager();

    // allocate the buffer of required size
    final Buffer bout = memoryManager.allocate(totalLen);
    // Instruct the FilterChain to call the next filter
    bout.put(SIGNATURE);
    bout.put(ver);
    bout.putInt(totalLen);
    bout.putShort((short) header.length);
    bout.put(header);
    // request type
    bout.put((byte) request.getType().ordinal());
    bout.put( request.getPayload());
    // Set the Buffer as a context message
    ctx.setMessage( bout.flip() );
    return ctx.getInvokeAction();
}
 
开发者ID:viant,项目名称:CacheStore,代码行数:42,代码来源:RequestCoder.java


示例8: doDecode

import org.glassfish.grizzly.Buffer; //导入依赖的package包/类
protected Request doDecode(Buffer buffer, int len, byte ver) {
    //read all byte from buffer first, in case exception during de serialize
    short headLen = buffer.getShort();
    byte[] bytes = new byte[ (int) headLen];
    buffer.get( bytes);
    //read request type before payload
    byte type = buffer.get();
    byte[] payload = new byte[ len - headLen - TOTAL - R_SIZE ];
    buffer.get( payload);
    Header header = Header.toHeader( bytes);
    // assign serializeVersion
    header.setSerializeVersion( ver);
    return new Request( header, payload, getRequestType( type));
}
 
开发者ID:viant,项目名称:CacheStore,代码行数:15,代码来源:RequestCoder.java


示例9: handleWrite

import org.glassfish.grizzly.Buffer; //导入依赖的package包/类
public NextAction handleWrite(FilterChainContext ctx) throws IOException {
  GrizzlyByteBufferWrapper wrapper = new GrizzlyByteBufferWrapper(ctx);
  try {
    ProtocolUtils.encode(ctx.getMessage(), wrapper);
    final Buffer buffer = wrapper.getBuffer();
    buffer.trim();

    ctx.setMessage(buffer);
    return ctx.getInvokeAction();

  } catch (Exception e) {
    throw new IOException("encode message to byte error", e);
  }
}
 
开发者ID:leeyazhou,项目名称:nfs-rpc,代码行数:15,代码来源:GrizzlyProtocolFilter.java


示例10: handleWrite

import org.glassfish.grizzly.Buffer; //导入依赖的package包/类
@Override
public NextAction handleWrite(FilterChainContext ctx) throws IOException {
    // final Object message = ctx.getMessage();
    //
    // HeapBuffer buffer = (HeapBuffer) message;
    // byte[] bytes = new byte[buffer.remaining()];
    // buffer.get(bytes);
    // byte[] encoded = binaryEncryptor.encrypt(bytes);
    // Buffer buf = new HeapMemoryManager().wrap(encoded);
    // ctx.setMessage(buf);
    System.out.println(System.nanoTime() + ":write:"
            + ((Buffer) ctx.getMessage()).remaining());
    return super.handleWrite(ctx);
}
 
开发者ID:chocotan,项目名称:kazeproxy,代码行数:15,代码来源:TunnelRedirectServerFilter.java


示例11: addToBuffer

import org.glassfish.grizzly.Buffer; //导入依赖的package包/类
public void addToBuffer(NIOInputStream in, ByteBuffer postBytes){
	Buffer buffer = in.readBuffer();
	ByteBuffer bb = buffer.toByteBuffer();
	try {
		postBytes.put(bb);			
	} finally {
		buffer.tryDispose();
	}
}
 
开发者ID:davruet,项目名称:shenanigans.io,代码行数:10,代码来源:AsyncPostHandler.java


示例12: readHeader

import org.glassfish.grizzly.Buffer; //导入依赖的package包/类
/** {@inheritDoc} */
@Override
public int readHeader(final Buffer input) throws IOException {
    if (input == null) {
        throw new IllegalArgumentException("'input' cannot be null.");
    }

    final byte[] messageLengthArr = new byte[headerLength];
    input.get(messageLengthArr);
    log.debug("inputRemaining={}", input.remaining());

    return ByteBuffer.wrap(messageLengthArr).getInt();
}
 
开发者ID:novabyte,项目名称:grizzly-protobuf,代码行数:14,代码来源:FixedLengthProtobufDecoder.java


示例13: readHeader

import org.glassfish.grizzly.Buffer; //导入依赖的package包/类
/** {@inheritDoc} */
@Override
public int readHeader(final Buffer input) throws IOException {
    if (input == null) {
        throw new IllegalArgumentException("'input' cannot be null.");
    }

    final BufferInputStream inputStream = new BufferInputStream(input);
    return CodedInputStream.readRawVarint32(input.get(), inputStream);
}
 
开发者ID:novabyte,项目名称:grizzly-protobuf,代码行数:11,代码来源:Varint32ProtobufDecoder.java


示例14: handleRead

import org.glassfish.grizzly.Buffer; //导入依赖的package包/类
@Override
public NextAction handleRead(FilterChainContext context) throws IOException {
    Object message = context.getMessage();
    Connection<?> connection = context.getConnection();
    Channel channel = GrizzlyChannel.getOrAddChannel(connection, url, handler);
    try {
        if (message instanceof Buffer) { // 收到新的数据包
            Buffer grizzlyBuffer = (Buffer) message; // 缓存

            ChannelBuffer frame;

            if (previousData.readable()) {
                if (previousData instanceof DynamicChannelBuffer) {
                    previousData.writeBytes(grizzlyBuffer.toByteBuffer());
                    frame = previousData;
                } else {
                    int size = previousData.readableBytes() + grizzlyBuffer.remaining();
                    frame = ChannelBuffers.dynamicBuffer(size > bufferSize ? size : bufferSize);
                    frame.writeBytes(previousData, previousData.readableBytes());
                    frame.writeBytes(grizzlyBuffer.toByteBuffer());
                }
            } else {
                frame = ChannelBuffers.wrappedBuffer(grizzlyBuffer.toByteBuffer());
            }

            Object msg;
            int savedReadIndex;

            do {
                savedReadIndex = frame.readerIndex();
                try {
                    msg = codec.decode(channel, frame);
                } catch (Exception e) {
                    previousData = ChannelBuffers.EMPTY_BUFFER;
                    throw new IOException(e.getMessage(), e);
                }
                if (msg == Codec2.DecodeResult.NEED_MORE_INPUT) {
                    frame.readerIndex(savedReadIndex);
                    return context.getStopAction();
                } else {
                    if (savedReadIndex == frame.readerIndex()) {
                        previousData = ChannelBuffers.EMPTY_BUFFER;
                        throw new IOException("Decode without read data.");
                    }
                    if (msg != null) {
                        context.setMessage(msg);
                        return context.getInvokeAction();
                    } else {
                        return context.getInvokeAction();
                    }
                }
            } while (frame.readable());
        } else { // 其它事件直接往下传
            return context.getInvokeAction();
        }
    } finally {
        GrizzlyChannel.removeChannelIfDisconnectd(connection);
    }
}
 
开发者ID:dachengxi,项目名称:EatDubbo,代码行数:60,代码来源:GrizzlyCodecAdapter.java


示例15: service

import org.glassfish.grizzly.Buffer; //导入依赖的package包/类
@Override
public void service(Request request, Response response) throws Exception {

    request.setCharacterEncoding("UTF-8");

    Buffer postBody = request.getPostBody(1024);
    String text = postBody.toStringContent();

    if (request.getParameter("text") != null) {
        text = request.getParameter("text");
    }

    String outputFormat = request.getParameter("format");

    InputStream inputStream = new ByteArrayInputStream(text.getBytes());
    OutputStream outputStream = new ByteArrayOutputStream();

    TintRunner.OutputFormat format = TintRunner.getOutputFormat(outputFormat, TintRunner.OutputFormat.JSON);
    pipeline.run(inputStream, outputStream, format);

    LOGGER.debug("Text: {}", text);

    String output = outputStream.toString();

    writeOutput(response, contentTypes.get(format), output);
}
 
开发者ID:dhfbk,项目名称:tint,代码行数:27,代码来源:TintHandler.java


示例16: hasInputRemaining

import org.glassfish.grizzly.Buffer; //导入依赖的package包/类
@Override
public boolean hasInputRemaining(AttributeStorage storage, Buffer input) {
    boolean result = input != null && input.hasRemaining();
    //logger.info("hasInputRemaining "+result +" storage "+storage.getAttributes().toString() + " buffer "+input.toString());
    return result;
}
 
开发者ID:viant,项目名称:CacheStore,代码行数:7,代码来源:RequestDecoder.java


示例17: handleRead

import org.glassfish.grizzly.Buffer; //导入依赖的package包/类
@Override
public NextAction handleRead(final FilterChainContext ctx) throws IOException {
    final Buffer buffer = ctx.getMessage();

    final int sourceBufferLength = buffer.remaining();
    // If source buffer doesn't contain header
    if (sourceBufferLength < TOTAL) {
        // shutdownNow the filterchain processing and store sourceBuffer to be
        // used next time
        return ctx.getStopAction(buffer);
    }
    byte signature = buffer.get();
    byte ver = buffer.get();
    int totalLen = buffer.getInt();
    if (signature != SIGNATURE  ) {
        //channel.close();
        throw new IOException("expect "+SIGNATURE+" but get "+signature+" "+ ctx.getAddress().toString()
                +" "+buffer.toString());
    }
    if ( totalLen < 0 || totalLen > MAX_LEN ) {
        //channel.close();
        throw new IOException(totalLen+" Exceed Integer.MAX_VALUE or MAX_LEN"+" "+ctx.getAddress().toString());
    }

    if ( sourceBufferLength < totalLen) {
        logger.info("notready bufferlength "+sourceBufferLength+" totallen "+totalLen);
        // shutdownNow the filterchain processing and store sourceBuffer to be
        // used next time
        return ctx.getStopAction(buffer);
    }
    else
        logger.info("ready bufferlength "+sourceBufferLength+" totallen "+totalLen);
    // shutdownNow the filterchain processing and store sourceBuffer to be
    // Check if the source buffer has more than 1 complete GIOP message
    // If yes - split up the first message and the remainder
    final Buffer remainder = sourceBufferLength > totalLen?
            buffer.split( totalLen) : null;

    ctx.setMessage( doDecode( buffer, totalLen, ver));
    // We can try to dispose the buffer
    buffer.tryDispose();
    // Instruct FilterChain to store the remainder (if any) and continue execution
    return ctx.getInvokeAction(remainder);
}
 
开发者ID:viant,项目名称:CacheStore,代码行数:45,代码来源:RequestCoder.java


示例18: GrizzlyByteBufferWrapper

import org.glassfish.grizzly.Buffer; //导入依赖的package包/类
public GrizzlyByteBufferWrapper(Buffer buffer) {
  this.buffer = buffer;
}
 
开发者ID:leeyazhou,项目名称:nfs-rpc,代码行数:4,代码来源:GrizzlyByteBufferWrapper.java


示例19: getBuffer

import org.glassfish.grizzly.Buffer; //导入依赖的package包/类
public Buffer getBuffer() {
  return buffer;
}
 
开发者ID:leeyazhou,项目名称:nfs-rpc,代码行数:4,代码来源:GrizzlyByteBufferWrapper.java



注:本文中的org.glassfish.grizzly.Buffer类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Java Source类代码示例发布时间:2022-05-21
下一篇:
Java StringReference类代码示例发布时间:2022-05-21
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap