IT運維知識：Netty框架簡介

2020-03-21 16:55 作者：admin 瀏覽量：

為中小企業(yè)解困 企業(yè)IT外包服務火起來了

提到中小企業(yè)的困難，我相信大家都會深有感觸，上沒有皇親國戚撐腰，下沒有達官貴族的支持，全都要靠自己的拼博和奮斗，其實非常不容易，那怎樣可以在現(xiàn)在這個環(huán)境下突出重圍呢？
 
總的來說，中小企業(yè)有三大困難： 首先，高昂的成本. 其次，較低的效率. 第三，太少的營收.
 
· 高昂的成本
對于生產(chǎn)型企業(yè)，主要是采購成本，廠房成本，人力成本占主要部分，對于服務型企業(yè)，主要是房租成本，人力成本，管理運營成本占主要部分，對于營銷型企業(yè)，主要是市場成本，人力成本，管理運營成本占主要部分，這三種類型的企業(yè)都有一個共同的特點，就是人力成本，中國近些年的快速發(fā)展，互聯(lián)網(wǎng)企業(yè)起著主導地位，互聯(lián)網(wǎng)人才的工資不斷攀升，導致各行各業(yè)的人力成本水漲船高.
中小企業(yè)無論招什么崗位的人，一個人一年的總體投入成本都在10萬元左右，這還是普通員工所支出的成本費用，如果一個企業(yè)10個人，一年就需要支出100多萬，就意味著一家企業(yè)如果年利潤在100萬左右完全是虧損的，因為其它費用還沒有計算其中，所以中小企業(yè)想盡一切找一些全能型人才來處理企業(yè)的需求，我們遇到一些中小企業(yè)，他們招一個前臺，即要會修電腦，處理公司的網(wǎng)絡，又要會開車，還在能做很多行政的文檔表格，可想而知這樣的人能力水平能達到什么程度，處理的效果以及及效率會是什么樣的，這也是為什么很多中小企業(yè)行政經(jīng)常離職的主要原因.
如果能減少這種綜合性人才，把相關的工作分類外包出去，我相信不僅成本會降低很多，而且效果也會好很多，具體我們在后面詳細說明如何操作.
· 較低的效率
企業(yè)效率低下主要有三個方面的原因，首先是管理的問題，管理者不會管理將直接導致整體效率下降. 其次是部門架構的問題，不合理的部門架構就像兩個不能對齒的輪子，不僅有摩擦還會有火花. 第三是軟硬件系統(tǒng)沒有選對，一個企業(yè)的運轉，不僅需要有合適的人才，還需要有合適的系統(tǒng)，智能手機未普及時大家用網(wǎng)頁來處理一切的事務，導致整個效率和效果都很差，至從APP在智能手機上誕生就徹底地改變了這個世界的速度，讓我們可以透過各種APP解決遇到的困境，很多事情我們需要干一年最后只需要一天或者一個小時.
· 太少的營收
互聯(lián)網(wǎng)的快速發(fā)展，改變了無數(shù)行業(yè)的銷售模式，傳統(tǒng)銷售是靠人海戰(zhàn)術，互聯(lián)網(wǎng)靠的是大數(shù)據(jù)營銷，智能機器人取代了人的工作，而且是7*24小時全年無休，還不用發(fā)工資，但大部分傳統(tǒng)行業(yè)的中小企業(yè)還是在用傳統(tǒng)的模式找客戶，付出了巨大的人力和時間，卻帶來了極少的收入. 面對這三種狀態(tài)，傳統(tǒng)中小企業(yè)需要如何轉型升級，如何改變自己呢？
對應這三個方面我們提出最基礎的變革，來幫助中小企業(yè)改變和適應當下的環(huán)境.
· 高昂的人力成本
外包是唯一的選擇，當年耐克為了對抗德國的阿迪，把自己所有生產(chǎn)產(chǎn)品全部外包給了東南亞的生產(chǎn)工廠，大大降低了自己產(chǎn)品的成本，從而讓自己的產(chǎn)品擁有與世界第一品牌的抗衡力量.還有華為這么大的企業(yè)，大部分行政前臺全部都是外包的，包括很多大企業(yè)的食堂也是外包的，不是他們沒有實力做，而是用專業(yè)的企業(yè)做專業(yè)的事.
所以中小企業(yè)很多方面的工作都是可以外包出去，大家可以自行研究一下，我就舉一個例子，比喻說中小企業(yè)內部的網(wǎng)絡管理員是完全沒有必要自己招聘，可以外包給有實力有經(jīng)驗的IT外包公司，每年最少節(jié)省70%的成本，而且專業(yè)的IT外包公司還能給到很多行業(yè)領先的經(jīng)驗和解決方案，可以讓你的企業(yè)更有競爭力，具體我就不在這里細說了，如果感興趣的中小企業(yè)可以留言，我們私下探討.
 
