增加获取连接状态的方法

protocol-core/src/main/java/wei/yigulu/netty/AbstractClientBuilder.java

@@ -46,6 +46,9 @@ public abstract class AbstractClientBuilder extends BaseProtocolBuilder {
 
 	protected ProtocolChannelInitializer channelInitializer = null;
 
+	public boolean isConnected(){
+		return this.future!=null && this.future.channel().isActive();
+	}
 
 	public void stop() {
 		log.info("关闭通道{}", this.builderId);

protocol-core/src/main/java/wei/yigulu/netty/AbstractMasterBuilder.java

@@ -25,7 +25,7 @@ public abstract class AbstractMasterBuilder extends AbstractClientBuilder implem
 	 */
 	@Override
 	public void sendFrameToOpposite(byte[] bytes) {
-		if (getFuture() != null && getFuture().channel().isActive()) {
+		if (isConnected()) {
 			getLog().info("se ==> " + DataConvertor.Byte2String(bytes));
 			getFuture().channel().writeAndFlush(Unpooled.copiedBuffer(bytes));
 		} else {
@@ -40,7 +40,7 @@ public abstract class AbstractMasterBuilder extends AbstractClientBuilder implem
 	 */
 	@Override
 	public void sendFrameToOpposite(ByteBuf byteBuf) {
-		if (getFuture() != null && getFuture().channel().isActive()) {
+		if (isConnected()) {
 			getLog().info("se ==> " + DataConvertor.ByteBuf2String(byteBuf));
 			getFuture().channel().writeAndFlush(Unpooled.copiedBuffer(byteBuf));
 		} else {