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

SocketChannel.isConnected介绍

[英]Indicates whether this channel's socket is connected.
[中]指示此通道的套接字是否已连接。

代码示例

代码示例来源：origin: apache/kafka

@Override
public boolean isConnected() {
  return socketChannel.isConnected();
}

代码示例来源：origin: apache/kafka

@Override
public boolean isConnected() {
  return socketChannel.isConnected();
}

代码示例来源：origin: TooTallNate/Java-WebSocket

public boolean isConnected() {
  return socketChannel.isConnected();
}

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

/**
   * Returns true if the channel for this key is connected. If the channel
   * does not need connecting, this always return true.
   */
  boolean isConnected() {
    return !(channel instanceof SocketChannel) || ((SocketChannel) channel).isConnected();
  }
}

代码示例来源：origin: jMonkeyEngine/jmonkeyengine

public boolean isConnected()
{
  return socket.isConnected();
}

代码示例来源：origin: apache/nifi

@Override
public boolean isClosed() {
  return !channel.isConnected();
}

代码示例来源：origin: apache/nifi

@Override
public boolean isConnected() {
  return channel != null && channel.isConnected();
}

代码示例来源：origin: apache/nifi

public boolean isConnected() {
  return socketChannel.isConnected();
}

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

@Override
public boolean isActive() {
  SocketChannel ch = javaChannel();
  return ch.isOpen() && ch.isConnected();
}

代码示例来源：origin: oldmanpushcart/greys-anatomy

private void write(SocketChannel socketChannel, ByteBuffer buffer) throws IOException {
  while (buffer.hasRemaining()
      && socketChannel.isConnected()) {
    if (-1 == socketChannel.write(buffer)) {
      // socket broken
      throw new IOException("write EOF");
    }
  }
}

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

@Override
public boolean isActive() {
  SocketChannel ch = javaChannel();
  return ch.isOpen() && ch.isConnected();
}

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

@Override
public boolean isActive() {
  SocketChannel ch = javaChannel();
  return ch.isOpen() && ch.isConnected();
}

代码示例来源：origin: apache/nifi

public SSLSocketChannel(final SSLContext sslContext, final SocketChannel socketChannel, final boolean client) throws IOException {
  if (!socketChannel.isConnected()) {
    throw new IllegalArgumentException("Cannot pass an un-connected SocketChannel");
  }
  this.channel = socketChannel;
  this.socketAddress = socketChannel.getRemoteAddress();
  final Socket socket = socketChannel.socket();
  this.hostname = socket.getInetAddress().getHostName();
  this.port = socket.getPort();
  this.engine = sslContext.createSSLEngine();
  this.engine.setUseClientMode(client);
  this.engine.setNeedClientAuth(true);
  streamInManager = new BufferStateManager(ByteBuffer.allocate(engine.getSession().getPacketBufferSize()));
  streamOutManager = new BufferStateManager(ByteBuffer.allocate(engine.getSession().getPacketBufferSize()));
  appDataManager = new BufferStateManager(ByteBuffer.allocate(engine.getSession().getApplicationBufferSize()));
}

代码示例来源：origin: apache/nifi

public SSLSocketChannel(final SSLEngine sslEngine, final SocketChannel socketChannel) throws IOException {
  if (!socketChannel.isConnected()) {
    throw new IllegalArgumentException("Cannot pass an un-connected SocketChannel");
  }
  this.channel = socketChannel;
  this.socketAddress = socketChannel.getRemoteAddress();
  final Socket socket = socketChannel.socket();
  this.hostname = socket.getInetAddress().getHostName();
  this.port = socket.getPort();
  // don't set useClientMode or needClientAuth, use the engine as is and let the caller configure it
  this.engine = sslEngine;
  streamInManager = new BufferStateManager(ByteBuffer.allocate(engine.getSession().getPacketBufferSize()));
  streamOutManager = new BufferStateManager(ByteBuffer.allocate(engine.getSession().getPacketBufferSize()));
  appDataManager = new BufferStateManager(ByteBuffer.allocate(engine.getSession().getApplicationBufferSize()));
}

代码示例来源：origin: alibaba/nacos

@Override
  public void run() {
    if (key != null && key.isValid()) {
      SocketChannel channel = (SocketChannel) key.channel();
      Beat beat = (Beat) key.attachment();
      if (channel.isConnected()) {
        return;
      }
      try {
        channel.finishConnect();
      } catch (Exception ignore) {
      }
      try {
        beat.finishCheck(false, false, beat.getTask().getCheckRTNormalized() * 2, "tcp:timeout");
        key.cancel();
        key.channel().close();
      } catch (Exception ignore) {
      }
    }
  }
}

代码示例来源：origin: apache/nifi

@Override
public boolean isClosed() {
  boolean closed = !socketChannel.isConnected();
  if (!closed) {
    try {
      this.in.isDataAvailable();
    } catch (IOException e) {
      try {
        close();
      } catch (IOException e1) {
      }
      closed = true;
    }
  }
  return closed;
}

代码示例来源：origin: alibaba/canal

public void disconnect() throws CanalClientException {
  if (rollbackOnDisConnect && channel.isConnected()) {
    rollback();
  }
  connected = false;
  if (runningMonitor != null) {
    if (runningMonitor.isStart()) {
      runningMonitor.stop();
    }
  } else {
    doDisconnect();
  }
}

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

public NioConnection(SocketChannel channel, NioBaseServer server) throws Exception {
  this.channel=channel;
  this.server=server;
  setSocketParameters(this.channel.socket());
  channel.configureBlocking(false);
  this.connected=channel.isConnected();
  send_buf=new Buffers(server.maxSendBuffers() *2); // space for actual bufs and length bufs!
  this.peer_addr=server.usePeerConnections()? null /* read by first receive() */
   : new IpAddress((InetSocketAddress)channel.getRemoteAddress());
  last_access=getTimestamp(); // last time a message was sent or received (ns)
}

代码示例来源：origin: apache/kafka

@Override
protected void startHandshake() throws IOException {
  assertTrue("SSL handshake initialized too early", socketChannel().isConnected());
  super.startHandshake();
}

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

protected void connect(Address dest, boolean send_local_addr) throws Exception {
  SocketAddress destAddr=new InetSocketAddress(((IpAddress)dest).getIpAddress(), ((IpAddress)dest).getPort());
  try {
    if(!server.deferClientBinding())
      this.channel.bind(new InetSocketAddress(server.clientBindAddress(), server.clientBindPort()));
    this.key=server.register(channel, SelectionKey.OP_CONNECT | SelectionKey.OP_READ, this);
    if(Util.connect(channel, destAddr) && channel.finishConnect()) {
      clearSelectionKey(SelectionKey.OP_CONNECT);
      this.connected=channel.isConnected();
    }
    if(this.channel.getLocalAddress() != null && this.channel.getLocalAddress().equals(destAddr))
      throw new IllegalStateException("socket's bind and connect address are the same: " + destAddr);
    if(send_local_addr)
      sendLocalAddress(server.localAddress());
  }
  catch(Exception t) {
    close();
    throw t;
  }
}