2. 程式人生 > >Netty初識之DiscardServer

Netty初識之DiscardServer

阿新 • • 發佈：2018-10-31

Netty

Netty專案是為了快速開發可維護的高效能高可擴充套件性協議伺服器和客戶端而努力提供非同步事件驅動的網路應用程式框架和工具。換句話說，Netty是一個NIO客戶端伺服器框架，可以快速輕鬆地開發諸如協議伺服器和客戶端之類的網路應用程式。它大大簡化了網路程式設計流程，如TCP和UDP套接字伺服器開發。

Tomcat和Netty的比較

Netty和Tomcat最大的區別就在於通訊協議，Tomcat是基於Http協議的，他的實質是一個基於http協議的web容器，但是Netty不一樣，他能通過程式設計自定義各種協議，因為netty能夠通過codec自己來編碼/解碼位元組流，完成類似redis訪問的功能，這就是netty和tomcat最大的不同

 

Netty特點:

  1. 併發高
  2. 傳輸快
  3. 封裝好

 

 

<?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>com.sengen</groupId>
  <artifactId>nettydemos</artifactId>
  <version>1.0-SNAPSHOT</version>

  <name>nettydemos</name>
  <!-- FIXME change it to the project's website -->
  <url>http://www.example.com</url>

  <properties>
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    <maven.compiler.source>1.8</maven.compiler.source>
    <maven.compiler.target>1.8</maven.compiler.target>
  </properties>

  <dependencies>
    <dependency>
      <groupId>junit</groupId>
      <artifactId>junit</artifactId>
      <version>4.11</version>
      <scope>test</scope>
    </dependency>
    <dependency>
      <groupId>io.netty</groupId>
      <artifactId>netty-all</artifactId>
      <version>4.0.32.Final</version>
    </dependency>
  </dependencies>

  <build>
    <pluginManagement><!-- lock down plugins versions to avoid using Maven defaults (may be moved to parent pom) -->
      <plugins>
        <plugin>
          <artifactId>maven-clean-plugin</artifactId>
          <version>3.0.0</version>
        </plugin>
        <!-- see http://maven.apache.org/ref/current/maven-core/default-bindings.html#Plugin_bindings_for_jar_packaging -->
        <plugin>
          <artifactId>maven-resources-plugin</artifactId>
          <version>3.0.2</version>
        </plugin>
        <plugin>
          <artifactId>maven-compiler-plugin</artifactId>
          <version>3.7.0</version>
        </plugin>
        <plugin>
          <artifactId>maven-surefire-plugin</artifactId>
          <version>2.20.1</version>
        </plugin>
        <plugin>
          <artifactId>maven-jar-plugin</artifactId>
          <version>3.0.2</version>
        </plugin>
        <plugin>
          <artifactId>maven-install-plugin</artifactId>
          <version>2.5.2</version>
        </plugin>
        <plugin>
          <artifactId>maven-deploy-plugin</artifactId>
          <version>2.8.2</version>
        </plugin>
      </plugins>
    </pluginManagement>
  </build>
</project>

 
package com.sengen.netty_beginner;

import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelInitializer;
import io.netty.channel.ChannelOption;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.SocketChannel;
import io.netty.channel.socket.nio.NioServerSocketChannel;
/**
 * Created by Administrator on 2018/8/17.
 * 描述:DiscardServer 啟動類
 * @author Young
 * @create 2018-08-17 14:35
 */
public class DiscardServer {
    private int port;

    public DiscardServer(int port) {
        this.port = port;
    }

    public static void main(String[] args) {
        int port;
        if(args.length>0){
            port = Integer.valueOf(args[1]);
        }else {
            port = 8080;
        }
        System.out.println("準備啟動中.........");
        new DiscardServer(port).run();
        //好像永遠都執行不到回家的程式碼......
        System.out.println("跑完了....肥噶!");
    }

