百度360必应搜狗淘宝本站头条
当前位置:网站首页 > 热门文章 > 正文

八、Netty入门服务端代码

bigegpt 2024-08-09 11:12 2 浏览

导论

前面几篇文章我们分别对一、JAVA IO/NIO体系介绍二、网络IO原理-创建ServerSocket-彻底弄懂IO三、JAVA中ServerSocket调用Linux系统内核四、「大厂职员教你」IO进化过程之BIO五、「大厂职员教你」Java-IO进化过程之NIO六、Selector实现Netty中Reactor单线程模型七、Selector实现Netty中Reactor主从模型 等几个纬度对JavaIO和NIO体系做了详细介绍,并由简到深的根据IO体系的升级过程做了系统分析。

前文中的第六、Selector实现Netty中Reactor单线程模型七、Selector实现Netty中Reactor主从模型文章我们已经使用Selector自己实现了Netty框架中的单线程模型、主从模型。如果能深入理解以上两篇文章,那么后续对于Netty的学习和理解Netty的Reactor会非常简单。今天我们先通过入门的角度从Idea中导入Netty包,并且使用Netty构建一个可用于接受数据的服务端。

IDEA的maven项目的netty包的导入(其他jar同)

在这之前要有搭建好maven的环境,如何搭建maven环境请自行百度。

1.

2.选择Modules


3.



4.等待一会选择,Download to可以不用勾选,下载的jar会放在本地的jar仓库里,如果勾选了则会在该项目下创建一个lib文件,并且将包放里面。

5.


6.选择一个netty包,点击ok,接下来选择即可。
最后选择


7.即可完成。
在该项目的pom.xml里加入netty依赖。

 <!-- netty -->
		<dependency>
			<groupId>io.netty</groupId>
			<artifactId>netty-all</artifactId>
			<version>5.0.0.Alpha2</version>
		</dependency>

netty入门服务端代码


import io.netty.bootstrap.ServerBootstrap;

import io.netty.channel.*;

import io.netty.channel.nio.NioEventLoopGroup;

import io.netty.channel.socket.nio.NioServerSocketChannel;

import io.netty.channel.socket.nio.NioSocketChannel;





/**

 * Created by Bruce on 2020/9/18

 * 使用 NettyIO实现多路复用器

 **/

public class NettyIO {



    public static void main(String[] args) throws InterruptedException {



        /**

         * //单线程模型---netty单线程模型---即接受客户端请求连接也负责处理客户端的数据

         * netty单线程模型---写法

         * NioEventLoopGroup boss = new NioEventLoopGroup(1);

         *         ServerBootstrap serverBootstrap = new ServerBootstrap();

         *         serverBootstrap.group(boss,boss)

         *                 .channel(NioServerSocketChannel.class)

         *                 .childHandler(new MyImbound());

         *

         *

         * //混合模型---netty混合模型---组内有一个boss即接受客户端请求连接也负责处理客户端的数据,其他线程只负责处理客户端的数据

         * netty混合模型---写法

         * NioEventLoopGroup boss = new NioEventLoopGroup(4);

         *         ServerBootstrap serverBootstrap = new ServerBootstrap();

         *         serverBootstrap.group(boss,boss)

         *                 .channel(NioServerSocketChannel.class)

         *                 .childHandler(new MyImbound());

         *

         * //主备模型---netty主备模型---boss 只负责接口客户端的连接请求 worker负责

         *

         * -----如果这里把 boss的参数改成  2,那么猜一下系统中会有几个线程?

         * 用JDK自带的jvisualvm看一下。

         *

         * NioEventLoopGroup boss = new NioEventLoopGroup(1);

         *         NioEventLoopGroup worker = new NioEventLoopGroup(3);

         *         ServerBootstrap serverBootstrap = new ServerBootstrap();

         *         serverBootstrap.group(boss,worker)

         *                 .channel(NioServerSocketChannel.class)

         *                 .childHandler(new MyImbound());

         *

         */

        NioEventLoopGroup boss = new NioEventLoopGroup(1);

        NioEventLoopGroup worker = new NioEventLoopGroup(3);

        ServerBootstrap serverBootstrap = new ServerBootstrap();

        serverBootstrap.group(boss,worker)

                .channel(NioServerSocketChannel.class)

                .childHandler(new ChannelInitializer<NioSocketChannel>() {

                    @Override

                    protected void initChannel(NioSocketChannel nioSocketChannel) throws Exception {

                        ChannelPipeline p = nioSocketChannel.pipeline();

                        p.addLast(new MyImbound());

                    }

                });



        ChannelFuture future = serverBootstrap.bind(8080).sync();

        future.channel().closeFuture().sync();

    }



}



class MyImbound extends ChannelHandlerAdapter{



    @Override

    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {

//        super.channelRead(ctx, msg);

        ctx.write(msg);

    }



    @Override

    public void channelReadComplete(ChannelHandlerContext ctx) throws Exception {

//        super.channelReadComplete(ctx);

        ctx.flush();

    }

}

数据打印:

