Netty中使用编解码器框架

目录

什么是编解码器？

解码器

将字节解码为消息

将一种消息类型解码为另一种

TooLongFrameException

编码器

将消息编码为字节

将消息编码为消息

编解码器类

通过http协议实现SSL/TLS和Web服务

什么是编解码器？

       每个网络应用程序都必须定义如何解析在两个节点之间来回传输的原始字节，以及如何将其和目标应用程序的数据格式做相互转换。这种转换逻辑由编解码器处理，编解码器由编码器和解码器组成，它们每种都可以将字节流从一种格式转换为另一种格式。

       如果将消息看作是对于特定的应用程序具有具体含义的结构化的字节序列—它的数据。那么编码器是将消息转换为适合于传输的格式（最有可能的就是字节流）。而对应的解码器则是将网络字节流转换回应用程序的消息格式。因此，编码器操作出站数据，而解码器处理入站数据。

解码器

       将字节解码为消息——ByteToMessageDecoder。

       将一种消息类型解码为另一种——MessageToMessageDecoder。

       因为解码器是负责将入站数据从一种格式转换到另一种格式的，所以 Netty 的解码器实现了 ChannelInboundHandler。

       比如一个实际的业务场景，两端通信，通过 JSON 交换信息，而且 JSON 文本需要加密，接收端就可以：
网络加密报文 -> 经过 ByteToMessageDecoder -> String 类型的JSON明文。
String 类型的 JSON 文本-> 经过 MessageToMessageDecoder -> Java 里的对象。

将字节解码为消息

       抽象类 ByteToMessageDecoder

       将字节解码为消息（或者另一个字节序列）是一项如此常见的任务，Netty 为它提供了一个抽象的基类：ByteToMessageDecoder。由于你不可能知道远程节点是否会一次性地发送一个完整的消息，所以这个类会对入站数据进行缓冲，直到它准备好处理。

       它最重要方法：decode(ChannelHandlerContext ctx,ByteBuf in,Listout)。是必须实现的唯一抽象方法。decode()方法被调用时将会传入一个包含了传入数据的 ByteBuf，以及一个用来添加解码消息的 List。对这个方法的调用将会重复进行，直到确定没 有新的元素被添加到该 List，或者该 ByteBuf 中没有更多可读取的字节时为止。然后，如果 该 List 不为空，那么它的内容将会被传递给 ChannelPipeline 中的下一个 ChannelInboundHandler。

将一种消息类型解码为另一种

        在两个消息格式之间进行转换（例如，从 String->Integer），方decode(ChannelHandlerContext ctx,I msg,Listout) 对于每个需要被解码为另一种格式的入站消息来说，该方法都将会被调用。解码消息随 后会被传递给 ChannelPipeline 中的下一个 ChannelInboundHandler。MessageToMessageDecoder，T 代表源数据的类型。

TooLongFrameException

       由于 Netty 是一个异步框架，所以需要在字节可以解码之前在内存中缓冲它们。因此，不能让解码器缓冲大量的数据以至于耗尽可用的内存。为了解除这个常见的顾虑，Netty 提供了 TooLongFrameException 类，其将由解码器在帧超出指定的大小限制时抛出。

        为了避免这种情况，你可以设置一个最大字节数的阈值，如果超出该阈值，则会导致抛出一个TooLongFrameException（随后会被ChannelHandler.exceptionCaught()方法捕获）。然后，如何处理该异常则完全取决于该解码器的用户。某些协议（如HTTP）可能允许你返回一个特殊的响应。而在其他的情况下，唯一的选择可能就是关闭对应的连接。

编码器

       解码器的功能正好相反。Netty 提供了一组类，用于帮助你编写具有以下功能的编码器：将消息编码为字节。MessageToByteEncoder 将消息编码为消息：MessageToMessageEncoder，T代表源数据的类型。
比如两端通信，通过 JSON 交换信息，而且 JSON 文本需要加密，发送端就可以：

Java 里的对象-> 经过 MessageToMessageEncoder -> String类型的JSON文本。

String 类型的 JSON 明文 -> 经过 MessageToByteEncoder-> 网络加密报文。

       我们可以把 MessageToByteEncoder 看成网络报文编码器，MessageToMessageEncoder 看成业务编码器。

将消息编码为字节

        encode(ChannelHandlerContext ctx,I msg,ByteBuf out) encode()方法是你需要实现的唯一抽象方法。它被调用时将会传入要被该类编码为 ByteBuf 的出站消息（类型为 I 的）。该 ByteBuf 随后将会被转发给 ChannelPipeline 中的下一个ChannelOutboundHandler。

