netty与http服务

客官°小女子只卖身不卖艺 2022-06-07 05:07 259阅读 0赞

http客户端

  1. package httpClient;
  3. import org.apache.commons.httpclient.HttpClient;
  4. import org.apache.commons.httpclient.methods.PostMethod;
  5. import org.apache.commons.httpclient.methods.StringRequestEntity;
  7. import java.util.HashMap;
  8. import java.util.Map;
  10. /**
  11.  * Created by sff on 2017/10/10.
  12.  */
  13. public class HttpClientTest {
  15.     public static void send(String url, String content) throws Exception{
  16.         HttpClient httpClient = new HttpClient();
  17.         httpClient.getParams().setContentCharset("UTF-8");
  18.         PostMethod postMethod = new PostMethod(url);
  19.         Map<String, String> headerMap = new HashMap<>();
  20.         headerMap.put("Host", "****");
  21.         headerMap.put("Accept-Encoding", "gzip");
  22.         for (Map.Entry<String, String> entry : headerMap.entrySet()) {
  23.             postMethod.addRequestHeader(entry.getKey(), entry.getValue());
  24.         }
  25.         StringRequestEntity entity = new StringRequestEntity(content, "text/plain", "UTF-8");
  26.         postMethod.setRequestEntity(entity);
  27.         try {
  28.             int result = httpClient.executeMethod(postMethod);
  29.             if (result == 200) {
  30.                 System.out.println("发送成功");
  31.             } else{
  32.                 System.out.println("发送失败");
  33.             }
  34.         } catch (Exception e) {
  35.             e.printStackTrace();
  36.         }
  37.     }
  39.     public static void main(String[] args) throws Exception{
  40.         StringBuilder stringBuilder = new StringBuilder("发送内容：\n");
  41. //        for(int i = 0; i < 1000; i++){
  42.             stringBuilder.append(0).append(" ");
  43.             for(int j = 0; j < 1000; j++){
  44.                 stringBuilder.append(j);
  45.             }
  46.             stringBuilder.append("\n");
  47. //        }
  48.         send("http://127.0.0.1:8088?", stringBuilder.toString());
  49.     }
  50. }

postMethod的setRequestEntity()方法是想post方法中放入参数，看requestEntity实现类有很多种

netty做http服务

