内嵌服务器Netty Http Server

内嵌式服务器不需要我们单独部署，列如SpringBoot默认内嵌服务器Tomcat,它运行在服务内部。使用Netty 编写一个 Http 服务器的程序，类似SpringMvc处理http请求那样。举例：xxl-job项目的核心包没有SpringMvc的Controller层，客户端却可以发送http请求，好奇怪！！！其实xxl-job-core 内部使用Netty做了HttpServer。

package com.xxl.job.executor.test.dto;

import lombok.Getter;
import lombok.Setter;

/**
 * User: ldj
 * Date: 2024/10/11
 * Time: 11:23
 * Description: No Description
 */
@Getter
@Setter
public class RequestDTO<T> {
    /**
     * 请求ur
     */
    private String uri;

    /**
     * 请求参数
     */
    private T param;
}


package com.xxl.job.executor.test.netty;

import com.xxl.job.executor.test.handler.NettyHttpServerHandler;
import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelInitializer;
import io.netty.channel.ChannelOption;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.SocketChannel;
import io.netty.channel.socket.nio.NioServerSocketChannel;
import io.netty.handler.codec.http.HttpObjectAggregator;
import io.netty.handler.codec.http.HttpServerCodec;
import io.netty.handler.timeout.IdleStateHandler;

import java.util.concurrent.TimeUnit;

/**
 * User: ldj
 * Date: 2024/10/11
 * Time: 10:57
 * Description: Netty Http服务
 */
public class NettyHttpServer {

    public static void main(String[] args) {
        // 服务端口
        int port = 9990;
        // 接收请求线程池
        EventLoopGroup bossGroup = new NioEventLoopGroup();
        // 处理请求线程池
        EventLoopGroup workerGroup = new NioEventLoopGroup();

        try {
            ServerBootstrap bootstrap = new ServerBootstrap();
            bootstrap.group(bossGroup, workerGroup)
                    .channel(NioServerSocketChannel.class)
                    .childOption(ChannelOption.SO_KEEPALIVE, true)
                    .childHandler(new ChannelInitializer<SocketChannel>() {
                        @Override
                        public void initChannel(SocketChannel channel) throws Exception {
                            channel.pipeline()
                                    .addLast(new IdleStateHandler(0, 0, 30 * 3, TimeUnit.SECONDS))
                                    .addLast(new HttpServerCodec())
                                    .addLast(new HttpObjectAggregator(5 * 1024 * 1024))
                                    .addLast(new NettyHttpServerHandler(new BaseService())); // 自定义handler
                        }
                    });

            // bind 绑定端口，启动服务
            ChannelFuture future = bootstrap.bind(port).sync();
            System.out.println("remote server started!");
            future.channel().closeFuture().sync();
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            try {
                // 关闭 EventLoopGroup
                workerGroup.shutdownGracefully();
                bossGroup.shutdownGracefully();
            } catch (Exception e) {
                System.out.println(e.getMessage() + e);
            }
        }
    }
}

package com.xxl.job.executor.test.netty;

/**
 * User: ldj
 * Date: 2024/10/11
 * Time: 12:55
 * Description: No Description
 */
public class BaseService {

    public String test(String param) {
        return "netty http test--> " + param;
    }
}

package com.xxl.job.executor.test.handler;

import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.xxl.job.executor.test.dto.RequestDTO;
import com.xxl.job.executor.test.netty.BaseService;
import io.netty.buffer.ByteBuf;
import io.netty.buffer.Unpooled;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.SimpleChannelInboundHandler;
import io.netty.handler.codec.http.*;
import io.netty.util.concurrent.DefaultThreadFactory;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.nio.charset.StandardCharsets;
import java.util.List;
import java.util.Map;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

/**
 * User: ldj
 * Date: 2024/10/11
 * Time: 11:11
 * Description: 处理请求逻辑
 */
public class NettyHttpServerHandler extends SimpleChannelInboundHandler<FullHttpRequest> {

    private static final Logger logger = LoggerFactory.getLogger(NettyHttpServerHandler.class);

    private BaseService baseService;

    public NettyHttpServerHandler(BaseService baseService) {
        this.baseService = baseService;
    }

    private static ThreadPoolExecutor executor = new ThreadPoolExecutor(
            200,
            300,
            5,
            TimeUnit.SECONDS,
            new LinkedBlockingQueue<>(2000),
            new DefaultThreadFactory("netty-http-server"),
            new ThreadPoolExecutor.AbortPolicy());