在linux环境或者windows环境下使用nc命令链接服务端,查看服务端打印过程。

具体linux系统或者windows系统如何安装nc命令,请从网络搜索或查看目录文档 ‘网络IO涉及到的-linux指令.docx’。

1.nc客户端1打印(Windows-nc命令打印)

C:\Users\Administrator>nc 127.0.0.1 8080
111111
111111

2.nc客户端1打印(Windows-nc命令打印)

C:\Users\Administrator>nc 127.0.0.1 8080
222
222

往期文章链接

一、JAVA IO/NIO体系介绍

二、网络IO原理-创建ServerSocket-彻底弄懂IO

三、JAVA中ServerSocket调用Linux系统内核

四、「大厂职员教你」IO进化过程之BIO

五、「大厂职员教你」Java-IO进化过程之NIO

六、Selector实现Netty中Reactor单线程模型
七、Selector实现Netty中Reactor主从模型

如需了解更多更详细内容也可关注本人CSDN博客:不吃_花椒

如果需要后续其他系列文章请赞赏后关注私聊。



后续文章中的整体JavaIO体系文章概览




相关推荐

10w qps缓存数据库——Redis(redis缓存调优)

一、Redis数据库介绍:Redis:非关系型缓存数据库nosql:非关系型数据库没有表,没有表与表之间的关系,更不存在外键存储数据的形式为key:values的形式c语言写的服务(监听端口),用来存...

Redis系列专题4--Redis配置参数详解

本文基于windowsX64,3.2.100版本讲解,不同版本默认配置参数不同在Redis中,Redis的根目录中有一个配置文件(redis.conf,windows下为redis.windows....

开源一夏 | 23 张图,4500 字从入门到精通解释 Redis

redis是目前出场率最高的NoSQL数据库,同时也是一个开源的数据结构存储系统,在缓存、数据库、消息处理等场景使用的非常多,本文瑞哥就带着大家用一篇文章入门这个强大的开源数据库——Redis。...

redis的简单与集群搭建(redis建立集群)

Redis是什么?是开源免费用c语言编写的单线程高性能的(key-value形式)内存数据库,基于内存运行并支持持久化的nosql数据库作用主要用来做缓存,单不仅仅是做缓存,比如:redis的计数器生...

推荐几个好用Redis图形化客户端工具

RedisPlushttps://gitee.com/MaxBill/RedisPlusRedisPlus是为Redis可视化管理开发的一款开源免费的桌面客户端软件,支持Windows、Linux...

关于Redis在windows上运行及fork函数问题

Redis在将数据库进行持久化操作时,需要fork一个进程,但是windows并不支持fork,导致在持久化操作期间,Redis必须阻塞所有的客户端直至持久化操作完成。微软的一些工程师花费时间在解决在...

你必须懂的Redis十大应用场景(redis常见应用场景)

Redis作为一款高性能的键值存储数据库,在互联网业务中有着广泛的应用。今天,我们就来详细盘点一下Redis的十大常用业务场景,并附上Golang的示例代码和简图,帮助大家更好地理解和应用Redis。...

极简Redis配置(redis的配置)

一、概述Redis的配置文件位于Redis安装目录下,文件名为redis.conf(Windows名为redis.windows.conf,linux下的是redis.conf)你可以通过C...

什么是redis,怎么启动及如何压测

从今天起咱们一起来学习一下关于“redis监控与调优”的内容。一、Redis介绍Redis是一种高级key-value数据库。它跟memcached类似,不过数据可以持久化,而且支持的数据类型很丰富。...

一款全新Redis UI可视化管理工具,支持WebUI和桌面——P3X Redis UI

介绍P3XRedisUI这是一个非常实用的RedisGUI,提供响应式WebUI访问或作为桌面应用程序使用,桌面端是跨平台的,而且完美支持中文界面。Githubhttps://github....

windows系统的服务器快速部署java项目环境地址

1、mysql:https://dev.mysql.com/downloads/mysql/(msi安装包)2、redis:https://github.com/tporadowski/redis/r...

window11 下 redis 下载与安装(windows安装redis客户端)

#热爱编程是一种怎样的体验#window11下redis下载与安装1)各个版本redis下载(windows)https://github.com/MicrosoftArchive/r...

一款轻量级的Redis客户端工具,贼好用!

使用命令行来操作Redis是一件非常麻烦的事情,我们一般会选用客户端工具来操作Redis。今天给大家分享一款好用的Redis客户端工具TinyRDM,它的界面清新又优雅,希望对大家有所帮助!简介Ti...

一个.NET开发且功能强大的Windows远程控制系统

我们致力于探索、分享和推荐最新的实用技术栈、开源项目、框架和实用工具。每天都有新鲜的开源资讯等待你的发现!项目介绍SiMayRemoteMonitorOS是一个基于Windows的远程控制系统,完...

Redis客户端工具详解(4款主流工具)

大家好,我是mikechen。Redis是大型架构的基石,也是大厂最爱考察内容,今天就给大家重点详解4款Redis工具@mikechen本篇已收于mikechen原创超30万字《阿里架构师进阶专题合集...