Netty入门(一)

在文章开始之前首先明确一个问题,为什么要使用Netty,Netty解决了什么问题,围绕着这个问题我们开始本篇文章的学习

  1. 为什么要使用Netty netty它是对jdk中nio模块的封装,你也可以不使用Netty,就像开发网站可以只使用Servlet+jsp一样。结果是效率低且Bug多
  2. Netty解决了什么问题 沿用知乎上的答案
jdk强迫你必须用socket来写服务器,实际上是很繁琐的。缺乏一个高层次的api。
netty说,我来写jdk的socket,并给你一个新的更简洁的api,你傻瓜式的就能写好一个网络服务器(而且是event-driven/proactor/reactor等等)。
当然,netty通过jni,引入了epoll这样的linux系统调用,使得它不单单是jdk的一个简单包裹,的确也加了些东西进去

想深入了解Netty的应用场景和优势可以参考知乎上的问答知乎传送门

按照我的讲解风格,先运行代码,跑起来再问为什么

  1. 导入依赖 本项目使用的是Gradle,下载Jar包的速度慢,可以配置阿里云的仓库
/*   repositories {
        maven {url 'http://maven.aliyun.com/nexus/content/groups/public/'}
        mavenLocal()
        mavenCentral()
    }*/
 compile (group: 'io.netty', name: 'netty-all', version: '4.1.25.Final')
  1. 编写服务器端
import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.*;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.SocketChannel;
import io.netty.channel.socket.nio.NioServerSocketChannel;
import io.netty.channel.socket.nio.NioSocketChannel;
import io.netty.handler.codec.string.StringDecoder;

import java.net.InetSocketAddress;

/**
 * @author tanoak@qq.com
 * @date 2018/6/26 22:46
 * @Desc
 */
public class NettyServer {
    // 端口号
    private final int port;
    public NettyServer(int port) {
        this.port = port;
    }

    public void start() throws Exception {
        ServerBootstrap serverBootstrap = new ServerBootstrap();//① 是一个启动NIO服务的辅助启动类
        NioEventLoopGroup worker = new NioEventLoopGroup();//②NioEventLoopGroup是用来处理IO操作的多线程事件循环器
        serverBootstrap
                .group(worker)
                .channel(NioServerSocketChannel.class)
                .childHandler(new ChannelInitializer<NioSocketChannel>() {
                    @Override
                    protected void initChannel(NioSocketChannel ch) {
                        ch.pipeline().addLast(new StringDecoder());
                        ch.pipeline().addLast(new SimpleChannelInboundHandler<String>() {
                            //读取客户端发送的消息
                            @Override
                            protected void channelRead0(ChannelHandlerContext ctx, String msg) {
                                System.out.println("【客户端发送的消息】"+msg);
                            }
                        });
                    }
                })
                .bind(port);
    }

    public static void main(String[] args) throws Exception {
        try {
            new NettyServer( 8088).start();
            System.out.println("启动成功");
        }catch (Exception e){
            System.out.println("启动失败");
        }
    }
}
  1. 客户端
import com.tanoak.demo1.client.EchoClientHandler;
import io.netty.bootstrap.Bootstrap;
import io.netty.channel.Channel;
import io.netty.channel.ChannelFuture;
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.string.StringEncoder;

import java.net.InetSocketAddress;
import java.time.LocalDateTime;
import java.util.Date;

/** 
 * @author tanoak@qq.com
 * @date 2018/6/25 0:46
 * @Desc
 */ 
public class NettyClient {
    private final String host;
    private final int port;
    public NettyClient(String host, int port) {
        this.host = host;
        this.port = port;
    }

    public void start() throws Exception {
        Bootstrap bootstrap = new Bootstrap();
        NioEventLoopGroup group = new NioEventLoopGroup();
        bootstrap.group(group)
                .channel(NioSocketChannel.class)
                .handler(new ChannelInitializer<Channel>() {
                    @Override
                    protected void initChannel(Channel ch) {
                        ch.pipeline().addLast(new StringEncoder());
                    }
                });
        Channel channel = bootstrap.connect(host, port).channel();
        while (true) {
            channel.writeAndFlush("现在时间:"+LocalDateTime.now());
            Thread.sleep(2000);
        }
    }

    public static void main(String[] args) throws Exception {
        new NettyClient("127.0.0.1",8088 ).start();
    }
}

代码运行OK后我们接下来看下服务器端它所做的工作

  1. 创建ServerBootstrap对象以及 NioEventLoopGroup 对象 。然后进行优雅的链式调用,这里看一下group(worker)这个方法的源码

group()方法进行了重载,接着就是channel()方法添加一个NioServerSocketChannel的类,然后childHandler()上 目的是添加handler,用来监听已经连接的客户端的Channel的动作和状态,childHandler会在客户端成功connect后执行

接下来我们来看下客户端的工作

重复步骤省略直接看连接服务器的代码 bootstrap.connect(),接着就是利用channel 对象向服务器端写入数据

至此一个简单的Demo就完成了,如讲解有误,请指正,本篇参考《Netty实战》这本书,这本书个人极力推荐,想了解Netty的可以考虑入门一本

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

编辑于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏史上最简单的Spring Cloud教程

5分钟带你入门Redis

1.redis概述 redis是一个开源的,先进的 key-value 存储可用于构建高性能的存储解决方案。它支持数据结构有字符串,哈希,列表,集合,带有范围查...

1868
来自专栏JadePeng的技术博客

XNginx - nginx 集群可视化管理工具

之前团队的nginx管理,都是运维同学每次去修改配置文件,然后重启,非常不方便,一直想找一个可以方便管理nginx集群的工具,翻遍web,未寻到可用之物,于是自...

1063
来自专栏Kirito的技术分享

Re:从零开始的Spring Session(二)

上一篇文章介绍了一些Session和Cookie的基础知识,这篇文章开始正式介绍Spring Session是如何对传统的Session进行改造的。官网这么介绍...

3467
来自专栏一名叫大蕉的程序员

分布式文件系统.get(LEVEL1)No.104

如果你有两个小时,还有IDE,还懂一点点 Java ,来坐下来,半个小时教你自己写一个分布式文件系统,还有电脑。因为这篇文章在手机完全没法看。。

791
来自专栏Java帮帮-微信公众号-技术文章全总结

struts2关于action拦截器使用方法 现记录如下

struts2关于action拦截器使用方法 现记录如下 以便将来取用 struts2 与spring与hibernate整合 struts2中拦截actio...

3466
来自专栏我叫刘半仙

手写一个简化版Tomcat

      Tomcat作为Web服务器深受市场欢迎,有必要对其进行深入的研究。在工作中,我们经常会把写好的代码打包放在Tomcat里并启动,然后在浏览器里就能...

3285
来自专栏微信公众号:Java团长

Java Web现代化开发:Spring Boot + Mybatis + Redis二级缓存

Spring-Boot因其提供了各种开箱即用的插件,使得它成为了当今最为主流的Java Web开发框架之一。Mybatis是一个十分轻量好用的ORM框架。Red...

932
来自专栏Java学习123

Java中的日志——Java.util.logging、log4j、commons-logging

2439
来自专栏熊二哥

Spring快速入门

Spring源码剖析一书,非常细致,但对于个人来说,意义不算特别的大,因此选其可用部分做个记录就好。 ? 功能 示例 配置文件的解析...

16810
来自专栏编舟记

R3 Corda 和 springboot 集成

因为Corda内置的Corda Webserver已经被标记成弃用了,一般不再提供支持;再者,springboot的生态明显占优。

1252

扫码关注云+社区