Customize Port and address

[activej]

Customize Port and address

[azzahrah]

Thank problem by this sample

public class MyWebsocketLauncher extends Launcher {

    public static final String PROPERTIES_FILE = "http-server.properties";

    @Inject
    AsyncHttpServer httpServer;

    @Provides
    Eventloop eventloop(io.activej.config.Config config, @Optional ThrottlingController throttlingController) {
        return Eventloop.create()
                .withInitializer(ofEventloop(config.getChild("eventloop")))
                .withInitializer(eventloop -> eventloop.withInspector(throttlingController));
    }

    @Provides
    AsyncHttpServer server(Eventloop eventloop, AsyncServlet rootServlet, io.activej.config.Config config) {
        return AsyncHttpServer.create(eventloop, rootServlet)
                //or set port from this
                .withListenPort(7070);
                //.withInitializer(ofHttpServer(config.getChild("http")));
    }

    @Provides
    io.activej.config.Config config() {
        return io.activej.config.Config.create()
                //.with("", io.activej.config.Config.EMPTY)
                //set by this method
                //.with("http.listenAddresses", io.activej.config.Config.ofValue(ofInetSocketAddress(), new InetSocketAddress(9090)))
                .overrideWith(ofClassPathProperties(PROPERTIES_FILE, true))
                .overrideWith(ofSystemProperties("config"));
    }

    @Override
    protected final io.activej.inject.module.Module getModule() {
        return combine(
                ServiceGraphModule.create(),
                JmxModule.create(),
                ConfigModule.create()
                        .withEffectiveConfigLogger(),
                getBusinessLogicModule()
        );
    }

    /**
     * Override this method to supply your launcher business logic.
     */
    protected io.activej.inject.module.Module getBusinessLogicModule() {
        return io.activej.inject.module.Module.empty();
    }

    @Override
    protected void run() throws Exception {
        logger.info("HTTP Server is now available at {}", String.join(", ", httpServer.getHttpAddresses()));
        awaitShutdown();
    }

    @Provides
    AsyncServlet servlet() {
        return RoutingServlet.create()
                .mapWebSocket("/websocket", webSocket -> readMessage(webSocket))
                .mapWebSocket("/", webSocket -> readMessage(webSocket));

    }

    void readMessage(WebSocket websocket) {

        websocket.messageReadChannel()
                .filter(msg -> msg.getType() == WebSocket.Message.MessageType.TEXT)
                .map(WebSocket.Message::getText)
                .streamTo(ChannelConsumer.ofConsumer(msg -> {
                    System.out.println(msg);
                    // sendData(websocket);
                }));

    }

    public static void main(String[] args) throws Exception {
        Eventloop eventloop = Eventloop.create().withCurrentThread();
        MyWebsocketLauncher launcher = new MyWebsocketLauncher();
        launcher.launch(args);
        System.out.println("Server is running");
        System.out.println("You can connect from telnet with command: telnet localhost 9922 or by running csp.TcpClientExample");
        eventloop.run();
    }
//
//    public static void main(String[] args) throws Exception {
//
//        Launcher launcher = new MyWebsocketLauncher() {
//            @Override
//            protected io.activej.inject.module.Module getBusinessLogicModule() {
//                return new AbstractModule() {
//                    @Provides
//                    public AsyncServlet servlet(io.activej.config.Config config) {
//                        String message = config.get("message", "Hello, world!");
//                        return request -> HttpResponse.ok200().withPlainText(message);
//                    }
//                };
//            }
//        };
//
//        launcher.launch(args);
//    }
}