CNCServer

package cnc;

import main.Vars;

import org.apache.mina.filter.codec.ProtocolCodecFilter;
import org.apache.mina.filter.codec.textline.TextLineCodecFactory;
import org.apache.mina.filter.logging.LoggingFilter;
import org.apache.mina.transport.socket.nio.*;

import java.io.IOException;
import java.net.InetSocketAddress;
import java.nio.charset.StandardCharsets;

import org.apache.mina.core.service.*;
import org.apache.mina.core.session.IdleStatus;

public class CNCServer implements Runnable{


    @Override
    public void run() {

        System.out.print("CNC server started on port "+Vars.CNC_SOCKET_PORT);

        IoAcceptor acceptor = new NioSocketAcceptor();

        try {

            acceptor.getFilterChain().addLast("logger", new LoggingFilter("CNCServer"));
            acceptor.getFilterChain().addLast("codec", new ProtocolCodecFilter(new TextLineCodecFactory(StandardCharsets.UTF_8, "\n", "\n")));
            acceptor.setHandler(new CNCServerHandler());

            acceptor.getSessionConfig().setReadBufferSize(2048);
            acceptor.getSessionConfig().setIdleTime(IdleStatus.BOTH_IDLE, 10);
            acceptor.bind(new InetSocketAddress(Vars.CNC_SOCKET_PORT));

        } catch(IOException ioe) {

        }


    }

}