将消息编码为消息

       encode(ChannelHandlerContext ctx,I msg,Listout) 这是需要实现的唯一方法。每个通过 write()方法写入的消息都将会被传递给 encode() 方法，以编码为一个或者多个出站消息。随后，这些出站消息将会被转发给 ChannelPipeline 中的下一个 ChannelOutboundHandler。

编解码器类

        Netty 抽象了编解码器类，为它们每个都将捆绑一个解码器/编码器对。这些类同时实现了 ChannelInboundHandler 和 ChannelOutboundHandler 接口。

相关的类：抽象类 ByteToMessageCodec。抽象类 MessageToMessageCodec。

通过http协议实现SSL/TLS和Web服务

服务端相关代码

public class HttpServer {public static final int port = 6789; //设置服务端端口private static EventLoopGroup group = new NioEventLoopGroup();   // 通过nio方式来接收连接和处理连接private static ServerBootstrap b = new ServerBootstrap();public static final boolean SSL = true;/*是否开启SSL模式*//*** Netty创建全部都是实现自AbstractBootstrap。* 客户端的是Bootstrap，服务端的则是ServerBootstrap。**/public static void main(String[] args) throws Exception {final SslContext sslCtx;if(SSL){SelfSignedCertificate ssc = new SelfSignedCertificate();sslCtx = SslContextBuilder.forServer(ssc.certificate(),ssc.privateKey()).build();}else{sslCtx = null;}try {b.group(group);b.channel(NioServerSocketChannel.class);b.childHandler(new ServerHandlerInit(sslCtx)); //设置过滤器// 服务器绑定端口监听ChannelFuture f = b.bind(port).sync();System.out.println("服务端启动成功,端口是:"+port);System.out.println("服务器启动模式： "+( SSL ? "SSL安全模式" :"普通模式"));// 监听服务器关闭监听f.channel().closeFuture().sync();} finally {group.shutdownGracefully(); //关闭EventLoopGroup，释放掉所有资源包括创建的线程}}
}
public class ServerHandlerInit extends ChannelInitializer<SocketChannel> {private final SslContext sslCtx;public ServerHandlerInit(SslContext sslCtx) {this.sslCtx = sslCtx;}@Overrideprotected void initChannel(SocketChannel ch) throws Exception {ChannelPipeline ph = ch.pipeline();if(sslCtx!=null){ph.addLast(sslCtx.newHandler(ch.alloc()));}/*把应答报文 编码*/ph.addLast("encoder",new HttpResponseEncoder());/*把请求报文 解码*/ph.addLast("decoder",new HttpRequestDecoder());/*聚合http为一个完整的报文*/ph.addLast("aggregator",new HttpObjectAggregator(10*1024*1024));/*把应答报文 压缩,非必要*/ph.addLast("compressor",new HttpContentCompressor());ph.addLast(new BusiHandler());}
}
public class BusiHandler extends ChannelInboundHandlerAdapter {/*** 发送的返回值* @param ctx     返回* @param context 消息* @param status 状态*/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 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();}}/** 建立连接时，返回消息*/@Overridepublic void channelActive(ChannelHandlerContext ctx) throws Exception {System.out.println("连接的客户端地址:" + ctx.channel().remoteAddress());}
}

返回的数据

public class RespConstant {private static final String[] NEWS = {"hello，world！","hello，netty！"};private static final Random R = new Random();public static String getNews(){return NEWS[R.nextInt(NEWS.length)];}
}

启动服务端后，访问https://127.0.0.1:6789/test

             

               

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

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

相关文章

uniapp 本地存储的方式

uniapp 本地存储的方式

1. uniapp 本地存储的方式 在uniapp开发中&#xff0c;本地存储是一个常见的需求。本地存储可以帮助我们在客户端保存和管理数据&#xff0c;以便在应用程序中进行持久化存储。本文将介绍uniapp中本地存储的几种方式&#xff0c;以及相关的代码示例。 1.1. 介绍 在移动应用开发…
阅读更多...
CRM的线索管理功能是什么?如何帮助企业实现业绩增长？

CRM的线索管理功能是什么?如何帮助企业实现业绩增长？

随着“以客户为中心”观念的逐渐普及&#xff0c;销售团队的客户比过去更复杂&#xff0c;交易周期更久&#xff0c;竞争也更激烈。假如没有明确的销售计划&#xff0c;团队可能陷入混乱&#xff0c;最后导致客户&公司之间的负面结果。在这种情况下&#xff0c;人工智能驱动…
阅读更多...
算法提升——LeetCode123场双周赛总结

