一個簡單的Netty-EchoDemo

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

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

本博客貓叔的博客，轉(zhuǎn)載請申明出處

閱讀本文約 “4分鐘”

適讀人群：Java-Netty 初級

Echo簡易通訊案例

版本：netty 4.1.*申明：本文旨在重新分享討論Netty官方相關(guān)案例，添加部分個人理解與要點(diǎn)解析。

這個是InChat的案例地址，里面補(bǔ)充了詳細(xì)的注釋，比起官方會容易看一點(diǎn)。

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

正文

EchoClient（客戶端）

EchoClientHandler

EchoServer（服務(wù)端）

EchoServerHandler

要點(diǎn)介紹

SslContext

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

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

SslContextBuilder

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

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

InsecureTrustManagerFactory

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

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

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

SelfSignedCertificate

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

生成臨時自簽名證書以進(jìn)行測試

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

項(xiàng)目源碼

EchoClient

/**
 * @ClassName EchoClient
 * @Description 一個簡單的應(yīng)答通訊的實(shí)例
 * @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)聽本地服務(wù)
    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é)議實(shí)現(xiàn)充當(dāng)工廠SSLEngine和SslHandler。在內(nèi)部，它通過JDK SSLContext或OpenSSL 實(shí)現(xiàn)SSL_CTX
        final SslContext sslCtx;
        if (SSL){
            //用于配置新SslContext以進(jìn)行創(chuàng)建的構(gòu)建器
            sslCtx = SslContextBuilder.forClient()
                    //用于驗(yàn)證遠(yuǎn)程端點(diǎn)證書的可信管理器
                    //InsecureTrustManagerFactory:在TrustManagerFactory沒有任何驗(yàn)證的情況下信任所有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通過分配新空間或通過包裝或復(fù)制現(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 服務(wù)端
 * @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:生成臨時自簽名證書以進(jìn)行測試
            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貓說

學(xué)習(xí)交流群：728698035

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

云服務(wù)器 GPU云服務(wù)器簡單編寫一個html 您編一個簡單點(diǎn)的簡單的簡單的爬蟲

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

轉(zhuǎn)載請注明本文地址：http://m.specialneedsforspecialkids.com/yun/76274.html

發(fā)表評論

登陸后可評論

0條評論

I_Am

男|高級講師

我要關(guān)注我要私信

TA的文章

[ C語言 ] 掃雷 ------＞用C語言實(shí)現(xiàn)game2

閱讀 3614·2021-11-15 11:38
leetcode300-每日刷題檔

閱讀 2810·2021-11-11 16:55
oneinstack+lnmp：nginx編譯Nginx fastcgi_cache模塊

閱讀 2562·2021-11-08 13:22
racknerd便宜VPS收集整理

閱讀 2639·2021-11-02 14:45
一名合格的軟件測試工程師該有的3種思維方式

閱讀 1321·2021-09-28 09:35
爆肝一周，用Python在物聯(lián)網(wǎng)設(shè)備上寫了個智能語音助手

閱讀 2596·2021-09-10 10:50
前端面試每日3+1——第104天

閱讀 471·2019-08-30 15:44
實(shí)習(xí)項(xiàng)目開發(fā)總結(jié)

閱讀 2787·2019-08-29 17:06

国产xxxx99真实实拍_久久不雅视频_高清韩国a级特黄毛片_嗯老师别我我受不了了小说

資訊專欄INFORMATION COLUMN

上云采購季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺、長期優(yōu)惠，快來選購！

一個簡單的Netty-EchoDemo

相關(guān)文章

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

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

Express + Ejs實(shí)現(xiàn)一個簡單的WebServer

JavaScript工廠模式

發(fā)表評論

0條評論

I_Am

男|高級講師

TA的文章

[ C語言 ] 掃雷 ------＞用C語言實(shí)現(xiàn)game2

leetcode300-每日刷題檔

oneinstack+lnmp：nginx編譯Nginx fastcgi_cache模塊

racknerd便宜VPS收集整理

一名合格的軟件測試工程師該有的3種思維方式

爆肝一周，用Python在物聯(lián)網(wǎng)設(shè)備上寫了個智能語音助手

前端面試每日3+1——第104天

實(shí)習(xí)項(xiàng)目開發(fā)總結(jié)

最新活動