java webserver-封裝請(qǐng)求協(xié)議2

Response:

public class Response {
        private BufferedWriter bw;
        //正文
        private StringBuilder content;
        //協(xié)議頭（狀態(tài)行與請(qǐng)求頭 回車）信息
        private StringBuilder headInfo;
        private int len; //正文的字節(jié)數(shù)

private final String BLANK =" ";
private final  String CRLF = "\r\n";
private Response() {
        content =new StringBuilder();
        headInfo=new StringBuilder();
        len =0;
}
public Response(Socket client) {
        this();
        try {
                bw=new BufferedWriter(new OutputStreamWriter(client.getOutputStream()));
        } catch (IOException e) {
                e.printStackTrace();
                headInfo = null;
        }
}

public Response(OutputStream os) {
        this();
        bw=new BufferedWriter(new OutputStreamWriter(os));
}
//動(dòng)態(tài)添加內(nèi)容
public  Response print(String info) {
        content.append(info);
        len+=info.getBytes().length;
        return this;
}
public  Response println(String info) {
        content.append(info).append(CRLF);
        len+=(info+CRLF).getBytes().length;
        return this;
}

//推送響應(yīng)信息
public void pushToBrowser(int code) throws IOException {
        if(null ==headInfo) {
                code = 505;
        }
        createHeadInfo(code);
        bw.append(headInfo);
        bw.append(content);
        bw.flush();
}

//構(gòu)建頭信息
private void createHeadInfo(int code) {
        //1、響應(yīng)行: HTTP/1.1 200 OK
        headInfo.append("HTTP/1.1").append(BLANK);
        headInfo.append(code).append(BLANK);
        switch(code) {
                case 200:
                        headInfo.append("OK").append(CRLF);
                        break;
                case 404:
                        headInfo.append("NOT FOUND").append(CRLF);
                        break;  
                case 505:
                        headInfo.append("SERVER ERROR").append(CRLF);
                        break;  
        }
        //2、響應(yīng)頭(最后一行存在空行):
        headInfo.append("Date:").append(new Date()).append(CRLF);
        headInfo.append("Server:").append("shsxt Server/0.0.1;charset=GBK").append(CRLF);
        headInfo.append("Content-type:text/html").append(CRLF);
        headInfo.append("Content-length:").append(len).append(CRLF);
        headInfo.append(CRLF);      
}

}

Request:

public class Request{
    //協(xié)議信息
    private String requestInfo;
    //請(qǐng)求方式
    private String method; 
    //請(qǐng)求url
    private String url; 
    //請(qǐng)求參數(shù)
    private String queryStr;
    private final  String CRLF = "\r\n";
    public Request(Socket client) throws IOException {
        this(client.getInputStream());
    }
    public Request(InputStream is) {        
        byte[] datas = new byte[1024*1024];
        int len;
        try {
            len = is.read(datas);
            this.requestInfo = new String(datas,0,len);         
        } catch (IOException e) {
            e.printStackTrace();
            return ;
        }
        //分解字符串
        parseRequestInfo();
    }

    private void parseRequestInfo() {
        System.out.println("------分解-------");
        System.out.println("---1、獲取請(qǐng)求方式: 開頭到第一個(gè)/------");
        this.method = this.requestInfo.substring(0, this.requestInfo.indexOf("/")).toLowerCase();
        this.method=this.method.trim();
        System.out.println("---2、獲取請(qǐng)求url: 第一個(gè)/ 到 HTTP/------");
        System.out.println("---可能包含請(qǐng)求參數(shù)? 前面的為url------");
        //1)、獲取/的位置
        int startIdx = this.requestInfo.indexOf("/")+1;
        //2)、獲取 HTTP/的位置
        int endIdx = this.requestInfo.indexOf("HTTP/");
        //3)、分割字符串
        this.url = this.requestInfo.substring(startIdx, endIdx);        
        //4)、獲??？的位置
        int queryIdx =this.url.indexOf("?");    
        if(queryIdx>=0) {//表示存在請(qǐng)求參數(shù),考慮在第一個(gè)位置的情況
            String[] urlArray = this.url.split("\\?");
            this.url =urlArray[0];
            queryStr =urlArray[1];
        }
        System.out.println(this.url);

        System.out.println("---3、獲取請(qǐng)求參數(shù):如果Get已經(jīng)獲取,如果是post可能在請(qǐng)求體中------");

        if(method.equals("post")) {
            String qStr =this.requestInfo.substring(this.requestInfo.lastIndexOf(CRLF)).trim();
            System.out.println(qStr+"-->"); 
            if(null==queryStr) {
                queryStr =qStr;
            }else { 
                queryStr +="&"+qStr;
            }
        }
        queryStr = null==queryStr?"":queryStr;
        System.out.println(method+"-->"+url+"-->"+queryStr);
    }

}

Server:

public class Server04 {
        private ServerSocket serverSocket ;
        public static void main(String[] args) {
                Server04 server = new Server04();
                server.start();
        }
        //啟動(dòng)服務(wù)
        public void start() {
                try {
                        serverSocket =  new ServerSocket(8888);
                         receive();
                } catch (IOException e) {
                        e.printStackTrace();
                        System.out.println("服務(wù)器啟動(dòng)失敗....");
                }
        }
        //接受連接處理
        public void receive() {
                try {
                        Socket client = serverSocket.accept();
                        System.out.println("一個(gè)客戶端建立了連接....");
                        //獲取請(qǐng)求協(xié)議

                Request request=new Request(client);

                //關(guān)注了內(nèi)容
                Response response=new Response(client); //創(chuàng)建好了輸出流
                response.print("<html>");    //通過輸出流輸出
                response.print("<head>");
                response.print("<title>");
                response.print("服務(wù)器響應(yīng)成功");
                response.print("</title>");
                response.print("</head>");
                response.print("<body>");
                response.print("shsxt server終于回來了。。。。");
                response.print("</body>");
                response.print("</html>");
                //關(guān)注了狀態(tài)碼
                response.pushToBrowser(200);

        } catch (IOException e) {
                e.printStackTrace();
                System.out.println("客戶端錯(cuò)誤");
        }
}
//停止服務(wù)
public void stop() {

}

}