哈，本人现在大三还在为了学业奋斗，这些天很累，好多实验，也快要考试了，自己还负责的web重构和app开发任务还是比较重的。小菜小菜在这些时间里面进步也是蛮多的，为什么要写web服务器呢?不仅仅是因为比较酷哈，这也是我们的课程要求撒
。当然要写就要写的比较好所以自己对这个实验也是蛮有兴趣的 。
服务器能够接受来自浏览器发来的的get的静态文件的请求，服务器可以处理来自浏览器的多次请求，因为这个服务器写出来花的时间并不长所以功能也想对来说简单些，不过小菜在日后会不断的完善期功能，当然也会参考Servlet规范写出支持Servlet的容器，不过这些都是后话了先看下面贴出代码并解释其过程：
这个是我的工程结构
1，程序入口：
package com.zdx.sever;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.InetAddress;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import com.zdx.domain.Request;
import com.zdx.domain.Response;
/**
* 这里使用到了线程池来处理客户端发的多次请求，以节约系统资源，减少线程的创建从而提高系统性能
* @author zdx
*
*/
public class MainServer {
private final int port = 8091;
// 线程池维护的最小线程数量
private static int corePoolSize = 3;
// 线程池维护的最大线程数
private static int maximumPoolSize = 10;
// 线程池维护线程所允许的空闲时间
private static int keepAliveTime=10;
// 线程池维护线程所允许的空闲时间的单位
private static TimeUnit timeUnit = TimeUnit.SECONDS;
// 线程池所使用的缓冲队列
private BlockingQueue<Runnable> blockingQueue;
// 线程池
private ExecutorService executor;
public MainServer() {
blockingQueue = new ArrayBlockingQueue<>(5);
//创建线程池对象
this.executor = new ThreadPoolExecutor(corePoolSize, maximumPoolSize,
keepAliveTime, timeUnit, blockingQueue);
}
/**
*
*处理请求
*
*/
public void dealRequest() {
try {
ServerSocket serverSocket = new ServerSocket(port);
Socket socket = null;
InetAddress inetAddress;
InputStream inputStream = null;
OutputStream outputStream = null;
while (true) {
//阻塞
socket = serverSocket.accept();
//创建Request对象
inputStream = socket.getInputStream();
inetAddress = socket.getInetAddress();
Request request=new Request(inputStream, inetAddress);
//创建Response;
outputStream = socket.getOutputStream();
Response response=new Response(outputStream);
//创建处理线程
HandlerRunnable handlerRunnable=new HandlerRunnable(request, response);
//将线程提交到线程池中进行处理
this.executor.submit(handlerRunnable);
}
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
public static void main(String[] args) {
MainServer mainServer=new MainServer();
mainServer.dealRequest();
}
}
2，下面是Request类，其中对请求做了解析和封装处理
package com.zdx.domain;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.net.InetAddress;
import java.util.HashMap;
import java.util.Map;
import com.zdx.util.RequestUtil;
public class Request {
private String requestType;
private String requestUrl;
private InputStream inputStream;
private InetAddress inetAddress;
private Map<String, Object> paramters;
public Request(InputStream inputStream, InetAddress inetAddress) {
this.inputStream = inputStream;
this.inetAddress = inetAddress;
this.paramters=new HashMap<String,Object>();
parseRequest();
}
private void parseRequest() {
BufferedReader bufferedReader = new BufferedReader(
new InputStreamReader(inputStream));
String msg;
try {
msg = bufferedReader.readLine();
while (msg == null) {
return;
}
//获得请求类型
String requestType = RequestUtil.getRequestType(msg);
if (requestType.equals("GET")) {
this.requestType = "GET";
} else {
this.requestType = "POST";
}
// 设置请求的资源
this.requestUrl = RequestUtil.getRequestFileName(msg);
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
public String getRequestType() {
return requestType;
}
public void setRequestType(String requestType) {
this.requestType = requestType;
}
public String getRequestUrl() {
return requestUrl;
}
public void setRequestUrl(String requestUrl) {
this.requestUrl = requestUrl;
}
public InputStream getInputStream() {
return inputStream;
}
public void setInputStream(InputStream inputStream) {
this.inputStream = inputStream;
}
}
3，设置Resopnse类;
package com.zdx.domain;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.util.HashMap;
import java.util.Map;
public class Response {
private OutputStream outputStream;
private BufferedWriter writer;
private Map<String, Object> paramter;
public Response(OutputStream outputStream) {
this.outputStream=outputStream;
this.writer=new BufferedWriter(new OutputStreamWriter(outputStream));
this.paramter = new HashMap<String, Object>();
}
public void output(byte[] datas) throws IOException {
outputStream.write(datas);
}
public OutputStream getOutputStream() {
return outputStream;
}
public void setOutputStream(OutputStream outputStream) {
this.outputStream = outputStream;
}
public Map<String, Object> getParamter() {
return paramter;
}
public void setParamter(Map<String, Object> paramter) {
this.paramter = paramter;
}
public Object addAttribute(String key, Object value) {
return this.paramter.put(key, value);
}
public Object setAttribute(String key, Object value) {
return this.paramter.put(key, value);
}
public Object removeAttribute(String key) {
return this.paramter.remove(key);
}
public void closeWriter() throws IOException{
this.writer.close();
}
public void closeOutPutStream() throws IOException{
this.outputStream.close();
}
}
4，具体的请求处理线程类：
package com.zdx.sever;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.net.Socket;
import com.zdx.domain.Request;
import com.zdx.domain.Response;
import com.zdx.util.Constant;
import com.zdx.util.RequestUtil;
public class HandlerRunnable implements Runnable {
private Request request;
private Response response;
public HandlerRunnable(Request request, Response response) {
this.request = request;
this.response = response;
}
@Override
public void run() {
try {
requestHandler();
} catch (IOException e) {
e.printStackTrace();
}
}
private void requestHandler() throws IOException {
String requestType = request.getRequestType();
if (requestType.equals("GET")) {
String fileName = request.getRequestUrl();
String filePath = Constant.WEB_ROOT + fileName;
System.out.println(filePath);
// GET the OutputSteam object
OutputStream outputStream = response.getOutputStream();
// 进行文件的读取
File file = new File(filePath);
if (file.exists()) {
FileInputStream fileInputStream = new FileInputStream(file);
byte[] bufferByte = new byte[1024];
int read = fileInputStream.read(bufferByte);
while (read != -1) {
outputStream.write(bufferByte, 0, read);
read = fileInputStream.read(bufferByte, 0, 1024);
}
} else {
outputStream.write("404!! can not find the file".getBytes());
}
outputStream.flush();
outputStream.close();
System.out.println("over!!");
}
}
public Request getRequest() {
return request;
}
public void setRequest(Request request) {
this.request = request;
}
}
这几行代码就可以做到了下面是程序运行后的一个效果图：
看上面有图片有文字，哈哈，并可以处理多次请求，但是resopnse的相应头和其他信息都还没有做不过以后会做的，此容器的后续开发回持续更新，请前辈们给点意见指导哈
相关推荐
Dockerized 很酷的外观跑步码头工人运行Wg Gen Web的最简单方法是使用容器映像docker run --rm -it -v /tmp/wireguard:/data -p 8080:8080 -e "WG_CONF_DIR=/data" vx3r/wg-gen-web:latestDocker撰写代码段，用于...
Web编译0.1 这是我用Go语言编写的第一个程序，该程序在docker沙盒容器中的docker“ mono”映像上编译C＃代码（作为概念证明）。 http服务器公开了一个简单的文本区域“ /”，以演示该功能 compile是发生魔术的地方。...
这是一个很酷的概念。 但是，我认为，大多数人不会使用它，因为这样做很难。 走？ 在我的机器上运行Docker容器？ 什么？ 我不能仅将其用作简单的工具或服务吗？ 是的你可以。 这就是为什么我创建了这个非常简单和...
另一个具有可自定义GridItem的交互式可配置仪表板，具有IFrame和Bookmark，具有其他很酷的功能，具有使用Vuejs和Rust制作的Docker基本容器控制器（火箭） 为什么 ... 一切都是一个Web应用程序，可以在容器中与...
ui完全使用Clojurescript构建（很酷），使用和作为基础，以及用于基本小部件和样式的 。 我们的目标是建立用户体验，以便用户可以在任何虚拟化环境（例如，公共云，私有云和基础设施以及边缘设备）上开始捕获，部署...
这是一个非常有趣的系列，我想收集页面上常见的很酷的效果。 不限于任何框架（React，角度，角度等），只要可以将效果简单地插入页面中，就可以将其发送给我，我喜欢它们，希望您也喜欢它们。 背景装饰 粒子背景的...
方法：先计算出字体所在容器的高度N，然后清空容器内容，并添加N个span，span内容为原容器文字，每个span的颜色根据渐变色进行计算，而且其中文字的定位要比前一个span向上偏移一个像素。CSS中可以看到，每个span...
一个使用React和Redux构建的应用程序，以非常体面的方式提供了github用户的所有重要数据，还有很多很酷的功能尚未添加。它对于愿意雇用任何开发人员的人可能真的有用，它提供了github的可读性很好的数据用户和更多...
java企业门户开源 打开服务目录管理器 ...什么很酷？ 容器中的 OSCM，易于安装和更新，在 Kubernetes 集群中运行如何？ Apache TomEE 上的 OSCM，会话占用空间小，启动和故障转移时间短？ 用于使用 Ku
您的任务是实现一个非常酷的容器跟踪Web应用程序，该应用程序依赖于Web服务中的实时GPS数据（坐标）。 该服务需要接受一个容器跟踪号（又称容器ID），并能够可视化相应容器的位置（最好在地图上）。 Web应用程序的...
一个用 Java 实现的很酷的微框架网络，允许在短短一分钟内创建一个 REST 服务器。 由于 Pongee 是嵌入式服务器，因此您无需配置外部内容服务器或应用程序容器。 出于这个原因，您只需要编写代码，而不必担心服务器...
:pouting_face: ”未来的功能也许我们可以在评论中添加表情符号“表情符号很酷” 工作流程很酷技术领域在这里，listen使用了许多开源项目才能正常工作： -一个真棒前端libary :spouting_whale: -为了使我们的应用...
Laravel PHP 框架 Laravel 是一个具有表现力、优雅语法的 Web 应用程序框架。 我们相信发展必须是一种令人愉快的、创造性的体验，才能真正实现。 Laravel 试图通过简化大多数 Web 项目中使用的常见任务（例如身份...
喀布尔遥测 Kerbal Space Program的遥测插件。 该程序使用在KSP端运行的服务器和客户端，该客户端能够通过Web浏览器运行KSP端计算机或任何其他... 到达轨道时（从界面执行时）很酷的动画。 多语言支持（英语，俄语
更新：2018年6月移至 。带有JBoss Cool Store Persistence演示的App Dev Cloud 该演示将在任何... 酷存储区旁边是一个PostgreSQL数据库容器，该容器为JBoss BRMS平台提供持久存储，并通过Kubernetes服务进行连接。
java开发工程师面试中被经常问到知识点大全，pdf文档，本文分为十九个模块，分别是∶ JavaSE基础、容器、多线程、反射、对象拷贝 Java Web相关的（servlet,JSP）、异常、网络、常见的23种设计模式 java的spring相关...
最早的App开发只有原生这个概念，Html页面只是用来做一些简单的静态资源展示，但是随着H5的兴盛，大家发现很多功能、逻辑都可用web来实现，然后原生作为容器显示，而且H5展示的页面更炫酷、功能更丰富，在IOS、...
它使用一些很酷的技术： 泽西岛-Rest API Guice-依赖注入 Gradle-建筑 码头-Servlet容器 Jackson-JSON序列化和反序列化 Webjars-服务于Web端库 要使用Jetty启动服务器，只需从项目根目录中的终端运行此./gradlew ...
-v0.2beta2版本中关于PersistChildren(true)的描述有误，这个是设计时属性，和运行时是否保持状态没有关系。 -修正CheckBox控件的CheckedChanged事件会被触发两次的BUG（Data PostBack->AutoPostBack, Event ...
该Web应用程序是使用JBoss BRMS生成的项目作为依赖项构建的WAR，提供了一个示例项目，显示了开发人员如何专注于应用程序代码，而业务分析师可以专注于基于JBoss BRMS产品Web的规则，事件和规则流。仪表盘。 该演示...