Netty入門教程(一) 實現(xiàn)DISCARD服務

更多關于Java方面的文章,歡迎訪問燕歸來https://www.zhoutao123.com

官方那個給出的介紹是：Netty是由JBOSS提供的一個java開源框架掖疮。Netty提供異步的、事件驅(qū)動的網(wǎng)絡應用程序框架和工具颗祝，用以快速開發(fā)高性能浊闪、高可靠性的網(wǎng)絡服務器和客戶端程序恼布。然后我們簡單理解一下，這玩意就是個程序搁宾，干什么的折汞？netty是封裝java socket noi的。 類似的功能是 apache的mina盖腿。

使用Netty實現(xiàn)Socket丟棄服務

相對于Tomcat這種Web Server（顧名思義主要是提供Web協(xié)議相關的服務的）爽待，Netty是一個Network Server，是處于Web Server更下層的網(wǎng)絡框架翩腐，也就是說你可以使用Netty模仿Tomcat做一個提供HTTP服務的Web容器堕伪。其實一個好使的處理Socket的東西

實現(xiàn)丟棄服務

這里插一下，就是我們的的通信是建立在一定的協(xié)議之上的栗菜，就比如我們常用的Web工程欠雌，前臺（瀏覽器）發(fā)送一個請求，后臺做出相應返回相應的結果疙筹，這個SOCKET通信的過程亦是如此富俄。

在netty官方指南里面有講，世上最簡單的協(xié)議不是'Hello, World!' 而是 DISCARD(拋棄服務)而咆。這個協(xié)議將會拋棄任何收到的數(shù)據(jù)霍比，而不響應。就是你客戶端發(fā)送消息暴备，好悠瞬，發(fā)送過去了，服務器也收到了涯捻，但是拋棄了浅妆。

說白了，就是你發(fā)一條消息給我障癌，我收到了凌外，僅此而已，不做任何響應涛浙。下面我們看看大致的步驟康辑。

  • 創(chuàng)建項目,添加Netty 依賴
  • 實現(xiàn)丟棄服務
  • 運行服務
  • 使用Python進行測試

創(chuàng)建項目,添加Netty 依賴

使用IDEA創(chuàng)建一個普通項目，然后添加jar包或者直接創(chuàng)建一個maven項目也行轿亮。

在Maven中搜索netty-all 即可 地址是 http://mvnrepository.com/artifact/io.netty/netty-all 建議選擇5.0.0以上的版本疮薇。
或者直接創(chuàng)建Maven項目，引入依賴如下


<!-- https://mvnrepository.com/artifact/io.netty/netty-all -->
<dependency>
    <groupId>io.netty</groupId>
    <artifactId>netty-all</artifactId>
    <version>5.0.0.Alpha2</version>
</dependency>

實現(xiàn)丟棄服務

package com.company;

import io.netty.buffer.ByteBuf;
import io.netty.channel.ChannelHandlerAdapter;
import io.netty.channel.ChannelHandlerContext;
import io.netty.util.CharsetUtil;
import io.netty.util.ReferenceCountUtil;

/**
 * 本文件由周濤創(chuàng)建,位于com.company包下
 * 創(chuàng)建時間2018/4/20 11:46
 * 郵箱:zhoutao@xiaodouwangluo.com
 * 作用:實現(xiàn)丟棄服務
 *
 * @author tao
 */
public class DiscardServerHandle extends ChannelHandlerAdapter {

    /**
     * 接收到SOCKET的時候會調(diào)用此方法
     * @param ctx
     * @param msg
     * @throws Exception
     */
    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
        try {
            //獲取到接收的內(nèi)容我注，并且實現(xiàn)
            ByteBuf in = (ByteBuf) msg;
            String message = in.toString(CharsetUtil.UTF_8);
            System.out.println(message);
        } finally {
            ReferenceCountUtil.release(msg);
        }
    }


    /**
     * 有新的連接加入的時候
     * @param ctx
     * @throws Exception
     */
    @Override
    public void handlerAdded(ChannelHandlerContext ctx) throws Exception {
        System.out.println("新增Channel ,ChannelId = " + ctx.channel().id());
    }

    /**
     * 有連接斷開被移除的時候調(diào)用
     * @param ctx
     * @throws Exception
     */
    @Override
    public void handlerRemoved(ChannelHandlerContext ctx) throws Exception {
        System.out.println("移除Channel ,ChannelId = " + ctx.channel().id());
    }

    /**
     * 發(fā)生異常的時候調(diào)用
     * @param ctx
     * @param cause
     * @throws Exception
     */
    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
        cause.printStackTrace();
        ctx.close();

    }
}

