{"id":8643,"date":"2023-10-03T18:47:43","date_gmt":"2023-10-03T17:47:43","guid":{"rendered":"https:\/\/www.baeldung.com\/?p=166456"},"modified":"2023-10-03T18:47:43","modified_gmt":"2023-10-03T17:47:43","slug":"rsocket-interface-in-spring-6","status":"publish","type":"post","link":"https:\/\/gamefootballmobileanimeiphone.com\/index.php\/2023\/10\/03\/rsocket-interface-in-spring-6\/","title":{"rendered":"RSocket Interface in Spring 6"},"content":{"rendered":"

\"\"<\/p>\n

1. Overview<\/h2>\n
<\/div>\n

In this tutorial, we’ll explore how to utilize RSocket<\/a> in the Spring Framework 6.<\/em><\/p>\n

Working with RSocket<\/a> has become simpler with the introduction of declarative RSocket clients in version 6 of the Spring Framework.<\/em> This feature eliminates the need for repetitive boilerplate code, allowing developers to use RSocket more efficiently and effectively.<\/strong><\/p>\n

2. Maven Dependency<\/h2>\n
<\/div>\n

We start by creating a Spring Boot project in our preferred IDE and add the spring-boot-starter-rsocket<\/em><\/a> dependency to the pom.xml<\/em> file:<\/p>\n

<dependency> \r\n    <groupId>org.springframework.boot<\/groupId> \r\n    <artifactId>spring-boot-starter-rsocket<\/artifactId>\r\n    <version>3.1.4<\/version>\r\n<\/dependency> \r\n<\/code><\/pre>\n
3. Creating RSocket Server<\/h2>\n
<\/div>\n
First, we’ll create a responder that uses a controller to manage incoming requests:<\/p>\n
@MessageMapping("MyDestination")\r\npublic Mono<String> message(Mono<String> input) {\r\n    return input.doOnNext(msg -> System.out.println("Request is:" + msg + ",Request!"))\r\n      .map(msg -> msg + ",Response!");\r\n}<\/code><\/pre>\n
Besides, we’ll add the following property to the application.properties<\/em> file to enable the server to listen on port 7000<\/em> via MyDestination:<\/em><\/p>\n
spring.rsocket.server.port=7000<\/code><\/pre>\n
4. Client Code<\/h2>\n
<\/div>\n
Now, we need to develop the client code. To keep things simple, we’ll create the client code in the same project but in a separate package. In reality, they must be in a unique project.<\/p>\n
To proceed, let us create the client interface:<\/p>\n
public interface MessageClient {\r\n    @RSocketExchange("MyDestination")\r\n    Mono<String> sendMessage(Mono<String> input);\r\n}\r\n<\/code><\/pre>\n
When using our client interface, we use @RSocketExchange<\/em> to show the RSocket endpoint. Basically, this just means we need some info to establish the endpoint path. We can do that at the interface level by assigning a shared path<\/strong>. It’s super easy and helps us to know which endpoint we want to use.<\/p>\n
5. Testing<\/h2>\n
<\/div>\n
Every Spring Boot project includes a class annotated with @SpringBootApplication<\/em>. This class runs when the project is loaded. Therefore, we can use this class and add some beans to test a scenario.<\/p>\n
5.1. Create RSocketServiceProxyFactory<\/em> Bean<\/h3>\n
<\/div>\n
First, we need to create a bean to generate an RSocketServiceProxyFactory<\/em>.<\/p>\n
This factory is responsible for creating proxy instances of the RSocket service interface. It handles the creation of these proxies and establishes the necessary connection to the RSocket server by specifying the host and port where the server will receive incoming connections:<\/p>\n
@Bean\r\npublic RSocketServiceProxyFactory getRSocketServiceProxyFactory(RSocketRequester.Builder requestBuilder) {\r\n    RSocketRequester requester = requestBuilder.tcp("localhost", 7000);\r\n    return RSocketServiceProxyFactory.builder(requester).build();\r\n}<\/code><\/pre>\n
5.2. Create Message Client<\/h3>\n
<\/div>\n
Then, we’ll create a Bean<\/em> responsible for generating a client interface:<\/strong><\/p>\n
@Bean\r\npublic MessageClient getClient(RSocketServiceProxyFactory factory) {\r\n    return factory.createClient(MessageClient.class);\r\n}<\/code><\/pre>\n
5.3. Create Runner Bean<\/em><\/h3>\n
<\/div>\n
Finally, let’s create a runner bean that uses the MessageClient<\/em> instance to send and receive messages from the server:<\/p>\n
@Bean\r\npublic ApplicationRunner runRequestResponseModel(MessageClient client) {\r\n    return args -> {\r\n        client.sendMessage(Mono.just("Request-Response test "))\r\n          .doOnNext(message -> {\r\n              System.out.println("Response is :" + message);\r\n          })\r\n          .subscribe();\r\n    };\r\n}<\/code><\/pre>\n
5.4. Test Results<\/h3>\n
<\/div>\n
When we run our Spring Boot project through the command line, the following results are displayed:<\/p>\n
>>c.b.r.responder.RSocketApplication : Started \r\n>>RSocketApplication in 1.127 seconds (process running for 1.398)\r\n>>Request is:Request-Response test ,Request!\r\n>>Response is :Request-Response test ,Response!<\/code><\/pre>\n
6. RSocket Interaction Models<\/h2>\n
<\/div>\n
RSocket is a binary protocol used to create fast and responsive distributed applications. It offers different communication patterns for exchanging data between servers and clients.<\/p>\n
With these interaction models, developers can design systems that meet specific requirements for data flow, backlog, and application behavior.<\/p>\n
RSocket has four main interaction models available. The main difference between these approaches is based on the cardinality of input and output.<\/strong><\/p>\n
6.1. Request-Response<\/h3>\n
<\/div>\n
In this approach, every request receives a single response. Therefore, we used a Mono<\/em><\/a> request with a cardinality of one and received a Mono<\/em> response with the same cardinality.<\/p>\n
Until now, all our code in this article were based on a request-response model.<\/p>\n
6.2. Request-Stream<\/h3>\n
<\/div>\n
When we subscribe to a newsletter, we receive a regular flow of updates from the server. When the client makes the initial request, the server sends a data stream in response.<\/p>\n
The request can be either a Mono<\/em> or a Void<\/em>, but the response will always be a Flux<\/em><\/a>:<\/p>\n
@MessageMapping("Counter")\r\npublic Flux<String> Counter() {\r\n    return Flux.range(1, 10)\r\n      .map(i -> "Count is: " + i);\r\n}<\/code><\/pre>\n
6.3. Fire-and-Forget<\/h3>\n
<\/div>\n
When we send a letter through the mail, we usually just drop it in the mailbox and don’t expect to receive a reply. Similarly, in the fire-and-forget context, the response can be either null<\/em> or a single Mono<\/em>:<\/p>\n
@MessageMapping("Warning")\r\npublic Mono<Void> Warning(Mono<String> error) {\r\n    error.doOnNext(e -> System.out.println("warning is :" + e))\r\n      .subscribe();\r\n    return Mono.empty();\r\n}<\/code><\/pre>\n
6.4. Channel<\/h3>\n
<\/div>\n
Imagine a walkie-talkie that allows two-way communication where both parties can talk and listen simultaneously, just like having a conversation. This type of communication relies on sending and receiving data Flux<\/em>:<\/p>\n
@MessageMapping("channel")\r\npublic Flux<String> channel(Flux<String> input) {\r\n    return input.doOnNext(i -> {\r\n          System.out.println("Received message is : " + i);\r\n      })\r\n      .map(m -> m.toUpperCase())\r\n      .doOnNext(r -> {\r\n          System.out.println("RESPONSE IS :" + r);\r\n      });\r\n}<\/code><\/pre>\n
7. Conclusion<\/h2>\n
<\/div>\n
In this article, we explored the new declarative RSocket client feature in Spring 6. We also learned how to use it with the @RSocketExchange<\/em> annotation.<\/p>\n
Additionally, we saw in detail how to create and set up the service proxy so that we can easily and safely connect to a remote endpoint using the TCP protocol.<\/p>\n
Furthermore, the source code for this tutorial is available over on GitHub<\/a>.<\/p>\n
\"\"<\/p>\n
<\/a> <\/a> <\/a> <\/a> <\/a> <\/a> <\/a> <\/div>\n\n
Commercials Cooperation Advertisements:<\/b><\/h2>\r\n

(1) IT Teacher IT Freelance
 <\/p>\r\nIT\u96fb\u8166\u88dc\u7fd2<\/a>
\u7acb\u523b\u8a3b\u518a\u53ca\u5831\u540d\u96fb\u8166\u88dc\u7fd2\u8ab2\u7a0b\u5427! <\/a>
\r\n\r\n\u7535\u5b50\u8ba1\u7b97\u673a -\u6559\u80b2 -IT \u96fb\u8166\u73ed\u201d ( IT\u96fb\u8166\u88dc\u7fd2 ) \u63d0\u4f9b\u4e00\u500b\u65b9\u4fbf\u7684\u7535\u5b50\u8ba1\u7b97\u673a \u6559\u80b2\u5e73\u53f0, \u70ba\u5927\u5bb6\u914d\u5c0d\u4fe1\u606f\u6280\u672f, \u96fb\u8166 \u8001\u5e2b, IT freelance \u548c programming expert. \u8b93\u5927\u5bb6\u65b9\u4fbf\u5730\u5c31\u80fd\u627e\u5230\u5408\u9069\u7684\u96fb\u8166\u88dc\u7fd2, \u96fb\u8166\u73ed, \u5bb6\u6559, \u79c1\u4eba\u8001\u5e2b.  
\r\n\r\nWe are a education and information platform which you can find a IT private tutorial teacher or freelance. 
\r\n\r\nAlso we provide different information about information technology, Computer, programming, mobile, Android, apple, game, movie, anime, animation\u2026 \r\n<\/p>\n

(2) ITSec
 <\/p>https:\/\/itsec.vip\/\r\nSecure<\/a> \r\n

 \r\n
www.ITSec.vip<\/a> 
 
 \r\n
www.Sraa.com.hk<\/a> 
 
 \r\n
www.ITSec.hk<\/a> 
 
 \r\n
www.Penetrationtest.hk<\/a> 
 
 \r\n
www.ITSeceu.uk<\/a> 
 
 \r\nSecure Your Computers from Cyber Threats and mitigate risks with professional services to defend Hackers. 

\r\nITSec provide IT Security and Compliance Services, including IT Compliance Services, Risk Assessment, IT Audit, Security Assessment and Audit, ISO 27001 Consulting and Certification, GDPR Compliance Services, Privacy Impact Assessment (PIA), Penetration test, Ethical Hacking, Vulnerabilities scan, IT Consulting, Data Privacy Consulting, Data Protection Services, Information Security Consulting, Cyber Security Consulting, Network Security Audit, Security Awareness Training. \r\n

Contact us right away. 

Email (Prefer using email to contact us): 
SalesExecutive@ITSec.vip<\/p>","protected":false},"excerpt":{"rendered":"
\"\"<\/p>\n
Explore the new declarative RSocket client feature in Spring 6.<\/p>\n
<\/a>\u00a0<\/a>\u00a0<\/a>\u00a0<\/a>\u00a0<\/a>\u00a0<\/a>\u00a0<\/a>\u00a0<\/div>\n","protected":false},"author":411,"featured_media":0,"comment_status":"open","ping_status":"closed","sticky":false,"template":"","format":"standard","meta":{"_monsterinsights_skip_tracking":false,"_monsterinsights_sitenote_active":false,"_monsterinsights_sitenote_note":"","_monsterinsights_sitenote_category":0,"site-container-style":"default","site-container-layout":"default","site-sidebar-layout":"default","disable-article-header":"default","disable-site-header":"default","disable-site-footer":"default","disable-content-area-spacing":"default","footnotes":""},"categories":[22],"tags":[61,122,127,129,124,128,125,132,131,133,126,130,123,66,94,88,97,56,64,65,60,112,40,75,95,104,33,120,105,101,98,115,30,29,41,86,70,69,68,72,71,26,118,108,87,46,55,48,52,54,51,50,83,62,58,57,109,35,59,63,85,79,82,96,80,27,81,114,44,42,43,45,38,39,110,117,100,111,116,73,89,90,92,91,93,84,78,37,102,34,36,77,67,74,99,113,4090,119,28,121,32,47,49,53,103,31,76],"class_list":["post-8643","post","type-post","status-publish","format-standard","hentry","category-mobile","tag-airpods","tag-anime","tag-anime-characters","tag-anime-cosplay","tag-anime-edits","tag-anime-merchandise","tag-anime-movies","tag-anime-news","tag-anime-recommendations","tag-anime-reviews","tag-anime-series","tag-anime-streaming","tag-animes","tag-app-store","tag-app-store-samsung","tag-appgallery","tag-appgallery-oneplus","tag-apple","tag-apple-music","tag-apple-tv","tag-apple-watch","tag-bbc-sport","tag-best-mobile-games","tag-bixby","tag-bixby-xiaomi","tag-champions-league","tag-cyberpunk","tag-cyberpunk-2077","tag-fantasy-football","tag-fifa","tag-football","tag-formula-1","tag-fortnite","tag-free-fire","tag-free-mobile-games","tag-freebuds-pro","tag-galaxy-a52","tag-galaxy-note-20","tag-galaxy-s21","tag-galaxy-watch-4","tag-galaxy-z-fold-3","tag-game","tag-games","tag-golf","tag-harmonyos","tag-how-to-backup-iphone","tag-how-to-factory-reset-iphone","tag-how-to-reset-iphone","tag-how-to-restore-iphone","tag-how-to-unlock-iphone","tag-how-to-unlock-iphone-5","tag-how-to-unlock-iphone-6","tag-huawei","tag-ios","tag-ipad","tag-iphone","tag-live-soccer","tag-lol","tag-macbook","tag-macos","tag-mate-40-pro","tag-mi-11-lite","tag-mi-home-security-camera-basic-1080p","tag-mi-home-security-camera-basic-1080p-huawei","tag-mi-smart-band-6","tag-minecraft","tag-miui","tag-mlb-scores","tag-mobile-game-design","tag-mobile-game-development","tag-mobile-game-marketing","tag-mobile-game-monetization","tag-mobile-games","tag-mobile-gaming","tag-nba-scores","tag-nba-standings","tag-nfl","tag-nfl-scores","tag-nhl-scores","tag-one-ui","tag-oneplus","tag-oneplus-9-pro","tag-oneplus-buds-pro","tag-oneplus-nord-ce-5g","tag-oxygenos","tag-p40-pro-plus","tag-poco-x3-pro","tag-pokemon","tag-premier-league","tag-pubg","tag-pubg-mobile","tag-redmi-note-10-pro","tag-samsung","tag-samsung-pay","tag-soccer","tag-sports","tag-spring","tag-steam","tag-steeam","tag-top-10-anime","tag-valorant","tag-when-do-the-iphone-7-come-out","tag-when-does-the-iphone-7-come-out","tag-when-is-the-iphone-7-coming-out","tag-world-cup","tag-xbox-series-x","tag-xiaomi"],"aioseo_notices":[],"_links":{"self":[{"href":"https:\/\/gamefootballmobileanimeiphone.com\/index.php\/wp-json\/wp\/v2\/posts\/8643","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/gamefootballmobileanimeiphone.com\/index.php\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/gamefootballmobileanimeiphone.com\/index.php\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/gamefootballmobileanimeiphone.com\/index.php\/wp-json\/wp\/v2\/users\/411"}],"replies":[{"embeddable":true,"href":"https:\/\/gamefootballmobileanimeiphone.com\/index.php\/wp-json\/wp\/v2\/comments?post=8643"}],"version-history":[{"count":1,"href":"https:\/\/gamefootballmobileanimeiphone.com\/index.php\/wp-json\/wp\/v2\/posts\/8643\/revisions"}],"predecessor-version":[{"id":8644,"href":"https:\/\/gamefootballmobileanimeiphone.com\/index.php\/wp-json\/wp\/v2\/posts\/8643\/revisions\/8644"}],"wp:attachment":[{"href":"https:\/\/gamefootballmobileanimeiphone.com\/index.php\/wp-json\/wp\/v2\/media?parent=8643"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/gamefootballmobileanimeiphone.com\/index.php\/wp-json\/wp\/v2\/categories?post=8643"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/gamefootballmobileanimeiphone.com\/index.php\/wp-json\/wp\/v2\/tags?post=8643"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}