本文整理了Java中io.netty.channel.Channel.connect()方法的一些代码示例，展示了Channel.connect()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Channel.connect()方法的具体详情如下：
包路径：io.netty.channel.Channel
类名称：Channel
方法名：connect

Channel.connect介绍

暂无

代码示例

代码示例来源：origin: netty/netty

@Override
  public void run() {
    if (localAddress == null) {
      channel.connect(remoteAddress, connectPromise);
    } else {
      channel.connect(remoteAddress, localAddress, connectPromise);
    }
    connectPromise.addListener(ChannelFutureListener.CLOSE_ON_FAILURE);
  }
});

代码示例来源：origin: redisson/redisson

@Override
  public void run() {
    if (localAddress == null) {
      channel.connect(remoteAddress, connectPromise);
    } else {
      channel.connect(remoteAddress, localAddress, connectPromise);
    }
    connectPromise.addListener(ChannelFutureListener.CLOSE_ON_FAILURE);
  }
});

代码示例来源：origin: wildfly/wildfly

@Override
  public void run() {
    if (localAddress == null) {
      channel.connect(remoteAddress, connectPromise);
    } else {
      channel.connect(remoteAddress, localAddress, connectPromise);
    }
    connectPromise.addListener(ChannelFutureListener.CLOSE_ON_FAILURE);
  }
});

代码示例来源：origin: normanmaurer/netty-in-action

/**
   * Listing 1.3 Asynchronous connect
   *
   * Listing 1.4 Callback in action
   * */
  public static void connect() {
    Channel channel = CHANNEL_FROM_SOMEWHERE; //reference form somewhere
    // Does not block
    ChannelFuture future = channel.connect(
        new InetSocketAddress("192.168.0.1", 25));
    future.addListener(new ChannelFutureListener() {
      @Override
      public void operationComplete(ChannelFuture future) {
        if (future.isSuccess()) {
          ByteBuf buffer = Unpooled.copiedBuffer(
              "Hello", Charset.defaultCharset());
          ChannelFuture wf = future.channel()
              .writeAndFlush(buffer);
          // ...
        } else {
          Throwable cause = future.cause();
          cause.printStackTrace();
        }
      }
    });

  }
}

代码示例来源：origin: aadnk/ProtocolLib

@Override
public ChannelFuture connect(SocketAddress paramSocketAddress1,
    SocketAddress paramSocketAddress2, ChannelPromise paramChannelPromise) {
  return delegate.connect(paramSocketAddress1, paramSocketAddress2, paramChannelPromise);
}

代码示例来源：origin: aadnk/ProtocolLib

@Override
public ChannelFuture connect(SocketAddress paramSocketAddress1,
    SocketAddress paramSocketAddress2) {
  return delegate.connect(paramSocketAddress1, paramSocketAddress2);
}

代码示例来源：origin: aadnk/ProtocolLib

@Override
public ChannelFuture connect(SocketAddress paramSocketAddress,
    ChannelPromise paramChannelPromise) {
  return delegate.connect(paramSocketAddress, paramChannelPromise);
}

代码示例来源：origin: aadnk/ProtocolLib

@Override
public ChannelFuture connect(SocketAddress paramSocketAddress) {
  return delegate.connect(paramSocketAddress);
}

代码示例来源：origin: apache/activemq-artemis

@Override
  public void run() {
    if (localAddress == null) {
      channel.connect(remoteAddress, connectPromise);
    } else {
      channel.connect(remoteAddress, localAddress, connectPromise);
    }
    connectPromise.addListener(ChannelFutureListener.CLOSE_ON_FAILURE);
  }
});

代码示例来源：origin: org.jboss.eap/wildfly-client-all

@Override
  public void run() {
    if (localAddress == null) {
      channel.connect(remoteAddress, connectPromise);
    } else {
      channel.connect(remoteAddress, localAddress, connectPromise);
    }
    connectPromise.addListener(ChannelFutureListener.CLOSE_ON_FAILURE);
  }
});

代码示例来源：origin: org.apache.activemq/artemis-jms-client-all

@Override
  public void run() {
    if (localAddress == null) {
      channel.connect(remoteAddress, connectPromise);
    } else {
      channel.connect(remoteAddress, localAddress, connectPromise);
    }
    connectPromise.addListener(ChannelFutureListener.CLOSE_ON_FAILURE);
  }
});

代码示例来源：origin: org.restcomm.media.core/media-core-network

