通过入门demo简单了解netty使用方法

这篇文章主要介绍了通过入门demo简单了解netty使用方法,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下

前言

最近做一个项目：

大概需求：多个温度传感器不断向java服务发送温度数据，该传感器采用socket发送数据；该数据以$符号开头和结尾，最后将处理的数据存入数据库；

我想到的处理方式：采用netty来接收和处理数据，然后用mybatis将处理后的数据存入数据库；

我在这之前从来没使用过netty，在网上倒是看到不少关于netty的文章，如今就趁着这个项目写一下我所学到的东西和遇到的问题，又是怎么去解决的；

接下来的几篇文章都是围绕着这个项目来写的；本篇主要写netty的入门demo；

正文

代码部分

新建一个maven项目

首先在pom.xml中导入：

 <!-- https://mvnrepository.com/artifact/io.netty/netty-all -->
    <dependency>
      <groupId>io.netty</groupId>
      <artifactId>netty-all</artifactId>
      <version>5.0.0.Alpha1</version>
    </dependency>

服务端
1. DiscardServer类，netty的服务端

public class DiscardServer {
  public void run(int port) throws Exception {
    EventLoopGroup bossGroup = new NioEventLoopGroup();
    EventLoopGroup workerGroup = new NioEventLoopGroup();
    System.out.println("准备运行端口：" + port);
    try {
      ServerBootstrap b = new ServerBootstrap();
      b = b.group(bossGroup, workerGroup)
          .channel(NioServerSocketChannel.class)
          .option(ChannelOption.SO_BACKLOG, 128)
          .childHandler(new ChildChannelHandler());
      //绑定端口，同步等待成功
      ChannelFuture f = b.bind(port).sync();
      //等待服务监听端口关闭
      f.channel().closeFuture().sync();
    } finally {
      //退出，释放线程资源
      workerGroup.shutdownGracefully();
      bossGroup.shutdownGracefully();
    }
  }
  public static void main(String[] args) throws Exception {
    new DiscardServer().run(8080);
  }
}

2. ChildChannelHandler类：

public class ChildChannelHandler extends ChannelInitializer<SocketChannel> {

  protected void initChannel(SocketChannel socketChannel) throws Exception {
    socketChannel.pipeline().addLast(new DiscardServerHandler());
  }
}

3. DiscardServerHandler类

在这里是继承的ChannelHandlerAdapter类，当然还可以继承其他的类，例如SimpleChannelInboundHandler，ChannelInboundHandlerAdapter都可以

public class DiscardServerHandler extends ChannelHandlerAdapter {
  @Override
  public void channelRead(ChannelHandlerContext ctx, Object msg) {

    try {
      ByteBuf in = (ByteBuf) msg;
      System.out.println("传输内容是");
      System.out.println(in.toString(CharsetUtil.UTF_8));
      ByteBuf resp= Unpooled.copiedBuffer("收到信息$".getBytes());
      ctx.writeAndFlush(resp);
    } finally {
      ReferenceCountUtil.release(msg);
    }
  }
  @Override
  public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
    // 出现异常就关闭
    cause.printStackTrace();
    ctx.close();
  }
}

启动netty服务；

好了，到这里就能开始接收数据了；

客服端

1.TimeClient类

public class TimeClient {
  public void connect(int port,String host)throws Exception{
    //配置客户端
    System.out.println(port+"--"+host);
    EventLoopGroup eventLoopGroup=new NioEventLoopGroup();
    try {
      Bootstrap b=new Bootstrap();
      b.group(eventLoopGroup).channel(NioSocketChannel.class)
          .option(ChannelOption.TCP_NODELAY,true)
          .handler(new ChannelInitializer<SocketChannel>() {
            protected void initChannel(SocketChannel socketChannel) throws Exception {
              socketChannel.pipeline().addLast(new TimeClientHandler());
            }
          });
      //绑定端口，同步等待成功
      ChannelFuture f = b.connect(host,port).sync();
      //等待服务监听端口关闭
      f.channel().closeFuture().sync();
    }finally {
      //优雅退出，释放线程资源
      eventLoopGroup.shutdownGracefully();
    }
  }
  public static void main(String[] args) throws Exception {
    new TimeClient().connect(8090,"localhost");
  }
}

2.TimeClientHandler 类

public class TimeClientHandler extends ChannelHandlerAdapter {
  private byte[] req;
  public TimeClientHandler(){
    req="$tmb00035ET3318/08/22 11:5704026.75,027.31,20.00,20.00$".getBytes();
  }
  @Override
  public void channelActive(ChannelHandlerContext ctx) throws Exception {
    ByteBuf message=nZ4+R"+R"+R"+R"+R"+R"+R"+R"4("G&"j^c4(L4(4(4(rv"G>rgr7*jjbn3&"Gg"rZbGJ3:RV6cr'b.2J32j^cOc>kj#疾22j^cr'7*{/>R1	J1MB#63v.">R"GZWv&皺+_vjr.22j^g?bBB#kj"g7BV6/"Gzsr7*rbjw"b&O6j"r7*r'>G3kn'3&O66Z>b"G^G*jOror'

*r'rZc2bkkn+Z啑ех}rvbrZj3ro疒j惚r'&*rokkR2