Golang gRPC

为什么要使用 gRPC?

我们的示例是一个简单的路线映射应用程序,它允许客户端获取有关路线上的特征的信息,创建路线摘要,并与服务器和其他客户端交换路线信息,例如交通更新。

使用 gRPC,我们可以在 .proto 文件中定义一次服务,并在 gRPC 支持的任何语言中生成客户端和服务器,这些客户端和服务器反过来可以在从大型数据中心的服务器到您自己的平板电脑等各种环境中运行——不同语言和环境之间通信的所有复杂性都由 gRPC 为您处理。我们还获得了使用协议缓冲区的所有优势,包括高效的序列化、简单的 IDL 和简单的接口更新。

设置

您应该已经安装了生成客户端和服务器接口代码所需的工具——如果您还没有,请参阅快速入门中的先决条件部分以获取设置说明。

获取示例代码

示例代码是 grpc-go 仓库的一部分。

  1. 将仓库下载为 zip 文件 并解压缩,或者克隆仓库

    $ git clone -b v1.63.0 --depth 1 https://github.com/grpc/grpc-go
    
  2. 更改到示例目录

    $ cd grpc-go/examples/route_guide
    

定义服务

我们的第一步(正如您从gRPC 简介中了解到的那样)是使用协议缓冲区定义 gRPC 服务以及方法请求响应类型。有关完整的 .proto 文件,请参见routeguide/route_guide.proto。

要定义服务,您需要在 .proto 文件中指定一个名为 service 的服务

service RouteGuide {...
}

然后,您在服务定义中定义 rpc 方法,指定它们的请求和响应类型。gRPC 允许您定义四种服务方法,所有这些方法都在 RouteGuide 服务中使用

  • 简单 RPC,其中客户端使用存根将请求发送到服务器并等待响应返回,就像普通的函数调用一样。

    // Obtains the feature at a given position.
    rpc GetFeature(Point) returns (Feature) {}
    
  • 服务器端流式 RPC,其中客户端向服务器发送请求并获得一个流来读取返回的消息序列。客户端从返回的流中读取,直到没有更多消息为止。正如您在示例中看到的,您可以在响应类型之前放置 stream 关键字来指定服务器端流式方法。

    // Obtains the Features available within the given Rectangle.  Results are
    // streamed rather than returned at once (e.g. in a response message with a
    // repeated field), as the rectangle may cover a large area and contain a
    // huge number of features.
    rpc ListFeatures(Rectangle) returns (stream Feature) {}
    
  • 客户端流式 RPC,其中客户端写入一系列消息并使用提供的流将它们发送到服务器。客户端完成消息写入后,它将等待服务器读取所有消息并返回其响应。您可以在请求类型之前放置 stream 关键字来指定客户端流式方法。

    // Accepts a stream of Points on a route being traversed, returning a
    // RouteSummary when traversal is completed.
    rpc RecordRoute(stream Point) returns (RouteSummary) {}
    
  • 双向流式 RPC,其中双方使用读写流发送一系列消息。两个流独立运行,因此客户端和服务器可以按任何顺序进行读写:例如,服务器可以等待接收所有客户端消息后再写入其响应,或者它可以交替读取一条消息,然后写入一条消息,或者其他一些读写组合。每个流中的消息顺序得以保留。您可以在请求和响应之前都放置 stream 关键字来指定此类型的方法。

    // Accepts a stream of RouteNotes sent while a route is being traversed,
    // while receiving other RouteNotes (e.g. from other users).
    rpc RouteChat(stream RouteNote) returns (stream RouteNote) {}
    

我们的 .proto 文件还包含用于我们的服务方法中使用的所有请求和响应类型的协议缓冲区消息类型定义——例如,以下是 Point 消息类型

// Points are represented as latitude-longitude pairs in the E7 representation
// (degrees multiplied by 10**7 and rounded to the nearest integer).
// Latitudes should be in the range +/- 90 degrees and longitude should be in
// the range +/- 180 degrees (inclusive).
message Point {int32 latitude = 1;int32 longitude = 2;
}