算法提升——LeetCode123场双周赛总结

周赛题目 三角形类型 II 给你一个下标从0开始长度为3的整数数组nums&#xff0c;需要用它们来构造三角形。 如果一个三角形的所有边长度相等&#xff0c;那么这个三角形称为equilateral。 如果一个三角形恰好有两条边长度相等&#xff0c;那么这个三角形称为isosceles。 如…
阅读更多...
华为机考入门python3--（11）牛客11-数字颠倒

华为机考入门python3--（11）牛客11-数字颠倒

分类&#xff1a;字符串 知识点&#xff1a; int转字符串 str int(num) 对字符串进行逆序 my_str str[::-1] 题目来自【牛客】 def reverse_integer(n): # 将整数转换为字符串 str_n str(n) # 使用[::-1]来反转字符串 reversed_str str_n[::-1] return reversed…
阅读更多...
蓝桥杯---分小组

蓝桥杯---分小组

9名运动员参加比赛,需要分3组进行预赛. 有哪些分组的方案呢? 我们标记运动员为 A,B,C .... I 下面的程序列出了所有的分组方法。 该程序的正常输出为:
阅读更多...
蓝桥杯嵌入式第8届真题(完成) STM32G431

蓝桥杯嵌入式第8届真题(完成) STM32G431

蓝桥杯嵌入式第8届真题(完成) STM32G431 题目 分析和代码 对比第六届和第七届&#xff0c;这届的题目在逻辑思维上确实要麻烦不少&#xff0c;可以从题目看出&#xff0c;这届题目对时间顺序的要求很严格&#xff0c;所以就可以使用状态机的思想来编程&#xff0c;拿到类似题…
阅读更多...
C#中实现串口通讯（使用SerialPort类）

C#中实现串口通讯（使用SerialPort类）

仅作自己学习使用 1 准备部份 需要两个调试软件commix和Virtual Serial Port Driver&#xff0c;分别用于监视串口和创造虚拟串口。 第一个软件是这样的&#xff1a; 资源在这里&#xff1a;免费下载&#xff1a;Commix 也可以前往官网下载&#xff1a;Bwsensing— Attitude…
阅读更多...
华为OD机试真题C卷-篇3

华为OD机试真题C卷-篇3

文章目录 查找一个有向网络的头节点和尾节点幼儿园篮球游戏 查找一个有向网络的头节点和尾节点 在一个有向图中&#xff0c;有向边用两个整数表示&#xff0c;第一个整数表示起始节点&#xff0c;第二个整数表示终止节点&#xff1b;图中只有一个头节点&#xff0c;一个或者多…
阅读更多...
腾讯云游戏服务器配置有哪些？

腾讯云游戏服务器配置有哪些？

2024年更新腾讯云游戏联机服务器配置价格表&#xff0c;可用于搭建幻兽帕鲁、雾锁王国等游戏服务器&#xff0c;游戏服务器配置可选4核16G12M、8核32G22M、4核32G10M、16核64G35M、4核16G14M等配置&#xff0c;可以选择轻量应用服务器和云服务器CVM内存型MA3或标准型SA2实例&am…
阅读更多...
Java实现用户画像活动推荐系统 JAVA+Vue+SpringBoot+MySQL

Java实现用户画像活动推荐系统 JAVA+Vue+SpringBoot+MySQL

目录 一、摘要1.1 项目介绍1.2 项目录屏 二、功能模块2.1 数据中心模块2.2 兴趣标签模块2.3 活动档案模块2.4 活动报名模块2.5 活动留言模块 三、系统设计3.1 用例设计3.2 业务流程设计3.3 数据流程设计3.4 E-R图设计 四、系统展示五、核心代码5.1 查询兴趣标签5.2 查询活动推荐…
阅读更多...
JavaEE作业-实验二

JavaEE作业-实验二

目录 1 实验内容 2 实验要求 3 思路 4 核心代码 5 实验结果 1 实验内容 实现两个整数求和的WEB程序 2 实验要求 ①采用SpringMVC框架实现 ②数据传送到WEB界面采用JSON方式 3 思路 ①创建一个SpringMVC项目&#xff0c;配置好相关的依赖和配置文件。 ②创建一个Con…
阅读更多...
kafka 文件存储机制

kafka 文件存储机制

文章目录 1. 思考四个问题&#xff1a;1.1 topic中partition存储分布&#xff1a;1.2 partiton中文件存储方式&#xff1a;1.3 partiton中segment文件存储结构&#xff1a;1.4 在partition中如何通过offset查找message: 2. kafka日志存储参数配置 Topic是逻辑上的概念&#xff…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023