publicvoidprocessEvent(Event event){// 拦截器处理数据 event =interceptorChain.intercept(event);if(event ==null){return;}// channel选择器 对设置的channel遍历发送数据List<Channel>requiredChannels=selector.getRequiredChannels(event);for(ChannelreqChannel: requiredChannels){Transactiontx=reqChannel.getTransaction();Preconditions.checkNotNull(tx,"Transaction object must not be null");try{tx.begin();reqChannel.put(event);tx.commit();}catch(Throwablet){tx.rollback();...}