用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服务器中，多线程可以用来处理并发请求，每个请求由单独的线程处理，提高服务器的响应速度。 #### 2. 数据分析 - 对于大规模的数据集，可以使用多线程进行并行处理，显著加快计算速度。 #### 3. 游戏开发 -...
3. 采用模拟 Proacto r的事件处理模式，利用线程池实现多线程机制，实现高并发通信，减少频繁创建和销毁线程带来的开销；（信号和互斥锁） 4. 主进程负责事件的读写，子线程负责业务逻辑——用有限状态机解析HTTP...
在Linux环境下，C语言实现一个简单的单线程Web服务器是一项挑战性的任务，它涉及到网络编程、多路复用I/O、HTTP协议...实际生产环境中，通常会采用多线程或多进程模型，或者使用异步I/O技术如epoll来提高服务器性能。
7. **多线程和异步处理**：模拟服务器可能需要处理并发请求，因此了解如何在.NET中使用线程和异步编程（如async/await）是很重要的。这将确保服务器能够有效地处理多个客户端请求而不阻塞。 8. **安全性和身份验证*...
【Linux 单线程网络服务器设计】 Linux 单线程网络服务器是一种在Linux操作系统上实现...它特别适用于高并发、低延迟的网络服务，例如Web服务器和代理服务器，其设计思想和关键技术对于系统开发者有着重要的参考价值。
在Unix系统中，多线程常用于服务器编程，如Web服务器通过创建多个线程处理并发请求。多进程则常见于大型软件，如数据库系统，每个进程负责一部分工作，通过进程通信协调。 总结，Unix的多线程和多进程编程提供了...
多线程TCP/IP服务器是一种高效的设计模式，它允许多个客户端同时连接并处理请求，从而提高了服务的并发能力。本项目“multithread-tcpip”正是这样一个实现，用C语言编写，专门用于处理HTTP协议中的GET、POST、...
本文将深入探讨多线程的概念、应用及其在实际开发中的运用，结合“2ccc.com.txt”和“Elavotor”这两个文件名，我们可以推断可能涉及的是一个具体的多线程实现示例，比如Web服务器或者电梯控制系统的模拟。...
5. **异步编程**：为了防止多线程阻塞主线程，C#引入了异步编程模型，使用`async`和`await`关键字。这使得程序可以继续执行其他任务，而无需等待IO操作（如网络请求）完成，提高了程序的响应性。 6. **线程安全**：...
在C#编程中，模拟POST提交通常用于模拟用户在网页上的表单提交行为，例如上传文件，特别是图片。这个过程涉及到HTTP协议的理解、文件流处理以及服务器端的存储逻辑。以下将详细介绍如何实现这个功能。 首先，理解...
2. **多线程**: 在这个实现中，服务器采用了多线程来处理并发请求。Python的`threading`模块提供了创建和管理线程的功能。当一个HTTP请求到达时，服务器会创建一个新的线程来处理该请求，这样可以避免单线程阻塞导致...
本项目涉及的是在Java环境下，模拟实现HTTP 1.0版本的FTP功能，并结合多线程技术来提高效率。以下是这个项目的核心知识点： 1. **HTTP 1.0**: HTTP（超文本传输协议）是互联网上应用最广泛的一种网络协议，用于从...
在模拟Tomcat的过程中，了解并实现这些步骤可以帮助我们更好地理解Web服务器的工作流程，特别是Java的多线程模型在其中的应用。同时，标签"java tomcat"提示我们需要关注的是与Java和Tomcat相关的技术，例如Servlet...
例如，一个Web服务器可能会有多个生产者线程负责接收和解析客户端请求，而消费者线程则处理这些请求并返回响应。在这种情况下，队列充当了请求缓冲区的角色，保持生产者和消费者的平衡，避免因处理速度不匹配而导致...
- 文件名可能暗示了一个性能测试，旨在确定Web服务器处理请求的最大阻塞时间。 - 这种测试通常涉及模拟大量并发用户，观察服务器在不同负载下对新消息的处理能力，以及是否能及时唤醒接收线程。 7. **优化策略**...
在了解PHP多线程并发实现方法之前，首先需要明白PHP语言本身并不是设计为支持传统意义上的多线程并发模型。PHP是一种主要用于Web开发的服务器端脚本语言，它通常以单线程的方式运行。每次有请求进入，PHP都会启动一...
"WebServer:基于模拟Proactor的C ++轻量级web服务器" 这个标题揭示了我们讨论的核心内容，即一个使用C++编程语言开发的轻量级Web服务器。它采用了Proactor模式作为其核心设计原则，这是一种异步事件处理模式，特别...
- 使用多线程处理客户端连接，避免单线程阻塞。 - 优化图像传输，使用高效的压缩算法，并考虑使用帧率控制，避免过于频繁的屏幕更新。 - 对于大流量的数据传输，可以考虑使用TCP的滑动窗口协议，自动调整发送速率...