使用Kotlin编写一个Http服务器

首发于Enaium的个人博客


引言

在本文中,我们将使用 Kotlin 编写一个简单的 HTTP 服务器。我们将使用 Java 的 ServerSocket 类来实现这个服务器。我们将创建一个简单的服务器,它将监听端口 8000,并在接收到请求时返回一个简单的响应。

Http 的格式

HTTP 请求和响应都是文本格式的。HTTP 请求由请求行、请求头和请求体组成。HTTP 响应由状态行、响应头和响应体组成。

具体可以到 MDN 查看。

代码实现

首先我们需要创建一个Method枚举和一个Version枚举,用于表示请求的方法和版本。

enum class Method {GET,POST,UNKNOWN;companion object {fun parse(method: String): Method =when (method) {"GET" -> GET"POST" -> POSTelse -> UNKNOWN}}
}
enum class Version {HTTP_1_1,UNKNOWN;companion object {fun parse(version: String): Version = when (version) {"HTTP/1.1" -> HTTP_1_1else -> UNKNOWN}}override fun toString(): String {return when (this) {HTTP_1_1 -> "HTTP/1.1"UNKNOWN -> "UNKNOWN"}}
}

然后我们创建一个HttpRequest类,用于表示 HTTP 请求。

data class HttpRequest(val method: Method,val path: String,val version: Version,val headers: Map<String, String>,val body: String
)

接着我们为HttpRequest类添加一个静态方法parse,用于解析 HTTP 请求。

companion object {fun parse(reader: BufferedReader): HttpRequest {}
}

parse方法中,我们首先读取请求行,然后读取请求头,最后读取请求体。

首先我们先来定义一些默认值。

var method = Method.UNKNOWN
var path = ""
var version = Version.UNKNOWN
val headers = mutableMapOf<String, String>()
var body = ""

然后我们读取请求的所有数据,不过需要注意这里不不能使用readTextreadLines,这些方法会导致Socket被关闭。

val request = StringBuilder()
var readed: String?
while (reader.readLine().also { readed = it } != null && readed!!.isNotEmpty()) {request.append(readed).append("\n")
}

接着我们解析请求的数据。

request.lines().forEachIndexed { index, line ->if (index == 0) {val splitWithSpace = line.split(" ")method = Method.parse(splitWithSpace[0])path = splitWithSpace[1]version = Version.parse(splitWithSpace[2])} else if (line.contains(": ")) {val split = line.split(": ")headers[split[0]] = split[1]} else if (line.isEmpty()) {} else {body = line}
}

首先是第一行,我们使用空格分割,然后解析请求方法、路径和版本。然后是请求头,我们使用冒号空格分割,然后解析请求头。最后是请求体,如果不为空,我们就保存请求体。

最后我们将解析的数据返回。

return HttpRequest(method,path,version,headers,body
)

接着我们创建一个HttpResponse类,用于表示 HTTP 响应。

data class HttpResponse(val version: Version = Version.HTTP_1_1,val statusCode: Int,val statusText: String,val headers: Map<String, String> = emptyMap(),val body: String = ""
)

然后我们为HttpResponse类重写toString方法,用于将响应转换为字符串。

override fun toString(): String {return """$version $statusCode $statusText${headers.map { "${it.key}: ${it.value}" }.joinToString("\n")}$body""".trimIndent()
}

接着我们创建一个Handler类型,用于处理请求。

typealias Handler = (HttpRequest) -> HttpResponse

然后我们创建一个Route类,用于表示路由。

data class Route(val method: Method, val path: String, val handler: Handler)

接着创建一个Router类,用于管理路由。

class Router {private val routes = mutableListOf<Route>()fun get(path: String, handler: Handler) {routes.add(Route(Method.GET, path, handler))}fun handle(socket: ServerSocket) {}
}

Router类中,我们定义了一个routes属性,用于保存所有的路由。然后我们定义了一个get方法,用于添加一个 GET 请求的路由。最后我们定义了一个handle方法,用于处理请求。

接着我们需要实现handle方法。

fun handle(socket: ServerSocket) {while (true) {val client = socket.accept()val reader = client.getInputStream().bufferedReader()val writer = client.getOutputStream().bufferedWriter()val httpRequest = HttpRequest.parse(reader)routes.findLast { it.method == httpRequest.method && it.path == httpRequest.path }?.let {val toString = it.handler.invoke(httpRequest).toString()writer.write(toString)writer.flush()} ?: let {writer.write(HttpResponse(Version.HTTP_1_1,404,"NotFound",headers = mapOf("Content-Type" to "text/html"),body = "<h1>404 Not Found</h1>").toString())writer.flush()}client.close()}
}

