org.atmosphere.cpr.AsynchronousProcessor: Websocket protocol not supported

[Zaeem6100]

the Web socket doesn't make connection as it was working before but i update to drop wizard (2.0.25 to 4.0.6)

Error

WARN  [2024-01-31 15:26:37,772] org.atmosphere.cpr.AsynchronousProcessor: Websocket protocol not supported
127.0.0.1 - - [31/Jan/2024:15:26:37 +0000] "GET /websocket/sensitivity/progress/148 HTTP/1.1" 501 0 "-" "-" 2

using libraries
```

org.atmosphere
atmosphere-runtime
3.0.3

    <dependency>
        <groupId>org.atmosphere</groupId>
        <artifactId>atmosphere-annotations</artifactId>
        <version>2.7.10</version>
    </dependency>

    <dependency>
        <groupId>org.eclipse.jetty.websocket</groupId>
        <artifactId>websocket-server</artifactId>
        <version>9.4.53.v20231009</version>
    </dependency>

[zUniQueX]

Hi @Zaeem6100. Dropwizard 4 uses Jetty 11. So a dependency to Jetty 9 will cause conflicts.

Please upgrade the websocket artifact to Jetty 11 too.

[Zaeem6100]

Using the latest version of the websocket-server

[Zaeem6100]

Tried

<dependency>
            <groupId>org.eclipse.jetty.websocket</groupId>
            <artifactId>websocket-servlet</artifactId>
            <version>11.0.19</version>
        </dependency>

and

<dependency>
            <groupId>org.eclipse.jetty.websocket</groupId>
            <artifactId>websocket-jetty-server</artifactId>
            <version>11.0.3</version>
        </dependency>

but wont work

[zUniQueX]

@Zaeem6100 Here is an example repo on how to use Jetty with websockets.

[Zaeem6100]

@zUniQueX
Here is my Sample code for the Config

private BroadcasterFactory initializeAtmosphere(SensitivityConfiguration configuration, Environment environment) {
        AtmosphereServlet servlet = new AtmosphereServlet();
        servlet.framework().addInitParameter(ApplicationConfig.ANNOTATION_PACKAGE, WebSocketHandler.class.getPackage().getName());
        servlet.framework().addInitParameter(ApplicationConfig.WEBSOCKET_SUPPORT, "true");
        ServletRegistration.Dynamic registration = environment.servlets().addServlet("atmosphere", servlet);
        registration.addMapping(WEBSOCKET_SERVLET_MAPPING);
        BroadcasterFactory broadcasterFactory = servlet.framework().getBroadcasterFactory();
        return broadcasterFactory;
    }

and on Run

final Client client = new JerseyClientBuilder(environment)
                .using(configuration.getJerseyClientConfiguration())
                .build(getName());
        BroadcasterFactory broadcasterFactory = initializeAtmosphere(configuration, environment);
        WebappComponent component = DaggerWebappComponent.builder()
                .mainSession(hibernateBundle.getSessionFactory())
                .client(client)
                .broadcasterFactory(broadcasterFactory)
                .otherServicesUrl(configuration.getOtherServicesUrl())
                .build();

Resource File

@AtmosphereHandlerService(path = "/websocket/sensitivity/progress/{id}")
public class WebSecketResource implements AtmosphereHandler {

    private Long id;
    /**
     * Name of the round broadcaster.
     */
    private static final String ROUND_BROADCASTER_NAME = "progress";
    private static final ObjectMapper OBJECT_MAPPER = new ObjectMapper();
    private static final Logger log = LoggerFactory.getLogger(WebSecketResource.class);

    @Override
    public void onRequest(AtmosphereResource atmosphereResource) throws IOException {
        AtmosphereRequest request = atmosphereResource.getRequest();
        String[] split = request.getPathInfo().split("/");
        if (!request.getPathInfo().startsWith("/progress/")
                || request.getPathInfo().split("/").length < 1) {
            atmosphereResource.getResponse().setStatus(HttpStatus.NOT_FOUND_404);
            atmosphereResource.write("Websocket endpoint not found");
            atmosphereResource.close();
            return;
        }
        id = Long.valueOf(request.getPathInfo().split("/")[2]);
        log.debug("IN onRequest");
        BroadcasterFactory broadcasterFactory = atmosphereResource.getAtmosphereConfig().getBroadcasterFactory();
        Broadcaster broadcaster = getBroadcaster(broadcasterFactory, id);
        atmosphereResource.setBroadcaster(broadcaster);
        atmosphereResource.getResponse().setContentType(MediaType.APPLICATION_JSON);
        atmosphereResource.suspend();
    }

    private boolean isBroadcast(AtmosphereResourceEvent event) {
        log.debug("IN isBroadcast");
        return event.getMessage() != null && !event.isCancelled() && !event.isClosedByClient() && !event.isClosedByApplication();
    }

    @Override
    public void onStateChange(AtmosphereResourceEvent event) throws IOException {
        AtmosphereResource resource = event.getResource();
        log.debug("IN onStateChange"+ event.toString());
        if (isBroadcast(event)) {
            resource.write(event.getMessage().toString());
            switch (resource.transport()) {
                case WEBSOCKET:
                case STREAMING:
                    resource.getResponse().flushBuffer();
                    break;
                default:
                    resource.resume();
                    break;
            }
        }
    }

    @Override
    public void destroy() {
    }
    public static void broadcastRound(BroadcasterFactory broadcasterFactory, long id, double progress) {
        ProgressResponse message = new ProgressResponse(progress);
        String json;
        try {
            json = OBJECT_MAPPER.writeValueAsString(message);
        } catch (JsonProcessingException e) {
            throw new IllegalStateException("Unable to convert round object to json", e);
        }
        getBroadcaster(broadcasterFactory, id).broadcast(json);
    }
    public static void destroy(BroadcasterFactory broadcasterFactory, long id) {
        Broadcaster broadcaster = getBroadcaster(broadcasterFactory, id);
        if(!broadcaster.isDestroyed())
            broadcaster.destroy();
    }
    private static Broadcaster getBroadcaster(BroadcasterFactory broadcasterFactory, long id) {
        return broadcasterFactory.lookup(ROUND_BROADCASTER_NAME+"/"+id, true);
    }

Maven

        <dependency>
            <groupId>org.atmosphere</groupId>
            <artifactId>atmosphere-runtime</artifactId>
            <version>3.0.4</version>
        </dependency>

        <dependency>
            <groupId>org.atmosphere</groupId>
            <artifactId>atmosphere-annotations</artifactId>
            <version>2.7.10</version>
        </dependency>
        <dependency>
            <groupId>org.eclipse.jetty.websocket</groupId>
            <artifactId>websocket-jakarta-server</artifactId>
            <version>11.0.19</version>
        </dependency>

        <dependency>
            <groupId>org.apache.commons</groupId>
            <artifactId>commons-math3</artifactId>
            <version>3.6.1</version>
        </dependency>

        <dependency>
            <groupId>com.google.dagger</groupId>
            <artifactId>dagger</artifactId>
            <version>2.44.2</version>
        </dependency>

drop wizard version is 4.0.6

[zUniQueX]

@Zaeem6100 I haven't used atmosphere before and cannot provide information on their software.

When quickly looking into the project, they seem to have changed quite a bit between versions 2.7 and 3. E.g. version 2.7 had a dedicated class related to Jetty. If you have problems while migrating, please try asking at their project.