本文整理汇总了Java中org.jboss.netty.buffer.DynamicChannelBuffer类的典型用法代码示例。如果您正苦于以下问题:Java DynamicChannelBuffer类的具体用法?Java DynamicChannelBuffer怎么用?Java DynamicChannelBuffer使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
DynamicChannelBuffer类属于org.jboss.netty.buffer包,在下文中一共展示了DynamicChannelBuffer类的7个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: encode
import org.jboss.netty.buffer.DynamicChannelBuffer; //导入依赖的package包/类
@Override
protected Object encode(ChannelHandlerContext ctx, Channel channel,
Object message) throws Exception {
if (message instanceof SyncMessage) {
ChannelBuffer buf = new DynamicChannelBuffer(512);
ChannelBufferOutputStream os = new ChannelBufferOutputStream(buf);
TCompactProtocol thriftProtocol =
new TCompactProtocol(new TIOStreamTransport(os));
((SyncMessage) message).write(thriftProtocol);
ChannelBuffer len = ChannelBuffers.buffer(4);
len.writeInt(buf.readableBytes());
return ChannelBuffers.wrappedBuffer(len, buf);
}
return message;
}
开发者ID:nsg-ethz,项目名称:iTAP-controller,代码行数:17,代码来源:ThriftFrameEncoder.java
示例2: messageReceived
import org.jboss.netty.buffer.DynamicChannelBuffer; //导入依赖的package包/类
@Override
public void messageReceived(ChannelHandlerContext ctx, MessageEvent event) throws Exception {
if (event.getMessage() instanceof HttpRequest) {
try {
HttpServletRequest httpServletRequest = new NettyHttpServletRequestAdaptor((HttpRequest) event.getMessage(), ctx.getChannel());
HttpResponse response = new DefaultHttpResponse(HTTP_1_1, OK);
response.setContent(new DynamicChannelBuffer(200));
HttpServletResponse httpServletResponse = new NettyHttpServletResponseAdaptor(response, ctx.getChannel());
dispatcher.dispatch(httpServletRequest,httpServletResponse);
response.headers().set(HttpHeaders.Names.CONTENT_LENGTH,response.getContent().writerIndex());
ChannelFuture future = ctx.getChannel().write(response);
future.addListener(ChannelFutureListener.CLOSE);
} catch (Exception e) {
e.printStackTrace();
}
}
}
开发者ID:code4craft,项目名称:netty-servlet,代码行数:18,代码来源:HttpServerHandler.java
示例3: messageReceived
import org.jboss.netty.buffer.DynamicChannelBuffer; //导入依赖的package包/类
@Override
public void messageReceived(ChannelHandlerContext ctx, MessageEvent e)
throws Exception {
HttpRequest request = (HttpRequest) e.getMessage();
String uri = request.getUri();
System.out.println("uri:" + uri);
HttpResponse response = new DefaultHttpResponse(HttpVersion.HTTP_1_1, HttpResponseStatus.OK);
ChannelBuffer buffer = new DynamicChannelBuffer(2048);
buffer.writeBytes("hello!! 你好".getBytes("UTF-8"));
response.setContent(buffer);
response.setHeader("Content-Type", "text/html; charset=UTF-8");
response.setHeader("Content-Length", response.getContent().writerIndex());
Channel ch = e.getChannel();
// Write the initial line and the header.
ch.write(response);
ch.disconnect();
ch.close();
}
开发者ID:laizhihuan,项目名称:java-test-demo,代码行数:21,代码来源:HttpServerHandler.java
示例4: startUp
import org.jboss.netty.buffer.DynamicChannelBuffer; //导入依赖的package包/类
@Before
public void startUp() {
byte[] bytes = PAYLOAD.getBytes();
buf = new DynamicChannelBuffer(bytes.length);
buf.writeBytes(bytes);
}
开发者ID:HydAu,项目名称:Camel,代码行数:7,代码来源:NettyConverterTest.java
示例5: DynamicChannelBufferOutputStream
import org.jboss.netty.buffer.DynamicChannelBuffer; //导入依赖的package包/类
/**
* Constructor
*
* @param estimatedLength Estimated length of the buffer
*/
public DynamicChannelBufferOutputStream(int estimatedLength) {
buffer = (DynamicChannelBuffer)
ChannelBuffers.dynamicBuffer(ByteOrder.LITTLE_ENDIAN,
estimatedLength, DirectChannelBufferFactory.getInstance());
}
开发者ID:renato2099,项目名称:giraph-gora,代码行数:11,代码来源:DynamicChannelBufferOutputStream.java
示例6: DynamicChannelBufferInputStream
import org.jboss.netty.buffer.DynamicChannelBuffer; //导入依赖的package包/类
/**
* Constructor.
*
* @param buffer Buffer to read from
*/
public DynamicChannelBufferInputStream(DynamicChannelBuffer buffer) {
this.buffer = buffer;
}
开发者ID:renato2099,项目名称:giraph-gora,代码行数:9,代码来源:DynamicChannelBufferInputStream.java
示例7: getDynamicChannelBuffer
import org.jboss.netty.buffer.DynamicChannelBuffer; //导入依赖的package包/类
/**
* Get the dynamic channel buffer
*
* @return dynamic channel buffer (not a copy)
*/
public DynamicChannelBuffer getDynamicChannelBuffer() {
return buffer;
}
开发者ID:renato2099,项目名称:giraph-gora,代码行数:9,代码来源:DynamicChannelBufferOutputStream.java
注:本文中的org.jboss.netty.buffer.DynamicChannelBuffer类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论