netty创建tcp (使用maven构建)

作者: 奋斗live | 来源:发表于2019-06-13 17:16 被阅读0次

netty创建tcp (使用maven构建)
Spring Boot+Mybatis项目总结
使用Maven来进行项目的创建、构建测试和文档的生成
springboot创建maven聚合项目(附下载demo)
ElasticSearch 基于Netty的通信原理
Android中SSL通信中使用的bks格式证书的生成
Spring小记(1)：构建一个Maven的Spring项目
Node.js 网络开发
Android简单使用netty及谷歌的protobuf
没错,请求DNS服务器还可以使用UDP协议

一、环境

java 版本 1.8.0_181

二、项目结构

项目结构如下图所示

image.png

三、导入必要的依赖

以下是pom.xml的配置

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>netty_tcp_test</groupId>
    <artifactId>netty_tcp_test</artifactId>
    <version>1.0-SNAPSHOT</version>

    <properties>
        <netty.version>4.1.25.Final</netty.version>
        <os.detected.classifier>linux-x86_64</os.detected.classifier>
    </properties>

    <dependencies>
        <!-- https://mvnrepository.com/artifact/io.netty/netty-all -->
        <dependency>
            <groupId>io.netty</groupId>
            <artifactId>netty-codec</artifactId>
            <version>${netty.version}</version>
        </dependency>
        <dependency>
            <groupId>io.netty</groupId>
            <artifactId>netty-transport</artifactId>
            <version>${netty.version}</version>
        </dependency>
        <dependency>
            <groupId>io.netty</groupId>
            <artifactId>netty-transport-native-epoll</artifactId>
            <version>${netty.version}</version>
            <classifier>${os.detected.classifier}</classifier>
        </dependency>
        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <version>4.12</version>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>io.netty</groupId>
            <artifactId>netty-codec-http</artifactId>
            <version>${netty.version}</version>
        </dependency>
        <dependency>
            <groupId>io.netty</groupId>
            <artifactId>netty-handler</artifactId>
            <version>${netty.version}</version>
        </dependency>
        <dependency>
            <groupId>io.netty</groupId>
            <artifactId>netty-transport-udt</artifactId>
            <version>${netty.version}</version>
        </dependency>
        <dependency>
            <groupId>io.netty</groupId>
            <artifactId>netty-transport-sctp</artifactId>
            <version>${netty.version}</version>
        </dependency>

    </dependencies>
</project>

三、创建客户端代码

TcpClient的 main代码

package tcp;

import io.netty.bootstrap.Bootstrap;
import io.netty.channel.*;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.nio.NioSocketChannel;
import io.netty.handler.codec.LengthFieldBasedFrameDecoder;
import io.netty.handler.codec.LengthFieldPrepender;
import io.netty.handler.codec.serialization.ClassResolvers;
import io.netty.handler.codec.serialization.ObjectDecoder;
import io.netty.handler.codec.serialization.ObjectEncoder;
import org.omg.PortableServer.POA;

public class TcpClient {

    public static String HOST = "127.0.0.1";

    public static int PORT = 12340;

    public static Bootstrap bootstrap=getBootstrap();

    public static Channel channel = getChannel(HOST,PORT);

    public static final Bootstrap getBootstrap(){
        EventLoopGroup group = new NioEventLoopGroup();
        Bootstrap bootstrap = new Bootstrap();
        bootstrap.group(group).channel(NioSocketChannel.class);
        bootstrap.handler(new ChannelInitializer<Channel>() {
            @Override
            protected void initChannel(Channel ch) throws Exception{

                ChannelPipeline pipeline = ch.pipeline();
                pipeline.addLast("frameDecoder",new LengthFieldBasedFrameDecoder(Integer.MAX_VALUE,0,4,0,4));
                pipeline.addLast("frameEncoder",new LengthFieldPrepender(4));
                pipeline.addLast(new ObjectEncoder());
                pipeline.addLast(new ObjectDecoder(ClassResolvers.cacheDisabled(null)));
                pipeline.addLast("handler",new TcpClientHandler());
            }
        });
        bootstrap.option(ChannelOption.SO_KEEPALIVE,true);
        return bootstrap;
    }

    public static final Channel getChannel(String HOST, int PORT){
        Channel channel = null;
        try{
            channel = bootstrap.connect(HOST,PORT).sync().channel();
            System.out.println("连接成功");
        }catch (Exception e){
            System.out.println("连接server(IP{},PROT{})失败");
            return null;
        }
        return channel;
    }

    public static void sendMsg(Object msg) throws Exception{
        if(channel!=null){
            channel.writeAndFlush(msg).sync();
        }else{
            System.out.println("消息发送失败，连接尚未建立");
        }
    }

}

处理器TcpClientHandler代码

package tcp;

import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.SimpleChannelInboundHandler;

public class TcpClientHandler extends SimpleChannelInboundHandler<Object> {
    @Override
    protected void channelRead0(ChannelHandlerContext ctx,Object msg) throws Exception{

    }
}

四、创建服务端代码

TcpServer服务端的main代码

package tcp;

import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.*;
import io.netty.channel.nio.NioEventLoop;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.SocketChannel;
import io.netty.channel.socket.nio.NioServerSocketChannel;
import io.netty.handler.codec.LengthFieldBasedFrameDecoder;
import io.netty.handler.codec.LengthFieldPrepender;
import io.netty.handler.codec.serialization.ClassResolvers;
import io.netty.handler.codec.serialization.ObjectDecoder;
import io.netty.handler.codec.serialization.ObjectEncoder;
import org.omg.CORBA.PUBLIC_MEMBER;

