手寫一個(gè)HTTP圖片資源服務(wù)器，太容易了叭！
閱讀本文大概需要 8 分鐘。
來自：binhao.blog.csdn.net/article/details/112059406
摘要
一、什么是http服務(wù)器
http服務(wù)器用來干什么：
二、如何自己簡單實(shí)現(xiàn)一個(gè)http服務(wù)器
什么樣的請求能進(jìn)來或者說是有效的?(第一層請求攔截) 請求的解析和響應(yīng)結(jié)果的生成?(需要精通http協(xié)議) io模型如何選擇，怎樣充分利用發(fā)揮服務(wù)器性能？（涉及多線程，復(fù)雜的io模型） 可插拔要怎么實(shí)現(xiàn)？如tomcat可以通過一個(gè)servlet讓開發(fā)人員進(jìn)行處理。 …等等，實(shí)現(xiàn)一個(gè)http服務(wù)器絕對是一件很困難的事，所有網(wǎng)絡(luò)應(yīng)用層都是基于這個(gè)向上設(shè)計(jì)的。
三、自己實(shí)現(xiàn)的http服務(wù)器
四、Http服務(wù)器實(shí)現(xiàn)（Java）
import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;
import java.nio.ByteBuffer;
import java.nio.channels.FileChannel;
import java.util.Properties;
/**
* Copyright(c)[email protected]
* @author liubinhao
* @date 2021/1/1
* ++++ ______ ______ ______
* +++/ /| / /| / /|
* +/_____/ | /_____/ | /_____/ |
* | | | | | | | | |
* | | | | | |________| | |
* | | | | | / | | |
* | | | | |/___________| | |
* | | |___________________ | |____________| | |
* | | / / | | | | | | |
* | |/ _________________/ / | | / | | /
* |_________________________|/b |_____|/ |_____|/
*/
public class HttpServer {
public static final String RESOURCE_PATH = "D:/image";
public static void main(String[] args) throws IOException {
ServerSocket server = new ServerSocket(80);
while (true){
Socket client = server.accept();
InputStream inputStream = client.getInputStream();
String s = handleNewClientMessage(inputStream);
Request request = Request.parse(s);
System.out.println(request);
//假設(shè)請求的都是文件
String uri = request.getUri();
File file = new File(RESOURCE_PATH + uri);
FileInputStream fileInputStream = new FileInputStream(file);
FileChannel channel = fileInputStream.getChannel();
ByteBuffer buffer = ByteBuffer.allocate((int) file.length());
channel.read(buffer);
buffer.rewind();
Response response = new Response();
response.setTopRow("HTTP/1.1 200 OK");
response.getHeaders().put("Content-Type",readProperties(getType(request.getUri())));
response.getHeaders().put("Content-Length",String.valueOf(file.length()));
response.getHeaders().put("Server","httpserver-lbh");
response.setBody(buffer.array());
response.setOutputStream(client.getOutputStream());
response.setClient(client);
System.out.println(response);
System.out.println(client.isClosed());
//響應(yīng)客戶端
response.service();
inputStream.close();
client.close();
}
}
private static String handleNewClientMessage(InputStream inputStream) throws IOException {
byte[] bytes = new byte[1024];
int read = inputStream.read(bytes);
StringBuilder buffer = new StringBuilder();
if (read != -1) {
for (byte b:bytes) {
buffer.append((char)b);
}
}
return buffer.toString();
}
/**
* 我個(gè)人放mimetype文件類型的文件，需要單獨(dú)修改
*/
private static final String MIME_PROPERTIES_LOCATION =
"D:\\individual\\springcloudDemo\\src\\main\\java\\contentype.properties";
public static String readProperties(String key) {
System.out.println(System.getProperty("user.dir"));
Properties prop = new Properties();
try {prop.load(new FileInputStream(MIME_PROPERTIES_LOCATION));
return prop.get(key).toString();
} catch (IOException e) {
e.printStackTrace();
}
return null;
}
public static String getType(String uri) {
System.out.println("uri:" + uri);
String stringDot = ".";
String dot = "\\.";
String[] fileName;
if (uri.contains(stringDot)) {
fileName = uri.split(dot);
return fileName[fileName.length - 1];
}
return null;
}
}
import java.util.Arrays;
import java.util.HashMap;
import java.util.Map;
/**
* Copyright(c)[email protected]
* @author liubinhao
* @date 2021/1/1
* ++++ ______ ______ ______
* +++/ /| / /| / /|
* +/_____/ | /_____/ | /_____/ |
* | | | | | | | | |
* | | | | | |________| | |
* | | | | | / | | |
* | | | | |/___________| | |
* | | |___________________ | |____________| | |
* | | / / | | | | | | |
* | |/ _________________/ / | | / | | /
* |_________________________|/b |_____|/ |_____|/
*/
public class Request {
private String method;
private String uri;
private String version;
private byte[] body;
private Map<String, String> headers;
public String getMethod() {
return method;
}
public String getUri() {
return uri;
}
public String getVersion() {
return version;
}
public byte[] getBody() {
return body;
}
public Map<String, String> getHeaders() {
return headers;
}
public void setMethod(String method) {
this.method = method;
}
public void setUri(String uri) {
this.uri = uri;
}
public void setVersion(String version) {
this.version = version;
}
public void setHeaders(Map<String, String> headers) {
this.headers = headers;
}
public void setBody(byte[] body) {
this.body = body;
}
@Override
public String toString() {
return "Request{" +
"method='" + method + '\'' +
", uri='" + uri + '\'' +
", version='" + version + '\'' +
", body=" + Arrays.toString(body) +
", headers=" + headers +
'}';
}
private static final String CONTENT_SEPARATE_SIGN = "\r\n\r\n";
private static final String LINE_SEPARATE_SIGN = "\r\n";
private static final String SPACE_SEPARATE_SIGN = "\\s+";
private static final String KV_SEPARATE_SIGN = ":";
//**********************************解析請求*************************************
private static void parseTopReq(Request req, String[] topReq){
req.setMethod (topReq[0]);
req.setUri (topReq[1]);
req.setVersion(topReq[2]);
}
private static void parseHeaders(Request req, String[] headerStr){
HashMap<String, String> headers = new HashMap<>(12);
for (String s : headerStr) {
String[] keyValue = s.split(KV_SEPARATE_SIGN);
headers.put(keyValue[0], keyValue[1]);
}
req.setHeaders(headers);
}
public static Request parse(String reqStr) {
Request req = new Request();
String[] httpInfo = reqStr.split(CONTENT_SEPARATE_SIGN);
if (httpInfo.length==0){
return null;
}
if (httpInfo.length > 1){
req.setBody(httpInfo[1].getBytes());
}
String[] content = httpInfo[0].split(LINE_SEPARATE_SIGN);
// http first row of a http request
String[] firstRow = content[0].split(SPACE_SEPARATE_SIGN);
// http / get demo_path.type
parseTopReq(req, firstRow);
parseHeaders(req, Arrays.copyOfRange(content,1,content.length));
return req;
}
}
import java.io.IOException;
import java.io.OutputStream;
import java.net.Socket;
import java.util.HashMap;
import java.util.Map;
/**
* Copyright..@lbhbinhao@163.com
* Author:liubinhao
* Date:2020/12/28
* ++++ ______ ______ ______
* +++/ /| / /| / /|
* +/_____/ | /_____/ | /_____/ |
* | | | | | | | | |
* | | | | | |________| | |
* | | | | | / | | |
* | | | | |/___________| | |
* | | |___________________ | |____________| | |
* | | / / | | | | | | |
* | |/ _________________/ / | | / | | /
* |_________________________|/b |_____|/ |_____|/
*/
public class Response{
private String topRow;
private Map<String, String> headers = new HashMap<>(12);
private byte[] body;
private int responseCode;
private OutputStream outputStream;
public String getTopRow() {
return topRow;
}
public void setTopRow(String topRow) {
this.topRow = topRow;
}
public Map<String, String> getHeaders() {
return headers;
}
public void setHeaders(Map<String, String> headers) {
this.headers = headers;
}
public byte[] getBody() {
return body;
}
public void setBody(byte[] body) {
this.body = body;
}
public OutputStream getOutputStream() {
return outputStream;
}
public void setOutputStream(OutputStream outputStream) {
this.outputStream = outputStream;
}
public int getResponseCode() {
return responseCode;
}
public void setResponseCode(int responseCode) {
this.responseCode = responseCode;
}
public static final byte[] LINE_SEPARATE_SIGN_BYTES = "\r\n".getBytes();
public static final byte[] KV_SEPARATE_SIGN_BYTES = ":".getBytes();
private Socket client;
public Socket getClient() {
return client;
}
public void setClient(Socket client) {
this.client = client;
}
// 如果頭數(shù)據(jù)里不包含Content-Length: x 類型為Transfer-Encoding:
// chunked 說明響應(yīng)數(shù)據(jù)的長度不固定，結(jié)束符已"\r\n0\r\n"這5個(gè)字節(jié)為結(jié)束符
public void service() throws IOException {
outputStream.write(this.getTopRow().getBytes());
outputStream.write(LINE_SEPARATE_SIGN_BYTES);
for (Map.Entry<String, String> entry : this.getHeaders().entrySet()){
outputStream.write(entry.getKey().getBytes());
outputStream.write(KV_SEPARATE_SIGN_BYTES);
outputStream.write(entry.getValue().getBytes());
outputStream.write(LINE_SEPARATE_SIGN_BYTES);
}
outputStream.write(LINE_SEPARATE_SIGN_BYTES);
outputStream.write(this.getBody());
outputStream.flush();
}
@Override
public String toString() {
return "Response{" +
"topRow='" + topRow + '\'' +
", headers=" + headers +
// ", body=" + Arrays.toString(body) +
", responseCode=" + responseCode +
", client=" + client +
'}';
}
}
#mdb=application/x-mdb
mfp=application/x-shockwave-flash
mht=message/rfc822
mhtml=message/rfc822
mi=application/x-mi
mid=audio/mid
midi=audio/mid
mil=application/x-mil
mml=text/xml
mnd=audio/x-musicnet-download
mns=audio/x-musicnet-stream
mocha=application/x-javascript
movie=video/x-sgi-movie
mp1=audio/mp1
mp2=audio/mp2
mp2v=video/mpeg
mp3=audio/mp3
mp4=video/mp4
mpa=video/x-mpg
mpd=application/vnd
#ms-project
mpe=video/x-mpeg
mpeg=video/mpg
mpg=video/mpg
mpga=audio/rn-mpeg
mpp=application/vnd
#ms-project
mps=video/x-mpeg
mpt=application/vnd
五、總結(jié)
https://github.com/haobinliu/app-server/tree/server-x-test/server-x/src/com/lbh
評論
圖片
表情