首页 / NETTY / Netty学习--基础组件

Netty学习--基础组件

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了Netty学习--基础组件，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含2874字，纯文字阅读大概需要5分钟。

内容图文

使用netty的开源框架

Dubbo：阿里开源的高性能rpc通讯框架

RocketMQ：阿里出品的高性能消息队列

Spark：为大规模数据处理设计的一款计算引擎

Elasticsearch,Cassandra,Flink,Netty-SocketIO,Spring5,Play,Grpc...

 

Netty是什么

  • 异步事件驱动框架，用户快速开发高性能服务端和客户端
  • 封装了JDK底层BIO和NIO模型，提供高可用的API
  • 自带编解码器解决拆包粘包问题，用户只用关心业务逻辑
  • 精心设计的reactor线程模型支持高并发海量连接
  • 自带各种协议栈可以在处理任何一种通用协议都不用亲自动手

Netty基本组件

在没有netty的情况下，客户端和服务端的通信

            
public class ServerBoot {

    private static final int PORT = 8000;

    public static void main(String[] args) {
   　　　// 启动一个server
        Server server = new Server(PORT);
        server.start();
    }
}

Server端的代码如下：

public class Server {

    private ServerSocket serverSocket;

    public Server(int port) {
        try {
　　　　　　　// 根据端口号绑定端口
            this.serverSocket = new ServerSocket(port);
            System.out.println("服务端启动成功，端口:" + port);
        } catch (IOException exception) {
            System.out.println("服务端启动失败");
        }
    }

    // 避免创建server的程序阻塞ServerBoot的主线程，所以把端口监听放到一个独立的线程中
    public void start() {
        new Thread(new Runnable() {
            @Override
            public void run() {
                doStart();
            }
        }).start();
    }
    
    // 接收客户端的连接
    private void doStart() {
        while (true) {
            try {
　　　　　　　　　 // 接收到客户端连接，accept是个阻塞方法,当一个客户端过来后才创建socket
                Socket client = serverSocket.accept();
  　　　　　　　　// 避免socket读写阻塞serverSocket.accept，所以ClientHandler需要新建一个线程
                new ClientHandler(client).start();
            } catch (IOException e) {
                System.out.println("服务端异常");
            }
        }
    }
}

 

ClientHandler代码如下：

public class ClientHandler {

    public static final int MAX_DATA_LEN = 1024;
    // 保存客户端socket
    private final Socket socket;

    public ClientHandler(Socket socket) {
        this.socket = socket;
    }

    public void start() {
        System.out.println("新客户端接入");
        new Thread(new Runnable() {
            @Override
            public void run() {
                doStart();
            }
        }).start();
    }

    private void doStart() {
        try {
            InputStream inputStream = socket.getInputStream();
　　　　　　　// 客户端与服务端通信
            while (true) {
                byte[] data = new byte[MAX_DATA_LEN];
                int len;
                while ((len = inputStream.read(data)) != -1) {
                    String message = new String(data, 0, len);
                    System.out.println("客户端传来消息: " + message);
                    socket.getOutputStream().write(data);
                }

            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

 

客户端Client的代码如下：

public class Client {
    private static final String HOST = "127.0.0.1";
    private static final int PORT = 9010;
    private static final int SLEEP_TIME = 5000;

    public static void main(String[] args) throws IOException {
        final Socket socket = new Socket(HOST, PORT);

        new Thread(new Runnable() {
            @Override
            public void run() {
                System.out.println("客户端启动成功!");
                while (true) {
                    try {
                        String message = "hello world";
                        System.out.println("客户端发送数据: " + message);
                        socket.getOutputStream().write(message.getBytes());
                    } catch (Exception e) {
                        System.out.println("写数据出错!");
                    }
                    sleep();
                }


            }
        }).start();

    }

    private static void sleep() {
        try {
            Thread.sleep(SLEEP_TIME);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

客户端与服务端通信的逻辑：

技术分享图片

 

服务端视角：

  1. 服务端首先监听端口
  2. 通过while(true)不断accept链接，如果客户端创建新的连接，服务端拿到连接,然后由处理器去处理客户端连接
  3. 服务端接收数据
  4. 服务端做业务逻辑处理
  5. 服务端发送数据给客户端

 

以上过程跟netty组件对应起来的关系如下：

 

原文：https://www.cnblogs.com/liekkas01/p/12639989.html

内容总结

以上是互联网集市为您收集整理的Netty学习--基础组件全部内容，希望文章能够帮你解决Netty学习--基础组件所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/1240613.html

来源：【匿名】