写点什么

如何使用 Rust 来构建微服务?

  • 2020-02-16
  • 本文字数:1739 字

    阅读完需:约 6 分钟

如何使用Rust来构建微服务?

Rust是一门很棒的语言,也是我在 2019 年和 2020 年(截止当前)学的最多的语言。Rust 几乎可以和任何语言互操作,同时对于容器和在 Kubernetes 上运行也非常友好。


今天,我想展示下如何使用 Rust 构建一个简单的微服务。本文中,我们将使用ActixTokio-Postgress和其他一些库,使用 Postgres 作为唯一数据源,同时为了便于开发,我们会将其运行在 Docker 容器中。另外,我还会使用自己开发的Barrel作为数据库迁移工具。代码将全部使用异步和非阻塞 IO 实现。

总体架构


这里我们采用多层架构,业务规则和 REST 请求定义在 news-contract 中实现。SOA 约定定义在 news-contract + news-service,数据结构(News)定义在 news-contract。REST 请求的 endpoint 和服务定义在 news-service 中。Postgres 持久化相关功能定义在 news-dao 中。

代码结构


我们一个有 5 个工程,最顶层是一个全局工作空间,作为第一个工程。其余工程有:


  • news-contract:SOA 约定部分,这里定义了其他工程使用的 News 结构体。

  • news-dao:包含响应式持久化代码,基于 tokio-postgres 实现对 News 资源的增删改查操作。

  • news-migrations:我们使用 barrel 和自定义逻辑来创建表结构和初始化测试数据。

  • news-service:这里我们有 endpoint、服务实现和包含 actix-web 框架配置的入口代码。


每个工程都有自己的依赖,定义在其 Cargo.toml 文件中。


同时,工程中还有 2 个处理 Docker 容器的脚本,一个用于运行 Postgres,另一个用于运行 psql。

数据迁移

现在,让我们来看看如何实现数据迁移(在 Postgres SQL 中创建表和插入记录)。



首先,我们需要连接运行在 Docker 容器中的 Postgres 数据库,创建一个向量,向其中添加所有需要运行的数据迁移逻辑。然后循环执行其中的所有数据迁移逻辑,并检查结果是否正常。


现在,让我们看下一段代码,数据迁移逻辑。



我创建了一个名为 NewsMigration 的 trait,其中包含 new 函数(用于创建结构体)和 run 函数(用于运行数据迁移)。如你所见,然后创建了 CreateTableNewsMigration 结构体,使用 impl 关键字实现了这个 trait。这里我使用了 barrel 来创建表结构,barrel 将会生成 Postgres SQL 的 INSERT 语句。最后,我们使用 pg_client 在 Postres 中运行生成的脚本。这段代码看上去很绕:&news_table[…],这里我们在传递 String 类型 news_table 的引用,将其变成 slice 之后,传给 pg_client 的 execute 函数。

SOA 约定

首先让我们来看下约定的第一部分,News 结构体。



我们定义了一个名为 News 的结构体,同时使用了 serde 和 serde_json,以便于该结构体的序列化和反序列化。这个结构体还实现了 Display trait,用于打印结构体内容。最后在文件的末尾有一个单元测试,用于测试结构体的打印。

Endpoint 和服务


这里我定义了一个基于 actix 的 HttpServer,然后定义了一系列处理器:index、list_news、insert_news、get_news_by_id 和 delete_news_by_id。服务将会运行在本地的 8080 端口上。所有的信息都使用 log 和 env_logger creates 进行日志记录。


现在让我们来看下 endpoint.rs,这里有 REST 请求的定义。



这里我们使用宏来定义 REST 操作,例如 PUT、DELETE 和 GET。每个函数处理器都定义成公有且非常简单,仅仅调用对应的服务,将返回结果序列化成 json 结构返回。



这是服务的实现,这里没有任何 REST 或者 actix 框架的依赖。这里是实现校验、业务逻辑和代理请求 dao crate 的地方。所有函数的增删改查操作都是异步的。

DAO

这里是魔法发生的地方,我们使用了 tokio-postgress 库。先来看下代码。



