在netty中使用native传输协议的方法
简介
对于IO来说,除了传统的block IO,使用最多的就是NIO了,通常我们在netty程序中最常用到的就是NIO,比如NioEventLoopGroup,NioServerSocketChannel等。
我们也知道在IO中有比NIO更快的IO方式,比如kqueue和epoll,但是这两种方式需要native方法的支持,也就是说需要在操作系统层面提供服务。
如果我们在支持Kqueue或者epoll的服务器上,netty是否可以提供对这些优秀IO的支持呢?
答案是肯定的。但是首先kqueue和epoll需要JNI支持,也就是说JAVA程序需要调用本地的native方法。
native传输协议的依赖
要想使用kequeue和epoll这种native的传输方式,我们需要额外添加项目的依赖,如果是linux环境,则可以添加如下的maven依赖环境:
<dependencies> <dependency> <groupId>io.netty</groupId> <artifactId>netty-transport-native-epoll</artifactId> <version>${project.version}</version> <classifier>linux-x86_64</classifier> </dependency> ... </dependencies>
其中version需要匹配你所使用的netty版本号,否则可能出现调用异常的情况。
classifier表示的是系统架构,它的值可以是linux-x86_64,也可以是linux-aarch_64.
如果你使用的mac系统,那么可以这样引入:
<dependencies> <dependency> <groupId>io.netty</groupId> <artifactId>netty-transport-native-kqueue</artifactId> <version>${project.version}</version> <classifier>osx-x86_64</classifier> </dependency> ... </dependencies>
netty除了单独的个体包之外,还有一个all in one的netty-all包,如果你使用了这个all in one的包,那么不需要额外添加native的依赖。
如果netty提供的系统架构并没有你正在使用的,那么你需要手动进行编译,以下是编译所依赖的程序包, 如果是在RHEL/CentOS/Fedora系统中,则使用:
sudo yum install autoconf automake libtool make tar \ glibc-devel \ libgcc.i686 glibc-devel.i686
如果是在Debian/Ubuntu系统中,则使用:
sudo apt-get install autoconf automake libtool make tar \ gcc
如果是在MacOS/BSD系统中,则使用:
brew install autoconf automake libtool
netty本地传输协议的使用
安装好依赖包之后,我们就可以在netty中使用这些native传输协议了。
native传输协议的使用和NIO的使用基本一致,我们只需要进行下面的替换即可。
如果是在liunx系统中,则进行下面的替换:
NioEventLoopGroup → EpollEventLoopGroup NioEventLoop → EpollEventLoop NioServerSocketChannel → EpollServerSocketChannel NioSocketChannel → EpollSocketChannel
如果是在mac系统中,则进行下面的替换:
NioEventLoopGroup → KQueueEventLoopGroup NioEventLoop → KQueueEventLoop NioServerSocketChannel → KQueueServerSocketChannel NioSocketChannel → KQueueSocketChannel
这里还是使用我们熟悉的聊天服务为例,首先看下基于Kqueue的netty服务器端应该怎么写:
EventLoopGroup bossGroup = new KQueueEventLoopGroup(1); EventLoopGroup workerGroup = new KQueueEventLoopGroup(); try { ServerBootstrap b = new ServerBootstrap(); b.group(bossGroup, workerGroup) .channel(KQueueServerSocketChannel.class) .handler(new LoggingHandler(LogLevel.INFO)) .childHandler(new NativeChatServerInitializer()); Channel channel = b.bind(PORT).sync().channel(); log.info("server channel:{}", channel); channel.closeFuture().sync();
和NIO一样,在服务器端我们需要使用KQueueEventLoopGroup创建两个EventLoopGroup,一个是bossGroup, 一个是workerGroup。
然后将这两个group传入到ServerBootstrap中,并且添加KQueueServerSocketChannel作为channel。
其他的内容和NIO server的内容是一样的。
接下来我们看下基于Kqueue的netty客户端改如何跟server端建立连接:
EventLoopGroup group = new KQueueEventLoopGroup(); try { Bootstrap b = new Bootstrap(); b.group(group) .channel(KQueueSocketChannel.class) .handler(new NativeChatClientInitializer()); // 建立连接 Channel ch = b.connect(HOST, PORT).sync().channel(); log.info("client channel: {}", ch);
这里使用的是KQueueEventLoopGroup,并将KQueueEventLoopGroup放到Bootstrap中,并且为Bootstrap提供了和server端一致的KQueueSocketChannel。
然后就是客户端向channel中写消息,这里我们直接从命令行输入:
// 从命令行输入 ChannelFuture lastWriteFuture = null; BufferedReader in = new BufferedReader(new InputStreamReader(System.in)); for (;;) { String line = in.readLine(); if (line == null) { break; } // 将从命令行输入的一行字符写到channel中 lastWriteFuture = ch.writeAndFlush(line + "\r\n"); // 如果输入'再见',则等待server端关闭channel if ("再见".equalsIgnoreCase(line)) { ch.closeFuture().sync(); break; } }
上面代码的意思是将命令行收到的消息写入到channel中,如果输入的是’再见’,则关闭channel。
为了能够处理字符串,这里用到了三个编码解码器:
// 添加行分割器 pipeline.addLast(new DelimiterBasedFrameDecoder(8192, Delimiters.lineDelimiter())); // 添加String Decoder和String Encoder,用来进行字符串的转换 pipeline.addLast(new StringEncoder()); pipeline.addLast(new StringDecoder());
分别是行分割器,字符编码器和字符解码器。
运行一下看,程序运行没问题,客户端和服务器端可以进行通讯。
总结
这里我们只以Kqueue为例介绍了netty中native传输协议的使用,具体的代码,大家可以参考:
learn-netty4
到此这篇关于在netty中使用native传输协议的文章就介绍到这了,更多相关native传输协议内容请搜索猪先飞以前的文章或继续浏览下面的相关文章希望大家以后多多支持猪先飞!
原文出处:https://juejin.cn/post/7101610658185084936
相关文章
关于React Native报Cannot initialize a parameter of type'NSArray<id<RCTBridgeModule>>错误(解决方案)
这篇文章主要介绍了关于React Native报Cannot initialize a parameter of type'NSArray<id<RCTBridgeModule>>错误,本文给大家分享解决方案,需要的朋友可以参考下...2021-05-12python使用socket高效传输视频数据帧(连续发送图片)
本文主要介绍了python使用socket高效传输视频数据帧(连续发送图片),文中通过示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下...2021-10-23- 这篇文章主要介绍了React Native 启动流程简析,文以 react-native-cli 创建的示例工程(安卓部分)为例,给大家分析 React Native 的启动流程,需要的朋友可以参考下...2021-08-18
- 这篇文章主要介绍了@Query注解的原生用法和native用法解析,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教...2021-08-27
- http://www.linuxforum.net Jephe Wu (2001-04-21 18:17:49) 一 简介: 1. POP适用于C/S结构的脱机模型的电子邮件协议,目前已发展到第三版,称POP3。脱机模型即不能在...2016-11-25
node.js 基于 STMP 协议和 EWS 协议发送邮件
这篇文章主要介绍了node.js 基于 STMP 协议和 EWS 协议发送邮件的示例,帮助大家更好的理解和使用node.js,感兴趣的朋友可以了解下...2021-02-15.Net WInform开发笔记(二)Winform程序运行结构图及TCP协议在Winform中的应用
中午没事,把去年刚毕业那会画的几张图翻出来了,大概介绍Winform应用程序运行的过程,以及TCP协议在Winform中的应用。感兴趣的朋友可以了解下;如果有Windows消息机制等基础,很好理解这两张...2020-06-25- 这篇文章主要介绍了Websocket协议详解及简单实例代码的相关资料,这里对websocket 协议进行详细介绍,并附简单实例代码,需要的朋友可以参考下...2016-12-19
- 是时候使用易入手又全面的Swif语言为iOS和mac OS X做应用开发了,下面这篇文章主要给大家分享介绍了十条实用的Swift小提示的相关资料,文中通过示例代码介绍的非常详细,需要的朋友可以参考借鉴,下面来一起看看吧...2020-06-30
- 路由管理的功能主要指的页面跳转、goBack、带参数跳转等功能,这篇文章主要给大家介绍了关于React Native自定义路由管理的相关资料,需要的朋友可以参考下...2021-08-04
- native是与C++联合开发的时候用的!使用native关键字说明这个方法是原生函数,也就是这个方法是用C/C++语言实现的,并且被编译成了DLL,由java去调用。本文给大家介绍java 中native方法使用,感兴趣的朋友一起看看吧...2020-09-16
- 这篇文章主要介绍了eclipse实现可认证的DH密钥交换协议,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下...2020-06-24
详解Flutter 调用 Android Native 的方法
这篇文章主要介绍了详解Flutter 调用 Android Native 的方法,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧...2021-01-25- 这篇文章主要介绍了python 基于UDP协议套接字通信的实现,帮助大家更好的理解和使用python,感兴趣的朋友可以了解下...2021-01-25
- 说到websocket大家一定不会陌生,WebSocket是HTML5一种新的协议。下面这篇文章主要给大家介绍了关于C# websocket及时通信协议的实现方法,文中通过示例代码介绍的非常详细,需要的朋友可以参考借鉴,下面来一起看看吧。...2020-06-25
ASP.NET Core SignalR中的流式传输深入讲解
这篇文章主要给大家介绍了关于ASP.NET Core SignalR中流式传输的相关资料,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧...2021-09-22- 本文记录如何使用vscode打造一个现代化的react-native开发环境,旨在提高开发效率和质量。本文给大家分享我遇到的问题及解决方法,感兴趣的朋友跟随小编一起看看吧...2021-07-07
- 这篇文章主要介绍了解协议时有符号和无符号整数型处理,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧...2021-09-22
- 这篇文章主要介绍了Netty结合Protobuf进行编解码,通过文档表述和代码实例充分说明了如何进行使用和操作,需要的朋友可以参考下...2021-06-26
- 本文出自: 作者: (2001-11-23 09:08:00) 第二步:转发主机到目的主机 R: 220 BBN-VAX.ARPA Simple Mail Transfer Service Ready S: HELO USC-ISIE.ARPA R: 250 BBN...2016-11-25