一個簡單的Netty-EchoDemo

I_Am 發(fā)布于2019-08-19 10:35 / 1161人閱讀

摘要：它甚至使用不安全的偽隨機生成器在內部更快地生成項目源碼一個簡單的應答通訊的實例判斷是否加密監(jiān)聽本地服務監(jiān)聽端口發(fā)送消息的大小，用于公共抽象類，安全套接字協(xié)議實現(xiàn)充當工廠和。

本博客貓叔的博客，轉載請申明出處

閱讀本文約 “4分鐘”

適讀人群：Java-Netty 初級

Echo簡易通訊案例

版本：netty 4.1.*

申明：本文旨在重新分享討論Netty官方相關案例，添加部分個人理解與要點解析。

這個是InChat的案例地址，里面補充了詳細的注釋，比起官方會容易看一點。

官方案例地址：https://netty.io/4.1/xref/io/...

正文

EchoClient（客戶端）

EchoClientHandler

EchoServer（服務端）

EchoServerHandler

要點介紹

SslContext

官方介紹：https://netty.io/4.1/api/io/n...

公共抽象類，安全套接字協(xié)議實現(xiàn)充當工廠SSLEngine和SslHandler。在內部，它通過JDK SSLContext或OpenSSL 實現(xiàn)SSL_CTX，還有關于它的使用方式，如果你需要ssl加密的話

SslContextBuilder

官方介紹：https://netty.io/4.1/api/io/n...

用于配置新SslContext以進行創(chuàng)建的構建器，其中包含多個方法這里就不多補充，大家可以去看看

InsecureTrustManagerFactory

官方介紹：https://netty.io/4.1/api/io/n...

在TrustManagerFactory沒有任何驗證的情況下信任所有X.509證書的不安全因素

注意：切勿TrustManagerFactory在生產(chǎn)中使用它。它純粹是出于測試目的，因此非常不安全。

SelfSignedCertificate

官方介紹：https://netty.io/4.1/api/io/n...

生成臨時自簽名證書以進行測試

注意：切勿在生產(chǎn)中使用此類生成的證書和私鑰。它純粹是出于測試目的，因此非常不安全。它甚至使用不安全的偽隨機生成器在內部更快地生成

項目源碼

EchoClient

/**
 * @ClassName EchoClient
 * @Description 一個簡單的應答通訊的實例
 * @Author MySelf
 * @Date 2019/8/17 17:56
 * @Version 1.0
 **/
public final class EchoClient {

    //判斷是否加密
    static final boolean SSL = System.getProperty("ssl") != null;
    //監(jiān)聽本地服務
    static final String HOST = System.getProperty("host", "127.0.0.1");
    //監(jiān)聽端口
    static final int PORT = Integer.parseInt(System.getProperty("port", "8007"));
    //發(fā)送消息的大小，用于EchoClientHandler
    static final int SIZE = Integer.parseInt(System.getProperty("size", "256"));

    public static void main(String[] args) throws Exception {
        //公共抽象類，安全套接字協(xié)議實現(xiàn)充當工廠SSLEngine和SslHandler。在內部，它通過JDK SSLContext或OpenSSL 實現(xiàn)SSL_CTX
        final SslContext sslCtx;
        if (SSL){
            //用于配置新SslContext以進行創(chuàng)建的構建器
            sslCtx = SslContextBuilder.forClient()
                    //用于驗證遠程端點證書的可信管理器
                    //InsecureTrustManagerFactory:在TrustManagerFactory沒有任何驗證的情況下信任所有X.509證書的不安全因素
                    //注：切勿TrustManagerFactory在生產(chǎn)中使用它。它純粹是出于測試目的，因此非常不安全。
                    .trustManager(InsecureTrustManagerFactory.INSTANCE).build();
        }else {
            sslCtx = null;
        }
        //事件循環(huán)
        EventLoopGroup group = new NioEventLoopGroup();
        try {
            Bootstrap b = new Bootstrap();
            b.group(group)
                    .channel(NioSocketChannel.class)
                    .option(ChannelOption.TCP_NODELAY,true)
                    .handler(new ChannelInitializer() {
                        @Override
                        protected void initChannel(SocketChannel sc) throws Exception {
                            ChannelPipeline p = sc.pipeline();
                            //了解SslContext的用法
                            if (sslCtx != null){
                                p.addLast(sslCtx.newHandler(sc.alloc(),HOST,PORT));
                            }
                            p.addLast(new EchoClientHandler());
                        }
                    });
            //這個sync后的代碼均會執(zhí)行
            ChannelFuture f = b.connect(HOST,PORT).sync();
            System.out.println("before-----");

            //這個sync后的代碼不會執(zhí)行
            f.channel().closeFuture().sync();
            System.out.println("after-----");
        }finally {
            group.shutdownGracefully();
        }
    }

}

EchoClientHandler

/**
 * @ClassName EchoClientHandler
 * @Description TODO
 * @Author MySelf
 * @Date 2019/8/17 18:06
 * @Version 1.0
 **/
public class EchoClientHandler extends ChannelInboundHandlerAdapter {

    private final ByteBuf firstMessage;

    public EchoClientHandler(){
        //獲取EchoClient的SIZE
        //Unpooled:ByteBuf通過分配新空間或通過包裝或復制現(xiàn)有字節(jié)數(shù)組，字節(jié)緩沖區(qū)和字符串來創(chuàng)建新的
        firstMessage = Unpooled.buffer(EchoClient.SIZE);
        for (int i = 0; i < firstMessage.capacity(); i++){
            firstMessage.writeByte((byte)i);
        }
    }

    @Override
    public void channelActive(ChannelHandlerContext ctx) throws Exception {
        ctx.writeAndFlush(firstMessage);
    }

    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
        ctx.write(msg);
    }

    @Override
    public void channelReadComplete(ChannelHandlerContext ctx) throws Exception {
        ctx.flush();
    }

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

