IT運維知識：Netty框架簡介

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

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

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

//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協議的支持。

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