import io.netty.handler.ssl.SslContext; //导入方法依赖的package包/类

public void start() throws CertificateException, SSLException, InterruptedException {

// Configure SSL.

final SslContext sslCtx;

if (ssl) {

SelfSignedCertificate ssc = new SelfSignedCertificate();

sslCtx = SslContext.newServerContext(ssc.certificate(), ssc.privateKey());

} else {

sslCtx = null;

}

// configure metrics

ScheduledExecutorService metricCollector = Executors.newScheduledThreadPool(1);

MixServerMetrics metrics = new MixServerMetrics();

ThroughputCounter throughputCounter = new ThroughputCounter(metricCollector, 5000L, metrics);

if (jmx) {// register mbean

MetricsRegistry.registerMBeans(metrics, port);

}

// configure initializer

SessionStore sessionStore = new SessionStore();

MixServerHandler msgHandler = new MixServerHandler(sessionStore, syncThreshold, scale);

MixServerInitializer initializer = new MixServerInitializer(msgHandler, throughputCounter,

sslCtx);

Runnable cleanSessionTask = new IdleSessionSweeper(sessionStore, sessionTTLinSec * 1000L);

ScheduledExecutorService idleSessionChecker = Executors.newScheduledThreadPool(1);

try {

// start idle session sweeper

idleSessionChecker.scheduleAtFixedRate(cleanSessionTask, sessionTTLinSec + 10L,

sweepIntervalInSec, TimeUnit.SECONDS);

// accept connections

acceptConnections(initializer, port, numWorkers);

} finally {

// release threads

idleSessionChecker.shutdownNow();

if (jmx) {

MetricsRegistry.unregisterMBeans(port);

}

metricCollector.shutdownNow();

}

}