java實(shí)現(xiàn)一個簡單的Web服務(wù)器實(shí)例解析
Web服務(wù)器也稱為超文本傳輸協(xié)議服務(wù)器，使用http與其客戶端進(jìn)行通信，基于java的web服務(wù)器會使用兩個重要的類，
java.net.Socket類和java.net.ServerSocket類，并基于發(fā)送http消息進(jìn)行通信。
這個簡單的Web服務(wù)器會有以下三個類：
*HttpServer
*Request
*Response
應(yīng)用程序的入口在HttpServer類中，main()方法創(chuàng)建一個HttpServer實(shí)例，然后調(diào)用其await()方法，顧名思義，await()方法會在指定端口上等待HTTP請求，對其進(jìn)行處理，然后發(fā)送響應(yīng)信息回客戶端，在接收到關(guān)閉命令前，它會保持等待狀態(tài)。
該應(yīng)用程序僅發(fā)送位于指定目錄的靜態(tài)資源的請求，如html文件和圖像，它也可以將傳入到的http請求字節(jié)流顯示到控制臺，但是，它并不發(fā)送任何頭信息到瀏覽器，如日期或者cookies等。
下面為這幾個類的源碼
Request：
package cn.com.server;
import java.io.InputStream;
public class Request {
private InputStream input;
private String uri;
public Request(InputStream input){
this.input=input;
}
public void parse(){
//Read a set of characters from the socket
StringBuffer request=new StringBuffer(2048);
int i;
byte[] buffer=new byte[2048];
try {
i=input.read(buffer);
}
catch (Exception e) {
e.printStackTrace();
i=-1;
}
for (int j=0;j<i;j++){
request.append((char)buffer[j]);
}
System.out.print(request.toString());
uri=parseUri(request.toString());
}
public String parseUri(String requestString){
int index1,index2;
index1=requestString.indexOf(" ");
if(index1!=-1){
index2=requestString.indexOf(" ",index1+1);
if(index2>index1){
return requestString.substring(index1+1,index2);
}
}
return null;
}
public String getUri(){
return this.uri;
}
}
Request類表示一個HTTP請求，可以傳遞InputStream對象來創(chuàng)建Request對象，可以調(diào)用InputStream對象中的read()方法來讀取HTTP請求的原始數(shù)據(jù)。
上述源碼中的parse()方法用于解析Http請求的原始數(shù)據(jù)，parse()方法會調(diào)用私有方法parseUrI()來解析HTTP請求的URI,除此之外，并沒有做太多的工作，parseUri()方法將URI存儲在變量uri中，調(diào)用公共方法getUri()會返回請求的uri。
Response:
package cn.com.server;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.OutputStream;
/**
* HTTP Response = Status-Line
* *(( general-header | response-header | entity-header ) CRLF)
* CRLF
* [message-body]
* Status-Line=Http-Version SP Status-Code SP Reason-Phrase CRLF
*
*/
public class Response {
private static final int BUFFER_SIZE=1024;
Request request;
OutputStream output;
public Response(OutputStream output){
this.output=output;
}
public void setRequest(Request request){
this.request=request;
}
public void sendStaticResource()throws IOException{
byte[] bytes=new byte[BUFFER_SIZE];
FileInputStream fis=null;
try {
File file=new File(HttpServer.WEB_ROOT,request.getUri());
if(file.exists()){
fis=new FileInputStream(file);
int ch=fis.read(bytes,0,BUFFER_SIZE);
while(ch!=-1){
output.write(bytes, 0, BUFFER_SIZE);
ch=fis.read(bytes, 0, BUFFER_SIZE);
}
} else{
//file not found
String errorMessage="HTTP/1.1 404 File Not Found\r\n"+
"Content-Type:text/html\r\n"+
"Content-Length:23\r\n"+
"\r\n"+
"<h1>File Not Found</h1>";
output.write(errorMessage.getBytes());
}
}
catch (Exception e) {
System.out.println(e.toString());
}
finally{
if(fis!=null){
fis.close();
}
}
}
}
Response對象在HttpServer類的await()方法中通過傳入套接字中獲取的OutputStream來創(chuàng)建。
Response類有兩個公共方法：setRequest()和sendStaticResource() ，setRequest()方法會接收一個Request對象為參數(shù)，sendStaticResource()方法用于發(fā)送一個靜態(tài)資源到瀏覽器，如Html文件。
HttpServer：
package cn.com.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 {
/**
* WEB_ROOT is the directory where our html and other files reside.
* For this package,WEB_ROOT is the "webroot" directory under the
* working directory.
* the working directory is the location in the file system
* from where the java command was invoke.
*/
public static final String WEB_ROOT=System.getProperty("user.dir")+File.separator+"webroot";
private static final String SHUTDOWN_COMMAND="/SHUTDOWN";
private Boolean shutdown=false;
public static void main(String[] args) {
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"));
}
catch (Exception e) {
e.printStackTrace();
System.exit(0);
}
while(!shutdown){
Socket socket=null;
InputStream input=null;
OutputStream output=null;
try {
socket=serverSocket.accept();
input=socket.getInputStream();
output=socket.getOutputStream();
//create Request object and parse
Request request=new Request(input);
request.parse();
//create Response object
Response response=new Response(output);
response.setRequest(request);
response.sendStaticResource();
}
catch (Exception e) {
e.printStackTrace();
continue;
}
}
}
}
這個類表示一個Web服務(wù)器，這個Web服務(wù)器可以處理對指定目錄的靜態(tài)資源的請求，該目錄包括由公有靜態(tài)變量final WEB_ROOT指明的目錄及其所有子目錄。
現(xiàn)在在webroot中創(chuàng)建一個html頁面，命名為index.html,源碼如下：
<!DOCTYPE html> <html> <head> <meta charset="UTF-8"> <title>Insert title here</title> </head> <body> <h1>Hello World!</h1> </body> </html>
現(xiàn)在啟動該WEB服務(wù)器，并請求index.html靜態(tài)頁面。
所對應(yīng)的控制臺的輸出：
如此，一個簡單的http服務(wù)器便完成了。
總結(jié)
以上就是本文關(guān)于java實(shí)現(xiàn)一個簡單的Web服務(wù)器實(shí)例解析的全部內(nèi)容，希望對大家有所幫助。感興趣的朋友可以繼續(xù)參閱本站其他相關(guān)專題，如有不足之處，歡迎留言指出。感謝朋友們對本站的支持！
相關(guān)文章
Spring boot2X Consul如何通過RestTemplate實(shí)現(xiàn)服務(wù)調(diào)用
這篇文章主要介紹了spring boot2X Consul如何通過RestTemplate實(shí)現(xiàn)服務(wù)調(diào)用,文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友可以參考下2019-12-12
這篇文章主要介紹了Java中的StringBuilder性能測試,本文包含測試代碼和測試結(jié)果,最后得出結(jié)論,需要的朋友可以參考下2014-09-09
這篇文章主要介紹了Java中的并發(fā)工具類詳細(xì)解析,CountDownLatch、 CyclicBarrier 和 Semaphore 工具類提供了一種并發(fā)流程控制的手段,Exchanger 工具類則提供了在線程間交換數(shù)據(jù)的一種手段,需要的朋友可以參考下2023-12-12
springboot+jersey+tomcat實(shí)現(xiàn)跨域方式上傳文件到服務(wù)器的方式
這篇文章主要介紹了springboot+jersey+tomcat實(shí)現(xiàn)跨域方式上傳文件到服務(wù)器,本文結(jié)合實(shí)例代碼給大家介紹的非常詳細(xì)，對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值，需要的朋友可以參考下2023-03-03
SpringBoot與Spring中數(shù)據(jù)緩存Cache超詳細(xì)講解
我們知道內(nèi)存讀取速度遠(yuǎn)大于硬盤讀取速度，當(dāng)需要重復(fù)獲取相同數(shù)據(jù)時，一次一次的請求數(shù)據(jù)庫或者遠(yuǎn)程服務(wù)，導(dǎo)致在數(shù)據(jù)庫查詢或者遠(yuǎn)程方法調(diào)用上小號大量的時間，最終導(dǎo)致程序性能降低，這就是數(shù)據(jù)緩存要解決的問題，學(xué)過計(jì)算機(jī)組成原理或者操作系統(tǒng)的同學(xué)們應(yīng)該比較熟悉2022-10-10
spring boot加入攔截器Interceptor過程解析
這篇文章主要介紹了spring boot加入攔截器Interceptor過程解析,文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友可以參考下2019-10-10
解決SpringMVC 返回Java8 時間JSON數(shù)據(jù)的格式化問題處理
本篇文章主要介紹了解決SpringMVC 返回Java8 時間JSON數(shù)據(jù)的格式化問題處理，小編覺得挺不錯的，現(xiàn)在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2017-02-02
SpringBoot整合Mybatis-Plus分頁失效的解決
本文主要介紹了SpringBoot整合Mybatis-Plus分頁失效的解決，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2023-01-01
SpringBoot實(shí)現(xiàn)文件上傳與下載功能的示例代碼
文件上傳與下載是Web應(yīng)用開發(fā)中常用的功能之一。接下來我們將討論如何在Spring?Boot的Web應(yīng)用開發(fā)中，如何實(shí)現(xiàn)文件的上傳與下載，感興趣的可以了解一下2022-06-06
這篇文章主要介紹了Spring定時任務(wù)無故停止又不報錯的解決，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2021-11-11