?

用Socket和ServerSocket這兩個類模擬監聽80端口請求的WEB服務器
其實很簡單的，我搞了一晚上才搞定。。。。。。

說說為神馬吧，主要是InputStream的阻塞機制！
剛開始，我一次性讀取1024字節，成功了。然后我又想到如果請求的字節數很長的話，只讀取一次肯定不行， 于是就用循環的方法使用read方法讀取Request輸入流的數據。
然后，悲劇的事情就發生了！！！ read方法竟然阻塞了，然后找資料找了好久找不到有用的資料，
只看見有人說用java.nio包里面的新類可以實現。 我就想啊，我是學習的，面對問題怎么能逃避了？？？ ?
于是繼續研究其中的算法和InputStream提供的各種方法。（我想其中不合理的代碼就不必貼了，認真看我這篇文章的人應該都能想到的）
最先啊，是看到java.nio.channel包里面有將InputStream轉換為可讀通道的方法，我就試了試，轉換之后，發現、、、無論算法怎么處理、讀取著還是不行啊。 仍然阻塞
然后，我想到一種方法：
???? 就是定義字節數組一定長度LEN， 然后循環讀取， 如果某一次讀取到的數據(read(buf)的返回值)小于100的話，不是意味著輸入流讀取到了結尾了么？ 然后我就高高興興的實現這種想法了 ? ? 。 再然后呢。。。我就發現如果InputStream里面的字節數如果是LEN的整倍數的話，最后一次讀取也是 ==LEN的，還是會出現 read方法已經到了結尾但是循環仍然執行導致的阻塞現象

又一次失敗了
我就繼續想啊想，就想到了InputStream提供的available()方法，這個方法返回的是下一次讀取的估計字節數，當初我就看到了這個方法，但是看到文檔上說的這個方法不建議使用，就一直沒想用。。。真是到了無可奈何啊。只好又試試這個方法的效果
于是呢，我就用了這種方法：
????? 在每一次循環讀取之前判斷InputStream剩余的字節數是不是 0 、即剩余字節是不是空的，如果是空的就不讀了，這種方法果然奏效！！！ 但是經過我的反復測試啊，發現又出現了一個問題，同一個瀏覽器的同一個頁面如果刷新的話，這個頁面第一次請求時候available() 正常， 下來的請求就不正常了，available()直接就 == 0 了， 第一次頁面請求 之后 的每一次頁面刷新后臺都讀取不到請求數據。 Socket我都關閉了啊！怎么會出現這種情況？？？ 納悶了， 又找了好長時間的資料，仍然沒有解決辦法。好像是上一次處理的InputStream的available()保留下來了一樣，但是如果另開一個頁面請求就正常。。。。
? ?
然后就是我想到的終極解決辦法了， 我假設的是 用戶請求內容不可能是空值 ，于是，我就用了do{}while循環，先執行讀取一次，在判斷available()的值是不是0，這樣就保證了上一個問題的影響。 至于為什么這么做，我也是說不明白的，就是當時的一種靈感吧。。。我感覺是為了把InputStream讀取指針先放在流頭。這樣可以避免干擾。

? ? ? 額語文水平很低啊、看的同學們勉強湊合吧
? ? ? 小弟現在大二，經驗有限，高手老鳥輕噴啊
第一次發不會貼代碼、試試吧！

主服務類：

    
package server.test01;

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.InetAddress;
import java.net.ServerSocket;
import java.net.Socket;

/**
 * @author sulin
 */
public class MyService {

	private final String HOST = "127.0.0.1";	//綁定的主機127.0.0.1，不設置也可、默認即為IP或localhost
	private final int BACKLOG = 1;				//最大請求并發量
	private final int PORT = 80;				//服務器綁定端口
	
	public void startService(){
		//建立指定HOST和PORT的服務器
		ServerSocket server = null;
		try {
			server = new ServerSocket(this.PORT, this.BACKLOG, InetAddress.getByName(this.HOST));
		} catch (IOException e) {
			e.printStackTrace();
		}
		//服務開始工作
		System.out.println("服務器開始工作");
		while(true){
			try{
				//偵測一次請求
				final Socket socket = server.accept();
				final InputStream in = socket.getInputStream();
				final OutputStream out = socket.getOutputStream();
				//多線程機制響應請求
				new Thread(){
					public void run() {
						try {
							//處理響應偵探到的請求
							MyRequest request = new MyRequest(in);
							request.Parse();
							MyResponse response = new MyResponse(out);
							response.setRequest(request);
							response.SendResponse();
							//本次請求處理結束
							socket.close();
						} catch (IOException e) {
							e.printStackTrace();
						}
					}
				}.start();
			}catch(Exception e){
				e.printStackTrace();
			}
		}
		
	}
	
	/**
	 * 程序入口
	 * @param args
	 */
	public static void main(String[] args) {
		MyService service = new MyService();
		service.startService();
	}
	
}


  

請求處理類

    
package server.test01;

import java.io.IOException;
import java.io.InputStream;

public class MyRequest {
	
	private InputStream in;				//請求的輸入流
	private String uri;					//請求的uri
	private String request = "";		//請求處理后的字符串
	
	public MyRequest( InputStream in ) {
		this.in = in;
	}
	public String getUri() {
		return uri;
	}
	
	/**
	 * 提供對request請求的解析服務
	 */
	public void Parse(){
		try {
			byte[] buffer = new byte[377];
			int len;
			do{
				len = in.read(buffer);
				request += new String(buffer).substring(0, len);
			}while(in.available()>0);
		} catch (IOException e) {
			e.printStackTrace();
		}		
		this.uri = this.ParseURI();
		System.out.println(uri);
	}
	
	private String ParseURI(){
		String[] ss = this.request.trim().split(" ");
		if(ss.length > 2){
			return ss[1];
		}else{
			return "";
		}
	}
	
}

  

另外一個相應類MyResponse就不貼了。。。

WEB服務器工作機制由淺至深（1）：多線程模擬服務器并防止阻塞