3年前 (2021-05-15)  相关技术 |   抢沙发  636 
文章评分 0 次,平均分 0.0

在微服务的多样化世界中,HTTP是代理到代理通信中无可争议的领导者。它成熟,无处不在。但在某些情况下,HTTP请求-响应可能很麻烦。如果您需要传统请求-响应之外的通信模式,如fire-and-forgetstreaming,该怎么办?如果你想向任何一个方向发送信息呢?

有了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特性。该项目还依赖于lombokspringbootstartersocket库。Lombok为Java数据类添加了构造函数、gettersetterequals,还简化了对日志等内容的访问。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

 

除特别注明外,本站所有文章均为老K的Java博客原创,转载请注明出处来自https://javakk.com/1918.html

关于

发表评论

表情 格式

暂无评论

登录

忘记密码 ?

切换登录

注册