【Tomcat与网络11】如何自己实现一个简单的HTTP服务器

在前面我们尝试解释Tomcat的理论，但是呢，很多时候那些复杂的架构和设计会让我们眼花缭乱，以至于忽略了最进本的问题——服务器到底是什么？今天我们就用尽量简单的代码实现一个简易的HTTP服务器。

HTTP启动之后要持续监听，所以我们可以使用NioServer中的Handler就可以了，在修改后的HttpHandler中首先获取到请求报文并打印出报文的头部，包括协议的首行、请求方法的类型、Url和Http版本等，之后将接收到的请求消息(也就是报文信息)封装在一起，最后将这些信息打包成一个报文发送给客户端。

我们这里为了简单，将HttpHandler使用单线程来处理，并且选择SelectionKey的操作类型等都放在Handler中了。

主体代码：

    public static void main(String[] args) throws Exception{//创建ServerSocketChannel，监听8040端口ServerSocketChannel ssc=ServerSocketChannel.open();ssc.socket().bind(new InetSocketAddress(8040));//设置为非阻塞模式ssc.configureBlocking(false);//为ssc注册选择器Selector selector=Selector.open();ssc.register(selector, SelectionKey.OP_ACCEPT);//创建处理器while(true){// 等待请求，每次等待阻塞5s，超过5s后线程继续向下运行// 这里如果传入0或者不传参数将一直阻塞if(selector.select(5000)==0){continue;}// 获取待处理的SelectionKeyIterator<SelectionKey> keyIter=selector.selectedKeys().iterator();while(keyIter.hasNext()){SelectionKey key=keyIter.next();// 启动新线程处理SelectionKeynew Thread(new HttpHandler(key)).run();// 处理完后，从待处理的SelectionKey迭代器中移除当前所使用的keykeyIter.remove();}}}

我们在上面将端口设置为8040了，因为8080有时候会和其他软件冲突，有时候会被浏览器隐藏，所以我们使用一个更可控的。

之后，我们就来写真正需要干活的Hander：

  private static class HttpHandler implements Runnable{private int bufferSize = 2048;private String  localCharset = "UTF-8";private SelectionKey key;public HttpHandler(SelectionKey key){this.key = key;}@Overridepublic void run() {try{// 接收到连接请求时if(key.isAcceptable()){handleAccept();}// 读数据if(key.isReadable()){handleRead();}} catch(IOException ex) {ex.printStackTrace();}}
}

我们使用一个线程来处理清楚，所以我们需要继续实现run()方法,根据选择器的状态来完成接收数据还是读取数据。

先看接收数据：

        public void handleAccept() throws IOException {SocketChannel clientChannel=((ServerSocketChannel)key.channel()).accept();clientChannel.configureBlocking(false);clientChannel.register(key.selector(), SelectionKey.OP_READ, ByteBuffer.allocate(bufferSize));}

这段代码看似简单，其实包含的逻辑并不少，我们可以看到这里是从key获得Socket通信使用了哪个通道(对于HTTP的就是不同端口号)，这个key是哪里的呢？是我们再创建HttpHandler的时候传过来的，也就是这一行：

  new Thread(new HttpHandler(key)).run();

 这相当于老板让你干活的时候，给你的锤子。

之后的这一行，就是自己创建了一个channel注册给key。

clientChannel.register(key.selector()...)

这里相当于打仗之前，你去军长那里报道，说你能打，然后军长Key就记住你了。

之后我们看读取数据的处理逻辑：

 public void handleRead() throws IOException {// 获取channelSocketChannel sc=(SocketChannel)key.channel();// 获取buffer并重置ByteBuffer buffer=(ByteBuffer)key.attachment();buffer.clear();// 没有读到内容则关闭if(sc.read(buffer)==-1){sc.close();} else {// 接收请求数据buffer.flip();String receivedString = Charset.forName(localCharset).newDecoder().decode(buffer).toString();// 控制台打印请求报文头String[] requestMessage = receivedString.split("\r\n");for(String s: requestMessage){System.out.println(s);// 遇到空行说明报文头已经打印完if(s.isEmpty())break;}// 控制台打印首行信息String[] firstLine = requestMessage[0].split(" ");System.out.println();System.out.println("Method:\t"+firstLine[0]);System.out.println("url:\t"+firstLine[1]);System.out.println("HTTP Version:\t"+firstLine[2]);System.out.println();// 返回客户端StringBuilder sendString = new StringBuilder();sendString.append("HTTP/1.1 200 OK\r\n");//响应报文首行，200表示处理成功sendString.append("Content-Type:text/html;charset=" + localCharset+"\r\n");sendString.append("\r\n");// 报文头结束后加一个空行sendString.append("<html><head><title>显示报文</title></head><body>");sendString.append("接收到请求报文是：<br/>");for(String s: requestMessage){sendString.append(s + "<br/>");}sendString.append("</body></html>");buffer = ByteBuffer.wrap(sendString.toString().getBytes(localCharset));sc.write(buffer);sc.close();}}

这里，我们可以看到执行读的时候，我们使用key里获得channel的。这就相当于司令要求你所在的连队突袭，然后你的军长key就从自己的小本本上找到你，然后让你们行动。我们看一下执行效果：

在浏览器输入http://localhost:8040/

然后在控制台，我们看到http收到的相应如下：


最后附上完整代码：

public class HttpServer {public static void main(String[] args) throws Exception{//创建ServerSocketChannel，监听8040端口ServerSocketChannel ssc=ServerSocketChannel.open();ssc.socket().bind(new InetSocketAddress(8040));//设置为非阻塞模式ssc.configureBlocking(false);//为ssc注册选择器Selector selector=Selector.open();ssc.register(selector, SelectionKey.OP_ACCEPT);//创建处理器while(true){// 等待请求，每次等待阻塞5s，超过5s后线程继续向下运行// 这里如果传入0或者不传参数将一直阻塞if(selector.select(5000)==0){continue;}// 获取待处理的SelectionKeyIterator<SelectionKey> keyIter=selector.selectedKeys().iterator();while(keyIter.hasNext()){SelectionKey key=keyIter.next();// 启动新线程处理SelectionKeynew Thread(new HttpHandler(key)).run();// 处理完后，从待处理的SelectionKey迭代器中移除当前所使用的keykeyIter.remove();}}}private static class HttpHandler implements Runnable{private int bufferSize = 2048;private String  localCharset = "UTF-8";private SelectionKey key;public HttpHandler(SelectionKey key){this.key = key;}public void handleAccept() throws IOException {SocketChannel clientChannel=((ServerSocketChannel)key.channel()).accept();clientChannel.configureBlocking(false);clientChannel.register(key.selector(), SelectionKey.OP_READ, ByteBuffer.allocate(bufferSize));}public void handleRead() throws IOException {// 获取channelSocketChannel sc=(SocketChannel)key.channel();// 获取buffer并重置ByteBuffer buffer=(ByteBuffer)key.attachment();buffer.clear();// 没有读到内容则关闭if(sc.read(buffer)==-1){sc.close();} else {// 接收请求数据buffer.flip();String receivedString = Charset.forName(localCharset).newDecoder().decode(buffer).toString();// 控制台打印请求报文头String[] requestMessage = receivedString.split("\r\n");for(String s: requestMessage){System.out.println(s);// 遇到空行说明报文头已经打印完if(s.isEmpty())break;}// 控制台打印首行信息String[] firstLine = requestMessage[0].split(" ");System.out.println();System.out.println("Method:\t"+firstLine[0]);System.out.println("url:\t"+firstLine[1]);System.out.println("HTTP Version:\t"+firstLine[2]);System.out.println();// 返回客户端StringBuilder sendString = new StringBuilder();sendString.append("HTTP/1.1 200 OK\r\n");//响应报文首行，200表示处理成功sendString.append("Content-Type:text/html;charset=" + localCharset+"\r\n");sendString.append("\r\n");// 报文头结束后加一个空行sendString.append("<html><head><title>显示报文</title></head><body>");sendString.append("接收到请求报文是：<br/>");for(String s: requestMessage){sendString.append(s + "<br/>");}sendString.append("</body></html>");buffer = ByteBuffer.wrap(sendString.toString().getBytes(localCharset));sc.write(buffer);sc.close();}}@Overridepublic void run() {try{// 接收到连接请求时if(key.isAcceptable()){handleAccept();}// 读数据if(key.isReadable()){handleRead();}} catch(IOException ex) {ex.printStackTrace();}}}
}

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/663075.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

校园网网络规划与设计——计算机网络实践报告

校园网网络规划与设计——计算机网络实践报告

W...Y的主页 &#x1f60a; 代码仓库分享&#x1f495; 目录 一、设计目的 二、软硬件环境 三、理论基础 四、设计方案 五、网络配置步骤 六、设计过程中出现的问题及相应解决办法 八、参考资料 一、设计目的 深入理解网络工程的三层层次设计模型&#xff1b; 掌握网络…
阅读更多...
Python实现GCJ02坐标系向WGS84坐标系的转换

Python实现GCJ02坐标系向WGS84坐标系的转换

GCJ02坐标系 GCJ-02&#xff08;官方称地形图非线性保密处理算法&#xff0c;俗称火星坐标系、国测局坐标&#xff09;是一种基于WGS-84制定的大地测量系统&#xff0c;由中国大陆国家测绘地理信息局制定。此坐标系所采用的混淆算法会在经纬度中加入看似随机的偏移。 使用GCJ…
阅读更多...
ubuntu nginx配置密码访问并下载

ubuntu nginx配置密码访问并下载

nginx配置密码访问_htpasswd: cannot create file-CSDN博客 sudo apt-get install nginx sudo apt install apache2-utils # htpasswd -c /htpasswd/passwd.db test htpasswd -c /etc/nginx/htpasswd.d/nginx_passwd.kibana test # htpasswd -c ccreate 创建文件 # /htp…
阅读更多...
2024年美赛数学建模A题思路分析 - 资源可用性和性别比例

2024年美赛数学建模A题思路分析 - 资源可用性和性别比例

# 1 赛题 问题A&#xff1a;资源可用性和性别比例 虽然一些动物物种存在于通常的雄性或雌性性别之外&#xff0c;但大多数物种实质上是雄性或雌性。虽然许多物种在出生时的性别比例为1&#xff1a;1&#xff0c;但其他物种的性别比例并不均匀。这被称为适应性性别比例的变化。…
阅读更多...
【Java】阻塞队列

【Java】阻塞队列

目录 BlockingQueue BlockingQueue接口 三个主要实现类介绍&#xff1a; ArrayBlockingQueue&#xff1a;有界队列 LinkedBlockingQueue&#xff1a;无界队列 SynchronousQueue:同步队列 队列对比 BlockingQueue 对于Queue而言&#xff0c;BlockingQueue是主要的线程安全…
阅读更多...
有深浅入数据分析 - 启发法（凭人类的天性做分析）

有深浅入数据分析 - 启发法（凭人类的天性做分析）

在做数据分析的时候&#xff0c;往往最优的方法是艰难耗时间的 凭经验处理&#xff0c;迅速做出决策&#xff0c;确识能够奏效&#xff0c;进行数据分析的重要而必要的技能 领导的要求是&#xff1a; 邋遢集的处理方式是&#xff1a; 计量的方式处理 上图的调查问卷可以…
阅读更多...
pytorch模型里 safetensors 文件、bin文件和pth文件区别、加载和保存方式

pytorch模型里 safetensors 文件、bin文件和pth文件区别、加载和保存方式

目录 PyTorch模型中的safetensors文件和bin文件区别 safetensors文件 bin文件 结论 区别bin文件和pth文件 1. 文件格式 2. 通用性 3. 期望内容 4. 兼容性和移植性 结论 加载和保存safetensors文件 保存safetensors文件 加载safetensors文件 加载和保存bin文件 保…
阅读更多...
JVM 内存配置参数积累

JVM 内存配置参数积累

0、简介 在进行JVM内存配置时&#xff0c;应当考虑到应用程序的实际需求和运行环境的资源限制&#xff0c;合理分配Xmx、Xms和Xmn参数&#xff0c;以获得最佳的性能表现。通常建议将Xms和Xmx设置为相同的值&#xff0c;以避免JVM在运行过程中动态调整堆大小带来的性能损耗。而…
阅读更多...
Axure 动态面板初使用-实现简单的tab切换页面效果

Axure 动态面板初使用-实现简单的tab切换页面效果

使用工具版本 Axure 9 实现的效果 步骤过程 1、打开Axure 9&#xff0c;默认进入一个空白页&#xff0c;首先从元件库拉一个动态面板到页面中&#xff0c;位置肯定是C位咯~ 2、将面板尺寸调整一下&#xff0c;设置成你喜欢的数字&#xff0c;比如我就喜欢800600 3、然后…
阅读更多...
学习日志以及个人总结（13） 指针！

学习日志以及个人总结（13） 指针！

指针 定义 访问内存地址 操控硬件 指针&#xff1a; 指针基本数据据类 指针数组 指针函数 指针指针 1.指针&#xff1a;就是地址-----就是内存的单元的编号 2.指针变量 语法&#xff1a; 基类型* 指针变量名&#xff1b; 基类型-------数据类型//基础数据类型 //数组…
阅读更多...
python脚本将照片按时间线整理

python脚本将照片按时间线整理

说明&#xff1a;有一次自己瞎折腾&#xff0c;然后把服务器相册搞崩了&#xff0c;后来做了备份同步给找了回来&#xff0c;但是相册的时间线全乱了&#xff0c;看起来非常难受。所以就想通过文件夹的形式把照片重新分类&#xff0c;分类后的结构如下(红色字体为文件夹)&#…
阅读更多...
item_get-根据ID取商品详情(shopee.item_get)：跨境电商的未来趋势

item_get-根据ID取商品详情(shopee.item_get)：跨境电商的未来趋势

根据您的需求&#xff0c;我为您撰写了一篇关于“item_get-根据ID取商品详情(shopee.item_get)&#xff1a;跨境电商的未来趋势”的文章。由于篇幅限制&#xff0c;我将提供文章的概要和部分内容&#xff0c;完整的文章将需要更多细节和展开。 item_get-根据ID取商品详情(shope…
阅读更多...
《区块链简易速速上手小册》第7章：区块链在其他行业的应用（2024 最新版）

《区块链简易速速上手小册》第7章：区块链在其他行业的应用（2024 最新版）

文章目录 7.1 供应链管理7.1.1 供应链管理中区块链的基础7.1.2 主要案例&#xff1a;食品安全追踪7.1.3 拓展案例 1&#xff1a;制药供应链7.1.4 拓展案例 2&#xff1a;汽车行业的零部件追踪 7.2 区块链在医疗保健中的应用7.2.1 医疗保健中区块链的基础7.2.2 主要案例&#xf…
阅读更多...
今天聊聊软件研发部门孵化策略

今天聊聊软件研发部门孵化策略

声明&#xff1a;上述内容纯属个人瞎说&#xff0c;如有雷同请联系删除。 引&#xff1a;公司研发二部的同事召回来了&#xff0c;这边先恭喜他们荣耀而归。大家都欢心鼓舞、人事嘘寒问暖、综合端盘倒水&#xff1b;真热闹……。我们部门的同事就在边上办公&#xff0c;感触很深…
阅读更多...
如何处理缓存一致性问题

如何处理缓存一致性问题

* 如何解决缓存一致性问题 * 1. 更新缓存 * ①先更新缓存&#xff0c;再更新数据库. 如果先更新缓存成功了&#xff0c;但是更新数据库失败了&#xff0c;那么数据库将出现脏数据&#xff0c;否掉 * ②先更新数据库&#xff0c;再更新缓存. 如果先更新数据库&#xff0c;但更…
阅读更多...
1451A/D/F捷变信号发生器

1451A/D/F捷变信号发生器

01 1451A/D/F捷变信号发生器 产品综述&#xff1a; 1451系列捷变信号发生器采用直接数字合成&#xff08;DDS&#xff09;技术和直接模拟合成技术&#xff08;ADS&#xff09;相结合的设计方案&#xff0c;实现覆盖10MHz~3/20/40GHz全频段的频率捷变&#xff0c;捷变时间小于…
阅读更多...
UMI初始化脚手架 Simple App、 Ant Design Pro、Vue Simple App、Umi Plugin 4者的区别

UMI初始化脚手架 Simple App、 Ant Design Pro、Vue Simple App、Umi Plugin 4者的区别

这四个概念分别代表不同的工具和框架&#xff0c;它们的主要区别如下&#xff1a; Simple App&#xff1a;这通常指的是一个基础的、最小化的应用程序。它可能只包含最基础的功能&#xff0c;如用户界面、一些简单的交互等。这种应用程序通常用于学习和实验目的&#xff0c;或者…
阅读更多...
分布式事务（四）——TCC补偿模式解决方案

分布式事务（四）——TCC补偿模式解决方案

系列目录&#xff1a; 《分布式事务&#xff08;一&#xff09;—— 事务的基本概念》 《分布式事务&#xff08;二&#xff09;—— CAP和Base理论》 《分布式事务&#xff08;三&#xff09;—— 两阶段提交解决方案&#xff08;2PC&#xff09;》 一、常见分布式事务解决…
阅读更多...
Android selinux调试(rk3588 android 12平台)

Android selinux调试(rk3588 android 12平台)

Android selinux调试(rk3588 android 12平台)&#xff1a; 参考文档&#xff1a; Android系统10 RK3399 init进程启动(二十七) Selinux Type和Attribute https://www.jb51.net/article/277418.htm Android selinux策略文件的编译与加载 https://c.biancheng.net/view/1151.h…
阅读更多...
WPF DataTemplate内重写BorderBrush，VisualBrush内数据源绑定提示绑定失败

WPF DataTemplate内重写BorderBrush，VisualBrush内数据源绑定提示绑定失败

定义DataTemplate 数据模板文件&#xff0c;内容如下 <DataTemplate x:Key"{DataTemplateKey {x:Type VM:TemplateListVM}}" DataType"{x:Type VM:TemplateListVM}"> <Grid Margin"0" Grid.Row"3" Height"50" Ver…
阅读更多...
最新文章

Copyright @ 2022~2023