    private void run() {
        /**NioEventLoopGroup是一個處理I/O操作的多執行緒事件迴圈.Netty為不同型別的傳輸提供了各種EventLoopGroup實現.在這個例子中,我們正在實現一個
         * 伺服器端應用程式,因此將使用兩個NioEventLoopGroup.
         * 第一個 通常稱為老闆,接收傳入的連線;
         * 第二個 通常稱為工人,一旦老闆接收連線並將接受的連線註冊給工作人員,就處理接收的連線的流量.
         *        使用多少執行緒以及他們如何對映到建立的通道取決於EventLoopGroup實現,甚至可以通過建構函式進行配置.
         */
        EventLoopGroup bossGroup = new NioEventLoopGroup();
        EventLoopGroup workerGroup = new NioEventLoopGroup();
        try{
            /**
             * ServerBootstrap是一個幫助類,用於設定伺服器.可以直接使用Channel設定伺服器.但是一般情況都不這樣做..
             **/
            ServerBootstrap sb = new ServerBootstrap();
            sb.group(bossGroup,workerGroup)
                    /**
                     * 在這裡,我們指定使用NioServerSocketChannel類來例項化一個新的Channel來接收傳入的連線.
                     * (每個客戶端連線服務端,我們都為他們建立一個channel,那麼這個channel對於面向物件的我們來說就是一個類,我們統一對於我們接收
                     * 到的連線都初始化為:NioServerSocketChannel)
                     */
                    .channel(NioServerSocketChannel.class)
                    /**
                     * 這裡指定的處理程式將始終由新接收的Channel進行評估.ChannelInitializer是一個特殊的處理程式,旨在幫助使用者配置新的Channel.
                     * 若想通過新增一些處理程式(如DiscardServerHandler)來配置新Channel的ChannelPipeline來實現網路應用程式.
                     * 隨著應用程式的複雜化,可能在管道中新增更多的處理程式..(其實這就是需要自己重新實現包含自己處理邏輯的Channel.
                     * 類似於DiscardServerHandler,繼承ChannelInboundHandlerAdapter一樣)
                     * */
                    .childHandler(new ChannelInitializer<SocketChannel>() {
                        @Override
                        protected void initChannel(SocketChannel socketChannel) throws Exception {
                            socketChannel.pipeline().addLast(new DiscardServerHandler());
                        }
                    })
                    /**
                     * 設定特定於Channel實現的引數.正在編寫一個TCP/IP伺服器.因此可以設定套接字選項.如tcpNoDelay和keepAlive
                     *
                     * option()和childOption()方法.
                     * option()用於接收傳入連線的NioServerChannel.
                     * childOption()用於在這種情況下由父級ServerChannel接收的通道,即NioServerSocketChannel.
                     * 個人認為:前者用於配置父級Channel,後者配置自定義的子集Channel.
                    */
                    .option(ChannelOption.SO_BACKLOG,128)
                    .childOption(ChannelOption.SO_KEEPALIVE,true);

            ChannelFuture future = sb.bind(port).sync();
            future.channel().closeFuture().sync();

        }catch(Exception e){
            System.out.println("有異常,快跑...........");
        }finally{
            bossGroup.shutdownGracefully();
            workerGroup.shutdownGracefully();
        }
    }


}

 
package com.sengen.netty_beginner;

import io.netty.buffer.ByteBuf;
import io.netty.channel.Channel;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;
import io.netty.util.ReferenceCountUtil;

import java.net.SocketAddress;

/**
 * Created by Administrator on 2018/8/17.
 * 描述:手動完成比hello world還簡單的程式
 * @author Young
 * @create 2018-08-17 14:29
 */
public class DiscardServerHandler extends ChannelInboundHandlerAdapter {
    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
        //將Object強轉成ByteBuf(引用計數物件)
//        ((ByteBuf)msg).release();
        ByteBuf in = (ByteBuf) msg;
        try {
            while (in.isReadable()) {
                Channel channel = ctx.channel();
                SocketAddress socketAddress = channel.remoteAddress();
                System.out.println(socketAddress+"連線了你");
                System.out.print((char) in.readByte());
                System.out.flush();
            }
        } finally {
            ReferenceCountUtil.release(msg);
        }

    }

    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