netty

  1. package httpServer;
  3. import io.netty.bootstrap.ServerBootstrap;
  4. import io.netty.channel.*;
  5. import io.netty.channel.nio.NioEventLoopGroup;
  6. import io.netty.channel.socket.SocketChannel;
  7. import io.netty.channel.socket.nio.NioServerSocketChannel;
  8. import io.netty.handler.codec.http.HttpObjectAggregator;
  9. import io.netty.handler.codec.http.HttpRequestDecoder;
  10. import io.netty.handler.codec.http.HttpRequestEncoder;
  11. import io.netty.handler.codec.http.HttpServerCodec;
  12. import io.netty.handler.stream.ChunkedWriteHandler;
  13. import logbus.agent.log.LogDefinition;
  14. import logbus.agent.netty.codec.XDecoderFactory;
  15. import logbus.agent.netty.codec.XEncoderFactory;
  16. import logbus.agent.sink.Sink;
  17. import logbus.agent.source.impl.server.netty.ServerSourceHandlerFactory;
  18. import logbus.protocol.netty.XNetty;
  20. import java.util.Map;
  22. /**
  23.  * http请求的netty服务器
  24.  * Created by sff on 2017/10/9.
  25.  */
  26. public class HttpServerSourceNetty implements XNetty {
  27.     /** 端口号 */
  28.     private int port;
  30.     // 分配用于处理事务的线程组数量
  31.     protected static final int bisGroupSize = Runtime.getRuntime().availableProcessors();
  32.     // 每个线程组中线程的数量
  33.     protected static final int worGroupSize = 2;
  36.     /**
  37.      * 初始化
  38.      * @param port
  39.      * @param encrypt
  40.      * @throws InterruptedException
  41.      */
  42.     public HttpServerSourceNetty(String groupName, String sourceName, int port, boolean encrypt) throws InterruptedException{
  43.         this.port = port;
  44.         try{
  45.             start();
  46.         } catch (InterruptedException e){
  47.             String msg = new StringBuilder("name值为").append(sourceName).append(
  48.                     "的source的server服务器开启失败").toString();
  49.             LogDefinition.COMMON.error(msg, e);
  50.             throw new InterruptedException(msg);
  51.         }
  52.     }
  54.     @Override
  55.     public void start() throws InterruptedException{
  56.         EventLoopGroup boss = new NioEventLoopGroup(bisGroupSize);
  57.         EventLoopGroup worker = new NioEventLoopGroup(worGroupSize);
  58.         ServerBootstrap bootstrap = new ServerBootstrap();
  59.         //group函数其实就是将parentGroup和ChildGroup进行赋值，其中parentGroup用于处理accept事件，ChildGroup用于处理accpt的Channel的IO事件。
  60.         bootstrap.group(boss, worker);
  61.         bootstrap.channel(NioServerSocketChannel.class);
  62.         bootstrap.option(ChannelOption.SO_BACKLOG, 128);
  63.         bootstrap.option(ChannelOption.TCP_NODELAY, true);
  64.         bootstrap.childOption(ChannelOption.SO_KEEPALIVE, true);
  65.         bootstrap.childHandler(new ChannelInitializer<SocketChannel>() {
  66.             @Override
  67.             protected void initChannel(SocketChannel socketChannel) throws Exception{
  68.                 ChannelPipeline p = socketChannel.pipeline();
  69.                 // server端发送的是httpResponse，所以要使用HttpResponseEncoder进行编码
  70.                 p.addLast(new HttpServerCodec());
  71.                 p.addLast("aggregator", new HttpObjectAggregator(64 * 1024 * 1024));
  72.                 p.addLast("chunkedWriter", new ChunkedWriteHandler());
  73.                 p.addLast(new HttpServerSourceHandlerFactory().getHandler());
  74.             }
  75.         });
  76.         ChannelFuture f = bootstrap.bind(port).sync();
  77.         if(f.isSuccess()){
  79.         }
  80.     }
  82. }

