Spring Boot集成netty实现客户端服务端交互示例详解

<!--netty-->

<dependency>

  <groupid>io.netty</groupid>

  <artifactid>netty-all</artifactid>

  <version> 4.1 . 32 . final </version>

</dependency>

netty:

  port: 7000

  url: 172.16 . 0.7

package com.safelocate.app.nettyserver;

import io.netty.bootstrap.serverbootstrap;

import io.netty.channel.*;

import io.netty.channel.nio.nioeventloopgroup;

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

import org.apache.log4j.logger;

import org.springframework.stereotype测试数据ponent;

import java.net.inetsocketaddress;

@component

public class nettyserver {

  //logger

  private static final logger logger = logger.getlogger(nettyserver. class );

  public void start(inetsocketaddress address){

  eventloopgroup bossgroup = new nioeventloopgroup( 1 );

  eventloopgroup workergroup = new nioeventloopgroup();

  try {

   serverbootstrap bootstrap = new serverbootstrap()

    .group(bossgroup,workergroup)

    .channel(nioserversocketchannel. class )

    .localaddress(address)

    .childhandler( new serverchannelinitializer())

    .option(channeloption.so_backlog, 128 )

    .childoption(channeloption.so_keepalive, true );

   // 绑定端口，开始接收进来的连接

   channelfuture future = bootstrap.bind(address).sync();

   logger.info( "server start listen at " + address.getport());

   future.channel().closefuture().sync();

  } catch (exception e) {

   e.printstacktrace();

   bossgroup.shutdowngracefully();

   workergroup.shutdowngracefully();

  }

  }

}

package com.safelocate.app.nettyserver;

import io.netty.channel.channelinitializer;

import io.netty.channel.socket.socketchannel;

import io.netty.handler.codec.string.stringdecoder;

import io.netty.handler.codec.string.stringencoder;

import io.netty.util.charsetutil;

public class serverchannelinitializer extends channelinitializer<socketchannel> {

  @override

  protected void initchannel(socketchannel channel) throws exception {

  channel.pipeline().addlast( "decoder" , new stringdecoder(charsetutil.utf_8));

  channel.pipeline().addlast( "encoder" , new stringencoder(charsetutil.utf_8));

  channel.pipeline().addlast( new serverhandler());

  }

}

package com.safelocate.app.nettyserver;

import io.netty.channel.channelhandlercontext;

import io.netty.channel.channelinboundhandleradapter;

import io.netty.channel.simplechannelinboundhandler;

import java.io.ioexception;

import java.io.outputstream;

import java.io.printwriter;

import java.net.inetaddress;

import java.net.socket;

public class serverhandler extends channelinboundhandleradapter {

  @override

  public void channelactive(channelhandlercontext ctx) {

  system.out.println( "channelactive----->" );

  }

  @override

  public void channelread(channelhandlercontext ctx, object msg) throws exception {

  system.out.println( "server channelread......" );

  system.out.println(ctx.channel().remoteaddress()+ "----->server :" + msg.tostring());

  //将客户端的信息直接返回写入ctx

  ctx.write( "server say :" +msg);

  //刷新缓存区

  ctx.flush();

  }

  @override

  public void exceptioncaught(channelhandlercontext ctx, throwable cause) throws exception {

  cause.printstacktrace();

  ctx.close();

  }

}

package com.safelocate.app;

import com.safelocate.app.nettyserver.nettyserver;

import io.netty.channel.channelfuture;

import org.springframework.beans.factory.annotation.autowired;

import org.springframework.beans.factory.annotation.value;

import org.springframework.boot测试数据mandlinerunner;

import org.springframework.boot.springapplication;

import org.springframework.boot.autoconfigure.springbootapplication;

import java.net.inetaddress;

import java.net.inetsocketaddress;

@springbootapplication

public class appapplication implements commandlinerunner {

  @value ( "${netty.port}" )

  private int port;

  @value ( "${netty.url}" )

  private string url;

  @autowired

  private nettyserver server;

  public static void main(string[] args) {

  springapplication.run(appapplication. class , args);

  }

  @override

  public void run(string... args) throws exception {

  inetsocketaddress address = new inetsocketaddress(url,port);

  system.out.println( "run .... . ... " +url);

  server.start(address);

  }

}

package client;

import io.netty.channel.channelhandlercontext;

import io.netty.channel.channelinboundhandleradapter;

public class clienthandler extends channelinboundhandleradapter {

  @override

  public void channelactive(channelhandlercontext ctx) {

  system.out.println( "clienthandler active" );

  }

  @override

  public void channelread(channelhandlercontext ctx, object msg) {

  system.out.println( "--------" );

  system.out.println( "clienthandler read message:" +msg);

  }

  @override

  public void exceptioncaught(channelhandlercontext ctx, throwable cause) {

  cause.printstacktrace();

  ctx.close();

  }

}

package client;

import io.netty.channel.channelinitializer;

import io.netty.channel.channelpipeline;

import io.netty.channel.socket.socketchannel;

import io.netty.handler.codec.string.stringdecoder;

import io.netty.handler.codec.string.stringencoder;

import io.netty.util.charsetutil;

public class clientchannelinitializer extends channelinitializer<socketchannel> {

  protected void initchannel(socketchannel channel) throws exception {

  channelpipeline p = channel.pipeline();

  p.addlast( "decoder" , new stringdecoder(charsetutil.utf_8));

  p.addlast( "encoder" , new stringencoder(charsetutil.utf_8));

  p.addlast( new clienthandler());

  }

}

package client;

import io.netty.bootstrap.bootstrap;

import io.netty.channel.*;

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.stringdecoder;

import io.netty.handler.codec.string.stringencoder;

public class client {

  static final string host = system.getproperty( "host" , "服务器的ip地址" );

  static final int port = integer.parseint(system.getproperty( "port" , "7000" ));

  static final int size = integer.parseint(system.getproperty( "size" , "256" ));

  public static void main(string[] args) throws exception {

  sendmessage( "hhhh" );

  }

  public static void sendmessage(string content) throws interruptedexception{

  // configure the client.

  eventloopgroup group = new nioeventloopgroup();

  try {

   bootstrap b = new bootstrap();

   b.group(group)

    .channel(niosocketchannel. class )

    .option(channeloption.tcp_nodelay, true )

    .handler( new channelinitializer<socketchannel>() {

    @override

    public void initchannel(socketchannel ch) throws exception {

     channelpipeline p = ch.pipeline();

     p.addlast( "decoder" , new stringdecoder());

     p.addlast( "encoder" , new stringencoder());

     p.addlast( new clienthandler());

    }

    });

   channelfuture future = b.connect(host, port).sync();

   future.channel().writeandflush(content);

   future.channel().closefuture().sync();

  } finally {

   group.shutdowngracefully();

  }

  }

}