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。

通過(guò)繼承ChannelHandlerAdapter來(lái)代替

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

context對(duì)象

一個(gè)ChannelHandler和一個(gè)ChannelHandlerContext對(duì)象一起被提供。一個(gè)ChannelHander通過(guò)一個(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í)例，來(lái)避免競(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

雖然使用成員變量來(lái)保存一個(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è)注解沒(méi)有指定，你就只能為每次需要添加到pipeline中的handler，每次創(chuàng)建一個(gè)新的實(shí)例。因?yàn)樗蟹枪蚕淼臓顟B(tài)，比如：成員變量。

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

您可能感興趣的文章: