前言
在微服务的多样化世界中，http是代理到代理通信中无可争议的领导者。它成熟，无处不在。但在某些情况下，http请求-响应可能很麻烦。如果您需要传统请求-响应之外的通信模式，如fire-and-forget或streaming，该怎么办？如果你想向任何一个方向发送信息呢？
有了http，有很多方法可以实现这一点，但这不是构建协议的目的。许多解决方案都带有额外的权衡或缺点。另外，这里没有规则手册说“你应该一直使用http”，像amqp这样的消息传递协议已经证明了这一点。所以，知道你的选择是什么是好的，每隔一段时间在你的列表中添加一些新技术也是健康的。这篇文章是关于一个这样的替代rsocket。
rsocket是一种新的消息传递协议，旨在解决一些常见的微服务通信难题。使用rsocket，您可以获得一个在tcp或websockets上工作的灵活协议。这意味着您可以在不进行转换的情况下处理二进制消息。您可以使用诸如多路复用、背压、恢复和路由等现代控件，还可以使用多种消息传递模式，包括启动和忘记、请求-响应和流式传输。rsocket也是完全反应的，因此它非常适合于高吞吐量的微服务应用程序。早期采用者包括netflix、pivotal、阿里巴巴和facebook，它们都是提供可伸缩互联网服务的专家。
由于请求-响应是大多数web开发人员熟悉的基础，因此我们将以这种模式开始我们的rsocket之旅。请求-响应的语义相当简单，您发送一个请求，就得到一个响应。http是建立在这个基本的交互之上的，它非常常见。
在本文中，您将了解如何使用rsocket，使用spring boot作为服务器，使用终端应用程序作为客户机来执行请求响应。
请求-响应request-response只是spring和rsocket支持的四种交互模型之一。
当您按照下面的步骤操作时，您会注意到使用springboot构建rsocket服务器所需的代码量非常少。这里已经为您提供了代码，但是您也可以在几分钟内自己从头开始编写代码。
步骤1：设置环境
首先，检查是否安装了以下必备组件：
- java8或更高版本的javasdk（要检查，请在终端使用java-version）
- 一个工作的javaide（我正在使用intellij idea）
- 包含克隆或提取的演示代码示例的文件夹。
- linux bash/zsh shell（如果您是windows用户，请查看下面的注释）
如果您是windows用户，请切换到microsoft针对linux的windows子系统。
现在，将下载的项目文件夹设置为终端中的当前目录：
cd spring-rsocket-demo
在终端中，下载jar文件如下：
cd rsocket-server wget -o rsc.jar https://github.com/making/rsc/releases/download/0.4.2/rsc-0.4.2.jar
稍后您将使用此客户机与rsocket服务器进行对话，但现在，通过如下方式调用help命令来测试它是否正常工作：
java -jar rsc.jar --help
您应该会看到下面这样的一些输出（我已经截断了），解释了命令的用法和选项。
usage: rsc uri [options] non-option arguments: [string: uri] option description ------ ----------- --channel shortcut of --im request_channel -d, --data [string] data. use '-' to read data from ...
把这个终端窗口开着，你以后会需要的。
步骤2：检查服务器代码
在ide中打开rsocket服务器项目并检查代码。如您所见，在springboot中支持rsocket服务器所需的代码非常少。以下是一些亮点：
项目文件
在项目的pom.xml文件中，您可以看到spring boot rsocket服务器所需的<dependencies>。之所以使用springbootversion2.2.5.release，是因为在撰写本文时，该版本具有最适合生产的rsocket特性。该项目还依赖于lombok和springbootstartersocket库。lombok为java数据类添加了构造函数、getter、setter和equals，还简化了对日志等内容的访问。rsocket的springbootstarter将rsocket与springboot集成在一起，并在运行时自动为您配置一些rsocket基础设施。
应用程序属性
在application.properties文件中，rsocket服务器的tcp端口被设置为7000，spring boot的延迟初始化功能被打开。
spring.rsocket.server.port=7000 spring.main.lazy-initialization=true
消息类
第一个更详细的类叫做message.java。这个lombok@data类用于对客户机和服务器（或者“requester”和“responder”，如果您愿意的话）之间的请求和响应消息进行建模。这个类看起来像这样…
@data
@allargsconstructor
@noargsconstructor
public class message {
private string origin;
private string interaction;
private long index;
private long created = instant.now().getepochsecond();
public message(string origin, string interaction) {
this.origin = origin;
this.interaction = interaction;
this.index = 0;
}
public message(string origin, string interaction, long index) {
this.origin = origin;
this.interaction = interaction;
this.index = index;
}
}
使用这个类，您可以说一条消息来自何处（它的来源），它打算使用哪种消息传递样式（交互），以及消息序列中的序列号（它的索引）。lombok通过提供构造函数、getter、setter、tostring和hashcode实现来简化代码。
控制器类
rsocket服务器控制器代码可以在rsocketcontroller.java文件中找到。这个类被注释为spring@controller，这本质上意味着它声明了服务端点（在本例中为rsocket endpoints）。
@controller
public class rsocketcontroller {
@messagemapping("request-response")
message requestresponse(message request) {
log.info("received request-response request: {}", request);
// create a single message and return it
return new message(server, response);
}
}
在类中，有一个名为requestresponse（）的方法，它接受单个消息对象（请求）并返回单个消息对象（响应）。
您会注意到，这个requestresponse（）方法用@messagemapping（“request-response”）注释修饰。此注释声明任何包含请求-响应的rsocket路由的元数据的消息都应该由此方法处理。稍后从客户端发送请求消息时，您将使用此路由。
你注意到这和spring的rest控制器有什么不同吗？对于rest控制器，url路径映射（如/hello）用于将http调用与其处理程序方法相关联。
这就是代码。我们试试看。
步骤3：启动spring boot rsocket服务器
在第二个终端窗口中，保持现有终端窗口处于打开状态，将rsocket server文件夹设置为当前目录。然后使用以下命令构建并运行rsocket服务器：
./mvnw clean package spring-boot:run -dskiptests=true
或者，如果愿意的话，可以在javaide中使用“build”和“run”命令。
步骤4：使用rsocket cli向服务器发送命令
接下来，您将使用在步骤1中下载并测试的rsocket client rsc.jar向正在运行的服务器发送一条消息。返回到原来的终端窗口，在那里有–help文本并发出以下命令：
java -jar rsc.jar --debug --request --data "{\"origin\":\"client\",\"interaction\":\"request\"}" --route request-response tcp://localhost:7000
您将注意到该命令声明了一个rsocket消息路由（这是通过添加–route选项并指定路由的名称来实现的）。在本例中，路由是请求-响应，它与rsocketcontroller.java中请求-响应处理程序方法中声明的@messagemapping匹配。
当命令运行时，您将在终端窗口中看到一些调试信息，解释在请求-响应交互期间发生的事情。它看起来像这样：
2020-02-27 11:20:21.806 debug --- [actor-tcp-nio-1] i.r.framelogger : sending ->
frame => stream id: 1 type: request_response flags: 0b100000000 length: 69
metadata:
+-------------------------------------------------+
| 0 1 2 3 4 5 6 7 8 9 a b c d e f |
+--------+-------------------------------------------------+----------------+
|00000000| 10 72 65 71 75 65 73 74 2d 72 65 73 70 6f 6e 73 |.request-respons|
|00000010| 65 |e |
+--------+-------------------------------------------------+----------------+
data:
+-------------------------------------------------+
| 0 1 2 3 4 5 6 7 8 9 a b c d e f |
+--------+-------------------------------------------------+----------------+
|00000000| 7b 22 6f 72 69 67 69 6e 22 3a 22 43 6c 69 65 6e |{"origin":"clien|
|00000010| 74 22 2c 22 69 6e 74 65 72 61 63 74 69 6f 6e 22 |t","interaction"|
|00000020| 3a 22 52 65 71 75 65 73 74 22 7d |:"request"} |
+--------+-------------------------------------------------+----------------+
2020-02-27 11:20:21.927 debug --- [actor-tcp-nio-1] i.r.framelogger : receiving ->
frame => stream id: 1 type: next_complete flags: 0b1100000 length: 81
data:
+-------------------------------------------------+
| 0 1 2 3 4 5 6 7 8 9 a b c d e f |
+--------+-------------------------------------------------+----------------+
|00000000| 7b 22 6f 72 69 67 69 6e 22 3a 22 53 65 72 76 65 |{"origin":"serve|
|00000010| 72 22 2c 22 69 6e 74 65 72 61 63 74 69 6f 6e 22 |r","interaction"|
|00000020| 3a 22 52 65 73 70 6f 6e 73 65 22 2c 22 69 6e 64 |:"response","ind|
|00000030| 65 78 22 3a 30 2c 22 63 72 65 61 74 65 64 22 3a |ex":0,"created":|
|00000040| 31 35 38 32 38 30 32 34 32 31 7d |1582802421} |
+--------+-------------------------------------------------+----------------+
{"origin":"server","interaction":"response","index":0,"created":1582802421}
您看到的调试输出被分成三个“消息帧”。第一个消息帧被标记为metadata。在本例中，它显示发送到服务器的路由元数据（请求-响应）。第二帧显示客户机发送给服务器的数据消息（一个json字符串）。第三帧显示服务器返回给客户机的响应消息（也是一个json字符串）。
在最后一行，您可以看到来自服务器的json格式的响应被单独打印出来，确认我们的命令消息已被服务器成功接收和确认：
{"origin":"server","interaction":"response","index":0,"created":1582802421}
你刚刚使用rsocket发送了一条请求-响应消息。现在可以通过在终端窗口中按ctrl-c或关闭rsocket服务器来停止rsocket服务器。如果您使用ide运行rsocket服务器，您可以用通常的方式停止ide中的进程。
工作原理
你下载的rsocket rsc客户端使用rsocket消息传递协议向rsocketcontroller发送请求消息。消息通过tcp发送到tcp://localhost：7000服务器正在等待的位置。
在第一消息帧中发送消息路由指令。此路由指令使用cli客户端的–route选项设置，并设置为request-response。spring使用这个路由信息来选择正确的@messagemapping端点来调用requestresponse（message-request）方法。然后，该方法用自己的消息进行响应。cli客户机将终端窗口中的整个交互打印为一系列消息帧。
如果您继续下去，您会发现使用springboot编写一个简单的rsocket服务器是多么容易。
原文地址：https://spring.io/blog/2020/03/02/getting-started-with-rsocket-spring-boot-server
总结
到此这篇关于springboot创建rsocket服务器的文章就介绍到这了,更多相关springboot创建rsocket服务器内容请搜索www.887551.com以前的文章或继续浏览下面的相关文章希望大家以后多多支持www.887551.com！