//        cause.printStackTrace();
        System.out.println(ctx.channel().remoteAddress()+"強迫關閉了連線");
        System.out.println("跑完了......肥噶!");
        ctx.close();
    }
}

控制檯啟動main方法...網頁和cmd都可以訪問.....localhost:8080.....localhost改成ip通用的...

 

我感覺我要把我的github用起來了...貼程式碼不方便了.

 

相關推薦

Netty初識之DiscardServer

Netty Netty專案是為了快速開發可維護的高效能高可擴充套件性協議伺服器和客戶端而努力提供非同步事件驅動的網路應用程式框架和工具。換句話說，Netty是一個NIO客戶端伺服器框架，可以快速輕鬆地開發諸如協議伺服器和客戶端之類的網路應用程式。它大大簡化了網路程式設計流程，如TCP和UDP套接

Netty教程之初識Netty(1)

快速 事件 客戶端程序 rocket cassandra ssa 初識 我們 工具 Netty是什麽？ Netty是由JBOSS提供的一個java開源框架。 Netty提供異步的、事件驅動的網絡應用程序框架和工具，用以快速開發高性能、高可靠性的網絡服務器和客戶端程序。 封裝

Netty入門之客戶端與服務端通信(二)

ktr 數據格式 lis boot ride owa 參數 val cef Netty入門之客戶端與服務端通信(二) 一.簡介 　　在上一篇博文中筆者寫了關於Netty入門級的Hello World程序。書接上回，本博文是關於客戶端與服務端的通信，感覺也沒什麽好說的了，直接

netty學習之Reactor線程模型以及在netty中的應用

rec 直接 滿足 red 轉載 chan tail io處理 理論 轉載：http://blog.csdn.net/u010853261/article/details/55805216 說道netty的線程模型，我們第一反應就是經典的Reactor線程模型，下面我們就

Netty入門之WebSocket初體驗

說一說IO通訊 BIO通訊： BIO即同步阻塞模式一請求一應答的通訊模型，該模型最大的問題就是缺乏彈性伸縮能力，當客戶端併發訪問量增加後，服務端的執行緒個數和客戶端併發訪問數呈1：1的正比關係，由於執行緒是JAVA虛擬機器非常寶貴的系統資源，當執行緒數膨脹之後，系統的效能將急劇下降，隨著併發訪問量的繼續增

Netty精粹之玩轉NIO緩衝區

https://www.cnblogs.com/wxd0108/p/6681627.html 摘要: 在JAVA NIO相關的元件中，ByteBuffer是除了Selector、Channel之外的另一個很重要的元件，它是直接和Channel打交道的緩衝區，通常場景或是從ByteBuffer寫入

jQuery初識之選擇器、樣式操作和篩選器(模態框和選單示例)

一、jQuery 1、介紹 jQuery是一個快速、簡潔的JavaScript框架，是繼Prototype之後又一個優秀的JavaScript程式碼庫（或JavaScript框架）。 jQuery設計的宗旨是“write Less，Do More”，即倡導寫更少的程式碼，做更多的事情。 它封裝J

Netty 系列之 Netty 百萬級推送服務設計要點

Netty 系列之 Netty 百萬級推送服務設計要點 李林鋒 2015 年 1 月 4 日 話題：語言 & 開發架構 1. 背景 1.1. 話題來源 最近很多從事移動網際網路和物聯網開發的同學給我發郵件或者微博私信我，諮詢推送服務相關的問題。問題五花八門，

netty 三之訊息推送和心跳檢測

主要參考 https://blog.csdn.net/coder_py/article/details/73441043 有小改動（因使用的是netty4的包 netty-all-4.1.25.Final.jar） 通訊資訊的基類，需要實現序列化，定義了資訊的型別和客戶端ID，方便進行管

netty 二之pipeline

  一 netty簡單示例 先寫一個簡單的netty長連線Demo 服務端主要包括連線類（bootstrap）和業務處理類(channelHandler)，另外一個server啟動類，可以與連線類合併。 公用的類為訊息和訊息編碼，訊息解碼類。 訊息類： public

