import io.netty.handler.traffic.ChannelTrafficShapingHandler; //导入依赖的package包/类
@Override
public void initChannel(SocketChannel ch) throws Exception {
    final int kbps = 25;
    final int bytesPerSecond = kbps * 125;

    ChannelPipeline pipeline = ch.pipeline();
    pipeline.addLast(new ChannelTrafficShapingHandler(bytesPerSecond, bytesPerSecond));
    pipeline.addLast(new ElysiumDecoder());
    pipeline.addLast(new ElysiumConnectionHandler());
}
 

import io.netty.handler.traffic.ChannelTrafficShapingHandler; //导入依赖的package包/类
public TrafficShapingChannelHandler(final HandlerConfig handlerConfig)
{
    super(handlerConfig);

    this.channelTrafficShapingHandler = new ChannelTrafficShapingHandler(
            handlerParams.getLong(PARAM_WRITE_LIMIT),
            handlerParams.getLong(PARAM_READ_LIMIT)
    );
}
 

import io.netty.handler.traffic.ChannelTrafficShapingHandler; //导入依赖的package包/类
private void init(Channel channel, HandshakeRequest request, HandlerRegistration handlerReg) {
    NettyServerHandlerConfig<Object> cfg = handlerReg.config();

    if (cfg.getLoggerCategory() != null) {
        log = LoggerFactory.getLogger(cfg.getLoggerCategory());

        debug = log.isDebugEnabled();
        trace = log.isTraceEnabled();
    }

    if (debug) {
        log.debug("Initialized connection [from={}, protocol={}]", address(), cfg.getProtocol());
    }

    this.eventLoop = channel.eventLoop();
    this.serverHandler = cfg.getHandler();
    this.handlerReg = handlerReg;
    this.metrics = handlerReg.metrics();
    this.codec = request.codec();

    // Register this client.
    handlerReg.add(this);

    if (metrics != null) {
        channel.pipeline().addFirst(new ChannelTrafficShapingHandler(0, 0, NettyClient.TRAFFIC_SHAPING_INTERVAL) {
            @Override
            protected void doAccounting(TrafficCounter counter) {
                metrics.onBytesReceived(counter.lastReadBytes());
                metrics.onBytesSent(counter.lastWrittenBytes());
            }
        });

        metrics.onConnect();
    }

    // Accept handshake.
    HandshakeAccept accepted = new HandshakeAccept(hbInterval, hbLossThreshold, hbDisabled);

    channel.writeAndFlush(accepted).addListener(future -> {
            if (channel.isOpen()) {
                connectNotified = true;

                // Notify on connect.
                serverHandler.onConnect(request.payload(), this);
            }
        }
    );
}