今日重新写了一遍请求响应前面的代码,第二次学习的时候确实会有不一样的感触。
浏览器端
浏览器执行:解析URL,得到ip port contentAndParams . 通过ip port 创建socke流,再得到一个高级流将contentAndParams发送给服务器。浏览器等待服务器发送信息,并展示信息
package browser;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
import java.util.Scanner;
public class Browser {
private Scanner sc = new Scanner(System.in);
private Socket socket = null;
public void openBrowser() {
System.out.println("浏览器开始执行了");
System.out.println("URL:");
String url = sc.nextLine();
this.parseURL(url);
}
//设计一个方法解析URL
private void parseURL(String url) {
//找寻冒号所在位置
int colonIndex = url.indexOf(":");
//找寻斜杠所在位置
int slashIndex = url.indexOf("/");
//获取Ip port contentAndParams
String ip = url.substring(0, colonIndex);
int port = Integer.parseInt(url.substring(colonIndex + 1, slashIndex));
String contentAndParams = url.substring(slashIndex + 1);
//创建连接并发送请求
this.cerateSocketAndSendRequest(ip, port, contentAndParams);
}
//创建socket 将资源发送过去
private void cerateSocketAndSendRequest(String ip, int port, String contenAndParams) {
try {
//通过ip port 创建socket流
socket = new Socket(ip, port);
//得到一个PrintWriter流将信息发送出去
PrintWriter out = new PrintWriter(socket.getOutputStream());
out.println(contenAndParams);
out.flush();
//浏览器等待响应信息
this.receiveResponseContent();
} catch (IOException e) {
e.printStackTrace();
}
}
//设计一个方法 接受服务器回写的响应信息
private void receiveResponseContent() {
try {
BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
String responseContent = reader.readLine();
//解析响应信息并展示
this.parseResponseContentAndShow(responseContent);
} catch (IOException e) {
e.printStackTrace();
}
}
private void parseResponseContentAndShow(String responseContent){
System.out.println(responseContent);
}
}
服务器
服务器开放一个端口号,等待接收。接收到一个连接开启一个ServerHandler线程。然后包装socket.getInputStream成高级流读取一行信息,再解析资源。
创建了两个类 HttpServletRequest 和 HttpServletResponse 目的是接收响应求情的信息,另一个是为了接受响应回去的结果。之后找到ServletController类做事情,找到请求名对应的真实类做事情
增加了一个缓存机制,读取到一个请求加载一个,性能提高了
package server;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
public class Server {
//开启服务器的方法
public void serverStart(){
try {
System.out.println("浏览器开始执行了");
//创建一个服务
ServerSocket server=new ServerSocket(9999);
while(true){
//等待接收
Socket socket=server.accept();
//开启一个线程
new ServerHandler(socket).run();
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
package server;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.net.Socket;
import java.util.HashMap;
public class ServerHandler extends Thread{
private Socket socket;
public ServerHandler(Socket socket){
this.socket=socket;
}
public void run(){
//接收信息
this.receiveRequest();
//解析
//找人做事
//响应回去
}
//接受消息
private void receiveRequest(){
try {
InputStream is=socket.getInputStream();
InputStreamReader isr=new InputStreamReader(is);
BufferedReader reader=new BufferedReader(isr);
//读取消息
String contentAndParams=reader.readLine();
//解析
this.parseContentAndParams(contentAndParams);
} catch (IOException e) {
e.printStackTrace();
}
}
//解析资源
private void parseContentAndParams(String contentAndParams){
String content=null;
HashMap<String,String> paramsMap=null;
//content?key=value&key=value
//找寻到问号的位置
int questionMarkIndex=contentAndParams.indexOf("?");
//判断是否携带了参数
if(questionMarkIndex!=-1){
//携带了参数
content=contentAndParams.substring(0,questionMarkIndex);
paramsMap=new HashMap<>();
//处理后面携带的参数
String params=contentAndParams.substring(questionMarkIndex+1);
String []keyAndValues=params.split("&");
for(String keyAndValue:keyAndValues){
String []kv=keyAndValue.split("=");
paramsMap.put(kv[0],kv[1]);
}
}else{
//若没带参数
content=contentAndParams;
}
//创建了两个类 一个是为了存储接受请求携带的信息
//一个是为了接受响应回去的结果
HttpServletRequest request=new HttpServletRequest(content,paramsMap);
HttpServletResponse response=new HttpServletResponse();
//找到一个人 让他去底层找到真实的类做事情 并将response填满
ServletController.findController(request,response);
//响应回去
this.responseToBrowser(response);
}
//找人做事
private void responseToBrowser(HttpServletResponse response){
}
}
package server;
import java.util.HashMap;
public class HttpServletRequest {
//自定义的一个类
//目的存储浏览器发送请求和参数
private String content;
private HashMap<String,String> paramsMap;
public HttpServletRequest() {
}
public HttpServletRequest(String content, HashMap<String, String> paramsMap) {
this.content = content;
this.paramsMap = paramsMap;
}
public String getContent() {
return content;
}
public void setContent(String content) {
this.content = content;
}
public HashMap<String, String> getParamsMap() {
return paramsMap;
}
public void setParamsMap(HashMap<String, String> paramsMap) {
this.paramsMap = paramsMap;
}
}
package server;
public class HttpServletResponse {
private StringBuilder responseContent=new StringBuilder();
public void write(String str){
responseContent.append(str);
}
public String getResponseContent(){
return this.responseContent.toString();
}
}
package server;
import java.io.FileReader;
import java.io.IOException;
import java.lang.reflect.Method;
import java.util.Enumeration;
import java.util.HashMap;
import java.util.Properties;
public class ServletController{
//这个类的目的是为了管理 findController方法
//方法之前与服务器做的事情不一样 抽离出来
//每一次赵信controller类都需要参考web.properties配置文件
//读取文件性能会变低 因此可以增加一个缓存机制
//每一个Controller类都是由Controller方法来找寻类
// 找到类之后执行他的方法
//增加一个单例模式(controller类只有方法执行 没有属性)
private static HashMap<String ,String>controllerNameMap=new HashMap<>();
//添加一个集合 存储被管理的所有Controller类对象
private static HashMap<String,HttpServlet> controllerObjectMap = new HashMap<>();
//延迟加载对象的方式
//创建一个静态块 在当前类加载的时候将配置文件中的所有信息读取出来存入缓存集合中
static{
try {
Properties pro = new Properties();
pro.load(new FileReader("src//web.properties"));
Enumeration en = pro.propertyNames();
while(en.hasMoreElements()){
String content = (String)en.nextElement();
String realControllerName = pro.getProperty(content);
controllerNameMap.put(content,realControllerName);
}
} catch (IOException e) {
e.printStackTrace();
}
}
//找人干活---控制层 (controller action servlet)
//content----index map-----{{name,zzt},{},{}}
public static void findController(HttpServletRequest request,HttpServletResponse response){
//获取request对象中的请求名字
String content = request.getContent();
try {
//先去objectMap中找寻需要的对象
HttpServlet controllerObject = controllerObjectMap.get(content);
//若对象不存在 证明之前没有使用过
if(controllerObject==null){
//参考配置文件(缓存) 真实类名
String realControllerName = controllerNameMap.get(content);
//请求对应的真实类名是否存在
if(realControllerName!=null){
//反射获取类
Class clazz = Class.forName(realControllerName);
controllerObject = (HttpServlet) clazz.newInstance();
//将新创建的对象放在上面的对象集合内
controllerObjectMap.put(content,controllerObject);
}
}
//----以上可以确保controllerObject对象肯定存在-------------
//反射找寻类中的方法
Class controllerClass = controllerObject.getClass();
Method serviceMethod = controllerClass.getMethod("service",HttpServletRequest.class,HttpServletResponse.class);
serviceMethod.invoke(controllerObject,request,response);
} catch (ClassNotFoundException e) {
response.write("请求的"+content+"Controller不存在");
} catch (NoSuchMethodException e){
response.write("405 没有可以执行的方法");
} catch (Exception e){
e.printStackTrace();
}
}
}
package controller;
import server.HttpServlet;
import server.HttpServletRequest;
import server.HttpServletResponse;
public class IndexController extends HttpServlet {
@Override
public void service(HttpServletRequest request, HttpServletResponse response) {
//获取请求发送过来的参数
System.out.println("控制层执行了");
//找到业务层做事 业务层找dao层帮忙
//将业务层得到最终结果 响应给浏览器
response.write("XXX");
}
}
总结:学过的知识在复习一遍会有不一样的感触。特别现在对反射 IO流 单例 缓存机制有更深的记忆了。