@WebsocketMapping("/home")
public class HomeWebsocket extends AbstractWebsocket {
    private final static Logger log = LoggerFactory.getLogger(HomeWebsocket.class);

    @Override
    public void onOpen(Channel channel, Map<String, String> headers, Map<String, List<String>> queryString) {
        log.info("ws on open : channelId=[{}] headers=[{}] params=[{}]", channel.id(), headers, queryString);
        if (queryString == null) {
            rejectConnection(channel);
        }
    }

    @Override
    public void onMsg(Channel channel, String content) {
        log.info("receive: [{}] ", content);
        sendMsg(channel, content);
    }

    @Override
    public void onMsg(Channel channel, byte[] bytes) {
        log.info("receive: [{}]", bytes);
        sendMsg(channel, bytes);
    }

    @Override
    public void onClose(Channel channel) {
        log.info("ws on close: channelId=[{}]", channel.id());
    }

    @Override
    public void onError(Channel channel, Throwable throwable) {
        log.info("ws on error: channelId=[{}]", channel.id(), throwable);
    }
}

public class WsDemoApplication {

    public static void main(String[] args) throws Exception {
        WebsocketServerConfig config = new WebsocketServerConfig();

        WebsocketServer server = new WebsocketServer(config);
        server.registerWebsocket(new HomeWebsocket());

        server.run("0.0.0.0", 9003);
    }

}