@Override
public boolean isSecure(Channel channel, InetSocketAddress source) {
  if (channel.isActive()) {
    return channel.remoteAddress().equals(source);
  } else {
    try {
      ChannelFuture future = channel.connect(source).sync();
      return future.isSuccess();
    } catch (Exception e) {
      log.warn("Could not connect channel", e);
      return false;
    }
  }
}

代码示例来源：origin: org.restcomm.media.core/network

@Override
public boolean isSecure(Channel channel, InetSocketAddress source) {
  if (channel.isActive()) {
    return channel.remoteAddress().equals(source);
  } else {
    try {
      ChannelFuture future = channel.connect(source).sync();
      return future.isSuccess();
    } catch (Exception e) {
      log.warn("Could not connect channel", e);
      return false;
    }
  }
}

代码示例来源：origin: Rogiel/torrent4j

@Override
public boolean connect() {
  return channel.connect(channel.remoteAddress())
      .awaitUninterruptibly().isSuccess();
}

代码示例来源：origin: org.opendaylight.usc/usc-channel-impl

@Override
  public void channelRead(ChannelHandlerContext ctx, Object msg)
      throws Exception {
    final Channel ch = ctx.channel();
    final InetSocketAddress remoteAddress = ((DatagramPacket) msg)
        .sender();
    // this is to deal with UDP channels which don't by default have
    // remote address
    if (ch.remoteAddress() == null) {
      ch.connect(remoteAddress);
    }
    addCallHomeConnection(remoteAddress, ch);
    super.channelRead(ctx, msg);
    ch.pipeline().remove(this);
  }
};

代码示例来源：origin: org.restcomm.media.core/network

@Override
public void enterConnecting(NettyNetworkChannelState from, NettyNetworkChannelState to, NettyNetworkChannelEvent event, NettyNetworkChannelTransitionContext context) {
  final ChannelFuture future = this.globalContext.getChannel().connect(this.globalContext.getRemoteAddress());
  future.addListener(new ConnectCallback(context));
}

代码示例来源：origin: org.restcomm.media/network

@Override
public void enterConnecting(NettyNetworkChannelState from, NettyNetworkChannelState to, NettyNetworkChannelEvent event, NettyNetworkChannelTransitionContext context) {
  final ChannelFuture future = this.globalContext.getChannel().connect(this.globalContext.getRemoteAddress());
  future.addListener(new ConnectCallback(context));
}

代码示例来源：origin: org.restcomm.media.core/media-core-network

@Override
public void enterConnecting(NettyNetworkChannelState from, NettyNetworkChannelState to, NettyNetworkChannelEvent event, NettyNetworkChannelTransitionContext context) {
  final ChannelFuture future = this.globalContext.getChannel().connect(this.globalContext.getRemoteAddress());
  future.addListener(new ConnectCallback(context));
}

代码示例来源：origin: io.netty/netty-testsuite

public void testMultipleConnect(ServerBootstrap sb, Bootstrap cb) throws Exception {
  Channel sc = null;
  Channel cc = null;
  try {
    sb.childHandler(new ChannelInboundHandlerAdapter());
    sc = sb.bind(NetUtil.LOCALHOST, 0).syncUninterruptibly().channel();
    cb.handler(new ChannelInboundHandlerAdapter());
    cc = cb.register().syncUninterruptibly().channel();
    cc.connect(sc.localAddress()).syncUninterruptibly();
    ChannelFuture connectFuture2 = cc.connect(sc.localAddress()).await();
    assertTrue(connectFuture2.cause() instanceof AlreadyConnectedException);
  } finally {
    if (cc != null) {
      cc.close();
    }
    if (sc != null) {
      sc.close();
    }
  }
}

代码示例来源：origin: io.github.myui/hivemall

@Override
public void sendCancelRequest(@Nonnull Object feature, @Nonnull MixedWeight mixed)
    throws Exception {
  assert (initialized);
  float weight = mixed.getWeight();
  float covar = mixed.getCovar();
  int deltaUpdates = mixed.getDeltaUpdates();
  MixMessage msg = new MixMessage(event, feature, weight, covar, deltaUpdates, true);
  assert (groupID != null);
  msg.setGroupID(groupID);
  // TODO REVIEWME consider mix server faults (what if mix server dead? Do not send cancel request?)
  NodeInfo server = router.selectNode(msg);
  Channel ch = channelMap.get(server);
  if(!ch.isActive()) {// reconnect
    SocketAddress remoteAddr = server.getSocketAddress();
    ch.connect(remoteAddr).sync();
  }
  ch.writeAndFlush(msg); // send asynchronously in the background
}