用Netty手写Http/Https服务器

Netty是一个以事件驱动的异步通信网络框架，可以帮助我们实现多种协议的客户端和服务端通信，话不多说，上代码，需要引入下方依赖

        <dependency><groupId>io.netty</groupId><artifactId>netty-all</artifactId><version>4.1.42.Final</version></dependency><dependency><groupId>org.msgpack</groupId><artifactId>msgpack</artifactId><version>0.6.12</version></dependency><dependency><groupId>org.slf4j</groupId><artifactId>slf4j-api</artifactId><version>1.7.30</version></dependency><dependency><groupId>ch.qos.logback</groupId><artifactId>logback-core</artifactId><version>1.2.4</version></dependency><dependency><groupId>com.itextpdf</groupId><artifactId>itextpdf</artifactId><version>5.5.8</version></dependency><dependency><groupId>org.bouncycastle</groupId><artifactId>bcprov-jdk15on</artifactId><version>1.49</version><type>jar</type><scope>compile</scope><optional>true</optional></dependency><dependency><groupId>org.bouncycastle</groupId><artifactId>bcpkix-jdk15on</artifactId><version>1.49</version><type>jar</type><scope>compile</scope><optional>true</optional></dependency>

1.Server

package http;import constant.Constant;
import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelFutureListener;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.nio.NioServerSocketChannel;
import io.netty.handler.ssl.SslContext;
import io.netty.handler.ssl.SslContextBuilder;
import io.netty.handler.ssl.util.SelfSignedCertificate;import java.security.cert.CertificateException;public class HttpServer {// 通过nio方式来接收连接和处理连接private static EventLoopGroup group = new NioEventLoopGroup();// 服务端引导类private static ServerBootstrap b = new ServerBootstrap();// 是否开启SSL模式public static final boolean SSL = false;// Netty创建全部都是实现自AbstractBootstrap,客户端的是Bootstrap,服务端的则是ServerBootstrappublic static void main(String[] args) throws Exception {final SslContext sslContext;if (SSL) {SelfSignedCertificate ssc = new SelfSignedCertificate();sslContext = SslContextBuilder.forServer(ssc.certificate(),ssc.privateKey()).build();} else {sslContext = null;}try {b.group(group).channel(NioServerSocketChannel.class)// 设置过滤器.childHandler(new ServerHandlerInit(sslContext));// 异步进行绑定ChannelFuture f = b.bind(Constant.DEFAULT_PORT);// 给ChannelFuture 增加监听器f.addListener(new ChannelFutureListener() {@Overridepublic void operationComplete(ChannelFuture future) throws Exception {System.out.println("绑定端口已成功....");}});System.out.println("服务端启动成功，端口是:" + Constant.DEFAULT_PORT);System.out.println("服务器启动模式: " + (SSL ? "SSL安全模式" : "普通模式"));// 监听服务器关闭监听ChannelFuture closeFuture = f.channel().closeFuture().sync();closeFuture.addListener(new ChannelFutureListener() {@Overridepublic void operationComplete(ChannelFuture future) throws Exception {System.out.println("服务器已经关闭....");}});} finally {// 关闭EventLoopGroup,释放掉所有资源，包括创建的线程group.shutdownGracefully();}}
}
package http;import io.netty.channel.ChannelInitializer;
import io.netty.channel.ChannelPipeline;
import io.netty.channel.socket.SocketChannel;
import io.netty.handler.codec.http.HttpContentCompressor;
import io.netty.handler.codec.http.HttpObjectAggregator;
import io.netty.handler.codec.http.HttpRequestDecoder;
import io.netty.handler.codec.http.HttpResponseEncoder;
import io.netty.handler.ssl.SslContext;public class ServerHandlerInit extends ChannelInitializer<SocketChannel> {private final SslContext sslContext;public ServerHandlerInit(SslContext sslContext) {this.sslContext = sslContext;}@Overrideprotected void initChannel(SocketChannel ch) throws Exception {ChannelPipeline pipeline = ch.pipeline();if (sslContext != null) {pipeline.addLast(sslContext.newHandler(ch.alloc()));}// pipeline中的handler可以自定义名称方便排查问题// 把应答报文 编码pipeline.addLast("encoder", new HttpResponseEncoder());// 把请求报文 解码pipeline.addLast("decoder", new HttpRequestDecoder());// 聚合http为一个完整的报文pipeline.addLast("aggregator",new HttpObjectAggregator(10*1024*1024));// 把应答报文压缩pipeline.addLast("compressor", new HttpContentCompressor());pipeline.addLast(new BusinessHandler());}
}

2.业务处理类

package http;import io.netty.buffer.Unpooled;
import io.netty.channel.ChannelFutureListener;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;
import io.netty.handler.codec.http.*;
import io.netty.util.CharsetUtil;public class BusinessHandler extends ChannelInboundHandlerAdapter {@Overridepublic void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {String result = "";FullHttpRequest httpRequest = (FullHttpRequest)msg;System.out.println(httpRequest.headers());try {// 获取路径String path = httpRequest.uri();// 获取bodyString body = httpRequest.content().toString(CharsetUtil.UTF_8);// 获取请求方法HttpMethod method = httpRequest.method();System.out.println("接收到 " + method + "请求");// 如果不是这个路径，就直接返回错误if (!"/test".equalsIgnoreCase(path)) {result = "非法请求!" + path;send(ctx,result, HttpResponseStatus.BAD_REQUEST);return;}// 如果是GET请求if (HttpMethod.GET.equals(method)) {// 接收到的消息，做业务处理...System.out.println("body :" + body);result = "GET请求,应答:" + RespConstant.getNews();send(ctx, result, HttpResponseStatus.OK);return ;}// 如果是其他类型请求，如postif (HttpMethod.POST.equals(method)) {// 接收到的消息，做业务逻辑处理// ....// return;}} catch (Exception e) {System.out.println("处理请求失败!");e.printStackTrace();} finally {// 释放请求httpRequest.release();}}private void send(ChannelHandlerContext ctx, String context,HttpResponseStatus status) {FullHttpResponse response = new DefaultFullHttpResponse(HttpVersion.HTTP_1_1,status, Unpooled.copiedBuffer(context, CharsetUtil.UTF_8));response.headers().set(HttpHeaderNames.CONTENT_TYPE, "text/plain;charset=UTF-8");ctx.writeAndFlush(response).addListener(ChannelFutureListener.CLOSE);}// 建立连接时，返回消息@Overridepublic void channelActive(ChannelHandlerContext ctx) throws Exception {System.out.println("连接的客户端地址 :" + ctx.channel().remoteAddress());
//        super.channelActive(ctx);}
}

3.Client

package http;import constant.Constant;
import io.netty.bootstrap.Bootstrap;
import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelFutureListener;
import io.netty.channel.ChannelInitializer;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.SocketChannel;
import io.netty.channel.socket.nio.NioSocketChannel;
import io.netty.handler.codec.http.HttpClientCodec;
import io.netty.handler.codec.http.HttpContentDecompressor;
import io.netty.handler.codec.http.HttpObjectAggregator;public class HttpClient {public static final String HOST  = "127.0.0.1";public static void main(String[] args) throws InterruptedException {if (HttpServer.SSL) {System.out.println("服务器处于SSL模式，客户端不支持，推出");return ;}HttpClient client = new HttpClient();client.connect(Constant.DEFAULT_SERVER_IP, Constant.DEFAULT_PORT);}public void connect(String host, int port) throws InterruptedException {EventLoopGroup workerGroup = new NioEventLoopGroup();try {Bootstrap b = new Bootstrap();b.group(workerGroup).channel(NioSocketChannel.class).handler(new ChannelInitializer<SocketChannel>() {@Overrideprotected void initChannel(SocketChannel ch) throws Exception {ch.pipeline().addLast(new HttpClientCodec());// 聚合Http为一个完整的报文ch.pipeline().addLast("aggregator",new HttpObjectAggregator(10 * 1024 * 1024));// 解压缩ch.pipeline().addLast("decompressor", new HttpContentDecompressor());ch.pipeline().addLast(new HttpClientInboundHandler());}});// start ChannelFuture f = b.connect(host, port).sync();f.addListener(new ChannelFutureListener() {@Overridepublic void operationComplete(ChannelFuture future) throws Exception {System.out.println("连接成功....");}});ChannelFuture closeFuture = f.channel().closeFuture().sync();closeFuture.addListener(new ChannelFutureListener() {@Overridepublic void operationComplete(ChannelFuture future) throws Exception {System.out.println("关闭成功...");}});} finally {workerGroup.shutdownGracefully();}}}
package http;import constant.Constant;
import io.netty.buffer.ByteBuf;
import io.netty.buffer.Unpooled;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;
import io.netty.handler.codec.http.*;
import io.netty.util.CharsetUtil;import java.net.URI;public class HttpClientInboundHandler extends ChannelInboundHandlerAdapter {@Overridepublic void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {FullHttpResponse httpResponse = (FullHttpResponse) msg;System.out.println(httpResponse.status());System.out.println(httpResponse.headers());ByteBuf buf = httpResponse.content();System.out.println(buf.toString(CharsetUtil.UTF_8));httpResponse.release();}@Overridepublic void channelActive(ChannelHandlerContext ctx) throws Exception {System.out.println("channelActive.......");URI uri = new URI("/test");String msg = "Hello";DefaultFullHttpRequest request =new DefaultFullHttpRequest(HttpVersion.HTTP_1_1,HttpMethod.GET,uri.toASCIIString(),Unpooled.wrappedBuffer(msg.getBytes("UTF-8")));// 构建http请求request.headers().set(HttpHeaderNames.HOST, Constant.DEFAULT_SERVER_IP);request.headers().set(HttpHeaderNames.CONNECTION, HttpHeaderValues.KEEP_ALIVE);request.headers().set(HttpHeaderNames.CONTENT_LENGTH, request.content().readableBytes());// 发送http请求ctx.writeAndFlush(request);//        super.channelActive(ctx);}@Overridepublic void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {cause.printStackTrace();ctx.close();
//        super.exceptionCaught(ctx, cause);}
}
package http;import java.util.Random;public class RespConstant {private static final String[] NEWS = {"她那时候还太年轻，不知道所有命运赠送的礼物，早已在暗中标好了价格。——斯蒂芬·茨威格《断头皇后》","这是一个最好的时代，也是一个最坏的时代；这是一个智慧的年代，这是一个愚蠢的年代；\n" +"这是一个信任的时期，这是一个怀疑的时期；这是一个光明的季节，这是一个黑暗的季节；\n" +"这是希望之春，这是失望之冬；人们面前应有尽有，人们面前一无所有；\n" +"人们正踏上天堂之路，人们正走向地狱之门。 —— 狄更斯《双城记》",};private static final Random R = new Random();public static String getNews() {return NEWS[R.nextInt(NEWS.length)];}
}
package constant;import java.util.Date;/*** 常量*/
public class Constant {public static final Integer DEFAULT_PORT = 7777;public static final String DEFAULT_SERVER_IP= "127.0.0.1";// 根据输入信息拼接出一个应答信息public static String response(String msg) {return "Hello, " + msg + ", Now is" + new Date(System.currentTimeMillis()).toString(); }
}

4.总结分析

如果你想实现http请求，需要把HttpServer中的SSL置为false，结果如下
在这里插入图片描述
在这里插入图片描述
如果你想实现Https的请求，则将SSL的变量置为true,目前的代码中是没有支持客户端的SSL请求的，我们可以在postman或者chrome浏览器中查看
https://localhost:7777/test
在这里插入图片描述
由于我们的证书是自己设置的，所以chrome浏览器认为这个证书不是有效的，需要我们手动点击
在这里插入图片描述

IDEA中会出现红色证书错误，暂时可以不用管，你还可以在postman的GET请求中添加body
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述
到此http的简易服务器就搭建好了，如果你的程序出现了以下错误，请检查开头的pom配置是否下载成功，这是由于证书有问题才报的错
在这里插入图片描述

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

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

相关文章

BUU LFI COURSE 1

BUU LFI COURSE 1

靶场教程 1.开局界面&#xff0c;已给出源代码。2.存在文件包含include &#xff0c;直接通过传参 file 进行获取 flag。3.通过访问 url 发现报错&#xff0c;说明 flag 并不在当前目录下&#xff0c;只需要向前访问目录即可。 http://b6ed0fd6-c852-40d0-b285-32d9d00fbf00.…
阅读更多...
抖去推短视频矩阵系统+实景无人直播系统技术源头开发

抖去推短视频矩阵系统+实景无人直播系统技术源头开发

抖去推爆款视频生成器&#xff0c;通过短视频矩阵、无人直播&#xff0c;文案引流等&#xff0c;打造实体商家员工矩阵、用户矩阵、直播矩阵&#xff0c;辅助商家品牌曝光&#xff0c;团购转化等多功能赋能商家拓客引流。 短视频矩阵通俗来讲就是批量剪辑视频和批量发布视频&a…
阅读更多...
查询小世界账号网页HTML源码

查询小世界账号网页HTML源码

HTML源码&#xff0c;记事本打开后可以修改里面的内容&#xff0c;电脑本地双击html可以查看效果&#xff0c;复制小世界个人主页链接就可以查询QQ号&#xff0c; 蓝奏云&#xff1a;https://wfr.lanzout.com/ihXCn1lz2jnc
阅读更多...
MySQL数据库面试知识点

MySQL数据库面试知识点

1、数据库基础&#xff1a; MySQL是一个开源的关系型数据库管理系统&#xff0c;用于存储、管理和检索数据。它支持多种存储引擎&#xff0c;包括InnoDB、MyISAM等。MySQL是由瑞典公司MySQL AB开发&#xff0c;后来被Sun Microsystems收购&#xff0c;最终被甲骨文公司(Oracle…
阅读更多...
4G物联网LED智慧路灯杆显示屏产品介绍

4G物联网LED智慧路灯杆显示屏产品介绍

4GLED显示屏是一种具有4G网络连接功能的LED显示屏。它可以通过4G网络连接到互联网&#xff0c;实现远程管理和控制&#xff0c;方便进行内容更新和管理。同时&#xff0c;4GLED显示屏具有高亮度、高清晰度和高对比度的特点&#xff0c;可以提供清晰明亮的图像和视频展示效果。它…
阅读更多...
stm32产品架构

stm32产品架构

文章目录 前言一、pandas是什么&#xff1f;二、使用步骤 1.引入库2.读入数据 总结 前言 起因是我在看野火的ucosiii&#xff0c;然后他是基于i.mx芯片。然后我就很疑惑i.mx是什么芯片&#xff0c;看了下好像是ARM-M7(或者叫ARMCM7)架构的芯片。然后我又疑惑ARM-M7又是什么架…
阅读更多...
omron adept控制器维修SmartController EX

omron adept控制器维修SmartController EX

欧姆龙机器人adept运动控制器维修SmartController EX 19300-000 维修范围&#xff1a;姆龙机器人&#xff1b;码垛机器人&#xff1b;搬运机器人&#xff1b;焊机机器人&#xff1b;变位机等。 Adept Viper s650/s850用于装配、物料搬运、包装和机械装卸&#xff0c;循环周期短…
阅读更多...
二进制？十进制！（C语言刷题）（位运算）

二进制？十进制！（C语言刷题）（位运算）

专栏:https://blog.csdn.net/2301_79293429/category_12545690.html 题目描述 给定两个十进制整数 : A,B 你需要把它们的二进制形式以十进制的运算法则相加输出结果。 例如&#xff1a; A3,B2的时候&#xff0c;A 的二进制表示是 : 11 , B 的二进制表示是 10 &#xff0c;…
阅读更多...
物流实时数仓——概述与准备工作

物流实时数仓——概述与准备工作

目录 一、架构设计与技术栈 (一)数仓架构设计 (二)所用技术栈 (三)最终效果 二、关于离线与实时的相关概念 三、实时数仓设计思路 一、架构设计与技术栈 (一)数仓架构设计 (二)所用技术栈 Hadoop 3.3.4 Zookeeper 3.7.1 Kafka 3.3.1 Hbase 2.4.11 Redis 6.0.8 Flink 1.17…
阅读更多...
mysqldump添加从库或者重新同步从库

mysqldump添加从库或者重新同步从库

一、GTID添加从库的方法 1.如果master所有的binlog还在&#xff0c;安装slave后&#xff0c;直接change master 到master 原理是直接获取master所有的gtid并执行 优点是简单 缺点是如果binlog太多&#xff0c;数据完全同步需要的时间较长&#xff0c;并且需要master一开始就启…
阅读更多...
Leetcode2806. 取整购买后的账户余额

Leetcode2806. 取整购买后的账户余额

Every day a Leetcode 题目来源&#xff1a;2806. 取整购买后的账户余额 解法1&#xff1a;数学 题目要求为将 purchaseAmount 四舍五入到最近的 10 的倍数作为 roundedAmount&#xff0c;计算 100−roundedAmount 的值并返回。 分类讨论即可。 代码&#xff1a; /** lc…
阅读更多...
机器学习实验3——支持向量机分类鸢尾花

机器学习实验3——支持向量机分类鸢尾花

文章目录 &#x1f9e1;&#x1f9e1;实验内容&#x1f9e1;&#x1f9e1;&#x1f9e1;&#x1f9e1;数据预处理&#x1f9e1;&#x1f9e1;代码认识数据相关性分析径向可视化各个特征之间的关系图 &#x1f9e1;&#x1f9e1;支持向量机SVM求解&#x1f9e1;&#x1f9e1;直觉…
阅读更多...
CentOS：nohup后台运行jar文件包程序

CentOS：nohup后台运行jar文件包程序

1、java -jar XXX.jar 特点&#xff1a;当前ssh窗口被锁定&#xff0c;可按CTRL C打断程序运行&#xff0c;或直接关闭窗口&#xff0c;程序退出 那如何让窗口不锁定&#xff1f; 2、java -jar XXX.jar & &代表在后台运行。 特定&#xff1a;当前ssh窗口不被锁定&…
阅读更多...
Parade Series - Android Studio

Parade Series - Android Studio

硬件支持 CPU i7 RAM 16Gb -------------- ------- Java 3Gb Android 33GbJava Enviroment C:\ ├─ Java │ ├─ jdk1.8.0_181 │ ├─ jre1.8.0_181 │ ├─ maven-3.8.5 │ └─ gradle-6.5 └─ Cache├─ gr…
阅读更多...
世微AP2915宽电压无MOS管切换双色灯性价比方案

世微AP2915宽电压无MOS管切换双色灯性价比方案

1&#xff1a;产品描述 AP2915 是一款可以一路灯串切换两路灯串的降压恒流驱动器,高效率、外围简单、内置功率管&#xff0c;适用于 5-100V 输入的高精度降压 LED 恒流驱动芯片。内置功率管输出功率可达 12W&#xff0c;电流 1.2A。AP2915 一路灯亮切换两路灯亮&#xff0c;其…
阅读更多...
【第十五课】数据结构：堆 (“堆”的介绍+主要操作 / acwing-838堆排序 / c++代码 )

【第十五课】数据结构：堆 (“堆”的介绍+主要操作 / acwing-838堆排序 / c++代码 )

目录 关于堆的一些知识的回顾 数据结构&#xff1a;堆的特点 "down" 和 "up"&#xff1a;维护堆的性质 down up 数据结构&#xff1a;堆的主要操作 acwing-838堆排序 代码如下 时间复杂度分析 确实是在写的过程中频繁回顾了很多关于树的知识&…
阅读更多...
使用ElEment组件实现vue表单校验空值

使用ElEment组件实现vue表单校验空值

1.绑定表单组件数组rules 2.在data域中设定组件rules 3.设定调用方法函数 提交校验 取消&#xff1a; 测试页面 提交空值 失去焦点 取消重置 提交后重置
阅读更多...
Studio One 6 mac 6.5.2 激活版 数字音乐编曲创作

Studio One 6 mac 6.5.2 激活版 数字音乐编曲创作

PreSonus Studio One是PreSonus出品的一款功能强大的音乐创作软件。主要为用户提供音乐创作、录音、编辑、制作等功能。它可以让你创造音乐&#xff0c;无限的轨道&#xff0c;无限的MIDI和乐器轨道&#xff0c;虚拟乐器和效果通道&#xff0c;这些都是强大和完美的。 软件下载…
阅读更多...
机器学习西瓜书之对数几率回归

机器学习西瓜书之对数几率回归

算法原理 在线性模型的基础上增加一个激活函数用于映射。 知识预备 信息论 用概率论和随机过程为基本研究工具&#xff0c;研究广义通信系统的整个过程。常见的有无损压缩、有数据压缩等。 自信息&#xff1a; I ( X ) − log ⁡ b p ( x ) I(X)-\log_bp(x) I(X)−logb​p…
阅读更多...
【Maven】-- 打包添加时间戳的两种方法

【Maven】-- 打包添加时间戳的两种方法

一、需求 在执行 mvn clean package -Dmaven.test.skiptrue 后&#xff0c;生成的 jar 包带有自定义系统时间。 二、实现 方法一&#xff1a;使用自带属性&#xff08;不推荐&#xff09; 使用系统时间戳&#xff0c;但有一个问题&#xff0c;就是默认使用 UTC0 的时区。举例…
阅读更多...
最新文章

Copyright @ 2022~2023