Spring support for RSocket Java
Spring support for RSocket Java.
Questions tagged [spring-rsocket]
34 questions
4
votes
0 answers
Spring reactor rsocket connection limits
I'm managing socket client using spring integration TCP and try to use RSocket.
My target server has connections limit so I need like max-connections.
Would RSocket support this?
If It's not support, am i using rate-limit(third part lib)?
reperion
- 129
- 9
4
votes
1 answer
Is there a way to see the REQUEST_N exchanges in Spring RSocket
I'm using the Spring support for RSocket, specifically the request-stream model. I.e.:
@MessageMapping("stream")
Flux stream(final SubscriptionMessage request, @AuthenticationPrincipal UserDetails user) {
//....
}
If I…
BobW
- 91
- 6
3
votes
0 answers
Spring Boot - RSocket over websocket - Server responders not working
I am using Spring boot 2.6.3. This is a Spring webflux project and using RSocket over Websoocket for Notification.
Server side:-
build.gradle,
implementation 'org.springframework.boot:spring-boot-starter-webflux'
implementation…
user1578872
- 7,808
- 29
- 108
- 206
3
votes
1 answer
RSocket over websocket - reactor.core.Exceptions$ErrorCallbackNotImplemented: java.util.concurrent.CancellationException: Disposed
I am using Spring webflux for general requirement and Spring RSocket over websocket for server push & chat requirement.
Spring boot version - 2.5.6
implementation 'org.springframework.boot:spring-boot-starter-webflux'
implementation…
user1578872
- 7,808
- 29
- 108
- 206
3
votes
1 answer
Does spring-rsocket support return a RejectedSetupException in @ConnectMapping annotated method?
I follow the spring-rsocket-demo project to complete my code. I add some authentication logic in my server side code as follows. You can see I throw a exception in the after the authentication logic 'CLIENT.add(requester)'. I execute the test method…
Kami Wan
- 724
- 2
- 9
- 23
3
votes
1 answer
rsocket routing metadata using RSocket-Java for Spring Rsocket Server
How do I setup routing metadata (in payload using just RSocket-Java when server is using Spring Boot Rsocket.
Flux s = connection.flatMapMany(requester -> requester.requestStream(DefaultPayload.create("Some Message")))
Server is using…
user3549576
- 99
- 1
- 4
- 17
3
votes
0 answers
Adding CORS Configuration with Spring + RSocket + Websocket
How do I add CORS configuration to restrict to a set of allowed hosts to make requests to a websocket exposed via RSocket?
I tried @CrossOrigin annotation without any luck and I have tried adding the below without any luck. All the samples I could…
Shahul
- 69
- 3
2
votes
2 answers
Spring RSocket over WebSocket - Access user information from HTTP session
In my web application, users login using a username/password combination and get a session cookie. When initiating a WebSocket connection, I can easily access the user information in the WebSocketHandler, for example:
@Component
public class…
CalibeR.50
- 370
- 2
- 13
2
votes
1 answer
Java RSocket client connect with Spring RSocket channel
I have simple Spring boot RSocket service
@MessageMapping("msend")
public Flux msend(String message) {
log.info("msend channel publish " + message);
return Flux.just(message, " "+System.currentTimeMillis());
}
It…
Armen Arzumanyan
- 1,939
- 3
- 30
- 56
2
votes
1 answer
RSocket Js client not getting elements generated from a Spring Boot RSocket Server
Sample project available on Github: https://github.com/codependent/rsocket-rating-service
A Spring Boot RSocket server message mapping expects a requestResponse request, returning a simple POJO:
@MessageMapping("request-rating")
fun…
codependent
- 23,193
- 31
- 166
- 308
1
vote
0 answers
Spring boot rSocket endpoints can be accessed over WebFlux port
I have a spring boot server with both WebFlux controller and an rSocket controller
06-15 12:15:11.273|INFO|o.s.b.w.e.netty.NettyWebServer:111|main --- Netty started on port 8080
06-15 12:15:11.291|INFO|o.s.b.r.netty.NettyRSocketServer:65|main ---…
nightlytrails
- 2,448
- 3
- 22
- 33
1
vote
3 answers
How to pass JWT token in Metadata in Rsocket Client in Spring Boot
I have added routes and JWT token in metadata but while passing token from RSocket client to RSocket server it is adding extra bytes in token.
Client side code -----------
ByteBuf simpleAuthentication =…
Shivangi Varshney
- 21
- 3
1
vote
0 answers
Spring rsocket security with Webflux security
My Application is a Spring Webflux application with Spring boot version 2.6.6.
Since, I have a chat and notification requirement for the logged in user, trying to use RSocket over websocket for notification & messaging along with Webflux for web…
user1578872
- 7,808
- 29
- 108
- 206
1
vote
2 answers
How to make the path public in RSocketSecurity(Spring)
I have config class for RSocketSecurity
Something like that
@Configuration
@EnableRSocketSecurity
@EnableReactiveMethodSecurity
class RSocketAuthConfiguration {
and authorization for it (allows only authenticated users to subscribe )
…
Анна Цицилюк
- 13
- 3
1
vote
0 answers
spring rsocket response metadata
When using spring-boot-starter-rsocket is there a way to send response metadata from a MessageMapping-annotated method? I also don't see a way for RSocketRequester to receive metadata (all RSocketRequester.RetrieveSpec retrieveMethods seem to return…
gadams00
- 771
- 1
- 10
- 24