運行服務


package com.company;


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;

/**
 * 本文件由周濤創(chuàng)建,位于com.company包下
 * 創(chuàng)建時間2018/4/20 11:46
 * 郵箱:zhoutao@xiaodouwangluo.com
 * 作用:創(chuàng)建運行服務
 *
 * @author tao
 */
public class DiscardServer {

    private int port;

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

    public void run() throws InterruptedException {
        EventLoopGroup boos = new NioEventLoopGroup();
        EventLoopGroup worker = new NioEventLoopGroup();
        System.out.println("準備運行在端口:" + String.valueOf(this.port));

        try {

            ServerBootstrap serverBootstrap = new ServerBootstrap();
            serverBootstrap.group(boos, worker)
                    .channel(NioServerSocketChannel.class)
                    .option(ChannelOption.SO_BACKLOG, 128)
                    .childHandler(new ChannelInitializer<SocketChannel>() {
                        @Override
                        protected void initChannel(SocketChannel socketChannel) throws Exception {
                            socketChannel.pipeline().addLast(new DiscardServerHandle());
                        }
                    });

            ChannelFuture sync = serverBootstrap.bind(port).sync();
            sync.channel().closeFuture().sync();

        } finally {
            worker.shutdownGracefully();
            boos.shutdownGracefully();
        }

    }

    public static void main(String[] args) {
        DiscardServer server = new DiscardServer(8080);
        try {
            server.run();
        } catch (InterruptedException e) {
            System.out.println("發(fā)生了異常信息,異常信息如下所示：");
            e.printStackTrace();
        }
    }
}

使用Python進行測試

python內(nèi)置了socket庫可以實現(xiàn)連接按咒，我們這里使用Pyhton3.x來進行操作socket.當然這里只是演示SOCKET,你也可以使用其他方法嘗試連接socket比如 js,java，或者talnet命令仓手。


#!/usr/bin/env python
# encoding: utf-8

#coding=utf-8
__author__ = '藥師Aric'
'''
client端
長連接胖齐，短連接，心跳
'''
import socket
import time
host = '127.0.0.1'
port = 8080
client = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
client.setsockopt(socket.SOL_SOCKET, socket.SO_KEEPALIVE, 1) #在客戶端開啟心跳維護
client.connect((host, port))
send_count = 0
try:
    while True:
        timeStr= time.strftime("%Y-%m-%d %H:%M:%S", time.localtime())
        client.send((u"你好嗽冒，這是Python客戶端,已經(jīng)您發(fā)送消息 %s" % timeStr).encode())
        send_count = send_count + 1
        print("發(fā)送數(shù)據(jù)完成,已發(fā)送次數(shù)：%d" % send_count)
        time.sleep(2)
except:
    print("當前系統(tǒng)已經(jīng)和服務器斷開連接....")

運行Pyhton 代碼呀伙，嘗試連接SOCKET，執(zhí)行一會之后停止pyhton 添坊，結果如下:

python發(fā)送的數(shù)據(jù)

/Users/tao/Code/Python/redisDemo/venv/bin/python /Users/tao/Code/Python/redisDemo/main/index.py
發(fā)送數(shù)據(jù)完成,已發(fā)送次數(shù)：1
發(fā)送數(shù)據(jù)完成,已發(fā)送次數(shù)：2
發(fā)送數(shù)據(jù)完成,已發(fā)送次數(shù)：3
發(fā)送數(shù)據(jù)完成,已發(fā)送次數(shù)：4
發(fā)送數(shù)據(jù)完成,已發(fā)送次數(shù)：5
當前系統(tǒng)已經(jīng)和服務器斷開連接....

Netty收到的數(shù)據(jù)

image

更多關于Java方面的文章,歡迎訪問燕歸來https://www.zhoutao123.com

