This is an automated email from the ASF dual-hosted git repository.
yaohaishi pushed a change to branch 2.8.x
in repository https://gitbox.apache.org/repos/asf/servicecomb-java-chassis.git
from 399b94f40 [#4562] fixed dual-AZ engine disk abnormal scenario
registration center intermittently delete instance problem (#4563)
new ddf9805aa [SCB-2894] support @Transport annotation
new 5e1698a8f [SCB-2894] support WebSocket basic capability
new bb8c6fd88 [SCB-2894] support WebSocket message handling logic run on
the Executors serially
new 817d48bf6 [SCB-2894] optimize code
new 5aed95845 [SCB-2894] use the self-defined compression switch const
The 5 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../common/rest/AbstractRestInvocation.java | 31 ++-
.../common/rest/filter/HttpClientFilter.java | 7 +
.../HttpClientFilterBeforeSendRequestExecutor.java | 2 +-
.../common/rest/filter/HttpServerFilter.java | 12 +
...HttpServerFilterBeforeSendResponseExecutor.java | 4 +-
.../rest/filter/inner/ClientRestArgsFilter.java | 10 +-
.../rest/filter/inner/ServerRestArgsFilter.java | 6 +
.../common/rest/TestAbstractRestInvocation.java | 4 +-
.../java/org/apache/servicecomb/core/Const.java | 4 +
.../org/apache/servicecomb/core/Invocation.java | 27 ++
.../servicecomb/core/annotation/Transport.java | 25 +-
.../core/provider/consumer/InvokerUtils.java | 9 +
.../TransportClassAnnotationProcessor.java | 21 +-
.../TransportMethodAnnotationProcessor.java | 21 +-
...comb.swagger.generator.ClassAnnotationProcessor | 2 +-
...omb.swagger.generator.MethodAnnotationProcessor | 2 +-
.../edge/core/EdgeAddHeaderClientFilter.java | 6 +
.../foundation/common/http/HttpUtils.java | 39 ++-
.../foundation/common/net/URIEndpointObject.java | 16 ++
.../foundation/common/http/TestHttpUtils.java | 76 +++++-
.../discovery/AbstractEndpointDiscoveryFilter.java | 16 +-
.../foundation/vertx/VertxTLSBuilder.java | 20 ++
.../vertx/client/http/HttpClientOptionsSPI.java | 26 +-
.../foundation/vertx/client/http/HttpClients.java | 52 ++++
.../vertx/client/ws/WebSocketClientOptionsSPI.java | 117 ++++++++
.../WebSocketClientPoolFactory.java} | 31 +--
.../WebSocketClientWithContext.java} | 29 +-
.../VertxServerRequestToHttpServletRequest.java | 30 ++-
...lientWebSocketRequestToHttpServletRequest.java} | 32 ++-
...ientWebSocketResponseToHttpServletResponse.java | 88 ++++++
.../loadbalance/TestLoadBalanceHandler2.java | 14 +-
.../router/custom/RouterAddHeaderFilter.java | 6 +
.../reference/RestTemplateCopyHeaderFilter.java | 6 +
.../response/CompletableFutureProcessor.java | 27 ++
.../consumer/ClientWebSocketArgumentMapper.java | 20 +-
...a => ClientWebSocketArgumentMapperFactory.java} | 12 +-
.../invocation/ws/AbstractBaseWebSocket.java | 81 ++++++
.../invocation/ws/BinaryBytesWebSocketMessage.java | 10 +-
.../swagger/invocation/ws/ClientWebSocket.java | 9 +-
.../invocation/ws/SerialExecutorWrapper.java | 223 ++++++++++++++++
.../swagger/invocation/ws/ServerWebSocket.java | 9 +-
.../ServerWebSocketResponseProcessor.java} | 13 +-
.../invocation/ws/TextWebSocketMessage.java | 15 +-
.../swagger/invocation/ws/WebSocket.java | 59 +++++
.../swagger/invocation/ws/WebSocketAdapter.java | 17 +-
.../swagger/invocation/ws/WebSocketFrame.java | 7 +-
.../swagger/invocation/ws/WebSocketFrameType.java | 9 +-
.../swagger/invocation/ws/WebSocketMessage.java | 15 +-
.../swagger/invocation/ws/WebSocketPipe.java | 295 +++++++++++++++++++++
...icecomb.swagger.generator.ResponseTypeProcessor | 3 +-
...s.consumer.ConsumerContextArgumentMapperFactory | 1 +
.../invocation/ws/SerialExecutorWrapperTest.java | 132 +++++++++
.../ws/RestClientRequestWebSocketWrapper.java | 73 +++++
.../WebSocketClientInvocation.java} | 263 ++++++++----------
.../WebSocketTransportClient.java} | 40 +--
.../client/ws/WebSocketTransportClientManager.java | 23 +-
.../ws/WebSocketTransportClientOptionsSPI.java | 230 ++++++++++++++++
...ation.vertx.client.ws.WebSocketClientOptionsSPI | 2 +-
.../transport/rest/vertx/RestServerVerticle.java | 26 ++
.../transport/rest/vertx/TransportConfig.java | 49 ++++
.../transport/rest/vertx/WebSocketTransport.java} | 27 +-
.../rest/vertx/ws/VertxWebSocketAdaptor.java | 235 ++++++++++++++++
.../vertx/ws/WebSocketHandshakeServerFilter.java | 89 +++++++
.../ws/WebSocketResponseWrapClientFilter.java | 92 +++++++
...servicecomb.common.rest.filter.HttpClientFilter | 2 +-
...servicecomb.common.rest.filter.HttpServerFilter | 2 +-
.../services/org.apache.servicecomb.core.Transport | 1 +
67 files changed, 2525 insertions(+), 377 deletions(-)
copy
providers/provider-rest-common/src/main/java/org/apache/servicecomb/provider/rest/common/RestSchema.java
=> core/src/main/java/org/apache/servicecomb/core/annotation/Transport.java
(69%)
copy
swagger/swagger-generator/generator-springmvc/src/main/java/org/apache/servicecomb/swagger/generator/springmvc/processor/annotation/RestControllerClassAnnotationProcessor.java
=>
core/src/main/java/org/apache/servicecomb/core/transport/TransportClassAnnotationProcessor.java
(66%)
copy
swagger/swagger-generator/generator-jaxrs/src/main/java/org/apache/servicecomb/swagger/generator/jaxrs/processor/annotation/ProducesAnnotationProcessor.java
=>
core/src/main/java/org/apache/servicecomb/core/transport/TransportMethodAnnotationProcessor.java
(68%)
copy
common/common-access-log/src/main/resources/META-INF/services/org.apache.servicecomb.core.BootListener
=>
core/src/main/resources/META-INF/services/org.apache.servicecomb.swagger.generator.ClassAnnotationProcessor
(91%)
copy
common/common-access-log/src/main/resources/META-INF/services/org.apache.servicecomb.core.BootListener
=>
core/src/main/resources/META-INF/services/org.apache.servicecomb.swagger.generator.MethodAnnotationProcessor
(91%)
create mode 100644
foundations/foundation-vertx/src/main/java/org/apache/servicecomb/foundation/vertx/client/ws/WebSocketClientOptionsSPI.java
copy
foundations/foundation-vertx/src/main/java/org/apache/servicecomb/foundation/vertx/client/{tcp/AbstractTcpClientPoolFactory.java
=> ws/WebSocketClientPoolFactory.java} (51%)
copy
foundations/foundation-vertx/src/main/java/org/apache/servicecomb/foundation/vertx/client/{http/HttpClientWithContext.java
=> ws/WebSocketClientWithContext.java} (60%)
copy
foundations/foundation-vertx/src/main/java/org/apache/servicecomb/foundation/vertx/{http/VertxClientRequestToHttpServletRequest.java
=> ws/VertxClientWebSocketRequestToHttpServletRequest.java} (66%)
create mode 100644
foundations/foundation-vertx/src/main/java/org/apache/servicecomb/foundation/vertx/ws/VertxClientWebSocketResponseToHttpServletResponse.java
copy
core/src/main/java/org/apache/servicecomb/core/invocation/endpoint/EndpointMapper.java
=>
swagger/swagger-invocation/invocation-core/src/main/java/org/apache/servicecomb/swagger/invocation/arguments/consumer/ClientWebSocketArgumentMapper.java
(63%)
copy
swagger/swagger-invocation/invocation-core/src/main/java/org/apache/servicecomb/swagger/invocation/arguments/consumer/{ConsumerInvocationContextMapperFactory.java
=> ClientWebSocketArgumentMapperFactory.java} (76%)
create mode 100644
swagger/swagger-invocation/invocation-core/src/main/java/org/apache/servicecomb/swagger/invocation/ws/AbstractBaseWebSocket.java
copy
archetypes/business-service-jaxrs/src/main/resources/archetype-resources/src/main/java/Application.java
=>
swagger/swagger-invocation/invocation-core/src/main/java/org/apache/servicecomb/swagger/invocation/ws/BinaryBytesWebSocketMessage.java
(79%)
copy
foundations/foundation-registry/src/main/java/org/apache/servicecomb/registry/api/registry/MicroserviceStatus.java
=>
swagger/swagger-invocation/invocation-core/src/main/java/org/apache/servicecomb/swagger/invocation/ws/ClientWebSocket.java
(83%)
create mode 100644
swagger/swagger-invocation/invocation-core/src/main/java/org/apache/servicecomb/swagger/invocation/ws/SerialExecutorWrapper.java
copy
foundations/foundation-registry/src/main/java/org/apache/servicecomb/registry/api/registry/MicroserviceStatus.java
=>
swagger/swagger-invocation/invocation-core/src/main/java/org/apache/servicecomb/swagger/invocation/ws/ServerWebSocket.java
(83%)
copy
swagger/swagger-invocation/invocation-core/src/main/java/org/apache/servicecomb/swagger/invocation/{generator/ScbResponseProcessor.java
=> ws/ServerWebSocketResponseProcessor.java} (83%)
copy
foundations/foundation-registry/src/main/java/org/apache/servicecomb/registry/api/registry/MicroserviceInstanceStatus.java
=>
swagger/swagger-invocation/invocation-core/src/main/java/org/apache/servicecomb/swagger/invocation/ws/TextWebSocketMessage.java
(78%)
create mode 100644
swagger/swagger-invocation/invocation-core/src/main/java/org/apache/servicecomb/swagger/invocation/ws/WebSocket.java
copy
demo/demo-edge/edge-service/src/main/java/org/apache/servicecomb/demo/edge/service/encrypt/Encrypt.java
=>
swagger/swagger-invocation/invocation-core/src/main/java/org/apache/servicecomb/swagger/invocation/ws/WebSocketAdapter.java
(71%)
copy
service-registry/registry-service-center/src/main/java/org/apache/servicecomb/serviceregistry/event/NotPermittedEvent.java
=>
swagger/swagger-invocation/invocation-core/src/main/java/org/apache/servicecomb/swagger/invocation/ws/WebSocketFrame.java
(81%)
copy
foundations/foundation-registry/src/main/java/org/apache/servicecomb/registry/api/registry/MicroserviceStatus.java
=>
swagger/swagger-invocation/invocation-core/src/main/java/org/apache/servicecomb/swagger/invocation/ws/WebSocketFrameType.java
(84%)
copy
service-registry/registry-service-center/src/main/java/org/apache/servicecomb/serviceregistry/client/ClientException.java
=>
swagger/swagger-invocation/invocation-core/src/main/java/org/apache/servicecomb/swagger/invocation/ws/WebSocketMessage.java
(75%)
create mode 100644
swagger/swagger-invocation/invocation-core/src/main/java/org/apache/servicecomb/swagger/invocation/ws/WebSocketPipe.java
create mode 100644
swagger/swagger-invocation/invocation-core/src/test/java/org/apache/servicecomb/swagger/invocation/ws/SerialExecutorWrapperTest.java
create mode 100644
transports/transport-rest/transport-rest-client/src/main/java/org/apache/servicecomb/transport/rest/client/ws/RestClientRequestWebSocketWrapper.java
copy
transports/transport-rest/transport-rest-client/src/main/java/org/apache/servicecomb/transport/rest/client/{http/RestClientInvocation.java
=> ws/WebSocketClientInvocation.java} (52%)
copy
transports/transport-rest/transport-rest-client/src/main/java/org/apache/servicecomb/transport/rest/client/{RestTransportClient.java
=> ws/WebSocketTransportClient.java} (50%)
copy
foundations/foundation-registry/src/main/java/org/apache/servicecomb/registry/api/registry/HealthCheckMode.java
=>
transports/transport-rest/transport-rest-client/src/main/java/org/apache/servicecomb/transport/rest/client/ws/WebSocketTransportClientManager.java
(61%)
create mode 100644
transports/transport-rest/transport-rest-client/src/main/java/org/apache/servicecomb/transport/rest/client/ws/WebSocketTransportClientOptionsSPI.java
copy
common/common-access-log/src/main/resources/META-INF/services/org.apache.servicecomb.core.BootListener
=>
transports/transport-rest/transport-rest-client/src/main/resources/META-INF/services/org.apache.servicecomb.foundation.vertx.client.ws.WebSocketClientOptionsSPI
(90%)
copy
transports/transport-rest/{transport-rest-client/src/test/java/org/apache/servicecomb/transport/rest/client/FakeRestTransport.java
=>
transport-rest-vertx/src/main/java/org/apache/servicecomb/transport/rest/vertx/WebSocketTransport.java}
(61%)
create mode 100644
transports/transport-rest/transport-rest-vertx/src/main/java/org/apache/servicecomb/transport/rest/vertx/ws/VertxWebSocketAdaptor.java
create mode 100644
transports/transport-rest/transport-rest-vertx/src/main/java/org/apache/servicecomb/transport/rest/vertx/ws/WebSocketHandshakeServerFilter.java
create mode 100644
transports/transport-rest/transport-rest-vertx/src/main/java/org/apache/servicecomb/transport/rest/vertx/ws/WebSocketResponseWrapClientFilter.java
copy {demo/demo-signature =>
transports/transport-rest/transport-rest-vertx}/src/main/resources/META-INF/services/org.apache.servicecomb.common.rest.filter.HttpClientFilter
(90%)
copy {demo/demo-jaxrs/jaxrs-server =>
transports/transport-rest/transport-rest-vertx}/src/main/resources/META-INF/services/org.apache.servicecomb.common.rest.filter.HttpServerFilter
(90%)