EchoServer

/**
 * @ClassName EchoServer
 * @Description 服務端
 * @Author MySelf
 * @Date 2019/8/17 18:15
 * @Version 1.0
 **/
public final class EchoServer {

    static final boolean SSL = System.getProperty("ssl") != null;
    static final int PORT = Integer.parseInt(System.getProperty("port", "8007"));

    public static void main(String[] args) throws Exception {
        final SslContext sslCtx;
        if (SSL){
            //SelfSignedCertificate:生成臨時自簽名證書以進行測試
            SelfSignedCertificate ssc = new SelfSignedCertificate();
            sslCtx = SslContextBuilder.forServer(ssc.certificate(), ssc.privateKey()).build();
        }else{
            sslCtx = null;
        }

        EventLoopGroup bossGroup = new NioEventLoopGroup(1);
        EventLoopGroup workerGroup = new NioEventLoopGroup();
        final EchoServerHandler serverHandler = new EchoServerHandler();
        try {
            ServerBootstrap b = new ServerBootstrap();
            b.group(bossGroup,workerGroup)
                    .channel(NioServerSocketChannel.class)
                    .option(ChannelOption.SO_BACKLOG,100)
                    .handler(new LoggingHandler(LogLevel.INFO))
                    .childHandler(new ChannelInitializer() {
                        @Override
                        protected void initChannel(SocketChannel ch) throws Exception {
                            ChannelPipeline p = ch.pipeline();
                            if (sslCtx != null){
                                p.addLast(sslCtx.newHandler(ch.alloc()));
                            }
                            p.addLast(serverHandler);
                        }
                    });

            ChannelFuture f = b.bind(PORT).sync();

            f.channel().closeFuture().sync();

        }finally {
            bossGroup.shutdownGracefully();
            workerGroup.shutdownGracefully();
        }

    }

}

EchoServerHandler

/**
 * @ClassName EchoServerHandler
 * @Description TODO
 * @Author MySelf
 * @Date 2019/8/17 18:14
 * @Version 1.0
 **/
@ChannelHandler.Sharable
public class EchoServerHandler extends ChannelInboundHandlerAdapter {
    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
        ctx.write(msg);
    }

    @Override
    public void channelReadComplete(ChannelHandlerContext ctx) throws Exception {
        ctx.flush();
    }

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

公眾號：Java貓說

學習交流群：728698035

現(xiàn)架構設計（碼農(nóng)）兼創(chuàng)業(yè)技術顧問，不羈平庸，熱愛開源，雜談程序人生與不定期干貨。

云服務器 GPU云服務器簡單編寫一個html 您編一個簡單點的簡單的簡單的爬蟲

文章版權歸作者所有，未經(jīng)允許請勿轉載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。

轉載請注明本文地址：http://specialneedsforspecialkids.com/yun/76274.html

最近老是有兄弟問我，Vue雙向綁定的原理，以及簡單的原生js寫出來實現(xiàn)，我就來一個最簡單的雙向綁定，

摘要：廢話不多說直接看效果圖代碼很好理解，但是在看代碼之前需要知道雙向綁定的原理其實就是基于實現(xiàn)的雙向綁定官方傳送門這里我們用官方的話來說方法會直接在一個對象上定義一個新屬性，或者修改一個對象的現(xiàn)有屬性，并返回這個對象。廢話不多說直接看效果圖 showImg(https://segmentfault.com/img/bVbiYY5?w=282&h=500); 代碼很好理解，但是在看代碼之前...

zhangfaliang 2019-08-02 11:52 評論0 收藏0
最近老是有兄弟問我，Vue雙向綁定的原理，以及簡單的原生js寫出來實現(xiàn)，我就來一個最簡單的雙向綁定，

摘要：廢話不多說直接看效果圖代碼很好理解，但是在看代碼之前需要知道雙向綁定的原理其實就是基于實現(xiàn)的雙向綁定官方傳送門這里我們用官方的話來說方法會直接在一個對象上定義一個新屬性，或者修改一個對象的現(xiàn)有屬性，并返回這個對象。廢話不多說直接看效果圖 showImg(https://segmentfault.com/img/bVbiYY5?w=282&h=500); 代碼很好理解，但是在看代碼之前...

aristark 2019-08-23 12:40 評論0 收藏0
Express + Ejs實現(xiàn)一個簡單的WebServer

摘要：最近在看，讀完官方的起步教程后想著該自己折騰點東西，就先用實現(xiàn)一個超簡單的，主要記錄下思路。先推薦一個入門級的簡單實戰(zhàn)項目地址。不過鑒于初學，自身的思路肯定不會是最佳實踐，慢慢積累。最近在看node.js，讀完官方的起步教程后想著該自己折騰點東西，就先用express + ejs實現(xiàn)一個超簡單的webserver，主要記錄下思路。先推薦一個nodejs入門級的簡單實戰(zhàn)項目地址。很適合...

Tonny 2019-08-20 16:06 評論0 收藏0
JavaScript工廠模式

摘要：基于工廠角色和產(chǎn)品角色的多態(tài)性設計是工廠方法模式的關鍵。工廠方法模式之所以又被稱為多態(tài)工廠模式，是因為所有的具體工廠類都具有同一抽象父類。工廠方法模式總結工廠方法模式是簡單工廠模式的進一步抽象和推廣。 JavaScript工廠模式首先需要說一下工廠模式。工廠模式根據(jù)抽象程度的不同分為三種簡單工廠模式工廠方法模式抽象工廠模式 1.簡單工廠模式簡單工廠模式:又稱為靜態(tài)工廠方法...

oujie 2019-08-21 18:33 評論0 收藏0