Netty入门实例-Http服务

Http服务

=====================================================================

1.需求

2.创建服务端handler

在handler中我们对浏览器提交的Http请求做出处理

package com.dpb.netty.http;

import io.netty.buffer.ByteBuf;

import io.netty.buffer.Unpooled;

import io.netty.channel.ChannelHandlerContext;

import io.netty.channel.SimpleChannelInboundHandler;

import io.netty.handler.codec.http.*;

import io.netty.util.CharsetUtil;

import java.net.URI;

/**

• @program: netty4demo

• @description:

• @author: 波波烤鸭

• @create: 2019-12-24 16:49

*/

public class TestHttpServerHandler extends SimpleChannelInboundHandler {

/**

• 读取客户端发送的数据

• @param context

• @param httpObject

• @throws Exception

*/

@Override

protected void channelRead0(ChannelHandlerContext context, HttpObject httpObject) throws Exception {

if(httpObject instanceof HttpRequest){

// 判断是否是 Http请求

System.out.println(context.pipeline().hashCode());

System.out.println(httpObject.hashCode());

System.out.println(context.channel().remoteAddress());

HttpRequest request = (HttpRequest) httpObject;

URI uri = new URI(request.uri());

if(“/favicon.ico”.equals(uri.getPath())){

System.out.println(“请求了 favicon.ico 。。”);

return ;

}

ByteBuf byteBuf = Unpooled.copiedBuffer(“hello,我是服务端…”, CharsetUtil.UTF_8);

FullHttpResponse response = new DefaultFullHttpResponse(HttpVersion.HTTP_1_1,HttpResponseStatus.OK,byteBuf);

response.headers().set(HttpHeaderNames.CONTENT_TYPE,“text/plain;charset=utf-8”);

response.headers().set(HttpHeaderNames.CONTENT_LENGTH,byteBuf.readableBytes());

context.writeAndFlush(response);

}

}

}

3.创建服务端

创建服务端程序，创建服务。

package com.dpb.netty.http;

import io.netty.bootstrap.ServerBootstrap;

import io.netty.channel.*;

import io.netty.channel.nio.NioEventLoopGroup;

import io.netty.channel.socket.ServerSocketChannel;

import io.netty.channel.socket.SocketChannel;

import io.netty.channel.socket.nio.NioServerSocketChannel;

import io.netty.handler.codec.http.HttpServerCodec;

/**

• @program: netty4demo

• @description:

Kafka实战笔记

• Kafka入门
• 为什么选择Kafka
• Karka的安装、管理和配置

• Kafka的集群
• 第一个Kafka程序

afka的生产者

• Kafka的消费者
• 深入理解Kafka
• 可靠的数据传递

• Spring和Kalka的整合
• Sprinboot和Kafka的整合
• Kafka实战之削峰填谷
• 数据管道和流式处理(了解即可)

• Kafka实战之削峰填谷

加入社区：https://bbs.csdn.net/forums/4304bb5a486d4c3ab8389e65ecb71ac0
ka实战之削峰填谷**

• 数据管道和流式处理(了解即可)

[外链图片转存中…(img-pfT1DKAa-1725705287085)]

• Kafka实战之削峰填谷

[外链图片转存中…(img-nmnAW5Ur-1725705287086)]

加入社区：https://bbs.csdn.net/forums/4304bb5a486d4c3ab8389e65ecb71ac0