封裝請求協議:獲取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() {
}
}Response：
public class Response {
private BufferedWriter bw;
//正文
private StringBuilder content;
//協議頭（狀態行與請求頭 回車）信息
private StringBuilder headInfo;
private int len; //正文的字節數
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));
}
//流模式動態添加內容
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;
}
//推送響應信息
public void pushToBrowser(int code) throws IOException {
if(null ==headInfo) {
code = 505;
}
createHeadInfo(code);
bw.append(headInfo);
bw.append(content);
bw.flush();
}
//構建頭信息
private void createHeadInfo(int code) {
//1、響應行: 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、響應頭(最后一行存在空行):
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);
}
}免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
