SocketIOServer with Spring Boot RESTful API on the same port 8080

[radhakrishna67]

I am trying to include netty-socketio in spring boot RESTful API application and am trying to run it on the same port.
I am not successful this approach.
Is it possible to run the both netty-socketio and spring boot on the same port?

[avrilft]

You can use "https://github.com/trinopoty/socket.io-server-java"

[radhakrishna67]

@avrilft I have to run spring boot restful API along with netty-socketio server in the same apache tomcat on the port 443 in the production. Not like restful api on 443 and netty socketio on 8443 in the production

[avrilft]

If you're using springboot, check out the following examples. This example socketio service with springboot embedded tomcat to use the same port, the code below USES the library "https://github.com/trinopoty/socket.io-server-java"
<dependency> <groupId>io.socket</groupId> <artifactId>socket.io-server</artifactId> <version>4.0.1</version> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-websocket</artifactId> </dependency>xml

`
public class WebSocketConfig extends BaseController {

private final static Logger logger = LoggerFactory.getLogger(WebSocketConfig.class);

@Autowired
private AuthService authService;

@Bean
public ServerEndpointExporter serverEndpointExporter() {
    return new ServerEndpointExporter();
}

@Bean(destroyMethod = "shutdown")
public EngineIoServer engineIoServer() {
    EngineIoServer engine = new EngineIoServer();
    return engine;
}

@Bean
public SocketIoServer socketIoServer() {
    return new SocketIoServer(engineIoServer());
}

@Bean
@Qualifier("/")
public SocketIoNamespace socketIoNamespace() {
    SocketIoNamespace name = socketIoServer().namespace("/");
    return name;
}

}
public class WebSocketController {

private final static Logger logger = LoggerFactory.getLogger(WebSocketController.class);

private final static String USER_PROPERTIES_WEB_SOCKET = "$$USER_PROPERTIES_WEB_SOCKET";

private static EngineIoServer engineIoServer;

@OnOpen
public void onOpen(Session session, EndpointConfig config, @PathParam("token") String token) throws IOException {
    WebSocketIO socket = new WebSocketIO(session);
    session.getUserProperties().put(USER_PROPERTIES_WEB_SOCKET, socket);
    engineIoServer.handleWebSocket(socket);
}

@OnClose
public void onClose(Session session, CloseReason closeReason) {
    WebSocketIO socket = (WebSocketIO) session.getUserProperties().get(USER_PROPERTIES_WEB_SOCKET);
    if (socket != null) {
        socket.close();
    }
}

@OnError
public void onError(Session session, Throwable e) {
    WebSocketIO socket = (WebSocketIO) session.getUserProperties().get(USER_PROPERTIES_WEB_SOCKET);
    if (socket != null) {
        socket.sendError(e);
    }
}

@Autowired
public void setEngineIoServer(EngineIoServer engineIoServer) {
    WebSocketController.engineIoServer = engineIoServer;
}

}`

[nicsor]

you can do it with some tweaks:

duplicate this class from the library: SocketIOChannelInitializer

and add a custom handler just before PACKET_HANDLER:

netty-socketio/src/main/java/com/corundumstudio/socketio/SocketIOChannelInitializer.java

Line 184 in 65246f3

=> something like: pipeline.addLast(HTTP_REQUEST_HANDER, httpRequestHandler);

then use that custom class when initializing the socketio object:

        SocketIOServer server = new SocketIOServer(config);
        server.setPipelineFactory(new SocketIOChannelInitializerCustom());

httpRequestHandler mentioned earlier would be an instance of a custom class that implements SimpleChannelInboundHandler
and in which you override channelRead0:

public class HttpRequestHandler extends SimpleChannelInboundHandler<FullHttpRequest> {
    @Override
    protected void channelRead0(ChannelHandlerContext ctx, FullHttpRequest fullHttpRequest) throws Exception {
        // look at the path in fullHttpRequest if you want to handle it,
        if (will handle) {
              // add code here to prepare response
                ctx.writeAndFlush(response);
        } else {
            ctx.fireChannelRead(fullHttpRequest.retain());
        }
    }
}

worked for me :)