在日常的開發中，我們用過很多開源的web服務器，例如tomcat、apache等等。現在我們自己實現一個簡單的web服務器，基本的功能就是用戶點擊要訪問的資源，服務器將資源發送到客戶端的瀏覽器。web服務基于的是HTTP協議，用戶在瀏覽器的地址欄輸入要訪問的地址，服務器如何得到該地址是個關鍵。先看下一般的HTTP請求和響應報文的一般格式：

HTTP 請求報文

HTTP 響應報文

socket類套接字是網絡連接的斷點。套接字使得應用程序可以從網絡中讀取數據，可以向網絡中寫入數據。不同計算機上的應用程序可以通過套接字發送或接受字節流。java中提供了Socket類來實現這個功能，通過getInputStream和getOutputStream可以獲取網絡中的輸入輸出流。 但是，光靠Socket類還是不能夠實現我們構建一個服務器應用程序的功能的，因為服務器必須時刻待命，因此java里面提供了ServerSocket類來處理等待來自客戶端的請求，當ServerSocket接受到了來自客戶端的請求之后，它就會創建一個實例來處理與客戶端的通信。

服務器應用程序的實現 首先，我們要構建一個封裝請求信息的類requst,一個響應請求的類response,還要有一個主程序httpServer來處理客戶端來的請求。

下面是代碼：

Request類：

package server;
import java.io.IOException;
import java.io.InputStream;
/**
* 將瀏覽器發來的請求信息轉化成字符和截取url
*/
public class Request {
//輸入流
private InputStream input;
//截取url,如http://localhost:8080/index.html ，截取部分為 /index.html
private String uri;
public Request(InputStream inputStream){
this.input = inputStream;
}
public InputStream getInput() {
return input;
}
public void setInput(InputStream input) {
this.input = input;
}
public String getUri() {
return uri;
}
public void setUri(String uri) {
this.uri = uri;
}
//從套接字中讀取字符信息
public void parse(){
StringBuffer request = new StringBuffer(2048);
int i = 0;
byte[] buffer = new byte[2048];
try {
i = input.read(buffer);
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
i = -1;
}
for(int j = 0;j
request.append((char)(buffer[j]));
}
System.out.println(request.toString());
uri = parseUri(request.toString());
}
//截取請求的url 截取index.html
private String parseUri(String requestString){
int index1 = 0;
int index2 = 0;
index1 = requestString.indexOf(' ');
if(index1!=-1){
index2 = requestString.indexOf(' ',index1+1);
if(index2>index1){
return requestString.substring(index1+1,index2);
}
}
return null;
}
}
Responselei
package server;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.io.OutputStream;
/**
* 類說明 根據相應信息返回結果
*/
public class Response {
private static final int BUFFER_SIZE = 1024;
Request request;
OutputStream output;
public Response(OutputStream output){
this.output = output;
}
public void sendStaticResource() throws IOException{
byte[] bytes = new byte[BUFFER_SIZE];
FileInputStream fis = null;
File file = new File(HttpServer.WEB_ROOT,request.getUri());
if(file.exists()){
try {
fis = new FileInputStream(file);
int ch = fis.read(bytes,0,BUFFER_SIZE);
while(ch != -1){
output.write(bytes,0,ch);
ch = fis.read(bytes,0,BUFFER_SIZE);
}
} catch (FileNotFoundException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}catch(IOException e){
e.printStackTrace();
}finally{
if(fis !=null){
fis.close();
}
}
}else{
//找不到文件
String errorMessage = "HTTP/1.1 404 File Not Found\r\n" +
"Content-Type: text/html\r\n" +
"Content-Length: 23\r\n" +
"\r\n" +
"

File Not Found

";
try {

output.write(errorMessage.getBytes());
output.flush();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
public Request getRequest() {
return request;
}
public void setRequest(Request request) {
this.request = request;
}
public OutputStream getOutput() {
return output;
}
public void setOutput(OutputStream output) {
this.output = output;
}
public static int getBUFFER_SIZE() {
return BUFFER_SIZE;
}
}

HttpServer類

package server;
import java.io.File;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.InetAddress;
import java.net.ServerSocket;
import java.net.Socket;
/**

類說明
時刻等待前端請求

*/
public class HttpServer {
/**
* @param args
*/
//WEB_ROOT是服務器的根目錄
public static final String WEB_ROOT = System.getProperty("user.dir")+File.separator+"webroot";
//關閉的命令
// private static final String SHUTDOWN_COMMAND= "/SHUTDOWN";
public static void main(String[] args) {
// TODO Auto-generated method stub
HttpServer server = new HttpServer();
server.await();
}
public void await(){
ServerSocket serverSocket = null;
int port = 8080;
try {
serverSocket = new ServerSocket(port,1,InetAddress.getByName("127.0.0.1"));
while(true)
{
try {
Socket socket = null;
InputStream input = null;
OutputStream output = null;
socket = serverSocket.accept();
input = socket.getInputStream();
output = socket.getOutputStream();

封裝request請求

Request request = new Request(input);
request.parse();

封裝response對象

Response response = new Response(output);
response.setRequest(request);
response.sendStaticResource();
socket.close();
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
continue;
}
}
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}

以上就是關于“Java實現Web服務器的代碼”介紹，大家如果想了解更多相關知識，不妨來關注一下動力節點的Java視頻教程，里面的課程內容從入門到精通，細致全面，通俗易懂，適合沒有基礎的小伙伴學習，希望對大家的學習能夠有所幫助。