这是 DAO 层的实现。这里有一个名为 connect()的函数用于连接 Postgres 数据库,它使用异步非阻塞的方式实现。然后展示的是如何实现 find_by_id 功能。在 Postgres 中 ID 使用 UUID 来生成,因此需要将其转成字符串类型,这就是为什么代码中会看见 id::text=$1。同样在这一行中,我将从入参获取到的 ID 转换成了 &[&id]传入。DAO 层还有很多函数,有兴趣的话可以在我的 GitHub 上查看完整代码


视频:代码走读和功能演示


https://vimeo.com/384505355


完整代码:


https://github.com/diegopacheco/rust-playground/tree/master/rust-microservice


原文链接:


http://diego-pacheco.blogspot.com/2020/01/building-microservice-with-rust.html


2020-02-16 16:359321

评论

发布
暂无评论
发现更多内容

带你读论文丨基于视觉匹配的自适应文本识别

华为云开发者联盟

损失函数 视觉 文本识别 文档识别 视觉匹配

密码学系列之:1Password的加密基础PBKDF2

程序那些事

算法 加密解密 密码学 程序那些事

一文带你了解经典的Java垃圾回收机制

华为云开发者联盟

Java JVM 对象 垃圾回收机制 垃圾收集器

低代码平台的功能及其用处

低代码小观

程序员 低代码 开发工具 低代码开发平台 无代码

百度信息流和搜索业务中的KV存储实践

百度Geek说

后端 搜索

软件对智能汽车的影响

SOA开发者

大厂面试喜欢考算法,该怎么破?

博文视点Broadview

两个剪辑透明化融合视频特效处理

老猿Python

Python 音视频 视频剪辑 视频特效 引航计划

Elasticsearch IK 分词扩展词典(qbit)

qbit

elastic 扩展词 分词

深入理解Netty-从偶现宕机看Netty流量控制

vivo互联网技术

Java、 框架 netty

卷王本卷

FunTester

内卷 FunTester

2021年9月数据库流行度排行解读:聊聊国产数据库可以从哪方面做到以用户为中心

墨天轮

数据库 TiDB oceanbase 国产数据库 达梦

做等保测评找哪家公司好?怎么选择?

行云管家

网络安全 等级保护 等保测评

2B 销售系统设计需要考虑的 3 个层面

boshi

团队管理 销售管理

天壤完成新一轮战略融资 加速构建数字化转型通用智能平台

InfoQ 天津

MPU:鸿蒙轻内核的任务栈的溢出检察官

华为云开发者联盟

鸿蒙 内核 任务栈 MPU 内存保护单元

HUAWEI雄起!顶级网络工程师总结出了这份网络协议开源笔记

Java 架构 面试 程序人生 编程语言

2021 DEMO CHINA创新中国总决赛峰会闭幕,光子晶体斩获2021 DEMO GOD

创业邦

什么是低代码自动化以及它如何使你受益?

低代码小观

程序员 自动化 工具 低代码 低代码开发平台

iPhone13全线机型上线WeTest云手机平台

WeTest

共生、互生、再生——英特尔与合作伙伴携手共建未来城市数字新基建

科技新消息

星环ArgoDB+英特尔第三代至强=分布式闪存数据库“蜕变”

星环科技

数据库

p3c 插件,是怎么检查出你那屎山的代码?

小傅哥

小傅哥 代码规范 p3m pmd 开发手册

华为云顾炯炯:云原生应用传送网络AND的实现架构与核心技术分享

华为云开发者联盟

网络 华为云 应用传送网络 ADN 东数西算

「可视化助力」,医疗进步无限可能

ThingJS数字孪生引擎

大前端 物联网 可视化

OceanBase 源码解读(五):租户的一生

OceanBase 数据库

数据开发 oceanbase OceanBase 开源 OceanBase 社区版 OceanBase 数据库大赛

maven如何忽略指定的远程仓库

小江

maven nexus 迁移 java;

恒源云(GpuShare)_新功能制霸,信息量有点大

恒源云

高并发场景下的会话服务数据读写设计思路(附具体实施方案)

融云 RongCloud

数据库 缓存 即时通讯 IM 低时延

最新!Apache APISIX 通过中国信通院 “可信开源项目” 认证

API7.ai 技术团队

Apache 开源社区 api 网关 APISIX 信通院

搞一下CP AUTOSAR 入门 | 01 CP AUTOSAR Overview

SOA开发者

如何使用Rust来构建微服务?_编程语言_Diego Pacheco_InfoQ精选文章