65 lines
2.2 KiB
Java
65 lines
2.2 KiB
Java
package envoy.server;
|
|
|
|
import java.io.IOException;
|
|
import java.util.HashSet;
|
|
import java.util.Set;
|
|
|
|
import com.jenkov.nioserver.Server;
|
|
|
|
import envoy.server.data.ConfigItem;
|
|
import envoy.server.database.PersistenceManager;
|
|
import envoy.server.net.ObjectMessageProcessor;
|
|
import envoy.server.net.ObjectMessageReader;
|
|
import envoy.server.processors.ContactOperationProcessor;
|
|
import envoy.server.processors.ContactsRequestProcesor;
|
|
import envoy.server.processors.IdGeneratorRequestProcessor;
|
|
import envoy.server.processors.LoginCredentialProcessor;
|
|
import envoy.server.processors.MessageProcessor;
|
|
import envoy.server.processors.MessageStatusChangeProcessor;
|
|
import envoy.server.processors.UserStatusChangeProcessor;
|
|
|
|
/**
|
|
* Starts the server.<br>
|
|
* <br>
|
|
* Project: <strong>envoy-server-standalone</strong><br>
|
|
* File: <strong>Startup.java</strong><br>
|
|
* Created: <strong>24.12.2019</strong><br>
|
|
*
|
|
* @author Kai S. K. Engelbart
|
|
* @since Envoy Server Standalone v0.1-alpha
|
|
*/
|
|
public class Startup {
|
|
|
|
/**
|
|
* Starts the server.
|
|
*
|
|
* @param args the run configuration. Currently unused.
|
|
* @throws IOException if the server crashes
|
|
* @since Envoy Server Standalone v0.1-alpha
|
|
*/
|
|
public static void main(String[] args) throws IOException {
|
|
Set<ObjectProcessor<?>> processors = new HashSet<>();
|
|
processors.add(new LoginCredentialProcessor());
|
|
processors.add(new MessageProcessor());
|
|
processors.add(new MessageStatusChangeProcessor());
|
|
processors.add(new UserStatusChangeProcessor());
|
|
processors.add(new IdGeneratorRequestProcessor());
|
|
processors.add(new ContactsRequestProcesor());
|
|
processors.add(new ContactOperationProcessor());
|
|
Server server = new Server(8080, () -> new ObjectMessageReader(), new ObjectMessageProcessor(processors));
|
|
|
|
initializeCurrentMessageId();
|
|
|
|
server.start();
|
|
server.getSocketProcessor().registerSocketIdListener(ConnectionManager.getInstance());
|
|
|
|
System.out.println("Press the return key to stop the server...");
|
|
System.in.read();
|
|
System.exit(0);
|
|
}
|
|
|
|
private static void initializeCurrentMessageId() {
|
|
PersistenceManager persMan = PersistenceManager.getPersistenceManager();
|
|
if (persMan.getConfigItemById("currentMessageId") == null) persMan.addConfigItem(new ConfigItem("currentMessageId", "0"));
|
|
}
|
|
} |