手写tomcat：根本功能实现（3） - qidao123.com技术社区-IT企服评测·应用市场

package com.qcby.config;
import com.qcby.Util.SearchClassUtil;
import com.qcby.servlet.Httpservlet;
import com.qcby.zj.YbyServlet;
import java.util.HashMap;
import java.util.List;
import java.util.List;
import java.util.Map;
public class TomcatRoute {
public static HashMap<String, Httpservlet> Route = new HashMap<>();
static {
List<String> classesPath = SearchClassUtil.searchClass();
for (String path : classesPath) {
try {
//加载类
Class clazz = Class.forName(path);
//获取注解
YbyServlet webServlet = (YbyServlet) clazz.getDeclaredAnnotation(YbyServlet.class);
// 对象
Object servlet = clazz.getDeclaredConstructor().newInstance();
Route.put(webServlet.url(), (Httpservlet) servlet);
// Httpservlet servlet = (Httpservlet) clazz.newInstance();
// servletMap.put(webServlet.url(),servlet);
System.out.println(Route);
} catch (Exception e) {
e.printStackTrace();
}
}
}
}

复制代码

package com.qcby;
//tomcat主启动类
import com.qcby.config.TomcatRoute;
import com.qcby.servlet.Httpservlet;
import com.qcby.Request.HttpServletRequest;
import com.qcby.Response.HttpServletResponse;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.HashMap;
public class Mytomcat {
static HashMap<String,Httpservlet> routes= TomcatRoute.Route;
static HttpServletRequest request=new HttpServletRequest();
static HttpServletResponse response=new HttpServletResponse();
public static void dispatch(){
Httpservlet servlet=routes.get(request.getPath());
if(servlet!=null){
servlet.service(request,response);
}
}
public static void main(String[] args) {
try {
System.out.append("服务器启动......");
// 1.定义ServerSocket对象进行服务器的端口注册
ServerSocket serverSocket = new ServerSocket(8080);
while (true) {
// 2.监听客户端的socket链接程序
Socket socket = serverSocket.accept();//阻塞监听
// 3.从socket对象当中获得一个字节流对象
InputStream iStream = socket.getInputStream();
// 打印输出
int len = 0;
int ReviceLen = 0;
// 计算机网络数据是以8bit为一个单元进行发送，我们接收到发送方发生的byte数据
// 将其转化为utf-8格式输出
byte[] recvBuf = new byte[1024];
while ((ReviceLen = iStream.read(recvBuf)) != -1) {
String count=new String(recvBuf,0,ReviceLen,"UTF-8");
String method=count.split(" ")[0];
String url=count.split(" ")[1];
request.setMethod(method);
request.setPath(url);
}
dispatch();
}
} catch(Exception e){
// TODO: handle exception
}
}
}

复制代码

static HashMap<String,Httpservlet> routes = TomcatRoute.Route;
static HttpServletRequest request = new HttpServletRequest();
static HttpServletResponse response = new HttpServletResponse();

复制代码

public static void dispatch() {
Httpservlet servlet = routes.get(request.getPath());
if (servlet != null) {
servlet.service(request, response);
}
}

复制代码

public static void main(String[] args) {
try {
System.out.println("服务器启动......");
ServerSocket serverSocket = new ServerSocket(8080);
while (true) {
// 1. 监听客户端连接（阻塞）
Socket socket = serverSocket.accept();
InputStream iStream = socket.getInputStream();
// 2. 解析HTTP请求
byte[] recvBuf = new byte[1024];
int ReviceLen = iStream.read(recvBuf);
String count = new String(recvBuf, 0, ReviceLen, "UTF-8");
String method = count.split(" ")[0];
String url = count.split(" ")[1];
// 3. 设置请求信息
request.setMethod(method);
request.setPath(url);
// 4. 分发请求
dispatch();
}
} catch (Exception e) {
e.printStackTrace();
}
}

复制代码