生成客户端和服务器代码

接下来,我们需要从我们的 .proto 服务定义中生成 gRPC 客户端和服务器接口。我们使用协议缓冲区编译器 protoc 和一个特殊的 gRPC Go 插件来完成此操作。这与我们在快速入门中所做的类似。

从 examples/route_guide 目录中,运行以下命令

$ protoc --go_out=. --go_opt=paths=source_relative \--go-grpc_out=. --go-grpc_opt=paths=source_relative \routeguide/route_guide.proto

运行此命令会在 routeguide 目录中生成以下文件

  • route_guide.pb.go,它包含所有协议缓冲区代码来填充、序列化和检索请求和响应消息类型。
  • route_guide_grpc.pb.go,它包含以下内容
    • 用于客户端调用的接口类型(或存根),该接口类型包含在 RouteGuide 服务中定义的方法。
    • 用于服务器实现的接口类型,也包含在 RouteGuide 服务中定义的方法。

创建服务器

首先让我们看看如何创建 RouteGuide 服务器。如果您只对创建 gRPC 客户端感兴趣,您可以跳过本节,直接前往创建客户端(尽管您可能会觉得它仍然很有趣!)。

使我们的 RouteGuide 服务发挥作用有两个部分

  • 实现从服务定义生成的接口:执行我们服务的实际“工作”。
  • 运行一个 gRPC 服务器来监听来自客户端的请求并将它们调度到正确的服务实现。

您可以在server/server.go中找到我们的示例 RouteGuide 服务器。让我们仔细看看它是如何工作的。

实现 RouteGuide

如您所见,我们的服务器具有一个 routeGuideServer 结构类型,它实现了生成的 RouteGuideServer 接口

type routeGuideServer struct {...
}
...func (s *routeGuideServer) GetFeature(ctx context.Context, point *pb.Point) (*pb.Feature, error) {...
}
...func (s *routeGuideServer) ListFeatures(rect *pb.Rectangle, stream pb.RouteGuide_ListFeaturesServer) error {...
}
...func (s *routeGuideServer) RecordRoute(stream pb.RouteGuide_RecordRouteServer) error {...
}
...func (s *routeGuideServer) RouteChat(stream pb.RouteGuide_RouteChatServer) error {...
}
...
简单 RPC

routeGuideServer 实现我们所有的服务方法。让我们先看看最简单的类型 GetFeature,它只从客户端获取 Point 并从其数据库中返回相应的特征信息,即 Feature

func (s *routeGuideServer) GetFeature(ctx context.Context, point *pb.Point) (*pb.Feature, error) {for _, feature := range s.savedFeatures {if proto.Equal(feature.Location, point) {return feature, nil}}// No feature was found, return an unnamed featurereturn &pb.Feature{Location: point}, nil
}

该方法为 RPC 传递了一个上下文对象和客户端的 Point 协议缓冲区请求。它返回一个包含响应信息的 Feature 协议缓冲区对象以及一个 error。在方法中,我们用适当的信息填充 Feature,然后 return 它以及 nil 错误,告诉 gRPC 我们已经完成了处理 RPC,并且可以将 Feature 返回给客户端。

服务器端流式 RPC

现在让我们看看我们的一个流式 RPC。ListFeatures 是一个服务器端流式 RPC,因此我们需要将多个 Feature 发送回我们的客户端。

func (s *routeGuideServer) ListFeatures(rect *pb.Rectangle, stream pb.RouteGuide_ListFeaturesServer) error {for _, feature := range s.savedFeatures {if inRange(feature.Location, rect) {if err := stream.Send(feature); err != nil {return err}}}return nil
}

