首页 技术 正文
技术 2022年11月7日
0 收藏 999 点赞 903 浏览 4638 个字

1、首先完成一个server类,用来接收客户端的请求;代码都在一个while(true)循环中,模拟tomcat一直在启动,其中绑定一个端口,用来监听一个端口,然后创建一个输入流,获取请求的输入流,然后将输入流中的uri和参数通过request获取出来,然后通过response答应出来。

 package com.dongnao.mytomcat; import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.text.SimpleDateFormat;
import java.util.Date; public class Server {
private static int count=0;
public static void main(String[] args) {
ServerSocket ss=null;
Socket socket=null;
SimpleDateFormat format=new SimpleDateFormat("yyy-MM-dd HH:mm:ss");
String time=format.format(new Date()); try {
ss=new ServerSocket(9994);
System.out.println("已经连接服务器"); while(true){
socket =ss.accept();
count++;
System.out.println("第几次连接:"+count); InputStream is=socket.getInputStream();
Request request=new Request(is); OutputStream os=socket.getOutputStream(); Response response= new Response(os); //业务逻辑 ,获取静态资源;
String uri=request.getUri();
System.out.println(uri);
//判定这个是不是静态资源
if(isStaticSourse(uri)){
response.writeFile(uri.substring(1));
}else if(uri.endsWith(".action")){
if(uri.endsWith("/login.action")){
//取账户和密码
LoginServlet servlet=new LoginServlet();
try {
servlet.service(request, response);
} catch (Exception e) {
e.printStackTrace();
}
}
}
//出while循环后要关闭
os.close();
socket.close();
}
} catch (IOException e) {
e.printStackTrace();
} }
public static boolean isStaticSourse(String uri){
String[] suffixString={"html","css","js","jpg","jepg","png"};
boolean isStatic =false;
for(String suffix:suffixString){
if(uri.endsWith("."+suffix)){
isStatic=true;
break;
}
} return isStatic;
} }

2、创建一个request类,用来模拟request对象,用来获取对应的uri和参数,其中请求方式有get和post,get的也有参数,这里没忽略了,主要涉及的是post的请求方式,然后截取post中的请求参数。

 package com.dongnao.mytomcat; import java.io.IOException;
import java.io.InputStream;
import java.util.HashMap;
/**
* 解析请求类,解析请求资源的地址
* @author CYA
*
*/
public class Request {
private String uri;
private String pString;
//halderMap
private HashMap<String,String> paramMap=new HashMap<String,String>();
//取得客户参数名称;
public String getParamName(String key){ return paramMap.get(key);
}
public Request(InputStream is) throws IOException{
byte[] buff=new byte[1024];
int len=is.read(buff);
if(len>0){
String msg=new String(buff,0,len);
int start=msg.indexOf("GET")+4;
if(msg.indexOf("POST")!=-1){
start=msg.indexOf("POST")+5;
}
int end=msg.indexOf("HTTP/1.1")-1;
//获取对应的uri路径
uri=msg.substring(start, end);
if(msg.startsWith("POST")){
int paramString=msg.lastIndexOf("\n");
pString=msg.substring(paramString+1);
String [] parms=pString.split("&");
for(String parm:parms){
String[] temp= parm.split("=");
paramMap.put(temp[0], temp[1]);
}
}
System.out.println("-----"+uri+"-----"); }else{
System.out.println("bad request");
}
}
public String getUri() {
return uri;
}
public void setUri(String uri) {
this.uri = uri;
} }

3、创建一个response类,用来模拟response对象,其中主要是通过读取对应的静态资源,然后

 package com.dongnao.mytomcat; import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.io.OutputStream; /**
*��Ӧ�ķ�װ�ࣺд��Ϣ��ͻ���
* @author CYA
*
*/
public class Response {
private OutputStream os=null;
public Response(OutputStream os) {
this.os=os;
}
public void writeContent(String content) throws IOException{
content="HTTP/1.0 200 OK\nContent-type:text/html; charset=utf-8\n\n"+content;
os.write(content.getBytes());
os.flush();
os.close();
}
/**
* ��̬��Ӧ�������
* @param path
* @throws IOException
*/
public void writeHtmlFile(String path) throws IOException{
String htmlContentString=FileUtils.getFileContent(path);
writeContent(htmlContentString);
}
public void writeFile(String path){
//读取文件
try {
FileInputStream fis=new FileInputStream(path);
byte[] buff=new byte[512];
int len=0;
while((len=fis.read(buff))!=-1){
os.write(buff, 0, len);
}
fis.close();
os.flush();
os.close();
} catch (FileNotFoundException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
} }
}

4、创建一个loginservlet用来模拟dispacherservlet,封装request和response对象

 package com.dongnao.mytomcat; public class LoginServlet {
public void service(Request request,Response response) throws Exception{
String username=request.getParamName("username");
String password=request.getParamName("pwd");
if(username!=null&&username.equals("admin")&&password!=null&&password.equals("123")){
response.writeHtmlFile("welcome.html");
}else{
response.writeHtmlFile("error.html");
}
}
}

5其中封装了一个工具类,用来封装读取文件的内容。

 package com.dongnao.mytomcat; import java.io.BufferedReader;
import java.io.FileNotFoundException;
import java.io.FileReader;
import java.io.IOException; /**
*读取文件的工具类
* @author CYA
*
*/
public class FileUtils {
/**
* 工具类
*/
public static String getFileContent(String path){
StringBuffer sb=new StringBuffer();
FileReader fr=null;
BufferedReader br=null;
try {
fr=new FileReader(path);
br=new BufferedReader(fr);
String line=null;
while((line=br.readLine())!=null){
sb.append(line);
}
} catch (Exception e) {
e.printStackTrace();
} finally{
try {
br.close();
fr.close();
} catch (IOException e) {
e.printStackTrace();
}
}
return sb.toString();
}
}
相关推荐
python开发_常用的python模块及安装方法
adodb:我们领导推荐的数据库连接组件bsddb3:BerkeleyDB的连接组件Cheetah-1.0:我比较喜欢这个版本的cheeta…
日期:2022-11-24 点赞:878 阅读:9,487
Educational Codeforces Round 11 C. Hard Process 二分
C. Hard Process题目连接:http://www.codeforces.com/contest/660/problem/CDes…
日期:2022-11-24 点赞:807 阅读:5,903
下载Ubuntn 17.04 内核源代码
zengkefu@server1:/usr/src$ uname -aLinux server1 4.10.0-19-generic #21…
日期:2022-11-24 点赞:569 阅读:6,736
可用Active Desktop Calendar V7.86 注册码序列号
可用Active Desktop Calendar V7.86 注册码序列号Name: www.greendown.cn Code: &nb…
日期:2022-11-24 点赞:733 阅读:6,487
Android调用系统相机、自定义相机、处理大图片
Android调用系统相机和自定义相机实例本博文主要是介绍了android上使用相机进行拍照并显示的两种方式,并且由于涉及到要把拍到的照片显…
日期:2022-11-24 点赞:512 阅读:8,127
Struts的使用
一、Struts2的获取  Struts的官方网站为:http://struts.apache.org/  下载完Struts2的jar包,…
日期:2022-11-24 点赞:671 阅读:5,289