Кометт через websocket: "неизвестный транспорт Байе"
Я пытаюсь подключиться к commetd серверу через клиент websocket. Я использовал точно код из официальной демоверсии cometd на github без изменений и попытался подключиться к http://localhost:8080/cometd/test
... но как только мой клиент попытается выполнить http-запрос на обновление websocket, я получу ответ "HTTP/1.1 400 Unknown Bayeux Transport". Есть идеи?
Я попробовал это с SSL и без него, последнее явно уменьшило потенциальные источники ошибок. В обоих случаях я получаю одинаковую ошибку.
Вот мой pom, на случай, если я забыл некоторые важные зависимости, связанные с websocket
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>de.verlinkied</groupId>
<artifactId>bayeux-server</artifactId>
<version>1.0</version>
<properties>
<jetty.version>9.2.22.v20170606</jetty.version>
<cometd.version>3.1.3</cometd.version>
<slf4j.version>1.7.25</slf4j.version>
</properties>
<dependencies>
<dependency>
<groupId>org.eclipse.jetty.websocket</groupId>
<artifactId>websocket-api</artifactId>
<version>${jetty.version}</version>
</dependency>
<dependency>
<groupId>org.eclipse.jetty</groupId>
<artifactId>jetty-server</artifactId>
<version>${jetty.version}</version>
</dependency>
<dependency>
<groupId>org.eclipse.jetty</groupId>
<artifactId>jetty-servlet</artifactId>
<version>${jetty.version}</version>
</dependency>
<dependency>
<groupId>org.eclipse.jetty</groupId>
<artifactId>jetty-jmx</artifactId>
<version>${jetty.version}</version>
</dependency>
<dependency>
<groupId>org.eclipse.jetty.websocket</groupId>
<artifactId>javax-websocket-server-impl</artifactId>
<version>${jetty.version}</version>
</dependency>
<dependency>
<groupId>org.cometd.java</groupId>
<artifactId>cometd-java-server</artifactId>
<version>${cometd.version}</version>
</dependency>
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-api</artifactId>
<version>${slf4j.version}</version>
</dependency>
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-log4j12</artifactId>
<version>${slf4j.version}</version>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.codehaus.mojo</groupId>
<artifactId>exec-maven-plugin</artifactId>
<configuration>
<mainClass>de.verlinked.BayeuxServerTest</mainClass>
</configuration>
</plugin>
</plugins>
</build>
</project>
mvn зависимость: дерево дает следующее
[INFO] ------------------------------------------------------------------------
[INFO] Building bayeux-server 1.0
[INFO] ------------------------------------------------------------------------
[INFO]
[INFO] --- maven-dependency-plugin:2.8:tree (default-cli) @ bayeux-server ---
[INFO] de.verlinkied:bayeux-server:jar:1.0
[INFO] +- org.eclipse.jetty.websocket:websocket-api:jar:9.2.22.v20170606:compile
[INFO] +- org.eclipse.jetty:jetty-server:jar:9.2.22.v20170606:compile
[INFO] | +- javax.servlet:javax.servlet-api:jar:3.1.0:compile
[INFO] | +- org.eclipse.jetty:jetty-http:jar:9.2.22.v20170606:compile
[INFO] | \- org.eclipse.jetty:jetty-io:jar:9.2.22.v20170606:compile
[INFO] +- org.eclipse.jetty:jetty-servlet:jar:9.2.22.v20170606:compile
[INFO] | \- org.eclipse.jetty:jetty-security:jar:9.2.22.v20170606:compile
[INFO] +- org.eclipse.jetty:jetty-jmx:jar:9.2.22.v20170606:compile
[INFO] | \- org.eclipse.jetty:jetty-util:jar:9.2.22.v20170606:compile
[INFO] +- org.eclipse.jetty.websocket:javax-websocket-server-impl:jar:9.2.22.v20170606:compile
[INFO] | +- org.eclipse.jetty:jetty-annotations:jar:9.2.22.v20170606:compile
[INFO] | | +- org.eclipse.jetty:jetty-plus:jar:9.2.22.v20170606:compile
[INFO] | | | \- org.eclipse.jetty:jetty-jndi:jar:9.2.22.v20170606:compile
[INFO] | | +- org.eclipse.jetty:jetty-webapp:jar:9.2.22.v20170606:compile
[INFO] | | | \- org.eclipse.jetty:jetty-xml:jar:9.2.22.v20170606:compile
[INFO] | | +- javax.annotation:javax.annotation-api:jar:1.2:compile
[INFO] | | +- org.ow2.asm:asm:jar:5.0.1:compile
[INFO] | | \- org.ow2.asm:asm-commons:jar:5.0.1:compile
[INFO] | | \- org.ow2.asm:asm-tree:jar:5.0.1:compile
[INFO] | +- org.eclipse.jetty.websocket:javax-websocket-client-impl:jar:9.2.22.v20170606:compile
[INFO] | | \- org.eclipse.jetty.websocket:websocket-client:jar:9.2.22.v20170606:compile
[INFO] | +- org.eclipse.jetty.websocket:websocket-server:jar:9.2.22.v20170606:compile
[INFO] | | +- org.eclipse.jetty.websocket:websocket-common:jar:9.2.22.v20170606:compile
[INFO] | | \- org.eclipse.jetty.websocket:websocket-servlet:jar:9.2.22.v20170606:compile
[INFO] | \- javax.websocket:javax.websocket-api:jar:1.0:compile
[INFO] +- org.cometd.java:cometd-java-server:jar:3.1.3:compile
[INFO] | +- org.cometd.java:bayeux-api:jar:3.1.3:compile
[INFO] | \- org.cometd.java:cometd-java-common:jar:3.1.3:compile
[INFO] | \- org.eclipse.jetty:jetty-util-ajax:jar:9.2.22.v20170606:compile
[INFO] +- org.slf4j:slf4j-api:jar:1.7.25:compile
[INFO] \- org.slf4j:slf4j-log4j12:jar:1.7.25:compile
[INFO] \- log4j:log4j:jar:1.2.17:compile
[INFO] ------------------------------------------------------------------------
[INFO] BUILD SUCCESS
[INFO] ------------------------------------------------------------------------
Причал журнал показывает следующее
3411 [qtp1080615555-20] DEBUG org.eclipse.jetty.server.HttpChannel - HttpChannelOverHttp@31f5a8ff{r=1,c=false,a=IDLE,uri=/cometd/test} messageComplete
3411 [qtp1080615555-20] DEBUG org.eclipse.jetty.server.HttpInput - HttpInputOverHTTP@6f0992d0 EOF
3411 [qtp1080615555-20] DEBUG org.eclipse.jetty.server.HttpChannel - HttpChannelOverHttp@31f5a8ff{r=1,c=false,a=IDLE,uri=/cometd/test} handle enter
3412 [qtp1080615555-20 - /cometd/test] DEBUG org.eclipse.jetty.server.HttpChannelState - HttpChannelState@738a2171{s=IDLE i=true a=null} handling IDLE
3412 [qtp1080615555-20 - /cometd/test] DEBUG org.eclipse.jetty.server.HttpChannel - HttpChannelOverHttp@31f5a8ff{r=1,c=false,a=DISPATCHED,uri=/cometd/test} action REQUEST_DISPATCH
3412 [qtp1080615555-20 - /cometd/test] DEBUG org.eclipse.jetty.server.Server - REQUEST GET /cometd/test on HttpChannelOverHttp@31f5a8ff{r=1,c=false,a=DISPATCHED,uri=/cometd/test}
3412 [qtp1080615555-20 - /cometd/test] DEBUG org.eclipse.jetty.server.handler.ContextHandler - scope null||/cometd/test @ o.e.j.s.ServletContextHandler@35fdf572{/,null,AVAILABLE}
3413 [qtp1080615555-20 - /cometd/test] DEBUG org.eclipse.jetty.server.handler.ContextHandler - context=||/cometd/test @ o.e.j.s.ServletContextHandler@35fdf572{/,null,AVAILABLE}
3413 [qtp1080615555-20 - /cometd/test] DEBUG org.eclipse.jetty.servlet.ServletHandler - servlet |/cometd|/test -> org.cometd.server.CometDServlet-629a2d4a@4553b89a==org.cometd.server.CometDServlet,1,true
3413 [qtp1080615555-20 - /cometd/test] DEBUG org.eclipse.jetty.servlet.ServletHandler - chain=Jetty_WebSocketUpgradeFilter->org.cometd.server.CometDServlet-629a2d4a@4553b89a==org.cometd.server.CometDServlet,1,true
3414 [qtp1080615555-20 - /cometd/test] DEBUG org.eclipse.jetty.servlet.ServletHandler - call filter Jetty_WebSocketUpgradeFilter
3416 [qtp1080615555-20 - /cometd/test] DEBUG org.eclipse.jetty.servlet.ServletHandler - call servlet org.cometd.server.CometDServlet-629a2d4a@4553b89a==org.cometd.server.CometDServlet,1,true
3418 [qtp1080615555-20 - /cometd/test] DEBUG org.eclipse.jetty.server.HttpConnection - org.eclipse.jetty.server.HttpConnection$SendCallback@62e6f50[PROCESSING][i=ResponseInfo{HTTP/1.1 400 Unknown Bayeux Transport,304,false},cb=org.eclipse.jetty.server.HttpChannel$CommitCallback@6892f8b1] generate: NEED_HEADER (null,[p=0,l=304,c=2048,r=304],true)@START
Где вы можете видеть, что вызывается какой-то Jetty_WebSocketUpgradeFilter, что заставляет меня думать, что зависимость websocket присутствует, но все же что-то идет не так.
1 ответ
Jetty предлагает 2 разных варианта WebSocket, стандартный JSR 356 и Jetty.
Первый указывается в артефактах Maven с javax в названии артефакта, а второй - с указанием причала в названии артефакта.
Из вашего POM выше вы используете cometd-java-websocket-jetty-server, который является связыванием CometD со вкусом молы WebSocket.
Тем не менее, вы явно указываете в качестве зависимости javax-websocket-server-impl артефакт, который является ароматом JSR 356 Javax.
Я предполагаю, что если вы сделаете зависимости согласованными, то это зависит только от версии Javax или только от версии Jetty, которая решит вашу проблему.
Если вам не нужно использовать специфические особенности Jetty, я бы рекомендовал использовать Javax JSR 356 для обеих привязок CometD (org.cometd.java:cometd-java-websocket-javax-server) и зависимость от причала (org.eclipse.jetty.websocket:javax-websocket-server-impl).
У меня была точно такая же проблема. Я пытался отследить это. Мне кажется, что это вызвано тем, как сервер bayeux инициализирует сопоставления транспорта веб-сокетов из ws.cometdURLMapping имущество. Либо это, либо я использую неправильное значение ws.cometdURLMapping,
Предполагая, что зависимости веб-сокетов настроены правильно, поэтому с помощью jsr 356 запросы на обновление веб-сокетов проходят через Jetty WebSocketUpgradeFilter.doFilter(), Этот метод проверяет, является ли запрос допустимым запросом на обновление веб-сокета и что одно из его сопоставлений соответствует пути запроса веб-сокета.
Это где вещи терпят неудачу для меня. Там никогда не бывает успешного матча.
Я настроил ws.cometdURLMapping в /cometd/*, Я ожидал, что это будет означать, что любой запрос websocket для /cometd/<whatever/here> будет принято.
Этого не происходит, потому что AbstractWebSocketTransport.normalizeURLMapping() преобразует /cometd/* в /cometd который AFAICS интерпретируется кодом веб-сокета Jetty как регулярное выражение. Вот фрагмент кода Comet, на который я ссылаюсь:
protected List<String> normalizeURLMapping(String urlMapping) {
String[] mappings = urlMapping.split(",");
List<String> result = new ArrayList<>(mappings.length);
for (String mapping : mappings) {
if (mapping.endsWith("/*")) {
mapping = mapping.substring(0, mapping.length() - 2);
}
if (!mapping.startsWith("/")) {
mapping = "/" + mapping;
}
result.add(mapping);
}
return result;
}
Регулярное выражение ^/cometd$ конечно не соответствует моему пути запроса websocket, который /cometd/, или же /cometd/something-hereТаким образом, фильтр обновления websocket обойден.
Я не отслеживал, что происходит после этого, но я предполагаю, что, поскольку ни один транспорт не помечен как доступный, сервер комет просто выдает HTTP 400 Unknown Bayeux transport,