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

Channel.isReadable介绍

[英]Returns true if and only if the I/O thread will read a message from this channel. This method is a shortcut to the following code:

return (getInterestOps() & OP_READ) != 0;

[中]当且仅当I/O线程将从此通道读取消息时，返回true。此方法是以下代码的快捷方式：

return (getInterestOps() & OP_READ) != 0;

代码示例

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

public synchronized boolean isChannelReadable(String remoteAddress) {
  Channel ch = channelMap.get(remoteAddress);
  if (ch != null) {
    return ch.isReadable();
  } else {
    return false;
  }
}

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

if (!channel.isReadable() && ! rws.readSuspend) {
    logger.debug("Not unsuspend: " + channel.isReadable() + ':' +
        rws.readSuspend);
    if (channel.isReadable() && rws.readSuspend) {
      logger.debug("Unsuspend: " + channel.isReadable() + ':' +
          rws.readSuspend);
    } else {
      logger.debug("Normal unsuspend: " + channel.isReadable() + ':' +
          rws.readSuspend);
  logger.debug("Unsupsend final status => " + channel.isReadable() + ':' +
      rws.readSuspend);

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

logger.debug("Read suspend: " + wait + ':' + channel.isReadable() + ':' +
      rws.readSuspend);
  return;
if (channel.isReadable() && ! rws.readSuspend) {
  rws.readSuspend = true;
  channel.setReadable(false);
  if (logger.isDebugEnabled()) {
    logger.debug("Suspend final status => " + channel.isReadable() + ':' +
        rws.readSuspend);

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

logger.debug("Read suspend: " + wait + ':' + channel.isReadable() + ':' +
      rws.readSuspend);
  return;
if (channel.isReadable() && ! rws.readSuspend) {
  rws.readSuspend = true;
  channel.setReadable(false);
  if (logger.isDebugEnabled()) {
    logger.debug("Suspend final status => " + channel.isReadable() + ':' +
        rws.readSuspend);

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

if (channel.isReadable()) {

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

if (!channel.isReadable()) {

代码示例来源：origin: com.ning/async-http-client

public final void tryToOfferChannelToPool(Channel channel, boolean keepAlive, Object partitionKey) {
  if (channel.isConnected() && keepAlive && channel.isReadable()) {
    LOGGER.debug("Adding key: {} for channel {}", partitionKey, channel);
    Channels.setDiscard(channel);
    if (channelPool.offer(channel, partitionKey)) {
      if (maxConnectionsPerHostEnabled)
        channelId2PartitionKey.putIfAbsent(channel.getId(), partitionKey);
    } else {
      // rejected by pool
      closeChannel(channel);
    }
  } else {
    // not offered
    closeChannel(channel);
  }
}

代码示例来源：origin: apache/james-project

@Override
public boolean isReadable() {
  return channel.isReadable();
}

代码示例来源：origin: org.apache.james.protocols/protocols-netty

@Override
public boolean isReadable() {
  return channel.isReadable();
}

代码示例来源：origin: kaazing/gateway

@Override
public boolean isReadSuspended() {
  return channel.isReadable();
}

代码示例来源：origin: com.alibaba.jstorm/jstorm-core

public synchronized boolean isChannelReadable(String remoteAddress) {
  Channel ch = channelMap.get(remoteAddress);
  if (ch != null) {
    return ch.isReadable();
  } else {
    return false;
  }
}

代码示例来源：origin: zhaoshiling1017/voyage

public boolean isClosed() {
  return (null == channel) || !channel.isConnected() || !channel.isReadable() || !channel.isWritable();
}

代码示例来源：origin: io.gatling/async-http-client

public final void tryToOfferChannelToPool(Channel channel, boolean keepAlive, String poolKey) {
  if (keepAlive && channel.isReadable()) {
    LOGGER.debug("Adding key: {} for channel {}", poolKey, channel);
    channelPool.offer(channel, poolKey);
    if (maxConnectionsPerHostEnabled)
      channelId2KeyPool.putIfAbsent(channel.getId(), poolKey);
    Channels.setDiscard(channel);
  } else {
    // not offered
    closeChannel(channel);
  }
}

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

@Override
protected void invokeCommand(final ChannelHandlerContext ctx) throws Exception {
  Channel channel = ctx.getChannel();
  if (channel.isReadable()) {
    invokeCommandWhenReadable(ctx);
  }
  else {
    readableFuture.addListener(new ChannelFutureListener() {
      @Override
      public void operationComplete(ChannelFuture future) throws Exception {
        if (future.isSuccess()) {
          invokeCommandWhenReadable(ctx);
        }
      }
    });
  }
}

代码示例来源：origin: org.asynchttpclient/async-http-client-netty3-provider

public final void tryToOfferChannelToPool(Channel channel, boolean keepAlive, Object partitionKey) {
  if (channel.isConnected() && keepAlive && channel.isReadable()) {
    LOGGER.debug("Adding key: {} for channel {}", partitionKey, channel);
    Channels.setDiscard(channel);
    channelPool.offer(channel, partitionKey);
    if (maxConnectionsPerHostEnabled)
      channelId2PartitionKey.putIfAbsent(channel.getId(), partitionKey);
  } else {
    // not offered
    closeChannel(channel);
  }
}

代码示例来源：origin: fgp/AirReceiver

@Override
  public void messageReceived(final ChannelHandlerContext ctx, final MessageEvent evt)
    throws Exception
  {
    /* Get audio channel from the enclosing RaopAudioHandler */
    Channel audioChannel = null;
    synchronized(RaopAudioHandler.this) {
      audioChannel = m_audioChannel;
    }
    if ((m_audioChannel != null) && m_audioChannel.isOpen() && m_audioChannel.isReadable()) {
      audioChannel.getPipeline().sendUpstream(new UpstreamMessageEvent(
        audioChannel,
        evt.getMessage(),
        evt.getRemoteAddress())
      );
    }
  }
}

代码示例来源：origin: org.asynchttpclient/async-http-client-netty3

public final void tryToOfferChannelToPool(Channel channel, AsyncHandler<?> handler, boolean keepAlive, Object partitionKey) {
  if (channel.isConnected() && keepAlive && channel.isReadable()) {
    LOGGER.debug("Adding key: {} for channel {}", partitionKey, channel);
    Channels.setDiscard(channel);
    if (handler instanceof AsyncHandlerExtensions) {
      AsyncHandlerExtensions.class.cast(handler).onConnectionOffer(channel);
    }
    channelPool.offer(channel, partitionKey);
    if (maxConnectionsPerHostEnabled)
      channelId2PartitionKey.putIfAbsent(channel.getId(), partitionKey);
  } else {
    // not offered
    closeChannel(channel);
  }
}