· 較低的運營效率
上面我們說到了一是管理人員的能力水平?jīng)Q定了企業(yè)整體的運營效率，二是企業(yè)內部軟硬件系統(tǒng)所導致企業(yè)整體效率低下.對于管理人員如果中小企業(yè)請不起非常有能力的人才，就為自己的管理團隊找一名高管教練，花錢不多，而且效果非常的好，像阿里，蘋果等這樣的大企業(yè)都為自己的高管配備一對一的教練服務，我們中小企業(yè)可以為所有高管團隊配備一名教練就可以了，我們企業(yè)艾銻無限也是這么做的，這比讓高管出去學習效果好上一百倍，因為教練是針對企業(yè)績效的指導，不僅能幫助高管人的改變，還能讓企業(yè)業(yè)績發(fā)生巨大的變化.
關于如何選擇適合中小企業(yè)的軟硬件系統(tǒng)，可以好好研究一下阿里的釘釘，這家公司是中小企業(yè)效率軟硬件提升的王者，不僅很多產(chǎn)品免費，而且還手把手地教你如何使用，這對于沒有資金投入的中小企業(yè)來說是一個巨大的福音.
 
· 太少的業(yè)績營收
主要核心是改變模式，從人海戰(zhàn)術到利用互聯(lián)網(wǎng)技術，從只有銷售部才能產(chǎn)生業(yè)績到全員都可以貢獻業(yè)績，從找客戶到客戶主動找到企業(yè)這三個方面入手.互聯(lián)網(wǎng)技術給中小企業(yè)提供了很多銷售的可能性，比喻說百度推廣和搜索引擎優(yōu)化，可以讓精準用戶主動找到你的企業(yè)，讓更多客戶提著錢來和你合作.
對于只有銷售部才能產(chǎn)生銷售的時代已經(jīng)過去了，一家企業(yè)如果想要有好的營收，一定是全員銷售，每個人都是企業(yè)的銷售人員，每個人都可以為企業(yè)帶來營收，這種理念和思維一定要融入企業(yè)每個人的血液里，當然能達到這樣的高度，并不容易，需要企業(yè)的負責人花很多心思去培養(yǎng)大家的這種思維模式，去喚醒企業(yè)內部每個人擁有自主提升收入的意識.
過去是我們出去找客戶，互聯(lián)網(wǎng)時代可以做到客戶主動來找你，企業(yè)無論大小，品牌意識非常重要，如果你能做到行業(yè)數(shù)一數(shù)二，你根本不缺客戶，你也不用擔心自己企業(yè)的營收問題，說到電商，你立刻會想到天貓和淘寶，提到運動品牌，你立刻會想到阿迪和耐克，講到IT外包公司，立刻會想到艾銻無限和文思海輝，品牌的價值就是讓你無形中會主動想和他們建立一種關系. 綜上所述，我們提出了一些方向，可以給正處困境中的中小企業(yè)一些啟發(fā)，希望透過大家的一起努力，讓中小企業(yè)快速突圍，找到自己成長的規(guī)律和法門.透過這么多年的經(jīng)驗，我們已預測企業(yè)IT外包很快就會火起來，這是每家中小企業(yè)的剛需.
你的企業(yè)有外包業(yè)務嗎，歡迎來撩……
  IT運維知識：Netty框架簡介
 
 
一、概述
    Netty是由JBOSS提供的一個java開源框架。
    Netty提供異步的、事件驅動的網(wǎng)絡應用程序框架和工具，用以快速開發(fā)高性能、高可靠性的網(wǎng)絡服務器和客戶端程序。
二、體系結構圖 三、Netty的核心結構
    Netty是典型的Reactor模型結構，在實現(xiàn)上，Netty中的Boss類充當mainReactor，NioWorker類充當subReactor（默認NioWorker的個數(shù)是當前服務器的可用核數(shù)）。
    在處理新來的請求時，NioWorker讀完已收到的數(shù)據(jù)到ChannelBuffer中，之后觸發(fā)ChannelPipeline中的ChannelHandler流。
    Netty是事件驅動的，可以通過ChannelHandler鏈來控制執(zhí)行流向。因為ChannelHandler鏈的執(zhí)行過程是在subReactor中同步的，所以如果業(yè)務處理handler耗時長，將嚴重影響可支持的并發(fā)數(shù)。 四、客戶端和服務器端通信Demo
    Server-main:

ChannelFactory factory = new NioServerSocketChannelFactory(Executors.newCachedThreadPool(), Executors.newCachedThreadPool()); ServerBootstrap bootstrap = new ServerBootstrap(factory); bootstrap.setPipelineFactory(new ChannelPipelineFactory(){      @Override     public ChannelPipeline getPipeline() throws Exception {         return Channels.pipeline(new TimeServerHandler());     } }); bootstrap.setOption("child.tcpNoDelay", true); bootstrap.setOption("child.keepAlive", true); bootstrap.bind(new InetSocketAddress(1989));

    ChannelFactory 是一個創(chuàng)建和管理Channel通道及其相關資源的工廠接口，它處理所有的I/O請求并產(chǎn)生相應的I/O ChannelEvent通道事件。這個工廠并自己不負責創(chuàng)建I/O線程。應當在其構造器中指定該工廠使用的線程池，這樣我們可以獲得更高的控制力來管理應用環(huán)境中使用的線程。
    ServerBootstrap 是一個設置服務的幫助類。設置了一個繼承自ChannelPipelineFactory的匿名類，用來作為ChannelPipeline通道，當服務器接收到一個新的連接，一個新的ChannelPipeline管道對象將被創(chuàng)建，并且所有在這里添加的ChannelHandler對象將被添加至這個新的ChannelPipeline管道對象。
    Server-Handler:

