netty中的監(jiān)聽器
此處只會(huì)講解監(jiān)聽器的定義歹篓，因?yàn)楸O(jiān)聽器具體的實(shí)現(xiàn)都是根據(jù)使用時(shí)的邏輯做的定義夺英，之所以講解定義也是為了再講解其他地方如果使用到了他讀者可以大概猜測出他做了什么事情，然后再去看實(shí)現(xiàn)滋捶。
//jdk 提供的接口 只用于監(jiān)聽器的標(biāo)識(shí)痛悯，jdk官方建議所有監(jiān)聽器實(shí)現(xiàn)此標(biāo)識(shí)，而netty則接納了建議重窟，此接口不必糾結(jié)他僅僅是一個(gè)標(biāo)識(shí)接口载萌。
public interface EventListener {
}
//此接口繼承與上方接口，并且有個(gè)泛型是Future此類型并不陌生之前文章一直在講述他
//此接口的定義：監(jiān)聽Futuer的操作巡扇，當(dāng)Future中添加了監(jiān)聽器扭仁，F(xiàn)uture的個(gè)別方法被調(diào)用時(shí)則會(huì)觸發(fā)添加的監(jiān)聽器，一般有success厅翔、failure等還有些都是根據(jù)具體future實(shí)現(xiàn)走的
//如果有遺忘的讀者可以再看下前面的文章中通知調(diào)用部分
public interface GenericFutureListener<F extends Future<?>> extends EventListener {
//操作成功后的調(diào)用乖坠，傳入Future則是操作完成的Future
void operationComplete(F future) throws Exception;
}
//此監(jiān)聽器并沒有什么特殊的含義，只不過做了跟細(xì)化的約束刀闷，此監(jiān)聽器只會(huì)用于ChannelGroupFuture類型的Future
public interface ChannelGroupFutureListener extends GenericFutureListener<ChannelGroupFuture> {
}
//與上方接口一樣僅僅是一個(gè)監(jiān)聽器的別名熊泵，針對(duì)ChannelFuture做的約束監(jiān)聽器
public interface ChannelFutureListener extends GenericFutureListener<ChannelFuture> {
//內(nèi)部定義的默認(rèn)實(shí)現(xiàn)CLOSE 當(dāng)ChannelFuture關(guān)閉的時(shí)候如果添加了此監(jiān)聽器則會(huì)將管道一并關(guān)閉
ChannelFutureListener CLOSE = new ChannelFutureListener() {
@Override
public void operationComplete(ChannelFuture future) {
future.channel().close();
}
};
//當(dāng)future設(shè)置失敗的時(shí)候觸發(fā)CLOSE_ON_FAILURE監(jiān)聽器會(huì)將管道關(guān)閉
ChannelFutureListener CLOSE_ON_FAILURE = new ChannelFutureListener() {
@Override
public void operationComplete(ChannelFuture future) {
if (!future.isSuccess()) {
future.channel().close();
}
}
};
//CLOSE_ON_FAILURE是這是失敗則關(guān)閉仰迁，而FIRE_EXCEPTION_ON_FAILURE設(shè)置失敗則傳播異常具體在講述pipeline的時(shí)候會(huì)進(jìn)行講解
ChannelFutureListener FIRE_EXCEPTION_ON_FAILURE = new ChannelFutureListener() {
@Override
public void operationComplete(ChannelFuture future) {
if (!future.isSuccess()) {
future.channel().pipeline().fireExceptionCaught(future.cause());
}
}
};
}
//針對(duì)GenericFutureListener起的別名，對(duì)GenericFutureListener的泛型Future做了隱藏顽分。
public interface FutureListener<V> extends GenericFutureListener<Future<V>> { }
//通用的進(jìn)度監(jiān)聽器徐许，約束了Future的類型必須繼承于ProgressiveFuture
public interface GenericProgressiveFutureListener<F extends ProgressiveFuture<?>> extends GenericFutureListener<F> {
//操作進(jìn)度觸發(fā)將會(huì)調(diào)用此方法，傳入當(dāng)前future 和 當(dāng)前的進(jìn)度 和 總的進(jìn)度
void operationProgressed(F future, long progress, long total) throws Exception;
}
//針對(duì)GenericProgressiveFutureListener起的別名并沒有什么卒蘸，只是將約束更加精細(xì)化了
public interface ChannelProgressiveFutureListener extends GenericProgressiveFutureListener<ChannelProgressiveFuture> {
}
定義到此就差不多了雌隅，剩下的實(shí)現(xiàn)在后面具體使用的時(shí)候?qū)?huì)講述。