handle方法中,我们首先创建一个ServerSocket,然后进入一个无限循环。在循环中,我们首先接受一个客户端连接,然后创建一个BufferedReader和一个BufferedWriter,用于读取请求和写入响应。然后我们解析请求,然后查找路由,如果找到了路由,我们就调用路由的处理函数,然后将响应写入到客户端。如果没有找到路由,我们就返回一个 404 响应。最后我们关闭客户端连接。

最后我们创建一个Server类,用于创建服务器。

class HttpServer(port: Int) {private val serverSocket: ServerSocket = ServerSocket(port)fun start() {}
}

start方法中,我们创建一个Router,然后添加一个路由,最后调用Routerhandle方法。

val router = Router()
router.get("/") { _ ->HttpResponse(Version.HTTP_1_1, 200, "OK")
}
router.get("/hello") { _ ->HttpResponse(Version.HTTP_1_1, 200, "OK",headers = mapOf("Content-Type" to "text/html"),body = "<h1>Hello World!</h1>")
}
router.handle(serverSocket)

这样我们就完成了一个简单的 HTTP 服务器。

现在来测试一下我们的服务器。

fun main() {HttpServer(8080).start()
}

在终端中运行main函数,然后在浏览器中打开http://localhost:8080http://localhost:8080/hello,你应该能看到一个简单的页面。

总结

在本文中,我们使用 Kotlin 编写了一个简单的 HTTP 服务器。我们使用 Java 的 ServerSocket 类来实现这个服务器。我们创建了一个简单的服务器,它监听端口 8080,并在接收到请求时返回一个简单的响应。我们还创建了一个简单的路由系统,用于处理不同的请求。

完整源码

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

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

相关文章

RedHat8.4离线升级内核(漏洞编号CVE-2024-1086)