    @Override
    protected void channelRead0(ChannelHandlerContext channelHandlerContext, FullHttpRequest fullHttpRequest) throws Exception {
        RequestDTO<String> requestDTO = parseReqParam(fullHttpRequest);
        executor.execute(() -> {
            String response = getResponse(requestDTO);
            boolean keepAlive = HttpUtil.isKeepAlive(fullHttpRequest);
            writeToClient(channelHandlerContext, keepAlive, response);
        });
    }

    private void writeToClient(ChannelHandlerContext channel, boolean keepAlive, String response) {
        ByteBuf byteBuf = Unpooled.copiedBuffer(response, StandardCharsets.UTF_8);
        DefaultFullHttpResponse fullHttpResponse = new DefaultFullHttpResponse(HttpVersion.HTTP_1_1, HttpResponseStatus.OK,byteBuf);
        HttpHeaders headers = fullHttpResponse.headers();
        headers.set(HttpHeaderNames.CONTENT_TYPE,HttpHeaderValues.TEXT_HTML);
        headers.set(HttpHeaderNames.CONTENT_LENGTH,fullHttpResponse.content().readableBytes());
        if(keepAlive){
            headers.set(HttpHeaderNames.CONNECTION, HttpHeaderValues.KEEP_ALIVE);
        }

        channel.writeAndFlush(fullHttpResponse);
    }

    private String getResponse(RequestDTO<String> requestDTO) {
        String uri = requestDTO.getUri();
        String param = requestDTO.getParam();
        try {
            // 硬编码！更好的做法可参考SpringMvc的解析注解的value放进一个Map<url,Method>
            switch (uri){
                case "/test":
                    return baseService.test(param);
                default:
                    return "请求路径不存在！";
            }
        } catch (Exception e) {
            e.printStackTrace();
            return e.getMessage();
        }
    }

    private RequestDTO<String> parseReqParam(FullHttpRequest fullHttpRequest) throws JsonProcessingException {
        String uri = fullHttpRequest.uri();
        String param = null;
        logger.info("有参数uri:{}", uri);

        HttpMethod method = fullHttpRequest.method();
        if (HttpMethod.GET.equals(method)) {
            QueryStringDecoder decoder = new QueryStringDecoder(uri);
            Map<String, List<String>> parameters = decoder.parameters();
            param = new ObjectMapper().writerWithDefaultPrettyPrinter().writeValueAsString(parameters);
            logger.info("parameters -> {}", param);
            uri = decoder.rawPath();
            logger.info("不带参数uri:{}", uri);
        }

        if (HttpMethod.POST.equals(method)) {
            String contentTypeValue = fullHttpRequest.headers().getAsString(HttpHeaderNames.CONTENT_TYPE);
            if(contentTypeValue.contains(HttpHeaderValues.APPLICATION_JSON.toString())){
                param = fullHttpRequest.content().toString(StandardCharsets.UTF_8);
            }
        }

        RequestDTO<String> reqData = new RequestDTO<>();
        reqData.setUri(uri);
        reqData.setParam(param);

        return reqData;
    }
}

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

如若内容造成侵权/违法违规/事实不符，请联系我们进行投诉反馈qq邮箱809451989@qq.com，一经查实，立即删除！

相关文章

李德仁院士携实验室及大势文旅团队参加“湖北旅游、武当突破”名家谈，分享数智文旅发展新经验

李德仁院士携实验室及大势文旅团队参加“湖北旅游、武当突破”名家谈，分享数智文旅发展新经验

10月12日上午&#xff0c;2024世界武当太极大会在湖北省十堰市武当山盛大开幕。 2023年国家科学技术最高奖获得者、中国科学院、中国工程院院士、武汉大学李德仁教授携测绘遥感信息工程国家重点实验室&#xff08;后简称“实验室”&#xff09;团队以及大势智慧文旅团队&#…
阅读更多...
gcc学习

gcc学习

理论 在使用 GCC (GNU Compiler Collection) 进行 C 或 C 程序的编译时&#xff0c;可以将整个过程分为四个主要阶段&#xff1a;预处理、编译、汇编和链接。下面是每个阶段的命令示例&#xff1a; 1. 预处理-E 预处理阶段会处理所有的预处理指令&#xff08;如 #include 和…
阅读更多...
Qt消息对话框

Qt消息对话框