如您所见,这次我们没有在方法参数中获得简单的请求和响应对象,而是获得了请求对象(客户端想要在其中查找 Feature 的 Rectangle)以及一个特殊的 RouteGuide_ListFeaturesServer 对象来写入我们的响应。

在方法中,我们填充了尽可能多的需要返回的 Feature 对象,并使用它的 Send() 方法将其写入 RouteGuide_ListFeaturesServer。最后,就像在我们的简单 RPC 中一样,我们返回 nil 错误,告诉 gRPC 我们已经完成了写入响应。如果在此调用中发生任何错误,我们返回一个非 nil 错误;gRPC 层将将其转换为适当的 RPC 状态,以在网络上传输。

客户端流式 RPC

现在让我们看看一些更复杂的内容:客户端流式方法 RecordRoute,其中我们从客户端获得 Point 的流并返回一个包含其行程信息的 RouteSummary。如您所见,这次方法根本没有请求参数。相反,它获得了 RouteGuide_RecordRouteServer 流,服务器可以使用该流来读取写入消息——它可以使用 Recv() 方法接收客户端消息,并使用 SendAndClose() 方法返回其单个响应。

func (s *routeGuideServer) RecordRoute(stream pb.RouteGuide_RecordRouteServer) error {var pointCount, featureCount, distance int32var lastPoint *pb.PointstartTime := time.Now()for {point, err := stream.Recv()if err == io.EOF {endTime := time.Now()return stream.SendAndClose(&pb.RouteSummary{PointCount:   pointCount,FeatureCount: featureCount,Distance:     distance,ElapsedTime:  int32(endTime.Sub(startTime).Seconds()),})}if err != nil {return err}pointCount++for _, feature := range s.savedFeatures {if proto.Equal(feature.Location, point) {featureCount++}}if lastPoint != nil {distance += calcDistance(lastPoint, point)}lastPoint = point}
}

在方法体中,我们使用 RouteGuide_RecordRouteServer 的 Recv() 方法重复读取客户端的请求到一个请求对象(在本例中为 Point),直到没有更多消息:服务器需要在每次调用后检查 Recv() 返回的错误。 如果是 nil,则流仍然有效,可以继续读取;如果它是 io.EOF,则消息流已结束,服务器可以返回其 RouteSummary。 如果它有其他值,我们按原样返回错误,以便它被 gRPC 层转换为 RPC 状态。

双向流式 RPC

最后,让我们看看我们的双向流式 RPC RouteChat()