netty处理的handler

  1. package feedback.communicate.netty.http;
  3. import io.netty.buffer.ByteBuf;
  4. import io.netty.buffer.ByteBufAllocator;
  5. import io.netty.channel.ChannelHandlerContext;
  6. import io.netty.channel.ChannelInboundHandlerAdapter;
  7. import io.netty.handler.codec.http.*;
  9. import java.net.HttpCookie;
  10. import java.net.URI;
  11. import java.util.List;
  12. import java.util.Map;
  14. /**
  15.  * http server handler
  16.  * Created by sff on 2018/4/20.
  17.  */
  18. public class HttpServerHandler extends ChannelInboundHandlerAdapter {
  20.     public HttpServerHandler(){
  21.         super();
  22.     }
  24.     private List<String> splitMultiCookies(String header) {
  25.         List<String> cookies = new java.util.ArrayList<String>();
  26.         int quoteCount = 0;
  27.         int p, q;
  28.         for (p = 0, q = 0; p < header.length(); p++) {
  29.             char c = header.charAt(p);
  30.             if (c == '"') quoteCount++;
  31.             if (c == ';' && (quoteCount % 2 == 0)) {
  32.                 // it is comma and not surrounding by double-quotes
  33.                 cookies.add(header.substring(q, p));
  34.                 q = p + 1;
  35.             }
  36.         }
  37.         cookies.add(header.substring(q));
  38.         return cookies;
  39.     }
  41.     /**
  42.      * 接收get请求的数据
  43.      * @param ctx
  44.      * @param msg
  45.      */
  46.     public void handler(ChannelHandlerContext ctx, Object msg) throws Exception{
  47.         if (msg instanceof HttpRequest) {
  48.             System.out.println("###################");
  49.             FullHttpRequest request = (FullHttpRequest) msg;
  50.             // 收取cookie
  51.             String cookieHeader = request.headers().get(HttpHeaderNames.COOKIE);
  52.             List<String> cookieStrs = splitMultiCookies(cookieHeader);
  53.             for(int i = 0; i < cookieStrs.size(); i++) {
  54.                 List<HttpCookie> list = HttpCookie.parse(cookieStrs.get(i));
  55.                 for (int j = 0; j < list.size(); j++) {
  56.                     System.out.println(list.get(j).toString());
  57.                 }
  58.             }
  59.             // if GET Method: should not try to create a HttpPostRequestDecoder
  60.             if (request.method().equals(HttpMethod.GET)) {
  61.                 URI uri = new URI(request.uri());
  62.                 QueryStringDecoder decoderQuery = new QueryStringDecoder(request.getUri());
  63.                 Map<String, List<String>> uriAttributes = decoderQuery.parameters();
  64.                 System.out.println("GET内容：" + uri.getQuery());
  65.             }
  66.             //判断request请求是否是post请求
  67.             if (request.method().equals(HttpMethod.POST)) {
  68.                 ByteBuf content = request.content();
  69.                 byte[] req = new byte[content.readableBytes()];
  70.                 content.readBytes(req);
  71.                 String resultStr = new String(req, "UTF-8");
  72.                 System.out.println("POST内容：" + resultStr);
  73.                 content.release();
  74.             } else{
  75.                 request.release();
  76.             }
  77.             // 发送消息
  78.             String r = "sff is a good man.";
  79.             ByteBuf bf = ByteBufAllocator.DEFAULT.buffer(8*1024);
  80.             bf.writeBytes(r.getBytes());
  81.             HttpHeaders httpHeaders = new DefaultHttpHeaders();
  82.             HttpCookie cookie1 = new HttpCookie("feedback", "sff");
  83.             cookie1.setHttpOnly(true);
  84.             HttpCookie cookie2 = new HttpCookie("session_id", "123456");
  85.             HttpCookie cookie3 = new HttpCookie("tenant", "STULIB");
  86.             httpHeaders.add(HttpHeaderNames.SET_COOKIE, cookie1); // add 是可以添加同名的对象，set会把同名的对象覆盖掉
  87.             httpHeaders.add(HttpHeaderNames.SET_COOKIE, cookie2);
  88.             httpHeaders.add(HttpHeaderNames.SET_COOKIE, cookie3);
  89.             httpHeaders.set(HttpHeaderNames.CONTENT_TYPE, "text/plain");
  90.             httpHeaders.set(HttpHeaderNames.CONTENT_LENGTH, bf.readableBytes());
  91.             httpHeaders.set(HttpHeaderNames.CONNECTION, HttpHeaderValues.KEEP_ALIVE);
  92.             FullHttpResponse response = new DefaultFullHttpResponse(HttpVersion.HTTP_1_1, HttpResponseStatus.OK, bf);
  93.             response.headers().set(httpHeaders);
  94.             ctx.writeAndFlush(response);
  95.         }
  96.     }
  98.     @Override
  99.     public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
  100.         handler(ctx, msg);
  101.     }
  104.     @Override
  105.     public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause)
  106.             throws Exception {
  107.         // ignore
  108.     }
  109. }

FullHttpRequest的类里面可以查询header，body等数据

参考：Netty处理HTTP之GET,POST请求

发表评论

表情：
评论列表 （有 0 条评论，259人围观）

还没有评论，来说两句吧...

相关阅读

    相关 Netty剖析之Http服务案例

    前言 前面我们讲了Netty的线程模型，还有一些Netty的特性，以及使用Netty编写过一个Tcp服务案例，本次呢，我们将结合前面所学的知识，来编写一个Http服务案例

    怼烎@怼烎@/ 0 赞/ 112 阅读