问题对话框 对应API [static] QMessageBox::StandardButton QMessageBox::question( QWidget *parent, const QString &title, const QString &text, QMessageBox::StandardButtons buttons StandardButtons(Yes | No), QMessageBox::StandardButton defaultButt…
阅读更多...
「Java服务」快速接入SkyWalking方法指南

「Java服务」快速接入SkyWalking方法指南

一、背景 背景&#xff1a;Apache SkyWalking 是一个开源的分布式应用性能监控&#xff08;APM&#xff09;系统&#xff0c;主要用于监控微服务、云原生和容器化应用的性能。接入SkyWalking可以排查以智能投放服务为主的服务响应问题 技术架构 SkyWalking 的核心架构包括以…
阅读更多...
【开源物联网平台】Fastbee数据库持久层架构

【开源物联网平台】Fastbee数据库持久层架构

目录 一&#xff0c;数据库持久层架构 二&#xff0c;数据库组件 2.1 Druid 2.2 MyBatis-Plus 2.3 dynamic-datasource 2.4 ShardingSphere 一&#xff0c;数据库持久层架构 二&#xff0c;数据库组件 2.1 Druid Druid是Java语言中最好的数据库连接池。Druid能够提供强…
阅读更多...
Chrome与Firefox浏览器HTTP自动跳转HTTPS的解决方案

Chrome与Firefox浏览器HTTP自动跳转HTTPS的解决方案

一、背景介绍 随着网络安全意识的不断提高&#xff0c;越来越多的网站开始采用HTTPS协议&#xff0c;以确保数据传输的安全性。然而&#xff0c;有时用户在浏览网页时&#xff0c;可能会遇到HTTP请求被自动跳转至HTTPS的情况导致网站打不开&#xff0c;提示安全问题&#xff0…
阅读更多...
android——自定义控件（不停变化的textview、开关switch、动画效果的打勾）

android——自定义控件（不停变化的textview、开关switch、动画效果的打勾）

一、从开始数字到结束数字&#xff0c;不断变化 import android.animation.TypeEvaluator; import android.animation.ValueAnimator; import android.content.Context; import android.util.AttributeSet; import android.view.animation.AccelerateDecelerateInterpolator;i…
阅读更多...
深度学习实战94-基于图卷积神经网络GCN模型的搭建以及在金融领域的场景

深度学习实战94-基于图卷积神经网络GCN模型的搭建以及在金融领域的场景

大家好，我是微学AI，今天给大家介绍一下深度学习实战94-基于图卷积神经网络GCN模型的搭建以及在金融领域的场景。文章首先介绍了GCN模型的原理及模型结构，随后提供了数据样例，并详细展示了实战代码。通过本文，读者可以深入了解GCN模型在金融场景下的应用，同时掌握代码的具…
阅读更多...
使用标注工具并跑通官方yolov8分割segment自己的数据集

使用标注工具并跑通官方yolov8分割segment自己的数据集

1.下载标注工具用于打标签 使用标注工具&#xff0c;后面会用到智能标注 点击 创建AI多边形后命令行就自动下载对应的模型 单机要选中的图像就行&#xff0c;就可以智能选中&#xff0c;双击设置标签 依次标注所有图片 &#xff0c;最后保存成json格式的文件 2.使用labelme2y…
阅读更多...
关于mac下的nvm设置淘宝镜像源

关于mac下的nvm设置淘宝镜像源

1. 进入配置文件修改镜像源 vim ~/.bash_profile增加下面内容 export NVM_NODEJS_ORG_MIRRORhttps://npmmirror.com/mirrors/node/2. 查看远程node镜像 nvm ls-remote3. 下载镜像 nvm install 14.17.64. 使用镜像 nvm use 14.17.6
阅读更多...
总台戏曲探访类创新节目《风味梨园》开播 探寻一座城市的戏曲文化地图

总台戏曲探访类创新节目《风味梨园》开播 探寻一座城市的戏曲文化地图

戏曲艺术犹如一颗璀璨的明珠&#xff0c;承载着中华民族千年的历史文化底蕴&#xff0c;以其独有的艺术魅力&#xff0c;如悠扬的旋律、精湛的表演&#xff0c;深深吸引着无数观众。而每一座城市隐匿其后的美食文化&#xff0c;恰似一首动人的诗篇&#xff0c;代表着人们对美好…
阅读更多...
2013年国赛高教杯数学建模A题车道被占用对城市道路通行能力的影响解题全过程文档及程序

2013年国赛高教杯数学建模A题车道被占用对城市道路通行能力的影响解题全过程文档及程序

2013年国赛高教杯数学建模 A题 车道被占用对城市道路通行能力的影响 车道被占用是指因交通事故、路边停车、占道施工等因素&#xff0c;导致车道或道路横断面通行能力在单位时间内降低的现象。由于城市道路具有交通流密度大、连续性强等特点&#xff0c;一条车道被占用&#x…
阅读更多...
数学建模算法与应用 第11章 偏最小二乘回归及其方法

数学建模算法与应用 第11章 偏最小二乘回归及其方法

目录 11.1 偏最小二乘回归概述 11.2 Matlab 偏最小二乘回归命令 Matlab代码示例&#xff1a;偏最小二乘回归 11.3 案例分析&#xff1a;化学反应中的偏最小二乘回归 Matlab代码示例&#xff1a;光谱数据的PLS回归 习题 11 总结 偏最小二乘回归&#xff08;Partial Least …
阅读更多...
MySQL 【日期】函数大全（三）

MySQL 【日期】函数大全（三）

DATEOFYEAREXTRACTFROM_DAYSFROM_UNIXTIMEHOURLAST_DAYLOCALTIMELOCALTIMESTAMP 1、DATEOFYEAR DATEOFYEAR(expr) &#xff1a;返回一个从 1 到 366 代表给定日期是一年中的第几天的数字。 如果指定的表达式不是一个合法的日期或者日期时间&#xff0c;DAYOFYEAR() 函数将返回…
阅读更多...
无功补偿设备在室内及室外安装的区别

无功补偿设备在室内及室外安装的区别

无功补偿设备在室内和室外的安装存在多方面的区别&#xff0c;包括环境条件、设备选择、安装要求以及维护方式。下面详细介绍两者的区别及相应的注意事项。 一、环境条件的差异 1、室内安装 温度和湿度&#xff1a;相对受控&#xff0c;温度变化较小&#xff0c;湿度可调节&…
阅读更多...
k8s的部署和安装

k8s的部署和安装

k8s的部署和安装 一、Kubernets简介及部署方法 1.1 应用部署方式演变 在部署应用程序的方式上&#xff0c;主要经历了三个阶段&#xff1a; 传统部署&#xff1a;互联网早期&#xff0c;会直接将应用程序部署在物理机上 优点&#xff1a;简单&#xff0c;不需要其它技术的参…
阅读更多...
STM32传感器模块编程实践(六) 1.8寸液晶屏TFT LCD彩屏简介及驱动源码

STM32传感器模块编程实践(六) 1.8寸液晶屏TFT LCD彩屏简介及驱动源码

文章目录 一.概要二.TFT彩屏主要参数三.TFT彩屏参考原理图四.TFT彩屏模块接线说明五.模块SPI通讯协议介绍六.TFT彩屏模块显示1.显示英文字符串2.显示数字3.显示中文 七.TFT彩屏实现图片显示八.STM32单片机1.8寸 TFT LCD显示实验1.硬件准备2.软件工程3.软件主要代码4.实验效果 九…
阅读更多...
Redis set类型 zset类型

Redis set类型 zset类型

set类型 类型介绍 集合类型也是保存多个字符串类型的元素的&#xff0c;但和列表类型不同的是&#xff0c;集合中 1&#xff09;元素之间是⽆序 的 2&#xff09;元素不允许重复 ⼀个集合中最多可以存储 个元素。Redis 除了⽀持 集合内的增删查改操作&#xff0c;同时还⽀持多…
阅读更多...
【Vue】扫盲（五）Vue 的生命周期与钩子函数详解

【Vue】扫盲（五）Vue 的生命周期与钩子函数详解

【Vue】Vue扫盲&#xff08;一&#xff09;事件标签、事件修饰符&#xff1a;click.prevent click.stop click.stop.prevent、按键修饰符、及常用指令 【Vue】Vue扫盲&#xff08;二&#xff09;指令&#xff1a;v-for 、v-if、v-else-if、v-else、v-show 【Vue】Vue扫盲&…
阅读更多...
多种方式确定Linux是CentOS还是Ubuntu

多种方式确定Linux是CentOS还是Ubuntu

目录 前言正文 前言 对应的基本知识比较少&#xff0c;以下只是记录总结 由于目前使用的是centos&#xff0c;后续找到linux会对应补充 正文 要确定Linux系统是CentOS还是Ubuntu&#xff0c;可以通过以下几种方式进行分析 一、查看发行版信息文件&#xff1a; CentOS&…
阅读更多...
最新文章

Copyright @ 2022~2023