java 中 ChannelHandler的用法詳解
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),文中通過示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2020-12-12java?SpringBoot注解@Async不生效的解決方法
大家好,本篇文章主要講的是java?SpringBoot注解@Async不生效的解決方法,感興趣的同學(xué)趕快來看一看吧,對(duì)你有幫助的話記得收藏一下2022-01-01springboot 通過代碼自動(dòng)生成pid的方法
這篇文章主要介紹了springboot 通過代碼自動(dòng)生成pid的方法,小編覺得挺不錯(cuò)的,現(xiàn)在分享給大家,也給大家做個(gè)參考。一起跟隨小編過來看看吧2018-07-07很多人竟然不知道Java線程池的創(chuàng)建方式有7種
本文主要介紹了很多人竟然不知道Java線程池的創(chuàng)建方式有7種,文中通過示例代碼介紹的非常詳細(xì),具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下2021-07-07JAVA使用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)問題及解決方法,本文給大家分享問題原因就解決方法,對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下2020-09-09