欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

java 中 ChannelHandler的用法詳解

 更新時(shí)間:2017年08月06日 14:50:16   作者:追尋北極  
這篇文章主要介紹了java 中 ChannelHandler的用法詳解的相關(guān)資料,ChannelHandler處理一個(gè)I/O event或者攔截一個(gè)I/O操作,需要的朋友可以參考下

java 中 ChannelHandler的用法詳解

前言:

ChannelHandler處理一個(gè)I/O event或者攔截一個(gè)I/O操作,在它的ChannelPipeline中將其遞交給相鄰的下一個(gè)handler。

通過繼承ChannelHandlerAdapter來代替

因?yàn)檫@個(gè)接口有許多的方法需要實(shí)現(xiàn),你或許希望通過繼承ChannelHandlerAdapter來代替。

context對(duì)象

一個(gè)ChannelHandler和一個(gè)ChannelHandlerContext對(duì)象一起被提供。一個(gè)ChannelHander通過一個(gè)context對(duì)象和其所屬的那個(gè)ChannelPipeline進(jìn)行交互。使用context對(duì)象,ChannelHandler可以向上或者向下傳遞events,動(dòng)態(tài)地修改pipeline,或者存儲(chǔ)與handler相關(guān)的信息(使用AttributeKeys)。

狀態(tài)管理

一個(gè)ChannelHandler經(jīng)常需要存儲(chǔ)一些狀態(tài)相關(guān)的信息。最簡(jiǎn)單和推薦的方法是使用成員變量:

public interface Message {
  // your methods here
}

public class DataServerHandler extends SimpleChannelInboundHandler<Message> {

  private boolean loggedIn;

  @Override
  protected void messageReceived(ChannelHandlerContext ctx, Message message) {
    Channel ch = e.getChannel();
    if (message instanceof LoginMessage) {
      authenticate((LoginMessage) message);
      loggedIn = true;
    } else (message instanceof GetDataMessage) {
      if (loggedIn) {
        ch.write(fetchSecret((GetDataMessage) message));
      } else {
        fail();
      }
    }
  }
  ...
}

因?yàn)閔andler實(shí)例有一個(gè)狀態(tài)變量專注于一個(gè)連接,你必須為每一個(gè)handler實(shí)例創(chuàng)建一個(gè)新的handler實(shí)例,來避免競(jìng)態(tài)的情況以至于未認(rèn)證的客戶端可以獲得機(jī)密的信息:

// Create a new handler instance per channel.
// See ChannelInitializer.initChannel(Channel).
public class DataServerInitializer extends ChannelInitializer<Channel> {
  @Override
  public void initChannel(Channel channel) {
    channel.pipeline().addLast("handler", new DataServerHandler());
  }
}

使用AttributeKeys

雖然使用成員變量來保存一個(gè)handler的狀態(tài)是被推薦的,然而,由于一些原因你或許不想創(chuàng)建很多的handler實(shí)例。在這種情況下,你可以使用附在ChannelHandlerContext上的AttributeKeys:

public interface Message {
  // your methods here
}
@Sharable
public class DataServerHandler extends SimpleChannelInboundHandler<Message> {
  private final AttributeKey<Boolean> auth =
     AttributeKey.valueOf("auth");
  @Override
  protected void messageReceived(ChannelHandlerContext ctx, Message message) {
    Attribute<Boolean> attr = ctx.attr(auth);
    Channel ch = ctx.channel();
    if (message instanceof LoginMessage) {
      authenticate((LoginMessage) o);
      attr.set(true);
    } else (message instanceof GetDataMessage) {
      if (Boolean.TRUE.equals(attr.get())) {
        ch.write(fetchSecret((GetDataMessage) o));
      } else {
        fail();
      }
    }
  }
  ...
}

現(xiàn)在handler的狀態(tài)被附在了ChannelHandlerContext上了,你可以添加同樣的Handler實(shí)例到不同的pipeline上:

 public class DataServerInitializer extends ChannelInitializer<Channel> {

   private static final DataServerHandler SHARED = new DataServerHandler();

   @Override
   public void initChannel(Channel channel) {
     channel.pipeline().addLast("handler", SHARED);
   }
 }

@Sharable 注解

在上面使用AttributeKey的例子中,你應(yīng)該已經(jīng)注意到了@Sharable注解。

如果一個(gè)ChannelHandler被注解為@Sharable,那意味著你可以只創(chuàng)建一個(gè)handler實(shí)例,并把它添加到一個(gè)或多個(gè)ChannelPipeline中多次,并不用考慮競(jìng)態(tài)的情況。

如果這個(gè)注解沒有指定,你就只能為每次需要添加到pipeline中的handler,每次創(chuàng)建一個(gè)新的實(shí)例。因?yàn)樗蟹枪蚕淼臓顟B(tài),比如:成員變量。

如有疑問請(qǐng)留言或者到本站社區(qū)交流討論,感謝閱讀,希望能幫助到大家,謝謝大家對(duì)本站的支持!

相關(guān)文章

  • Spring 單元測(cè)試中如何進(jìn)行 mock的實(shí)現(xiàn)

    Spring 單元測(cè)試中如何進(jìn)行 mock的實(shí)現(xiàn)

    這篇文章主要介紹了Spring 單元測(cè)試中如何進(jìn)行 mock的實(shí)現(xiàn),文中通過示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
    2020-12-12
  • Java異常處理原理與用法實(shí)例分析

    Java異常處理原理與用法實(shí)例分析

    這篇文章主要介紹了Java異常處理原理與用法,結(jié)合實(shí)例形式分析了Java異常處理相關(guān)概念、原理、用法及操作注意事項(xiàng),需要的朋友可以參考下
    2020-04-04
  • java?SpringBoot注解@Async不生效的解決方法

    java?SpringBoot注解@Async不生效的解決方法

    大家好,本篇文章主要講的是java?SpringBoot注解@Async不生效的解決方法,感興趣的同學(xué)趕快來看一看吧,對(duì)你有幫助的話記得收藏一下
    2022-01-01
  • 在Jpa框架下拼接原生sql 并執(zhí)行的操作

    在Jpa框架下拼接原生sql 并執(zhí)行的操作

    這篇文章主要介紹了在Jpa框架下拼接原生sql 并執(zhí)行的操作,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教
    2021-06-06
  • springBoot快速訪問工程目錄下的靜態(tài)資源

    springBoot快速訪問工程目錄下的靜態(tài)資源

    springboot工程,是沒有webapp文件夾的,靜態(tài)文件放在src/main/resources/static文件夾下即可,模板文件放在src/main/resources/templates下,本文給大家介紹springBoot快速訪問工程目錄下的靜態(tài)資源的相關(guān)知識(shí),一起看看吧
    2021-06-06
  • java Swing實(shí)現(xiàn)五子棋游戲

    java Swing實(shí)現(xiàn)五子棋游戲

    這篇文章主要為大家詳細(xì)介紹了java Swing實(shí)現(xiàn)五子棋游戲,文中示例代碼介紹的非常詳細(xì),具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下
    2020-12-12
  • springboot 通過代碼自動(dòng)生成pid的方法

    springboot 通過代碼自動(dòng)生成pid的方法

    這篇文章主要介紹了springboot 通過代碼自動(dòng)生成pid的方法,小編覺得挺不錯(cuò)的,現(xiàn)在分享給大家,也給大家做個(gè)參考。一起跟隨小編過來看看吧
    2018-07-07
  • 很多人竟然不知道Java線程池的創(chuàng)建方式有7種

    很多人竟然不知道Java線程池的創(chuàng)建方式有7種

    本文主要介紹了很多人竟然不知道Java線程池的創(chuàng)建方式有7種,文中通過示例代碼介紹的非常詳細(xì),具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下
    2021-07-07
  • JAVA使用TreeMap對(duì)字符串進(jìn)行排序

    JAVA使用TreeMap對(duì)字符串進(jìn)行排序

    這篇文章主要介紹了JAVA使用TreeMap對(duì)字符串進(jìn)行排序,文中通過示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下
    2020-02-02
  • 解決IDEA的maven項(xiàng)目中沒有新建Servlet文件的選項(xiàng)問題

    解決IDEA的maven項(xiàng)目中沒有新建Servlet文件的選項(xiàng)問題

    這篇文章主要介紹了IDEA的maven項(xiàng)目中沒有新建Servlet文件的選項(xiàng)問題及解決方法,本文給大家分享問題原因就解決方法,對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下
    2020-09-09

最新評(píng)論