org.jboss.netty.channel.ChannelStateEvent.getChannel()方法的使用及代码示例

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

ChannelStateEvent.getChannel介绍

暂无

代码示例

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

@Override
public void channelConnected(ChannelHandlerContext ctx, ChannelStateEvent e) {
LOG.info("Connection established {}", e.getChannel().getRemoteAddress());
server.addChannel(e.getChannel());
}

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

@Override
public void channelInterestChanged(ChannelHandlerContext ctx, ChannelStateEvent e) throws Exception {
client.notifyInterestChanged(e.getChannel());
}
}

代码示例来源：origin: MovingBlocks/Terasology

@Override
public void channelOpen(ChannelHandlerContext ctx, ChannelStateEvent e) {
networkSystem.registerChannel(e.getChannel());
}

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

@Override
public void channelClosed(ChannelHandlerContext ctx, ChannelStateEvent e) throws Exception {
super.channelClosed(ctx, e);
LOG.info("Connection channelClosed {}", e.getChannel().getRemoteAddress());
MessageDecoder.removeTransmitHistogram(e.getChannel());
}

代码示例来源：origin: menacher/java-game-server

@Override
public void channelOpen(ChannelHandlerContext ctx, ChannelStateEvent e)
throws Exception {
AbstractNettyServer.ALL_CHANNELS.add(e.getChannel());
LOG.debug("Added Channel with id: {} as the {}th open channel", e
.getChannel().getId(), CHANNEL_COUNTER.incrementAndGet());
}

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

/**
* @see org.jboss.netty.channel.SimpleChannelUpstreamHandler#channelDisconnected(org.jboss.netty.channel.ChannelHandlerContext,
* org.jboss.netty.channel.ChannelStateEvent)
*/
@Override
public void channelDisconnected(ChannelHandlerContext ctx, ChannelStateEvent e) throws Exception {
LOG.info("Receive channelDisconnected to {}, channel = {}", client.getRemoteAddr(), e.getChannel());
// ctx.sendUpstream(e);
super.channelDisconnected(ctx, e);
client.disconnectChannel(e.getChannel());
}

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

@Override
public void channelDisconnected(ChannelHandlerContext ctx, ChannelStateEvent e) throws Exception {
super.channelDisconnected(ctx, e);
LOG.info("Connection channelDisconnected {}", e.getChannel().getRemoteAddress());
MessageDecoder.removeTransmitHistogram(e.getChannel());
server.getChannelGroup().remove(e.getChannel());
}

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

@Override
public void channelClosed(ChannelHandlerContext ctx, ChannelStateEvent e) throws Exception {
LOG.info("Connection to {} has been closed, channel = {}", client.getRemoteAddr(), e.getChannel());
super.channelClosed(ctx, e);
}

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

@Override
public void channelClosed(
ChannelHandlerContext ctx, ChannelStateEvent e) throws Exception {
LOG.info("Connection to {} disconnected.",
e.getChannel().getRemoteAddress());
super.channelClosed(ctx, e);
e.getChannel().close();
allChannels.remove(e.getChannel());
}

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

@Override
public void channelOpen(ChannelHandlerContext ctx, ChannelStateEvent evt)
throws Exception {
if ((maxShuffleConnections > 0) && (accepted.size() >= maxShuffleConnections)) {
LOG.info(String.format("Current number of shuffle connections (%d) is " +
"greater than or equal to the max allowed shuffle connections (%d)",
accepted.size(), maxShuffleConnections));
evt.getChannel().close();
return;
}
accepted.add(evt.getChannel());
super.channelOpen(ctx, evt);
}

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

@Override
public void channelOpen(ChannelHandlerContext ctx, ChannelStateEvent e)
throws Exception {
allChannels.add(e.getChannel());
super.channelOpen(ctx, e);
}

代码示例来源：origin: menacher/java-game-server

@Override
public void channelConnected(ChannelHandlerContext ctx, ChannelStateEvent e)
throws Exception
{
NettyTCPClient.ALL_CHANNELS.add(e.getChannel());
super.channelConnected(ctx, e);
}

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

