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:Edgware.RELEASE版本hystrix超时新坑

升级到Edgware.RELEASE发现,zuul中不管如何设置hystrix的超时时间均不起作用,仍然是默认的1000ms.  降回低版本后正常,但是低版本的...

26810
来自专栏JMCui

浅析 SpringMVC 原理和配置.

一、原理       Spring MVC基于模型-视图-控制器(Model-View-Controller,MVC)模式实现,它能够帮你构建像Spring框架...

3759
来自专栏技术翻译

使用Spring Cloud Netflix的Kotlin微服务:第2部分

在本系列的第1部分中,我们使用Kotlin介绍了Spring Cloud。我们讨论了Config Server,Discovery Server(Eureka)...

1692
来自专栏王大锤

iOS AFNetworking “Request failed: unacceptable content-type: text/html”问题

3877
来自专栏开发技术

spring-boot-2.0.3不一样系列之国际化

       针对spring boot,网上已有很多优质的系列教程,我就不再班门弄斧了(实际上是担心没别人写的好,哈哈哈!)。但是还是想蹭蹭spring bo...

3043
来自专栏AI-vell

java轻量RESTful api服务搭建(jersey+jetty)

由于开始要搭建一个java + python的服务,java端提供数据库增删改查逻辑供python端调用,第一时间想到了用REST(Representation...

3887
来自专栏圣杰的专栏

ABP入门系列(21)——切换MySQL数据库

源码路径:Github-LearningMpaAbp 1. 引言 Abp支持MySql已经不是什么新鲜事了,但按照官方文档:Entity Framework...

2499
来自专栏xingoo, 一个梦想做发明家的程序员

手把手教你搭建SpringMVC——最小化配置

为什么需要Spring MVC 最开始接触网页的时候,是纯的html/css页面,那个时候还是用Dreamweaver来绘制页面。 随着网站开发的深入,开始学习...

2145
来自专栏LanceToBigData

JavaWeb(三)JSP概述

一、JSP概述 1.1、JSP简介   一种动态网页开发技术。它使用JSP标签在HTML网页中插入Java代码。标签通常以<%开头以%>结束。JSP是一种Jav...

2696
来自专栏JAVA烂猪皮

Netty原理分析

Netty是一个高性能、异步事件驱动的NIO框架,基于JAVA NIO提供的API实现。它提供了对TCP、UDP和文件传输的支持,作为一个异步NIO框架,Net...

1622

扫码关注云+社区