12345678910111213141516171819202122232425262728293031323334353637383940414243444546 |
- package cn.hhj.http;
- import io.netty.buffer.Unpooled;
- import io.netty.channel.ChannelHandlerContext;
- import io.netty.handler.codec.http.*;
- public class GPResponse {
- //SocketChannel的封装
- private ChannelHandlerContext ctx;
- private HttpRequest req;
- public GPResponse(ChannelHandlerContext ctx, HttpRequest req) {
- this.ctx = ctx;
- this.req = req;
- }
- public void write(String out) throws Exception {
- try {
- if (out == null || out.length() == 0) {
- return;
- }
- // 设置 http协议及请求头信息
- FullHttpResponse response = new DefaultFullHttpResponse(
- // 设置http版本为1.1
- HttpVersion.HTTP_1_1,
- // 设置响应状态码
- HttpResponseStatus.OK,
- // 将输出值写出 编码为UTF-8
- Unpooled.wrappedBuffer(out.getBytes("UTF-8")));
- response.headers().set("Content-Type", "text/html;");
- // 当前是否支持长连接
- // if (HttpUtil.isKeepAlive(r)) {
- // // 设置连接内容为长连接
- // response.headers().set(CONNECTION, HttpHeaderValues.KEEP_ALIVE);
- // }
- ctx.write(response);
- } finally {
- ctx.flush();
- ctx.close();
- }
- }
- }
|