一、背景 针对Linux内核提取权限漏洞 (漏洞编号CVE-2024-1086&#xff09;&#xff0c;整理离线环境的修复方案。本文以离线修复方案为主进行说明&#xff0c;第八章对在线修复方案进行说明。 (一) 漏洞简介 近日&#xff0c;绿盟科技CERT监测网上有研究员公开披露了一个Lin…

SpringBoot Vue Bootstrap 旅游管理系统

SpringBoot Vue 旅游管理系统源码&#xff0c;附带环境安装&#xff0c;运行说明 源码地址 开发环境 jdk1.8,mysql8,nodejs16,navicat,idea 使用技术springboot mybatis vue bootstrap 部分功能截图预览

【SQLAlChemy】常见的数据类型有哪些,Column可选的参数有哪些呢?

常见数据类型与Column参数 常见类型 Integer&#xff1a;整数类型&#xff0c;对应数据库的 int 类型。Float&#xff1a;浮点数类型&#xff0c;对应数据库的 float 类型。它占用 32 位空间。Double&#xff1a;双精度浮点数类型&#xff0c;对应数据库的 double 类型&#…

【CS.PL】Lua 编程之道: 基础语法和数据类型 - 进度16%

2 初级阶段 —— 基础语法和数据类型 文章目录 2 初级阶段 —— 基础语法和数据类型2.0 关键字(keywords) &#x1f525;2.1 注释与标识符2.1.1 注释2.1.2 标识符 2.2 变量与赋值2.2.1 所有变量默认是全局变量 ≠ local, 有一个例外2.2.2 local变量是局部变量, 以end作为边界2.…

创建节约机关怎样向媒体投稿报道宣传?

创建节约机关并向媒体投稿报道宣传是一项重要的工作&#xff0c;它不仅能够提升机关的形象&#xff0c;还能促进社会各界对节约型社会的认识和支持。 作为一名新晋信息宣传员,初入职场的我满腔热血,怀揣着用文字传递价值的理想,却在投稿的道路上屡遭波折。面对每月的宣传任务,我…

表 达式树

》》》可以借助 LINQPad工具 using System; using System.Collections.Generic; using System.Data.Entity; using System.Linq; using System.Linq.Expressions; using System.Text; using System.Threading.Tasks; using System.Transactions;namespace EFDemo {public cla…

for循环学习(1)

一、循环和遍历 1.1 循环 循环是一种重复执行一段代码的结构&#xff0c;只要满足循环的条件&#xff0c;会一直执行这个代码。 循环条件&#xff1a;在一定范围之内&#xff0c;按照指定的次数来执行循环。 循环体&#xff1a;在循环中执行的命令序列&#xff0c;只要条件…

vite工程化搭建vue项目之自动按需导入

背景 当我们在使用vue3组合式开发的时候&#xff0c;大多数情况下我们的代码可能是这样的 <script setup lang"ts"> import { ref, reactive, toRefs, onMounted, computed } from vue; defineProps({}); </script><template><div></di…

共模信号与差模信号

差模信号又称串模信号&#xff0c;指的是两根线之间的信号差值&#xff1b;而共模信号又称对地信号&#xff0c;指的是两根线分别对地的信号。 差模信号&#xff1a;大小相等&#xff0c;方向相反的信号。共模信号&#xff1a;大小相等&#xff0c;方向相同的信号。 对于两输…

python的np.array()函数

1、创建数组 2、 与矩阵相关的函数 3、与排序相关的函数 4、 一元计算函数 5、 多元计算函数 6、 与文件读写相关的函数 7、与数组形状、属性相关的函数 8、 常用计算函数 9、 数组选取:切片和索引 10、np.random相关函数 Numpy常用的20个函数 一…

京准电钟 | 对比GPS,北斗卫星授时的场景有哪些?

京准电钟 | 对比GPS&#xff0c;北斗卫星授时的场景有哪些&#xff1f; 京准电钟 | 对比GPS&#xff0c;北斗卫星授时的场景有哪些&#xff1f; 对比国外的GPS&#xff0c;我国北斗卫星授时由于其高精度和稳定性&#xff0c;在各个领域都有广泛的应用场景。 以下是一些单北斗卫…

为什么需要负样本

假如我们只有正样本&#xff0c;模型在最开始训练的时候都是错误的&#xff0c;随着模型的迭代&#xff0c;准确率逐渐从0到1&#xff0c;最终将所有的样本都判别成正样本&#xff0c;也就是都在线的上方。 但真实的场景中有正有负&#xff0c;例如我们要做一个猫狗分类器&…

MySQL8.0默认TCP端口介绍

1、本文内容 选择题TCP/IPMySQL 8.0 的默认TCP端口show variables查看总结 2、选择题 A、3306 B、33060 C、33062 D、33063 3、TCP/IP TCP/IP&#xff08;Transmission Control Protocol/Internet Protocol&#xff0c;传输控制协议/网际协议&#xff09;是指能够在多个不同…

WINUI——CommunityToolkit.Mvvm Messenger接收消息时报错:Cannot access a disposed object.

背景 WINUI开发时使用CommunityToolkit.Mvvm的Messemger让UI展示一些信息时出现错误&#xff1a; System.ObjectDisposedException:“Cannot access a disposed object. ObjectDisposed_ObjectName_Name” 详细见下述截图&#xff1a; 开发环境 WIN11 WINUI&#xff13; …

如何在3天内开发一个鸿蒙app

华为鸿蒙操作系统&#xff08;HarmonyOS&#xff09;自2.0版本正式上线以来&#xff0c;在短时间内就部署超过了2亿台设备&#xff0c;纵观全球操作系统的发展史&#xff0c;也是十分罕见的。与其他手机操作系统不同&#xff0c;HarmonyOS自诞生之日起&#xff0c;就是一款面向…

【C++取经之路】继承

目录 继承的概念及定义 单继承的格式 继承方式和访问限定符 继承后子类访问基类成员的权限 基类和派生类对象赋值转换 切片 继承中的作用域 引申&#xff1a;重载和隐藏的区别 派生类的默认成员函数 继承与友元 继承与静态成员 如何实现一个不能被继承的类 复杂的…

【Java】解决Java报错:IllegalStateException during HTTP Request

文章目录 引言一、IllegalStateException的定义与概述1. 什么是IllegalStateException&#xff1f;2. IllegalStateException在HTTP请求中的常见触发场景3. 示例代码 二、解决方案1. 确保响应只被提交一次2. 正确管理Servlet的生命周期3. 避免重复访问输入流和输出流4. 使用框架…

Spring Security 与 JWT、OAuth 2.0 整合详解:构建安全可靠的认证与授权机制

Spring Security 与 OAuth 2.0 整合详解&#xff1a;构建安全可靠的认证与授权机制 将 JWT&#xff08;JSON Web Token&#xff09;与 OAuth 2.0 整合到 Spring Security 中可以为应用程序提供强大的认证和授权功能。以下是详细的整合步骤和代码示例。 1. 引入依赖 首先&…

HTML静态网页成品作业(HTML+CSS)—— 名人霍金介绍网页(6个页面)

&#x1f389;不定期分享源码&#xff0c;关注不丢失哦 文章目录 一、作品介绍二、作品演示三、代码目录四、网站代码HTML部分代码 五、源码获取 一、作品介绍 &#x1f3f7;️本套采用HTMLCSS&#xff0c;未使用Javacsript代码&#xff0c;共有6个页面。 二、作品演示 三、代…

vscode切换Python解释器

在vscode上切换解析器解决方案&#xff1a; 1、确认自己已经安装了python环境 2、command shift p ,在这里切换即可&#xff0c;见下图&#xff1a; 3、如果状态栏也就是右下角不现实切换操作的话&#xff0c;打开设置&#xff1a;