本文整理汇总了Java中org.apache.http.io.HttpMessageWriter类的典型用法代码示例。如果您正苦于以下问题:Java HttpMessageWriter类的具体用法?Java HttpMessageWriter怎么用?Java HttpMessageWriter使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
HttpMessageWriter类属于org.apache.http.io包,在下文中一共展示了HttpMessageWriter类的6个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: acceptClient
import org.apache.http.io.HttpMessageWriter; //导入依赖的package包/类
private void acceptClient(@NotNull Socket client) throws IOException {
final SessionInputBuffer inputBuffer = wrapInputStream(client.getInputStream());
final HttpMessageParser<HttpRequest> parser = new DefaultHttpRequestParser(inputBuffer,
new BasicLineParser(),
new DefaultHttpRequestFactory(),
MessageConstraints.DEFAULT
);
final SessionOutputBuffer outputBuffer = wrapOutputStream(client.getOutputStream());
final HttpMessageWriter<HttpResponse> writer = new DefaultHttpResponseWriter(outputBuffer);
while (!socket.isClosed()) {
try {
service(inputBuffer, outputBuffer, parser, writer);
} catch (ConnectionClosedException ignored) {
break;
} catch (HttpException e) {
log.error(e.getMessage(), e);
break;
}
}
}
开发者ID:bozaro,项目名称:git-as-svn,代码行数:21,代码来源:ProtobufRpcSocket.java
示例2: service
import org.apache.http.io.HttpMessageWriter; //导入依赖的package包/类
@SuppressWarnings("deprecation")
protected void service(@NotNull SessionInputBuffer inputBuffer, @NotNull SessionOutputBuffer outputBuffer, @NotNull HttpMessageParser<HttpRequest> parser, @NotNull HttpMessageWriter<HttpResponse> writer) throws IOException, HttpException {
try {
final HttpRequest request = parser.parse();
final HttpEntity entity;
if (request instanceof HttpEntityEnclosingRequest) {
final EntityDeserializer deserializer = new EntityDeserializer(new LaxContentLengthStrategy());
entity = deserializer.deserialize(inputBuffer, request);
((HttpEntityEnclosingRequest) request).setEntity(entity);
} else {
entity = null;
}
final HttpResponse response = service(request);
if (entity != null) {
entity.getContent().close();
}
if (response.getEntity() != null) {
response.addHeader(HttpHeaders.CONTENT_LENGTH, Long.toString(response.getEntity().getContentLength()));
response.addHeader(response.getEntity().getContentType());
response.addHeader(response.getEntity().getContentEncoding());
}
response.setHeader(HttpHeaders.SERVER, "Protobuf RPC");
writer.write(response);
if (response.getEntity() != null) {
final EntitySerializer serializer = new EntitySerializer(new LaxContentLengthStrategy());
serializer.serialize(outputBuffer, response, response.getEntity());
}
} finally {
outputBuffer.flush();
}
}
开发者ID:bozaro,项目名称:git-as-svn,代码行数:32,代码来源:ProtobufRpcSimpleHttp.java
示例3: create
import org.apache.http.io.HttpMessageWriter; //导入依赖的package包/类
public HttpMessageWriter create(final SessionOutputBuffer buffer) {
return new DefaultHttpRequestWriter(buffer, lineFormatter);
}
开发者ID:xxonehjh,项目名称:remote-files-sync,代码行数:4,代码来源:DefaultHttpRequestWriterFactory.java
示例4: create
import org.apache.http.io.HttpMessageWriter; //导入依赖的package包/类
public HttpMessageWriter create(final SessionOutputBuffer buffer) {
return new DefaultHttpResponseWriter(buffer, lineFormatter);
}
开发者ID:xxonehjh,项目名称:remote-files-sync,代码行数:4,代码来源:DefaultHttpResponseWriterFactory.java
示例5: createRequestWriter
import org.apache.http.io.HttpMessageWriter; //导入依赖的package包/类
/**
* Creates an instance of {@link HttpMessageWriter} to be used for
* writing out HTTP requests sent over this connection.
* <p>
* This method can be overridden in a super class in order to provide
* a different implementation of the {@link HttpMessageWriter} interface or
* to pass a different implementation of {@link LineFormatter} to the
* the default implementation {@link HttpRequestWriter}.
*
* @param buffer the session output buffer
* @param params HTTP parameters
* @return HTTP message writer
*/
protected HttpMessageWriter<HttpRequest> createRequestWriter(
final SessionOutputBuffer buffer,
final HttpParams params) {
return new HttpRequestWriter(buffer, null, params);
}
开发者ID:lamsfoundation,项目名称:lams,代码行数:19,代码来源:AbstractHttpClientConnection.java
示例6: createResponseWriter
import org.apache.http.io.HttpMessageWriter; //导入依赖的package包/类
/**
* Creates an instance of {@link HttpMessageWriter} to be used for
* writing out HTTP responses sent over this connection.
* <p>
* This method can be overridden in a super class in order to provide
* a different implementation of the {@link HttpMessageWriter} interface or
* to pass a different implementation of {@link LineFormatter} to the
* the default implementation {@link HttpResponseWriter}.
*
* @param buffer the session output buffer
* @param params HTTP parameters
* @return HTTP message writer
*/
protected HttpMessageWriter<HttpResponse> createResponseWriter(
final SessionOutputBuffer buffer,
final HttpParams params) {
return new HttpResponseWriter(buffer, null, params);
}
开发者ID:lamsfoundation,项目名称:lams,代码行数:19,代码来源:AbstractHttpServerConnection.java
注:本文中的org.apache.http.io.HttpMessageWriter类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论