`

Netty4详解二:开发第一个Netty应用程序

阅读更多

        既然是入门,那我们就在这里写一个简单的Demo,客户端发送一个字符串到服务器端,服务器端接收字符串后再发送回客户端。

一.配置开发环境

1.安装JDK

2.去官网下载jar包

(或者通过pom构建)

 

二.认识下Netty的Client和Server

        一个Netty应用模型,如下图所示,但需要明白一点的是,我们写的Server会自动处理多客户端请求,理论上讲,处理并发的能力决定于我们的系统配置及JDK的极限。


        1.Client连接到Server端

        2.建立链接发送/接收数据

        3.Server端处理所有Client请求

        这里有一个形象的比喻来形容Netty客户端和服务器端的交互模式,比如把你比作一个Client,把山比作一个Server,你走到山旁,就是和山建立了链接,你向山大喊了一声,就代表向山发送了数据,你的喊声经过山的反射形成了回声,这个回声就是服务器的响应数据。如果你离开,就代表断开了链接,当然你也可以再回来。好多人可以同时向山大喊,他们的喊声也一定会得到山的回应。

 

三.写一个Netty Server

        一个NettyServer程序主要由两部分组成:

        BootsTrapping:配置服务器端基本信息

        ServerHandler:真正的业务逻辑处理

1.BootsTrapping的过程:

package com.bijian.netty.server;

import io.netty.bootstrap.ServerBootstrap;
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.NioServerSocketChannel;
import java.net.InetSocketAddress;

public class EchoServer {

    private static final int port = 8080;

    public void start() throws InterruptedException {
        ServerBootstrap b = new ServerBootstrap();// 引导辅助程序
        EventLoopGroup group = new NioEventLoopGroup();// 通过nio方式来接收连接和处理连接
        try {
            b.group(group);
            b.channel(NioServerSocketChannel.class);// 设置nio类型的channel
            b.localAddress(new InetSocketAddress(port));// 设置监听端口
            b.childHandler(new ChannelInitializer<SocketChannel>() {//有连接到达时会创建一个channel
                protected void initChannel(SocketChannel ch) throws Exception {
                    // pipeline管理channel中的Handler,在channel队列中添加一个handler来处理业务
                    ch.pipeline().addLast("myHandler", new EchoServerHandler());
                }
            });
            ChannelFuture f = b.bind().sync();// 配置完成,开始绑定server,通过调用sync同步方法阻塞直到绑定成功
            System.out.println(EchoServer.class.getName() + " started and listen on " + f.channel().localAddress());
            f.channel().closeFuture().sync();// 应用程序会一直等待,直到channel关闭
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            group.shutdownGracefully().sync();//关闭EventLoopGroup,释放掉所有资源包括创建的线程
        }
    }

    public static void main(String[] args) {
        try {
            new EchoServer().start();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

        a.创建一个ServerBootstrap实例

        b.创建一个EventLoopGroup来处理各种事件,如处理链接请求,发送接收数据等。

        c.定义本地InetSocketAddress( port)好让Server绑定

        d.创建childHandler来处理每一个链接请求   

        e.所有准备好之后调用ServerBootstrap.bind()方法绑定Server

2.业务逻辑ServerHandler:

        要想处理接收到的数据,我们必须继承ChannelInboundHandlerAdapter接口,重写里面的MessageReceive方法,每当有数据到达,此方法就会被调用(一般是Byte类型数组),我们就在这里写我们的业务逻辑:

package com.bijian.netty.server;

import io.netty.buffer.Unpooled;
import io.netty.channel.ChannelFutureListener;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;
import io.netty.channel.ChannelHandler.Sharable;

/**
 * Sharable表示此对象在channel间共享
 * handler类是我们的具体业务类
 * */
@Sharable
//注解@Sharable可以让它在channels间共享
public class EchoServerHandler extends ChannelInboundHandlerAdapter {
    public void channelRead(ChannelHandlerContext ctx, Object msg) {
        System.out.println("server received data :" + msg);
        ctx.write(msg);//写回数据,
    }

    public void channelReadComplete(ChannelHandlerContext ctx) {
        ctx.writeAndFlush(Unpooled.EMPTY_BUFFER) //flush掉所有写回的数据
                .addListener(ChannelFutureListener.CLOSE); //当flush完成后关闭channel
    }

    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
        cause.printStackTrace();//捕捉异常信息
        ctx.close();//出现异常时关闭channel 
    }
}

3.关于异常处理

        我们在上面程序中也重写了exceptionCaught方法,这里就是对当异常出现时的处理。

 

四.写一个Netty Client

        一般一个简单的Client会扮演如下角色:

        a.连接到Server

        b.向Server写数据

        c.等待Server返回数据

        d.关闭连接

1.BootsTrapping的过程:

        和Server端类似,只不过Client端要同时指定连接主机的IP和Port。

package com.bijian.netty.client;

import io.netty.bootstrap.Bootstrap;
import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelFutureListener;
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 java.net.InetSocketAddress;

public class EchoClient {
    
    private final String host;
    private final int port;

    public EchoClient(String host, int port) {
        this.host = host;
        this.port = port;
    }

    public void start() throws Exception {
        EventLoopGroup group = new NioEventLoopGroup();
        try {
            Bootstrap b = new Bootstrap();
            b.group(group);
            b.channel(NioSocketChannel.class);
            b.remoteAddress(new InetSocketAddress(host, port));
            b.handler(new ChannelInitializer<SocketChannel>() {

                public void initChannel(SocketChannel ch) throws Exception {
                    ch.pipeline().addLast(new EchoClientHandler());
                }
            });
            ChannelFuture f = b.connect().sync();
            f.addListener(new ChannelFutureListener() {

                public void operationComplete(ChannelFuture future) throws Exception {
                    if (future.isSuccess()) {
                        System.out.println("client connected");
                    } else {
                        System.out.println("server attemp failed");
                        future.cause().printStackTrace();
                    }

                }
            });
            f.channel().closeFuture().sync();
        } finally {
            group.shutdownGracefully().sync();
        }
    }

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

        new EchoClient("127.0.0.1", 8080).start();
    }
}

        a.创建一个ServerBootstrap实例

        b.创建一个EventLoopGroup来处理各种事件,如处理链接请求,发送接收数据等。

        c.定义一个远程InetSocketAddress好让客户端连接

        d.当连接完成之后,Handler会被执行一次   

        e.所有准备好之后调用ServerBootstrap.connect()方法连接Server

2.业务逻辑ClientHandler:

        我们同样继承一个SimpleChannelInboundHandler来实现我们的Client,我们需要重写其中的三个方法:

package com.bijian.netty.client;

import io.netty.buffer.ByteBuf;
import io.netty.buffer.ByteBufUtil;
import io.netty.buffer.Unpooled;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.SimpleChannelInboundHandler;
import io.netty.channel.ChannelHandler.Sharable;
import io.netty.util.CharsetUtil;

@Sharable
public class EchoClientHandler extends SimpleChannelInboundHandler<ByteBuf> {
    
    /**
     *此方法会在连接到服务器后被调用 
     * */
    public void channelActive(ChannelHandlerContext ctx) {
        ctx.write(Unpooled.copiedBuffer("Netty rocks!", CharsetUtil.UTF_8));
        ctx.flush();
    }

    /**
     *此方法会在接收到服务器数据后调用 
     * */
    public void channelRead0(ChannelHandlerContext ctx, ByteBuf in) {
        System.out.println("Client received: " + ByteBufUtil.hexDump(in.readBytes(in.readableBytes())));
    }

    /**
     *捕捉到异常 
     * */
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
        cause.printStackTrace();
        ctx.close();
    }
}

        其中需要注意的是channelRead0()方法,此方法接收到的可能是一些数据片段,比如服务器发送了5个字节数据,Client端不能保证一次全部收到,比如第一次收到3个字节,第二次收到2个字节。我们可能还会关心收到这些片段的顺序是否可发送顺序一致,这要看具体是什么协议,比如基于TCP协议的字节流是能保证顺序的。

        还有一点,在Client端我们的业务Handler继承的是SimpleChannelInboundHandler,而在服务器端继承的是ChannelInboundHandlerAdapter,那么这两个有什么区别呢?最主要的区别就是SimpleChannelInboundHandler在接收到数据后会自动release掉数据占用的Bytebuffer资源(自动调用Bytebuffer.release())。而为何服务器端不能用呢,因为我们想让服务器把客户端请求的数据发送回去,而服务器端有可能在channelRead方法返回前还没有写完数据,因此不能让它自动release。

  

文章来源:http://blog.csdn.net/suifeng3051/article/details/25238243

  • 大小: 187.8 KB
分享到:
评论

相关推荐

    跟闪电侠学Netty:Netty即时聊天实战与底层原理-book-netty.zip

    《跟闪电侠学Netty:Netty即时聊天实战与底层原理》是一本深入浅出的Netty技术指南,旨在帮助读者掌握Netty框架,并利用它实现即时聊天应用,同时理解其底层工作原理。Netty是Java领域的一款高性能、异步事件驱动的...

    精通并发与netty 无加密视频

    第1讲:学习的要义 第2讲:Netty宏观理解 第3讲:Netty课程大纲深度解读 第4讲:项目环境搭建与Gradle配置 第5讲:Netty执行流程分析与重要组件介绍 第6讲:Netty回调与Channel执行流程分析 第7讲:Netty的...

    Netty教程用户手册

    本手册主要介绍如何使用Netty来解决在网络应用开发过程中遇到的问题,并提供了一系列实践案例。 #### 二、Netty解决的实际问题 - **标题**:问题篇 - **描述**:现代网络应用经常使用通用的目的应用程序或库进行...

    Netty使用与实现.pdf

    Netty是一个高性能、异步事件驱动的网络应用程序框架,用于快速开发可维护的高性能协议服务器与客户端。它简化了网络程序的开发过程,提供了丰富的特性支持,使得开发者能够专注于业务逻辑的实现。 #### 二、...

    Netty权威指南 第2版

    Netty是一个高性能、异步事件驱动的网络应用程序框架,用于快速开发可维护的高性能协议服务器和客户端。Netty的核心理念是提供一个高效、灵活且易于使用的API,使得开发者能够专注于业务逻辑,而不是底层网络通信的...

    Netty权威指南 第2版 + 源码

    Netty 是一个高性能、异步事件驱动的网络应用程序框架,用于快速开发可维护的高性能协议服务器和客户端。作为Java领域的网络通信库,Netty在分布式系统、微服务架构以及游戏服务器开发等领域广泛应用。《Netty权威...

    netty的jar包全集

    - **入门指南**:介绍如何搭建Netty环境,创建第一个服务器和客户端程序。 - **核心概念**:详细解释EventLoop、Channel、Pipeline(管道)、Handler(处理器)等核心概念。 - **编码解码**:说明如何使用编码器和...

    EasyChatServer是一个简单的聊天IM软件后端程序,采用SpringBoot + Netty框架。提供了单.zip

    EasyChatServer是一个基于SpringBoot和Netty框架构建的简单聊天即时通讯(IM)软件后端程序。这个项目展示了如何将这两个强大的技术结合在一起,为实时通信应用提供稳定、高效的服务器支持。SpringBoot以其便捷的...

    Netty空闲检测&Keepalive.pdf

    - 默认情况下,操作系统会在一定时间内(通常是2小时)发送第一个探测帧。 - 如果对方无响应,操作系统会多次发送探测帧,直至确认连接已经断开。 ##### 3.3 应用场景 - 对于长时间无交互的连接(如某些后台服务)...

    基于NIO的Netty网络框架(详解)

    * 第一层:Reactor通信调度层。该层的主要职责就是监听网络的连接和读写操作,负责将网络层的数据读取到内存缓冲区中,然后触发各种网络事件,例如连接创建、连接激活、读事件、写事件等,将这些事件触发到Pipeline...

    MQTT---HiveMQ源码详解(十三)Netty-MQTT消息、事件处理(源码举例解读).pdf

    1. 防止重复连接:通过向管道(pipeline)中添加 MqttDisallowSecondConnect 来防止同一个客户端的第二次连接。 2. 校验 clientID:检查 clientID 是否合法,如果不符合规则则直接返回。 3. 设置接管标志:设置 MQTT...

    计算机网络管理实验报告.pdf

    Apache Kafka是一个分布式流处理平台,它被广泛地应用于构建实时数据管道和流应用程序。Kafka能够在服务端持久化消息,支持高吞吐量,并且具有出色的耐用性。在实验中,Kafka作为中间存储,负责接收爬虫模块发来的...

    8583报文及各域的详解

    * 描述:位图的第一位用于指示是否使用扩展位图(128个域),否则表示只使用基本位图(64个域)。如使用某数据域,应在位图中将相应的位设为'1'。 每个域的定义结构为: typedef struct ISO8583 { int bit_flag; ...

    第四课:Dubbo调用模块详解1

    【Dubbo调用模块详解1】 Dubbo作为一款高性能的Java RPC框架,其调用模块是其核心组件之一,负责发起远程方法调用并获取返回结果。本篇将详细解析Dubbo调用模块的基本组成、非典型使用场景以及内部实现源码分析。 ...

    有关J-QQ项目程序

    J-QQ项目程序是一个基于Java技术栈开发的与QQ相关的应用程序,它可能涉及网络通信、数据库操作、用户界面等多个关键领域。在这个项目中,开发者利用Java的强大功能来实现QQ的一些核心特性,如即时消息传递、好友管理...

    高并发编程实战1,2,3阶段

    #### 第一阶段:基础理论与实践入门 ##### 1. 高并发编程概述 - **定义**:高并发编程是指系统能够同时处理大量请求或任务的能力。 - **应用场景**:电商平台、社交网络、在线支付等需要处理海量用户访问的场景。 - ...

Global site tag (gtag.js) - Google Analytics