新增参看连接状态方法

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

@@ -47,6 +47,10 @@ 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);
 		if (this.future != null) {

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 {