public class TcpServer {

    private static final String IP = "192.168.1.154";
    private static final int PORT = 12340;

    /*处理业务线程的线程组个数*/

    protected static final int BIZGROUPSIZE = Runtime.getRuntime().availableProcessors()*2;//默认

    /*业务出现线程大小*/
    protected static final int BIZTHREADSIZE=4;
    /*
     * NioEventLoopGroup实际上就是个线程池,
     * NioEventLoopGroup在后台启动了n个NioEventLoop来处理Channel事件,
     * 每一个NioEventLoop负责处理m个Channel,
     * NioEventLoopGroup从NioEventLoop数组里挨个取出NioEventLoop来处理Channel
     */
    private static final EventLoopGroup bossGroup = new NioEventLoopGroup(BIZGROUPSIZE);

    private static final EventLoopGroup workerGroup = new NioEventLoopGroup(BIZTHREADSIZE);

    protected static void shutdown(){
        workerGroup.shutdownGracefully();
        bossGroup.shutdownGracefully();
    }

    public static void run() throws Exception{
        ServerBootstrap b = new ServerBootstrap();
        b.group(bossGroup,workerGroup);
        b.channel(NioServerSocketChannel.class);
        b.childHandler(new ChannelInitializer<SocketChannel>() {

            @Override
            public void initChannel(SocketChannel ch) throws Exception{
                ChannelPipeline pipeline = ch.pipeline();
                pipeline.addLast("frameDecoder",new LengthFieldBasedFrameDecoder(Integer.MAX_VALUE,0,4,0,4));
                pipeline.addLast("frameEncoder",new LengthFieldPrepender(4));
                pipeline.addLast(new ObjectEncoder());
                pipeline.addLast(new ObjectDecoder(ClassResolvers.cacheDisabled(null)));
                pipeline.addLast(new TcpServerHandler());
            }
        });
        //标识当服务器请求处理线程全满时，用于临时存放已完成三次握手的请求的队列的最大长度
        b.option(ChannelOption.SO_BACKLOG,1024);
        //是否启用心跳保或机制
        b.childOption(ChannelOption.SO_KEEPALIVE,true);
        //绑定端口 开启监听
        ChannelFuture channelFuture = b.bind(PORT).sync();
        if(channelFuture.isSuccess()){
            System.out.println(("Tcp服务启动成功---"));
        }
        //获取channel的closeFuture，并且阻塞当前线程直到它完成
        channelFuture.channel().closeFuture().sync();

    }
    public static void main(String[] args) throws Exception{
        TcpServer.run();
    }
}

创建TcpServerHandler处理器代码

package tcp;

import io.netty.buffer.ByteBuf;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.SimpleChannelInboundHandler;
import io.netty.util.CharsetUtil;

public class TcpServerHandler extends SimpleChannelInboundHandler<Object> {

    @Override
    protected void channelRead0(ChannelHandlerContext ctx,Object msg) throws Exception{
        System.out.println("server received:"+msg.toString());
        ctx.write(msg);
    }

    @Override
    public  void exceptionCaught(ChannelHandlerContext ctx,Throwable cause) throws Exception{
        ctx.close();
    }

}

五、单元测试代码

客户端单元测试TcpClientTest

package tcp;

import org.junit.Test;

import static org.junit.Assert.*;

public class TcpClientTest {

    @Test
    public void sendMsg() {
        try{
            TcpClient.sendMsg("henhao");
        }catch (Exception e){

        }

    }
}

服务端单元测试 TcpServerTest

package tcp;

import org.junit.Test;

import static org.junit.Assert.*;

public class TcpServerTest {

   public static void main(String[] args){
       start();
   }

   @Test
   public void testServer(){
       start();
   }

   public static void start(){
       try{
           TcpServer.main(null);
       }catch (Exception e){

       }

   }
}

netty创建tcp (使用maven构建)
一、环境 java 版本 1.8.0_181 二、项目结构项目结构如下图所示三、导入必要的依赖以下是pom....
Spring Boot+Mybatis项目总结
IDEA创建maven项目使用IDEA创建maven项目，勾选从模板原型构建，这里选择maven-archety...
使用Maven来进行项目的创建、构建测试和文档的生成
Maven 使用原型（archetype）插件创建工程创建好的工程目录树构建工程构建好的工程目录树生成工程...
springboot创建maven聚合项目(附下载demo)
maven介绍使用idea构建聚合工程1. 创建父工程2. 创建子工程3. 添加项目依赖4. 添加maven依赖...
ElasticSearch 基于Netty的通信原理
ElasticSearch由Transport负责通信，基于TCP通信采用Netty实现，采用Plugin构建，具...
Android中SSL通信中使用的bks格式证书的生成
上一篇Android开发之基于Netty的TCP连接中使用SSL加密提到需要加载jks格式的证书来构建SSLCon...
Spring小记(1)：构建一个Maven的Spring项目
通过maven构建项目是一件很简单的事情，下面我们使用Maven来构建一个Spring的项目1、首先创建一个mav...
Node.js 网络开发
Node.js 的网络通信模块：构建 TCP 服务器使用 Node.js 创建 TCP 服务器同上除了 l...
Android简单使用netty及谷歌的protobuf
文章主要内容 netty TCP NIO服务端、客户端简单使用 netty UDP NIO使用谷歌protobu...
没错,请求DNS服务器还可以使用UDP协议
简介之前我们讲到了如何在netty中构建client向DNS服务器进行域名解析请求。使用的是最常见的TCP协议，...