java webserver-封装request请求协议

2024年3月3日 121次阅读 来源: wx5d21d5e6e5ab1

封装请求协议:获取method uri以及请求参数

public class Request {
    //协议信息
    private String requestInfo;
    //请求方式
    private String method;
    //请求的uri
    private String url;
    //请求的参数
    private String queryStr;
    public Request(InputStream is)
    {
        byte[] datas=new byte[1024*1024];
        int len = 0;
        try {
            len=is.read(datas);
            this.requestInfo =new String(datas,0,len);
            System.out.println(requestInfo);
        } catch (IOException e) {

        e.printStackTrace();
        return;
    }
    //分解字符串
    parseRequestInfo();

}
public Request(Socket client) throws IOException
{
    this(client.getInputStream()); //构造器的相互调用，只能放在首行
}

private void parseRequestInfo()
{
    System.out.println("----分解----");
    //获取请求方式
    System.out.println("1、获取请求方式：开头到第一个/之间");
    this.method=this.requestInfo.substring(0,this.requestInfo.indexOf("/")).toLowerCase();
    //获取url
    System.out.println("2、获取url:第一个/到HTTP/第一个字母之间");
    System.out.println("---可能包含请求参数？前面的为url");
    //url:获取第一个/的位置
    int startIdx1=this.requestInfo.indexOf("/")+1; //要/之后的内容
    //url:获取HTTP/的第一个字母的位置
    int endIdx2=this.requestInfo.indexOf("HTTP/"); //返回第一个字母的位置
    //url:分割字符串
    this.url=this.requestInfo.substring(startIdx1,endIdx2);
    //获取?的位置
    int queryIdx=this.url.indexOf("?"); //大于零表示存在
    if(queryIdx>0)
    {
        String[] urlArray=this.url.split("\\?");//必须转义
        this.url=urlArray[0];
        queryStr=urlArray[1];  //请求参数
    }
    System.out.println(this.url);
}
}

Server:

public class Server04 {
    private ServerSocket serverSocket ;
    public static void main(String[] args) {
        Server04 server = new Server04();
        server.start();
    }
    //启动服务
    public void start() {
        try {
            serverSocket =  new ServerSocket(8888);
             receive();
        } catch (IOException e) {
            e.printStackTrace();
            System.out.println("服务器启动失败....");
        }
    }
    //接受连接处理
    public void receive() {
        try {
            Socket client = serverSocket.accept();
            System.out.println("一个客户端建立了连接....");
            //获取请求协议

        Request request=new Request(client);

        //关注了内容
        Response response=new Response(client); //创建好了输出流
        response.print("<html>");    //通过输出流输出
        response.print("<head>");
        response.print("<title>");
        response.print("服务器响应成功");
        response.print("</title>");
        response.print("</head>");
        response.print("<body>");
        response.print("shsxt server终于回来了。。。。");
        response.print("</body>");
        response.print("</html>");
        //关注了状态码
        response.pushToBrowser(200);

    } catch (IOException e) {
        e.printStackTrace();
        System.out.println("客户端错误");
    }
}
//停止服务
public void stop() {

}

}
    原文作者：wx5d21d5e6e5ab1
    原文地址: https://blog.51cto.com/14437184/2435955
    本文转自网络文章，转载此文章仅为分享知识，如有侵权，请联系博主进行删除。
点赞