IT運(yùn)維知識(shí)：Netty框架簡(jiǎn)介

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

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

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

    新建一個(gè)HttpServerPipelineFactory類(lèi)，在getPipeline()方法中添加了對(duì)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類(lèi)型的對(duì)象，因?yàn)镹etty已經(jīng)用HttpRequestDecoder幫我們把接受到的數(shù)據(jù)都轉(zhuǎn)換為HttpRequest類(lèi)型了。
    使用了多個(gè)Handler后,通過(guò)下圖，Netty的事件驅(qū)動(dòng)就可以被很好的理解了：     UpstreamEvent是被UpstreamHandler們自底向上逐個(gè)處理，DownstreamEvent是被DownstreamHandler們自頂向下逐個(gè)處理，這里的上下關(guān)系就是向ChannelPipeline里添加Handler的先后順序關(guān)系。
 
六、總結(jié)
    Netty是一個(gè)簡(jiǎn)單卻不失強(qiáng)大的架構(gòu)。這個(gè)架構(gòu)由三部分組成——緩沖（Buffer）、通道（Channel）、事件模型（Event Model）——所有的高級(jí)特性都構(gòu)建在這三個(gè)核心組件之上。