func (s *routeGuideServer) RouteChat(stream pb.RouteGuide_RouteChatServer) error {for {in, err := stream.Recv()if err == io.EOF {return nil}if err != nil {return err}key := serialize(in.Location)... // look for notes to be sent to clientfor _, note := range s.routeNotes[key] {if err := stream.Send(note); err != nil {return err}}}
}

这次我们得到一个 RouteGuide_RouteChatServer 流,它与我们的客户端流式示例一样,可以用来读取和写入消息。但是,这次我们在客户端仍然向其消息流写入消息时,通过方法的流返回值。

这里的读写语法与我们的客户端流式方法非常相似,除了服务器使用流的 Send() 方法而不是 SendAndClose(),因为它正在写入多个响应。虽然双方总是按照写入顺序获得对方的邮件,但客户端和服务器都可以按任意顺序读写——流是完全独立运行的。

启动服务器

实现完所有方法后,我们还需要启动一个 gRPC 服务器,以便客户端可以使用我们的服务。以下代码段展示了我们如何为我们的 RouteGuide 服务做到这一点

lis, err := net.Listen("tcp", fmt.Sprintf("localhost:%d", port))
if err != nil {log.Fatalf("failed to listen: %v", err)
}
var opts []grpc.ServerOption
...
grpcServer := grpc.NewServer(opts...)
pb.RegisterRouteGuideServer(grpcServer, newServer())
grpcServer.Serve(lis)

要构建并启动服务器,我们需要

  1. 使用以下方法指定我们要用来监听客户端请求的端口
    lis, err := net.Listen(...).
  2. 使用 grpc.NewServer(...) 创建一个 gRPC 服务器实例。
  3. 将我们的服务实现注册到 gRPC 服务器。
  4. 在服务器上调用 Serve() 并提供我们的端口信息,执行阻塞等待,直到进程被杀死或调用 Stop()

创建客户端

在本节中,我们将介绍如何为我们的 RouteGuide 服务创建一个 Go 客户端。您可以在 grpc-go/examples/route_guide/client/client.go 中查看我们完整的示例客户端代码。

创建存根

要调用服务方法,我们首先需要创建一个 gRPC 通道 来与服务器通信。我们通过将服务器地址和端口号传递给 grpc.Dial() 来创建它,如下所示

var opts []grpc.DialOption
...
conn, err := grpc.Dial(*serverAddr, opts...)
if err != nil {...
}
defer conn.Close()

当服务需要身份验证凭据时,您可以在 grpc.Dial 中使用 DialOptions 来设置身份验证凭据(例如,TLS、GCE 凭据或 JWT 凭据)。RouteGuide 服务不需要任何凭据。

设置好 gRPC 通道 后,我们需要一个客户端 存根 来执行 RPC。我们可以使用从示例 .proto 文件生成的 pb 包提供的 NewRouteGuideClient 方法获得它。

client := pb.NewRouteGuideClient(conn)
调用服务方法

现在让我们看看如何调用服务方法。请注意,在 gRPC-Go 中,RPC 以阻塞/同步模式运行,这意味着 RPC 调用将等待服务器响应,并将返回响应或错误。

简单 RPC

调用简单的 RPC GetFeature 几乎与调用本地方法一样简单。

feature, err := client.GetFeature(context.Background(), &pb.Point{409146138, -746188906})
if err != nil {...
}

如您所见,我们在前面获得的存根上调用了该方法。在我们的方法参数中,我们创建并填充了一个请求协议缓冲区对象(在本例中为 Point)。我们还传递了一个 context.Context 对象,它允许我们在必要时更改 RPC 的行为,例如超时/取消正在进行的 RPC。如果调用没有返回错误,那么我们可以从第一个返回值中读取来自服务器的响应信息。

log.Println(feature)
服务器端流式 RPC

以下是我们调用服务器端流式方法 ListFeatures 的地方,该方法返回地理 Feature 的流。如果您已经阅读了 创建服务器,其中一些内容可能看起来很熟悉 - 流式 RPC 在两端以类似的方式实现。

rect := &pb.Rectangle{ ... }  // initialize a pb.Rectangle
stream, err := client.ListFeatures(context.Background(), rect)
if err != nil {...
}
for {feature, err := stream.Recv()if err == io.EOF {break}if err != nil {log.Fatalf("%v.ListFeatures(_) = _, %v", client, err)}log.Println(feature)
}

与简单 RPC 一样,我们将上下文和请求传递给该方法。但是,我们没有得到响应对象,而是得到了 RouteGuide_ListFeaturesClient 的实例。客户端可以使用 RouteGuide_ListFeaturesClient 流来读取服务器的响应。

我们使用 RouteGuide_ListFeaturesClient 的 Recv() 方法重复读取服务器的响应到响应协议缓冲区对象(在本例中为 Feature),直到没有更多消息:客户端需要在每次调用后检查 Recv() 返回的错误 err。如果为 nil,则流仍然有效,可以继续读取;如果它是 io.EOF,则消息流已结束;否则必须存在 RPC 错误,该错误将通过 err 传递。

客户端流式 RPC

客户端流式方法 RecordRoute 与服务器端方法类似,除了我们只将上下文传递给该方法并返回一个 RouteGuide_RecordRouteClient 流,我们可以使用它来写入和读取消息。

// Create a random number of random points
r := rand.New(rand.NewSource(time.Now().UnixNano()))
pointCount := int(r.Int31n(100)) + 2 // Traverse at least two points
var points []*pb.Point
for i := 0; i < pointCount; i++ {points = append(points, randomPoint(r))
}
log.Printf("Traversing %d points.", len(points))
stream, err := client.RecordRoute(context.Background())
if err != nil {log.Fatalf("%v.RecordRoute(_) = _, %v", client, err)
}
for _, point := range points {if err := stream.Send(point); err != nil {log.Fatalf("%v.Send(%v) = %v", stream, point, err)}
}
reply, err := stream.CloseAndRecv()
if err != nil {log.Fatalf("%v.CloseAndRecv() got error %v, want %v", stream, err, nil)
}
log.Printf("Route summary: %v", reply)

RouteGuide_RecordRouteClient 具有一个 Send() 方法,我们可以用它向服务器发送请求。完成使用 Send() 将客户端的请求写入流后,我们需要在流上调用 CloseAndRecv() 来让 gRPC 知道我们已完成写入并希望接收响应。我们从 CloseAndRecv() 返回的 err 中获取 RPC 状态。如果状态为 nil,则 CloseAndRecv() 的第一个返回值将是一个有效的服务器响应。

双向流式 RPC

最后,让我们看看我们的双向流式 RPC RouteChat()。与 RecordRoute 一样,我们只将上下文对象传递给该方法,并返回一个可以用来写入和读取消息的流。但是,这次我们在服务器仍然向其消息流写入消息时,通过方法的流返回值。

stream, err := client.RouteChat(context.Background())
waitc := make(chan struct{})
go func() {for {in, err := stream.Recv()if err == io.EOF {// read done.close(waitc)return}if err != nil {log.Fatalf("Failed to receive a note : %v", err)}log.Printf("Got message %s at point(%d, %d)", in.Message, in.Location.Latitude, in.Location.Longitude)}
}()
for _, note := range notes {if err := stream.Send(note); err != nil {log.Fatalf("Failed to send a note: %v", err)}
}
stream.CloseSend()
<-waitc

这里的读写语法与我们的客户端流式方法非常相似,除了我们在完成调用后使用流的 CloseSend() 方法。虽然双方总是按照写入顺序获得对方的邮件,但客户端和服务器都可以按任意顺序读写——流是完全独立运行的。

试一试!

从 examples/route_guide 目录执行以下命令

  1. 运行服务器

    $ go run server/server.go
    
  2. 从另一个终端运行客户端

    $ go run client/client.go
    

您将看到类似以下的输出

Getting feature for point (409146138, -746188906)
name:"Berkshire Valley Management Area Trail, Jefferson, NJ, USA" location:<latitude:409146138 longitude:-746188906 >
Getting feature for point (0, 0)
location:<>
Looking for features within lo:<latitude:400000000 longitude:-750000000 > hi:<latitude:420000000 longitude:-730000000 >
name:"Patriots Path, Mendham, NJ 07945, USA" location:<latitude:407838351 longitude:-746143763 >
...
name:"3 Hasta Way, Newton, NJ 07860, USA" location:<latitude:410248224 longitude:-747127767 >
Traversing 56 points.
Route summary: point_count:56 distance:497013163
Got message First message at point(0, 1)
Got message Second message at point(0, 2)
Got message Third message at point(0, 3)
Got message First message at point(0, 1)
Got message Fourth message at point(0, 1)
Got message Second message at point(0, 2)
Got message Fifth message at point(0, 2)
Got message Third message at point(0, 3)
Got message Sixth message at point(0, 3)

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/pingmian/59181.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

第三十四章 Vue路由进阶之声明式导航(导航高亮)

目录 一、导航高亮 1.1. 基于语法 1.2. 主要代码 二、声明式导航的两个类名 2.1. 声明式导航类名匹配方式 2.2. 声明式导航类名样式自定义 ​2.3. 核心代码 一、导航高亮 1.1. 基于语法 在Vue中通过VueRouter插件&#xff0c;我们可以非常简单的实现实现导航高亮效果…

群控系统服务端开发模式-应用开发-系统配置开发

其实在前面的章节中就已经提到过系统配置开发这块&#xff0c;包括建表及数据层开发都已完毕《群控系统服务端开发模式-应用开发-业务架构逻辑开发BaseAPI继续开发一》&#xff0c;今天在这里只要把系统配置控制层及验证层开发完毕就可以咯。 一、路由配置 因它是固定数据&…

第七部分:1. STM32之ADC实验--单通道实验

主要利用一个模拟量的电位器来实时改变电压值&#xff0c;通过STM32自带的ADC通道来采集这个数据&#xff0c;并打印出来&#xff01; 一句话&#xff0c;学完STM32&#xff0c;我就往南走&#xff0c;我的工资只有5000.~~~~Whappy

Ubuntu20.04两种安装及配置中文界面、输入法、换源、共享文件夹实现,及注意事项

虚拟机安装法 1、新建虚拟机&#xff0c;自定义下一步 任意指定路径 提高处理器数量能加快系统响应 完成以后不要运行&#xff0c;添加镜像文件 导入镜像文件&#xff0c;点击浏览 选择后打开->确认->运行虚拟机 出现这种情况就需要检查虚拟机的配置&#xff0c;操作系统…

记录解决vscode 登录leetcode中遇到的问题

1. 安装完 leetcode 点击sign in to leetcode 点击打开网站登录leetcode&#xff0c;发现网页无法打开。 解决办法&#xff1a;将leetcode.cn.js文件中的leetcode-cn.com路径都改成leetcode.cn 2. 继续点击 sign in to leetcode &#xff0c;选择使用账号登录&#xff0c;始…

docker镜像仓库实战

docker镜像仓库实战 搭建一个nginx服务基础知识(Web服务器)查找nginx镜像拉取镜像启动nginx镜像 搭建一个nginx服务 基础知识(Web服务器) Web 服务器&#xff0c;一般是指“网站服务器”&#xff0c;是指驻留于互联网上某种类型计算机的程序。Web 服务器可以向 Web 浏览器等客…

zabbix安装配置与使用

zabbix Zabbix的工作原理如下: 监控部分: Zabbix Agent安装在各个需要监控的主机上,它以主配置的时间间隔(默认60s)收集主机各项指标数据,如CPU占用率、内存使用情况等。 通讯部分: Agent会把收集的数据通过安全通道(默认10051端口)发送到Zabbix Server。Server会存储这些数…

2024江苏省网络建设与运维省赛Linux(十) mariadb 服务

(十) mariadb 服务 【任务描述】 请安装 mariadb 服务,建立数据表。 (1)配置 linux3 为 mariadb 服务器,创建数据库用户 xiao,在任意机器上对所有数据 库有完全权限。创建数据库 userdb;在库中创建表 userinfo,表结构如下: 数据库信息表 (2)在表中插入 2 条记…

CSS的三个重点

目录 1.盒模型 (Box Model)2.位置 (position)3.布局 (Layout)4.低代码中的这些概念 在学习CSS时&#xff0c;有三个概念需要重点理解&#xff0c;分别是盒模型、定位、布局 1.盒模型 (Box Model) 定义&#xff1a; CSS 盒模型是指每个 HTML 元素在页面上被视为一个矩形盒子。…

STM32中ARR(自动重装寄存器)为什么要减1

在STM32定时器的配置中&#xff0c;ARR&#xff08;自动重装载寄存器&#xff09;需要减1的原因主要与定时器的计数方式和寄存器的设置方式有关。以下是对此问题的详细解释&#xff1a; 一、定时器的计数方式 STM32的定时器通常采用递增计数方式&#xff0c;即计数器&#xf…

关于LLC知识23(频率越大变压器体积越小?)

为什么频率越高&#xff0c;同样的磁芯就可以用的更小&#xff1f; 变压器他负责的功能是 1、隔离 2、能量传递 这里主要是与能量传递有关 我们首先要知道&#xff0c;次级的输出功率一定的情况下&#xff0c;那么在一定的时段内消耗的能量就是一定的&#xff0c;比如1000W…

UE5.4 PCG Layered Biomes插件

B站学习链接 官方文档 一、PCGSpawn Preset&#xff1a;负责管理PCG要用到的植被资产有哪些 二、BiomesSettings&#xff1a;设置要使用的植被资产Layer、Spawn参数 1.高度Layer参数&#xff1a; 2.地形Layer&#xff1a;我这里用地形样条线绘制了一块地形Layer 绘制点和…

数字后端零基础入门系列 | Innovus零基础LAB学习Day8

###LAB15 Detail Routing for Signal Integrity, Timing, Power and Design for Yield 这个章节虽然标题有点长&#xff0c;但不要被它吓到&#xff0c;其实这个章节就是Innovus工具的绕线Routing。只不过这个阶段做Route不是仅仅是把所有的逻辑连接&#xff0c;用实际的金属层…

量化交易 股市技术指标

股市数据分类 股票数据根据信息来源和分析方法的不同&#xff0c;可以分为技术面数据和基本面数据。 技术面数据和基本面数据都是股票分析中重要的工具&#xff0c;它们提供了不同的视角和方法来评估股票的投资价值。投资者可以综合运用这两类数据&#xff0c;从技术面和基本…

记录一个狗血的docker问题

如果你的docker pull或者docker search操作老报超时问题&#xff0c;按网上说的改daemon.json或改什么resove.conf&#xff0c;hosts&#xff0c;改了之后还是不行&#xff0c;不妨直接实施用阿里云的指定仓库拉取&#xff0c;拉取前需要先docker log in 阿里云的账户&#xff…

【从零开始的LeetCode-算法】3222. 求出硬币游戏的赢家

给你两个 正 整数 x 和 y &#xff0c;分别表示价值为 75 和 10 的硬币的数目。 Alice 和 Bob 正在玩一个游戏。每一轮中&#xff0c;Alice 先进行操作&#xff0c;Bob 后操作。每次操作中&#xff0c;玩家需要拿出价值 总和 为 115 的硬币。如果一名玩家无法执行此操作&#…

MR30分布式IO模块与高效PLC协同

在现代工业自动化领域中&#xff0c;数据采集与控制系统扮演着至关重要的角色。其中&#xff0c;可编程逻辑控制器&#xff08;PLC&#xff09;和分布式IO模块&#xff08;Distributed I/O Modules&#xff09;是这一领域的两大核心组件。本文将详细介绍MR30分布式IO模块与PLC如…

贝尔不等式的验证

在量子计算机上运行一个实验&#xff0c;以演示使用Estimator原型违反CHSH不等式。 import numpy as npfrom qiskit import QuantumCircuit from qiskit.circuit import Parameter from qiskit.quantum_info import SparsePauliOpfrom qiskit_ibm_runtime import QiskitRuntim…

CSRF与SSRF

csrf(跨站请求伪造)的原理: csrf全称是跨站请求伪造(cross-site request forgery)&#xff0c;也被称为one-click attack 或者 session riding scrf攻击利用网站对于用户网页浏览器的信任&#xff0c;劫持用户当前已登录的web应用程序&#xff0c;去执行分用户本意的操作。 利…

Pr 视频效果:ASC CDL

视频效果/颜色校正/ASC CDL Color Correction/ASC CDL ASC CDL ASC CDL效果通过对红、绿、蓝三个原色通道的独立调整&#xff0c;实现对图像色彩的精确控制。在此基础上&#xff0c;还可用于调整处理后图像的整体饱和度。 ◆ ◆ ◆ 效果选项说明 斜率 Slope、偏移 Offset和功…