@Override
public void channelConnected(ChannelHandlerContext ctx, ChannelStateEvent e) throws Exception {
connectionStats.reportChannelConnect();
if(allchannels != null) {
allchannels.add(e.getChannel());
}
ctx.sendUpstream(e);
}

代码示例来源：origin: menacher/java-game-server

@Override
public void channelClosed(ChannelHandlerContext ctx, ChannelStateEvent e)
throws Exception
{
DatagramChannel datagramChannel = (DatagramChannel) e.getChannel();
Session session = NettyUDPClient.CLIENTS.get(datagramChannel
.getLocalAddress());
if ((null != session) && !session.isShuttingDown())
{
Event event = Events.event(e, Events.DISCONNECT);
session.onEvent(event);
}
}

代码示例来源：origin: menacher/java-game-server

@Override
public void channelClosed(ChannelHandlerContext ctx, ChannelStateEvent e)
throws Exception
{
LOG.debug("Netty Channel {} is closed.", e.getChannel().getId());
if (!playerSession.isShuttingDown())
{
// Should not send close to session, since reconnection/other
// business logic might be in place.
Event event = Events.event(e, Events.DISCONNECT);
playerSession.onEvent(event);
}
}

代码示例来源：origin: MovingBlocks/Terasology

@Override
public void channelConnected(ChannelHandlerContext ctx, ChannelStateEvent e) throws Exception {
logger.info("Sending Server Hello");
PublicIdentityCertificate serverPublicCert = config.getSecurity().getServerPublicCertificate();
new SecureRandom().nextBytes(serverRandom);
serverHello = NetData.HandshakeHello.newBuilder()
.setRandom(ByteString.copyFrom(serverRandom))
.setCertificate(NetMessageUtil.convert(serverPublicCert))
.setTimestamp(System.currentTimeMillis())
.build();
e.getChannel().write(NetData.NetMessage.newBuilder()
.setHandshakeHello(serverHello)
.build());
}

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

/**
* Sometime when connecting to a bad channel which isn't writable, this method will be called
*/
@Override
public void channelConnected(ChannelHandlerContext ctx, ChannelStateEvent event) {
// register the newly established channel
Channel channel = event.getChannel();
LOG.info("connection established to :{}, local port:{}", client.getRemoteAddr(), channel.getLocalAddress());
client.connectChannel(ctx.getChannel());
client.handleResponse(ctx.getChannel(), null);
}

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

private void sendGoAwayFrame(ChannelHandlerContext ctx, ChannelStateEvent e) {
// Avoid NotYetConnectedException
if (!e.getChannel().isConnected()) {
ctx.sendDownstream(e);
return;
}
ChannelFuture future = sendGoAwayFrame(ctx, e.getChannel(), null, SpdySessionStatus.OK);
if (spdySession.noActiveStreams()) {
future.addListener(new ClosingChannelFutureListener(ctx, e));
} else {
closeSessiOnFutureListener= new ClosingChannelFutureListener(ctx, e);
}
}

代码示例来源：origin: menacher/java-game-server

@Override
public void channelDisconnected(ChannelHandlerContext ctx,
ChannelStateEvent e) throws Exception
{
DatagramChannel datagramChannel = (DatagramChannel) e.getChannel();
Session session = NettyUDPClient.CLIENTS.get(datagramChannel
.getLocalAddress());
if ((null != session) && !session.isShuttingDown())
{
Event event = Events.event(e, Events.DISCONNECT);
session.onEvent(event);
}
else if (null != session)
{
System.out.println("Session is already shutting down. "
+ "Disconnect event will be discarded for channel {}"
+ datagramChannel.getId());
}
}

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

@Override
public void channelDisconnected(ChannelHandlerContext ctx, ChannelStateEvent e) throws Exception {
// Make sure the handshake future is notified when a connection has
// been closed during handshake.
synchronized (handshakeLock) {
if (handshaking) {
cancelHandshakeTimeout();
handshakeFuture.setFailure(new ClosedChannelException());
}
}
try {
super.channelDisconnected(ctx, e);
} finally {
unwrapNonAppData(ctx, e.getChannel(), false);
closeEngine();
}
}