netty 一之IO模型

專案總用到了netty框架，看了與netty相關的基礎知識，netty中用到了NIO，如何理解NIO，這就需要先理解I/O模型 I/O模型有5種I/O模型，借用釣魚的故事比較通俗易懂。 有以下五種釣魚方式： 王鐵錘 他先給魚竿上放好魚餌，然後就坐在自己的小板凳上，眼睛一直瞪著魚竿的盡

Netty——WebSocket之事

        在說WebSocket以前，我們再來看看HTTP協議，HTTP1.0，HTTP1.1，HTTP2.0每個版本的更新帶來更高效的更豐富的功能：短連線、長連線、快取處理的豐富、斷點續傳、錯誤通知的豐富、多路複用、請求優

Netty學習之路（六）-分隔符和定長解碼器的應用

之前已經使用了LineBasedFrameDecoder解決TCP粘包問題，現在再學兩種解決TCP粘包的方法。 DelimiterBasedFrameDecoder：可以自動完成以分隔符做結束標誌的訊息的解碼，分隔符自定義。 FixedLengthFrameDecoder:

Netty學習之路（五）-TCP粘包/拆包問題

TCP是個“流協議”，所謂流，就是沒有界限的一串資料。TCP底層並不瞭解上層業務資料的具體含義，它會根據TCP緩衝區的實際情況進行包的劃分，所以一個完整的包可能會被TCP拆分成多個包進行傳送，也有可能吧多個小的包封裝成一個大的資料包傳送，這就是TCP粘包和拆包問題。 TCP粘包/拆包產生

Netty學習之路（四）-Netty入門實戰

前面學習了用Java原生NIO的程式設計實踐，過程還是挺複雜的，需要熟練掌握Selector，ServerSocketChannel握，SocketChannel，ByteBuffer等。所以在絕大多數業務場景中我們可以使用Netty來進行NIO程式設計。先總結一下Netty的優點：

Netty學習之路（三）-AIO程式設計

NIO 2.0引入了新的非同步通道的概念，與之前非阻塞IO(NIO)不同的是，NIO 2.0非同步套接字通道是真正的非同步非阻塞I/O，對應於UNIX網路程式設計中的事件驅動I/O(AIO)。它不需要通過多路複用器對註冊的通道進行輪詢操作即可實現非同步讀寫，從而簡化了NIO的程式設計模型。話

Netty學習之路（九）-JBoss Marshalling編解碼

JBoss Marshalling 是一個Java物件序列化包，對JDK預設的序列化框架進行了優化，但又保持跟java.io.Serializable介面的相容，同時增加了一些可調的引數和附加的特性。 Marshalling開發環境準備 下載相關的Marshalling類庫:地址,將

Netty學習之路（二）-非同步IO（NIO）程式設計

NIO到底是什麼簡稱？有人稱之為New I/O，原因為他相對於之前的I/O類庫來說是新增的。這是官方叫法。但是，由於之前老的I/O類庫是阻塞I/O,New I/O類庫的目標就是讓java支援非阻塞I/O,所以更多的人稱之為非阻塞I/O(Non-block I/O)。在開始進行NIO程式設計之

Netty學習之路（一）- 同步與非同步IO

本篇部落格主要是講一些基礎，記錄我的學習過程，同時嘗試養成寫部落格的習慣。內容基本來自Netty權威指南加上一丟丟的個人理解。。。。 I/O基礎入門 在jdk1.4以前，java對i/o的支援並不完善，開發人員在開發高效能i/o時會遇到巨大的挑戰與困難，主要問題如下： 沒

Netty學習之路（八）-Google Protobuf編碼

Protobuf是一個靈活，高效，結構化的資料序列化框架，相比於XML等傳統的序列化工具，它更小，更快，更簡單。Protobuf支援資料結構化一次可以到處使用，甚至可以跨語言使用，通過程式碼生成工具可以自動生成不同語言版本的原始碼，甚至可以在使用不同版本的資料結構程序間進行資料傳遞，實現資料