@Override public void channelConnected(ChannelHandlerContext ctx, ChannelStateEvent e) throws Exception {     //TimeServer        Channel ch = e.getChannel();     ChannelBuffer time = ChannelBuffers.buffer(8);     time.writeLong(System.currentTimeMillis());     ChannelFuture future = ch.write(time);      future.addListener(new ChannelFutureListener() {                @Override               public void operationComplete(ChannelFuture arg0) throws Exception {                    Channel ch = arg0.getChannel();             ch.close();         }     }); }

    Handler中是我們的業(yè)務邏輯，在Server的Handler里重載了channelConnected方法，當收到連接請求時，將當前服務器時間寫入到Channel，并且在寫完后觸發(fā)關閉Channel。
    Client-main:

ChannelFactory factory = new NioClientSocketChannelFactory(Executors.newCachedThreadPool(), Executors.newCachedThreadPool()); ClientBootstrap bootstrap = new ClientBootstrap(factory); bootstrap.setPipelineFactory(new ChannelPipelineFactory() {     @Override       public ChannelPipeline getPipeline() throws Exception {         return Channels.pipeline(new TimeClientHandler());     } }); bootstrap.setOption("tcpNoDelay",true); bootstrap.setOption("keepAlive", true); bootstrap.connect(new InetSocketAddress("127.0.0.1", 1989));

    Client端初始化Netty的過程和Server類似，只是將使用到的類替換為Client端的。
    Client-Handler:

@Override public void messageReceived(ChannelHandlerContext ctx, MessageEvent e) throws Exception {     ChannelBuffer buf = (ChannelBuffer)e.getMessage();     Long currentTimeMillis = buf.readLong();     System.out.println(new Date(currentTimeMillis));     e.getChannel().close(); }

    Client端的Handler里，我們將從服務器端接收到的信息轉換為時間打印到控制臺。
五、基于HTTP協(xié)議的服務器端實現(xiàn)

//HttpServerPipelineFactory.java public class HttpServerPipelineFactory implements ChannelPipelineFactory {     @Override     public ChannelPipeline getPipeline() throws Exception {         ChannelPipeline pipeline = Channels.pipeline();         pipeline.addLast("decoder", new HttpRequestDecoder());         pipeline.addLast("encoder", new HttpResponseEncoder());         pipeline.addLast("handler", new HttpServerHandler());         return pipeline;     } }

    新建一個HttpServerPipelineFactory類，在getPipeline()方法中添加了對Http協(xié)議的支持。

// HttpServer.java bootstrap.setPipelineFactory(new HttpServerPipelineFactory());

    在Server里面使用我們新建的HttpServerPipelineFactory。

//HttpServerHandler.java public void messageReceived(ChannelHandlerContext ctx, MessageEvent e) throws Exception {     DefaultHttpRequest defaultHttpRequest = (DefaultHttpRequest)e.getMessage();     String uri = defaultHttpRequest.getUri();     byte[] data = defaultHttpRequest.getContent().array();     String content = URLDecoder.decode(new String(data),"utf-8").trim();     System.out.println(uri+"|"+content);     Channel ch = e.getChannel();     HttpResponse response = new DefaultHttpResponse(HTTP_1_1, OK);     ChannelBuffer buffer = new DynamicChannelBuffer(2048);     buffer.writeBytes("200".getBytes("UTF-8"));     response.setContent(buffer);     response.setHeader("Content-Type", "text/html;charset=UTF-8");     response.setHeader("Content-Length", response.getContent().writerIndex());     if (ch.isOpen() && ch.isWritable()) {           ChannelFuture future = ch.write(response);          future.addListener(new ChannelFutureListener() {                    @Override                   public void operationComplete(ChannelFuture arg0) throws Exception {                            Channel ch = arg0.getChannel();                         ch.close();             }           });     } }

    在Handler里面我們可以直接拿到DefaultHttpRequest類型的對象，因為Netty已經(jīng)用HttpRequestDecoder幫我們把接受到的數(shù)據(jù)都轉換為HttpRequest類型了。
    使用了多個Handler后,通過下圖，Netty的事件驅動就可以被很好的理解了：     UpstreamEvent是被UpstreamHandler們自底向上逐個處理，DownstreamEvent是被DownstreamHandler們自頂向下逐個處理，這里的上下關系就是向ChannelPipeline里添加Handler的先后順序關系。
 
六、總結
    Netty是一個簡單卻不失強大的架構。這個架構由三部分組成——緩沖（Buffer）、通道（Channel）、事件模型（Event Model）——所有的高級特性都構建在這三個核心組件之上。