/* * Copyright 2012 The Netty Project * * The Netty Project licenses this file to you under the Apache License, * version 2.0 (the "License"); you may not use this file except in compliance * with the License. You may obtain a copy of the License at: * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the * License for the specific language governing permissions and limitations * under the License. */ package io.netty.bootstrap; import io.netty.buffer.MessageBuf; import io.netty.buffer.Unpooled; import io.netty.channel.Channel; import io.netty.channel.ChannelException; import io.netty.channel.ChannelFuture; import io.netty.channel.ChannelFutureListener; import io.netty.channel.ChannelHandler; import io.netty.channel.ChannelHandlerContext; import io.netty.channel.ChannelInboundHandlerAdapter; import io.netty.channel.ChannelInboundMessageHandler; import io.netty.channel.ChannelInitializer; import io.netty.channel.ChannelOption; import io.netty.channel.ChannelPipeline; import io.netty.channel.EventLoopGroup; import io.netty.channel.ServerChannel; import io.netty.logging.InternalLogger; import io.netty.logging.InternalLoggerFactory; import io.netty.util.NetworkConstants; import java.net.InetAddress; import java.net.InetSocketAddress; import java.net.SocketAddress; import java.nio.channels.ClosedChannelException; import java.util.LinkedHashMap; import java.util.Map; import java.util.Map.Entry; public class ServerBootstrap { private static final InternalLogger logger = InternalLoggerFactory.getInstance(ServerBootstrap.class); private static final InetSocketAddress DEFAULT_LOCAL_ADDR = new InetSocketAddress(NetworkConstants.LOCALHOST, 0); private final ChannelHandler acceptor = new ChannelInitializer() { @Override public void initChannel(Channel ch) throws Exception { ch.pipeline().addLast(new Acceptor()); } }; private final Map, Object> parentOptions = new LinkedHashMap, Object>(); private final Map, Object> childOptions = new LinkedHashMap, Object>(); private EventLoopGroup parentGroup; private EventLoopGroup childGroup; private ServerChannel channel; private ChannelHandler handler; private ChannelHandler childHandler; private SocketAddress localAddress; public ServerBootstrap group(EventLoopGroup group) { if (group == null) { throw new NullPointerException("group"); } if (parentGroup != null) { throw new IllegalStateException("parentGroup set already"); } parentGroup = group; childGroup = group; return this; } public ServerBootstrap group(EventLoopGroup parentGroup, EventLoopGroup childGroup) { if (parentGroup == null) { throw new NullPointerException("parentGroup"); } if (this.parentGroup != null) { throw new IllegalStateException("parentGroup set already"); } this.parentGroup = parentGroup; this.childGroup = childGroup; return this; } public ServerBootstrap channel(ServerChannel channel) { if (channel == null) { throw new NullPointerException("channel"); } if (this.channel != null) { throw new IllegalStateException("channel set already"); } this.channel = channel; return this; } public ServerBootstrap option(ChannelOption parentOption, T value) { if (parentOption == null) { throw new NullPointerException("parentOption"); } if (value == null) { parentOptions.remove(parentOption); } else { parentOptions.put(parentOption, value); } return this; } public ServerBootstrap childOption(ChannelOption childOption, T value) { if (childOption == null) { throw new NullPointerException("childOption"); } if (value == null) { childOptions.remove(childOption); } else { childOptions.put(childOption, value); } return this; } public ServerBootstrap handler(ChannelHandler handler) { this.handler = handler; return this; } public ServerBootstrap childHandler(ChannelHandler childHandler) { if (childHandler == null) { throw new NullPointerException("childHandler"); } this.childHandler = childHandler; return this; } public ServerBootstrap localAddress(SocketAddress localAddress) { if (localAddress == null) { throw new NullPointerException("localAddress"); } this.localAddress = localAddress; return this; } public ServerBootstrap localAddress(int port) { localAddress = new InetSocketAddress(port); return this; } public ServerBootstrap localAddress(String host, int port) { localAddress = new InetSocketAddress(host, port); return this; } public ServerBootstrap localAddress(InetAddress host, int port) { localAddress = new InetSocketAddress(host, port); return this; } public ChannelFuture bind() { validate(); return bind(channel.newFuture()); } public ChannelFuture bind(ChannelFuture future) { validate(future); if (channel.isActive()) { future.setFailure(new IllegalStateException("channel already bound: " + channel)); return future; } if (channel.isRegistered()) { future.setFailure(new IllegalStateException("channel already registered: " + channel)); return future; } if (!channel.isOpen()) { future.setFailure(new ClosedChannelException()); return future; } try { channel.config().setOptions(parentOptions); } catch (Exception e) { future.setFailure(e); return future; } ChannelPipeline p = channel.pipeline(); if (handler != null) { p.addLast(handler); } p.addLast(acceptor); ChannelFuture f = parentGroup.register(channel).awaitUninterruptibly(); if (!f.isSuccess()) { future.setFailure(f.cause()); return future; } if (!channel.isOpen()) { // Registration was successful but the channel was closed due to some failure in // handler. future.setFailure(new ChannelException("initialization failure")); return future; } channel.bind(localAddress, future).addListener(ChannelFutureListener.CLOSE_ON_FAILURE); return future; } public void shutdown() { if (parentGroup != null) { parentGroup.shutdown(); } if (childGroup != null) { childGroup.shutdown(); } } private void validate() { if (parentGroup == null) { throw new IllegalStateException("parentGroup not set"); } if (channel == null) { throw new IllegalStateException("channel not set"); } if (childHandler == null) { throw new IllegalStateException("childHandler not set"); } if (childGroup == null) { logger.warn("childGroup is not set. Using parentGroup instead."); childGroup = parentGroup; } if (localAddress == null) { logger.warn("localAddress is not set. Using " + DEFAULT_LOCAL_ADDR + " instead."); localAddress = DEFAULT_LOCAL_ADDR; } } private void validate(ChannelFuture future) { if (future == null) { throw new NullPointerException("future"); } if (future.channel() != channel) { throw new IllegalArgumentException("future.channel() must be the same channel."); } validate(); } private class Acceptor extends ChannelInboundHandlerAdapter implements ChannelInboundMessageHandler { @Override public MessageBuf newInboundBuffer(ChannelHandlerContext ctx) throws Exception { return Unpooled.messageBuffer(); } @Override public void inboundBufferUpdated(ChannelHandlerContext ctx) { MessageBuf in = ctx.inboundMessageBuffer(); for (;;) { Channel child = in.poll(); if (child == null) { break; } child.pipeline().addLast(childHandler); for (Entry, Object> e: childOptions.entrySet()) { try { if (!child.config().setOption((ChannelOption) e.getKey(), e.getValue())) { logger.warn("Unknown channel option: " + e); } } catch (Throwable t) { logger.warn("Failed to set a channel option: " + child, t); } } try { childGroup.register(child); } catch (Throwable t) { logger.warn("Failed to register an accepted channel: " + child, t); } } } } }