Mercurial > hg > Database > Alice
view src/main/java/alice/daemon/AliceDaemon.java @ 612:86b39f5bf1d7 dispose
topologymanager jar execution
author | suruga |
---|---|
date | Wed, 19 Apr 2017 21:36:06 +0900 |
parents | d2f7d02c4976 |
children | 646f705e65b1 |
line wrap: on
line source
package alice.daemon; import java.io.FileWriter; import java.io.IOException; import java.net.InetAddress; import java.net.InetSocketAddress; import java.net.ServerSocket; import java.nio.channels.ServerSocketChannel; //import org.apache.log4j.Logger; //import org.apache.log4j.PatternLayout; //import org.apache.log4j.WriterAppender; public class AliceDaemon { private Config conf; private AcceptThread acceptThread; //private Logger log = Logger.getLogger(AliceDaemon.class); public AliceDaemon(Config conf) { this.conf = conf; //setLogger(); } // private void setLogger() { // Logger root = Logger.getRootLogger(); // if (conf.level != null) // root.setLevel(conf.level); // if (conf.logFile == null) // return; // PatternLayout layout = new PatternLayout(); // layout.setConversionPattern("%d %-5p %c - %m [%t] (%F:%L)%n"); // try { // FileWriter writer = new FileWriter(conf.logFile); // WriterAppender writerAppender = new WriterAppender(layout, writer); // root.removeAllAppenders(); // root.addAppender(writerAppender); // } catch (IOException e) { // e.printStackTrace(); // } // log.info("configured"); // } public void listen() { try { ServerSocketChannel ssChannel = ServerSocketChannel.open(); ServerSocket ss = ssChannel.socket(); ss.setReuseAddress(true); // listen on any address ipv4/ipv6 InetSocketAddress a = new InetSocketAddress("::", conf.localPort); System.out.println("AliceDaemon.listen: bind to " + a); ss.bind(a); acceptThread = new AcceptThread(ss, "ACCEPT" + conf.localPort); acceptThread.start(); } catch (IOException e) { e.printStackTrace(); } } }