Server:
創(chuàng)新互聯(lián)是一家專業(yè)提供霍州企業(yè)網(wǎng)站建設(shè),專注與成都做網(wǎng)站、成都網(wǎng)站制作、H5場(chǎng)景定制、小程序制作等業(yè)務(wù)。10年已為霍州眾多企業(yè)、政府機(jī)構(gòu)等服務(wù)。創(chuàng)新互聯(lián)專業(yè)網(wǎng)絡(luò)公司優(yōu)惠進(jìn)行中。
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("
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";
private Map<String,List<String>> parameterMap;
public Request(Socket client) throws IOException {
this(client.getInputStream());
}
public Request(InputStream is) {
parameterMap=new HashMap<String,List<String>>();
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)求方式: 開(kāi)頭到第一個(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);
//轉(zhuǎn)成Map fav=1&fav=2&uname=shsxt&age=18&others=""
convertMap();
}
//處理請(qǐng)求參數(shù)為Map
private void convertMap()
{
//分割字符串
String[] keyValues=this.queryStr.split("&");
for(String queryStr:keyValues)
{
//再次分割字符串按=分
String[] kv=queryStr.split("=");
kv=Arrays.copyOf(kv, 2); //拷貝數(shù)組kv中的兩個(gè)元素到kv
//獲取key和value
String key=kv[0];
String value=kv[1]==null?null:decode(kv[1],"utf-8");
//存儲(chǔ)到Map
if(!parameterMap.containsKey(key))//如果沒(méi)有,就創(chuàng)建
{
parameterMap.put(key,new ArrayList<String>() );
}
parameterMap.get(key).add(value);
}
}
//通過(guò)name獲取對(duì)應(yīng)的多個(gè)值
public String[] getParameterValues(String key)
{
List<String> values=this.parameterMap.get(key);
if(null==values||values.size()<1)
{
return null;
}
return values.toArray(new String[0]); //將列表轉(zhuǎn)成字符數(shù)組
}
//通過(guò)name獲取對(duì)應(yīng)的一個(gè)值
public String getParameter(String key)
{
String[] values= getParameterValues(key);
return values==null?null:values[0];
}
//處理中文
private String decode(String value,String enc)
{
try {
return java.net.URLDecoder.decode(value,enc);//第二個(gè)參數(shù)為字符集
} catch (UnsupportedEncodingException e) {
e.printStackTrace();
}
return null;
}
public String getMethod() {
return method;
}
public String getUrl() {
return url;
}
public String getQueryStr() {
return queryStr;
}
}
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);
}
}
分享名稱:javawebserver-獲取參數(shù)和處理中文
當(dāng)前路徑:http://chinadenli.net/article48/gphphp.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供搜索引擎優(yōu)化、網(wǎng)站建設(shè)、定制開(kāi)發(fā)、Google、商城網(wǎng)站、定制網(wǎng)站
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請(qǐng)盡快告知,我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如需處理請(qǐng)聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時(shí)需注明來(lái)源: 創(chuàng)新互聯(lián)