最后編輯于 ：
?著作權歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
  • 人面猴
    序言：七十年代末剿另，一起剝皮案震驚了整個濱河市，隨后出現(xiàn)的幾起案子贬蛙，更是在濱河造成了極大的恐慌雨女，老刑警劉巖，帶你破解...
    沈念sama閱讀 206,126評論 6贊 481
  • 死咒
    序言：濱河連續(xù)發(fā)生了三起死亡事件阳准，死亡現(xiàn)場離奇詭異氛堕，居然都是意外死亡，警方通過查閱死者的電腦和手機野蝇，發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 88,254評論 2贊 382
  • 救了他兩次的神仙讓他今天三更去死
    文/潘曉璐 我一進店門讼稚，熙熙樓的掌柜王于貴愁眉苦臉地迎上來，“玉大人绕沈，你說我怎么就攤上這事锐想。” “怎么了乍狐？”我有些...
    開封第一講書人閱讀 152,445評論 0贊 341
  • 道士緝兇錄：失蹤的賣姜人
    文/不壞的土叔 我叫張陵赠摇，是天一觀的道長。 經(jīng)常有香客問我浅蚪，道長藕帜，這世上最難降的妖魔是什么？ 我笑而不...
    開封第一講書人閱讀 55,185評論 1贊 278
  • ?港島之戀（遺憾婚禮）
    正文 為了忘掉前任惜傲，我火速辦了婚禮耘戚，結果婚禮上，老公的妹妹穿的比我還像新娘操漠。我一直安慰自己收津，他們只是感情好，可當我...
    茶點故事閱讀 64,178評論 5贊 371
  • 惡毒庶女頂嫁案：這布局不是一般人想出來的
    文/花漫 我一把揭開白布浊伙。 她就那樣靜靜地躺著撞秋，像睡著了一般。 火紅的嫁衣襯著肌膚如雪嚣鄙。 梳的紋絲不亂的頭發(fā)上吻贿，一...
    開封第一講書人閱讀 48,970評論 1贊 284
  • 城市分裂傳說
    那天，我揣著相機與錄音哑子，去河邊找鬼舅列。 笑死肌割，一個胖子當著我的面吹牛，可吹牛的內(nèi)容都是我干的帐要。 我是一名探鬼主播把敞，決...
    沈念sama閱讀 38,276評論 3贊 399
  • 雙鴛鴦連環(huán)套：你想象不到人心有多黑
    文/蒼蘭香墨 我猛地睜開眼，長吁一口氣：“原來是場噩夢啊……” “哼榨惠！你這毒婦竟也來了奋早？” 一聲冷哼從身側響起，我...
    開封第一講書人閱讀 36,927評論 0贊 259
  • 萬榮殺人案實錄
    序言：老撾萬榮一對情侶失蹤赠橙，失蹤者是張志新（化名）和其女友劉穎耽装，沒想到半個月后，有當?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體期揪，經(jīng)...
    沈念sama閱讀 43,400評論 1贊 300
  • ?護林員之死
    正文 獨居荒郊野嶺守林人離奇死亡掉奄，尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點故事閱讀 35,883評論 2贊 323
  • ?白月光啟示錄
    正文 我和宋清朗相戀三年，在試婚紗的時候發(fā)現(xiàn)自己被綠了凤薛。 大學時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片挥萌。...
    茶點故事閱讀 37,997評論 1贊 333
  • 活死人
    序言：一個原本活蹦亂跳的男人離奇死亡，死狀恐怖枉侧，靈堂內(nèi)的尸體忽然破棺而出引瀑，到底是詐尸還是另有隱情，我是刑警寧澤榨馁，帶...
    沈念sama閱讀 33,646評論 4贊 322
  • ?日本核電站爆炸內(nèi)幕
    正文 年R本政府宣布憨栽，位于F島的核電站，受9級特大地震影響翼虫，放射性物質(zhì)發(fā)生泄漏屑柔。R本人自食惡果不足惜，卻給世界環(huán)境...
    茶點故事閱讀 39,213評論 3贊 307
  • 男人毒藥：我在死后第九天來索命
    文/蒙蒙 一珍剑、第九天 我趴在偏房一處隱蔽的房頂上張望掸宛。 院中可真熱鬧，春花似錦招拙、人聲如沸唧瘾。這莊子的主人今日做“春日...
    開封第一講書人閱讀 30,204評論 0贊 19
  • 一樁弒父案别凤，背后竟有這般陰謀
    文/蒼蘭香墨 我抬頭看了看天上的太陽饰序。三九已至，卻和暖如春规哪，著一層夾襖步出監(jiān)牢的瞬間求豫，已是汗流浹背。 一陣腳步聲響...
    開封第一講書人閱讀 31,423評論 1贊 260
  • 情欲美人皮
    我被黑心中介騙來泰國打工， 沒想到剛下飛機就差點兒被人妖公主榨干…… 1. 我叫王不留蝠嘉，地道東北人最疆。 一個月前我還...
    沈念sama閱讀 45,423評論 2贊 352
  • 代替公主和親
    正文 我出身青樓，卻偏偏與公主長得像蚤告，于是被迫代替她去往敵國和親努酸。 傳聞我的和親對象是個殘疾皇子，可洞房花燭夜當晚...
    茶點故事閱讀 42,722評論 2贊 345