netty 实现tomcat
自定义基础类
tomcatservlet
public abstract class tomcatservlet {
public void service(servletrequest request, servletresponse response){
if ("get".equalsignorecase(request.getmethod())){
doget(request, response);
}else if ("post".equalsignorecase(request.getmethod())){
dopost(request, response);
}else {
doresponse(response, "暂不支持其它请求方法");
}
}
public abstract void doget(servletrequest request, servletresponse response);
public abstract void dopost(servletrequest request, servletresponse response);
public void doresponse(servletresponse response, string message){
response.write(message);
}
}
servletrequest
@data
public class servletrequest {
private channelhandlercontext context;
private httprequest httprequest;
public servletrequest(){
}
public servletrequest(channelhandlercontext context, httprequest httprequest){
this.context = context;
this.httprequest = httprequest;
}
public string getmethod(){
return httprequest.method().name();
}
public httpheaders getheaders(){
return httprequest.headers();
}
public map<string, list<string>> getparameters(){
querystringdecoder decoder = new querystringdecoder(httprequest.uri());
return decoder.parameters();
}
public map<string,string> getpostformparameters(){
map<string,string> params = new hashmap<>();
httppostrequestdecoder decoder = new httppostrequestdecoder(httprequest);
decoder.getbodyhttpdatas().foreach(item -> {
if (item.gethttpdatatype() == interfacehttpdata.httpdatatype.attribute){
attribute attribute = (attribute) item;
try {
string key = attribute.getname();
string value = attribute.getvalue();
params.put(key, value);
}catch (exception e){
e.printstacktrace();
}
}
});
return params;
}
public map<string, object> getpostbody(){
bytebuf content = ((fullhttprequest)httprequest).content();
byte[] bytes = new byte[content.readablebytes()];
content.readbytes(bytes);
return json.parseobject(new string(bytes)).getinnermap();
}
}
servletresponse
@data
public class servletresponse {
private channelhandlercontext context;
private httprequest httprequest;
public servletresponse(){
}
public servletresponse(channelhandlercontext context, httprequest httprequest){
this.context = context;
this.httprequest = httprequest;
}
public void write(string message){
fullhttpresponse response = new defaultfullhttpresponse(httpversion.http_1_1, httpresponsestatus.ok);
response.headers().set("content-type","application/json;charset=utf-8");
response.content().writecharsequence(message, standardcharsets.utf_8);
context.channel().writeandflush(response).addlistener(channelfuturelistener.close);
}
}
customservlet
ublic class customservlet extends tomcatservlet{
@override
public void doget(servletrequest request, servletresponse response) {
system.out.println("处理get请求");
system.out.println("请求参数为：");
request.getparameters().foreach((key,value) -> system.out.println(key + " ==> "+value));
doresponse(response, "get success");
}
@override
public void dopost(servletrequest request, servletresponse response) {
if (request.getheaders().get("content-type").contains("x-www-form-urlencoded")){
system.out.println("处理post form请求");
system.out.println("请求参数为：");
request.getpostformparameters().foreach((key,value) -> system.out.println(key + " ==> " + value));
doresponse(response, "post form success");
}else if (request.getheaders().get("content-type").contains("application/json")){
system.out.println("处理post json请求");
system.out.println("请求参数为：");
request.getpostbody().foreach((key,value) -> system.out.println(key + " ==> " + value));
doresponse(response, "post json success");
}else {
doresponse(response, "error：暂不支持其它post请求方式");
}
}
}
servletmapping：url与对应的tomcatservlet映射
public class servletmapping {
private static final map<string,tomcatservlet> urlservletmapping = new hashmap<>();
public static map<string, tomcatservlet> geturlservletmapping(){
return urlservletmapping;
}
}
web.properties：使用properties存储url与对应的tomcatservet
servlet.url=/hello servlet.classname=com.example.demo.tomcat.servlet.customservlet
netty 服务端
customserverhandler
public class customserverhandler extends simplechannelinboundhandler<fullhttprequest> {
@override
protected void channelread0(channelhandlercontext channelhandlercontext, fullhttprequest request) throws exception {
string uri = request.uri();
string path = uri;
if (uri.contains("?")){
path = uri.substring(0,uri.indexof("?"));
}
if (servletmapping.geturlservletmapping().containskey(path)){
servletrequest servletrequest = new servletrequest(channelhandlercontext, request);
servletresponse servletresponse = new servletresponse(channelhandlercontext, request);
servletmapping.geturlservletmapping().get(path).service(servletrequest, servletresponse);
}else {
fullhttpresponse response = new defaultfullhttpresponse(httpversion.http_1_1, httpresponsestatus.ok);
response.content().writecharsequence("404 not found："+path+"不存在", standardcharsets.utf_8);
channelhandlercontext.channel().writeandflush(response).addlistener(channelfuturelistener.close);
}
}
}
nettyserver
public class nettyserver {
private static final properties webproperties = new properties();
public static void init(){
try {
inputstream inputstream = new fileinputstream("./web.properties");
webproperties.load(inputstream);
for (object item : webproperties.keyset()){
string key = (string)item;
if (key.endswith(".url")){
string servletkey = key.replaceall("\\.url","\\.classname");
string servletname = webproperties.getproperty(servletkey);
tomcatservlet servlet = (tomcatservlet) class.forname(servletname).newinstance();
servletmapping.geturlservletmapping().put(webproperties.getproperty(key),servlet);
}
}
}catch (exception e){
e.printstacktrace();
}
}
public static void startserver(int port){
init();
eventloopgroup bossgroup = new nioeventloopgroup();
eventloopgroup workergroup = new nioeventloopgroup();
try {
serverbootstrap serverbootstrap = new serverbootstrap();
serverbootstrap.group(bossgroup, workergroup)
.channel(nioserversocketchannel.class)
.option(channeloption.so_backlog, 128)
.childoption(channeloption.so_keepalive, true)
.childhandler(new channelinitializer<socketchannel>() {
@override
protected void initchannel(socketchannel socketchannel) throws exception {
channelpipeline channelpipeline = socketchannel.pipeline();
channelpipeline.addlast(new httprequestdecoder());
channelpipeline.addlast(new httpresponseencoder());
channelpipeline.addlast(new httpobjectaggregator(65535));
channelpipeline.addlast(new customserverhandler());
}
});
channelfuture channelfuture = serverbootstrap.bind(port).sync();
channelfuture.channel().closefuture().sync();
}catch (exception e){
e.printstacktrace();
}finally {
bossgroup.shutdowngracefully();
workergroup.shutdowngracefully();
}
}
public static void main(string[] args) {
startserver(8000);
}
}
使用测试
get请求：localhost:8000/hello?name=瓜田李下&age=20
处理get请求
请求参数为：
name ==> [瓜田李下]
age ==> [20]
get请求：localhost:8000/hello2?name=瓜田李下&age=20
/hello2路径没有对应的tomcatservlet处理
post form请求：x-www-form-urlencoded
处理post form请求
请求参数为：
name ==> 瓜田李下
age ==> 20
post json请求
处理post json请求
请求参数为：
name ==> 瓜田李下
age ==> 20
post form-data请求
目前只支持x-www-form-urlencoded、post json请求，不支持其它请求方式
put：localhost:8000/hello?name=瓜田李下&age=20
目前只支持get、post请求方法，不支持其它方法
到此这篇关于netty 实现tomcat的文章就介绍到这了,更多相关netty 实现tomcat内容请搜索以前的文章或继续浏览下面的相关文章希望大家以后多多支持！
声明：如若本站内容侵犯了原著者的合法权益，可联系我们进行处理。
