本文整理了Java中com.sun.grizzly.tcp.http11.GrizzlyResponse
类的一些代码示例,展示了GrizzlyResponse
类的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。GrizzlyResponse
类的具体详情如下:
包路径:com.sun.grizzly.tcp.http11.GrizzlyResponse
类名称:GrizzlyResponse
[英]Wrapper object for the Coyote response.
[中]Coyote响应的包装器对象。
代码示例来源:origin: com.sun.grizzly/grizzly-http-utils
throws IOException {
if (isCommitted())
throw new IllegalStateException
(sm.getString("response.sendRedirect.ise"));
resetBuffer();
absolute = toAbsolute(location);
setStatus(302);
setHeader("Location", absolute);
} catch (IllegalArgumentException e) {
setStatus(404);
setSuspended(true);
代码示例来源:origin: org.glassfish.external/grizzly-module
/**
* Add the specified integer header to the specified value.
*
* @param name Name of the header to set
* @param value Integer value to be set
*/
public void addIntHeader(String name, int value) {
if (isCommitted())
return;
// Ignore any call from an included servlet
if (included)
return;
addHeader(name, "" + value);
}
代码示例来源:origin: com.sun.grizzly/grizzly-utils
@Override
public boolean timeout(){
// If the buffers are empty, commit the response header
try{
cancel();
} finally {
if (!grizzlyResponse.isCommitted()){
try{
grizzlyResponse.finishResponse();
} catch (IOException ex){
// Swallow?
}
}
}
return true;
}
代码示例来源:origin: com.sun.grizzly/grizzly-http-utils
/**
* Reset this response, and specify the values for the HTTP status code
* and corresponding message.
*
* @exception IllegalStateException if this response has already been
* committed
*/
public void reset(int status, String message) {
reset();
setStatus(status, message);
}
代码示例来源:origin: org.glassfish.external/grizzly-module
/**
* Application commit flag accessor.
*/
public boolean isAppCommitted() {
return (this.appCommitted || isCommitted() || isSuspended()
|| ((getContentLength() > 0)
&& (getContentCount() >= getContentLength())));
}
代码示例来源:origin: com.sun.grizzly/grizzly-utils
/**
* Application commit flag accessor.
*/
public boolean isAppCommitted() {
return (this.appCommitted || isCommitted() || isBufferSuspended()
|| ((getContentLength() > 0)
&& (getContentCount() >= getContentLength())));
}
代码示例来源:origin: com.sun.grizzly/grizzly-utils
if (isCommitted())
throw new IllegalStateException
(sm.getString("response.sendRedirect.ise"));
resetBuffer();
String absolute = toAbsolute(location, true);
setStatus(302);
setHeader("Location", absolute);
setContentType("text/html");
setLocale(Locale.getDefault());
String filteredMsg = filter(absolute);
StringBuilder sb = new StringBuilder(150 + absolute.length());
getWriter().write(sb.toString());
getWriter().flush();
} catch (IllegalStateException ise1) {
try {
getOutputStream().print(sb.toString());
} catch (IllegalStateException ise2) {
setStatus(404);
setSuspended(true);
代码示例来源:origin: com.sun.jersey/jersey-bundle
public OutputStream writeStatusAndHeaders(long contentLength,
ContainerResponse cResponse) throws IOException {
final javax.ws.rs.core.Response.StatusType statusInfo = cResponse.getStatusType();
if (statusInfo.getReasonPhrase() == null) {
response.setStatus(statusInfo.getStatusCode());
} else {
response.setStatus(statusInfo.getStatusCode(), statusInfo.getReasonPhrase());
}
if (contentLength != -1 && contentLength < Integer.MAX_VALUE)
response.setContentLength((int)contentLength);
for (Map.Entry<String, List<Object>> e : cResponse.getHttpHeaders().entrySet()) {
for (Object value : e.getValue()) {
response.addHeader(e.getKey(), ContainerResponse.getHeaderValue(value));
}
}
String contentType = response.getHeader("Content-Type");
if (contentType != null) {
response.setContentType(contentType);
}
return response.getOutputStream();
}
代码示例来源:origin: com.sun.grizzly/grizzly-http-utils
/**
* Send an error response with the specified status and message.
*
* @param status HTTP status code to send
* @param message Corresponding message to send
*
* @exception IllegalStateException if this response has
* already been committed
* @exception IOException if an input/output error occurs
*/
public void sendError(int status, String message) throws IOException {
checkResponse();
if (isCommitted())
throw new IllegalStateException
(sm.getString("response.sendError.ise"));
// Ignore any call from an included servlet
if (included)
return;
setError();
response.setStatus(status);
response.setMessage(message);
// Clear any data content that has been buffered
resetBuffer();
// Cause the response to be finished (from the application perspective)
setSuspended(true);
}
代码示例来源:origin: com.sun.grizzly/grizzly-websockets
final WSGrizzlyRequestImpl grizzlyRequest = new WSGrizzlyRequestImpl(1024);
grizzlyRequest.setRequest(request);
final GrizzlyResponse grizzlyResponse = new GrizzlyResponse(false, false, 1024);
grizzlyResponse.setResponse(response);
grizzlyRequest.setResponse(grizzlyResponse);
grizzlyResponse.setRequest(grizzlyRequest);
try {
代码示例来源:origin: com.sun.grizzly/grizzly-utils
final GrizzlyAdapter adapter = entry.getKey();
adapter.service(request, response);
if (response.getStatus() == 404 && i != size - 1) {
response.setStatus(200, "OK");
} else {
req.setNote(INVOKED_ADAPTER, adapter);
adapter.service(request.getRequest(), response.getResponse());
req.setNote(INVOKED_ADAPTER, adapter);
} else {
response.getResponse().setStatus(404);
customizedErrorPage(req, response.getResponse());
response.setStatus(404);
if (logger.isLoggable(Level.FINE)) {
logger.log(Level.FINE, "Invalid URL: " + req.decodedURI(), t);
customizedErrorPage(req, response.getResponse());
} catch (Exception ex2) {
if (logger.isLoggable(Level.WARNING)) {
代码示例来源:origin: com.sun.grizzly/grizzly-utils
/**
* Set the HTTP status to be returned with this response.
*
* @param status The new HTTP status
*/
public void setStatus(int status) {
setStatus(status, null);
}
代码示例来源:origin: jcabi/jcabi-http
response.addHeader(name, value);
response.addHeader(
HttpHeaders.SERVER,
String.format(
response.setStatus(answer.status());
final byte[] body = answer.bodyBytes();
response.getStream().write(body);
response.setContentLength(body.length);
if (cond.decrement() == 0) {
iter.remove();
代码示例来源:origin: com.sun.grizzly/grizzly-http-servlet
/**
* Customize the error page returned to the client.
* @param response the {@link GrizzlyResponse}
* @param message the Http error message
* @param errorCode the error code.
*/
public void customizeErrorPage(GrizzlyResponse response,String message, int errorCode){
response.setStatus(errorCode, message);
response.setContentType("text/html");
try{
response.getWriter().write("<html><body><h1>" + message
+ "</h1></body></html>");
response.getWriter().flush();
} catch (IOException ex){
// We are in a very bad shape. Ignore.
}
}
代码示例来源:origin: org.glassfish.external/grizzly-module
@Override
public void service(GrizzlyRequest request, GrizzlyResponse response) {
try {
response.setStatus(404);
response.flushBuffer();
} catch (IOException ex) {
Logger.getLogger(GrizzlyWebServer.class.getName()).log(
Level.SEVERE, null, ex);
}
}
});
代码示例来源:origin: org.glassfish.external/grizzly-module
/**
{@link GrizzlyAdapter} are called one by one, and the invokation stops when
* set the {@link GrizzlyResponse#getStatus} return the Http code <tt>200</tt>,
* which will stop the chain invokation.
* @param request The {@link GrizzlyRequest}
* @param response The {@link GrizzlyResponse}
*/
@Override
public void service(GrizzlyRequest request, GrizzlyResponse response) {
int size = adapters.size();
for (int i=0; i < size; i++){
adapters.get(i).service(request, response);
if (response.getStatus() == 404 && i != size -1){
response.setStatus(200, "OK");
} else {
return;
}
}
}
代码示例来源:origin: com.sun.grizzly/grizzly-http-utils
setCharacterEncoding(getCharacterEncoding());
代码示例来源:origin: org.jvnet.jax-ws-commons/jaxws-grizzly-httpspi
@Override
public void addResponseHeader(String name, String value) {
response.addHeader(name, value);
}
代码示例来源:origin: com.sun.grizzly/grizzly-http-utils
response.finishResponse();
response.recycle();
代码示例来源:origin: jcabi/jcabi-http
/**
* Notify this response about failure.
* @param response The response to notify
* @param failure The failure just happened
*/
private static void fail(final GrizzlyResponse<?> response,
final Throwable failure) {
response.setStatus(HttpURLConnection.HTTP_INTERNAL_ERROR);
final PrintWriter writer;
try {
writer = new PrintWriter(
new OutputStreamWriter(
response.getStream(),
MkGrizzlyAdapter.ENCODING
)
);
} catch (final UnsupportedEncodingException ex) {
throw new IllegalStateException(ex);
}
try {
writer.print(Logger.format("%[exception]s", failure));
} finally {
writer.close();
}
}
内容来源于网络,如有侵权,请联系作者删除!