北京云栖大会Tech Insight Workshop:《使用微服务框架快速构建一个分布式交易系统》篇

本文涉及的产品
服务治理 MSE Sentinel/OpenSergo,Agent数量 不受限
注册配置 MSE Nacos/ZooKeeper,182元/月
任务调度 XXL-JOB 版免费试用,400 元额度,开发版规格
简介: 本篇是北京云栖大会Tech Insight Workshop金融云主体《使用SOFA来快速构建金融级分布式交易系统》中的一个组成部分,用来介绍如何通过SOFA Boot来快速构建一个分布式微服务系统,以及如果通过金融云下中间件微服务产品来进行查看与管理。

背景介绍

本篇是北京云栖大会Tech Insight Workshop金融云主体《使用SOFA来快速构建金融级分布式交易系统》中的一个组成部分,用来介绍如何通过SOFA Boot来快速构建一个分布式微服务系统,以及如何通过金融云下中间件微服务产品来进行查看与管理。

DEMO整体架构与说明

image
在本篇中,会逐步引导学员借助SOFA Boot来创建【支付】服务(Core工程)和【交易】平台(Web工程),并且【支付】对外提供RPC服务,供【交易】平台进行调用,以及如何借助金融云进行应用的发布部署。

实验涉及SOFA产品

详细教程

创建支付服务和交易平台Web工程

看到下图则表示构建成功:
image

  • 通过IntelliJ IDEA导入已创建的工程
    image

注意:在导入向导中选择JDK1.8作为运行时环境。此外一直点击Next即可

  • 工程使用facade范式,在com.alipay.sofa.pay.facade下创建model,并创建PayOrder.java,并复制DEMO源码中对应路径下的文件内容
    core_create_facade_mo_del
  • 创建PayService接口
    core_create_facade_payservice_interface
  • 在com.alipay.sofa.pay.service下创建接口的实现类,目前尚未引入持久化层,所以这里接口的实现先返回mock数据core_create_service_impl
  • 截至目前,支付服务的程序实现部分已经初步完成,需要将刚设计的接口通过bean方式进行对外暴露,修改pay-demo-service的pay-emo-service.xml
    core_create_service_publish_bean
  • 由于该服务会通过金融云进行发布,所以需要增加如下配置core_create_service_app_properties

注意:
run.mode=NORMAL表示需要在金融云上发布/访问RPC调用
com.alipay.env=shared表示使用共享型中间件
com.alipay.instanceid在【金融云首页】-【产品与服务】-【中间件】-【中间件控制台】中的“实例标识”获得。

  • 删除test目录,该目录对本DEMO无用,并有可能会导致运行失败(core范例工程版本更新维护等原因)
    core_delete_test
  • 在保证本机maven环境设置好的前提下,开始编译支付服务
    core_compile_need_setmvnreadyfirst

构建成功,生成 【fat jar】
core_compile_done

  • 开始构建【交易】平台Web服务,参见SOFA Boot创建Web工程
    web_create_1
  • 通过IntelliJ IDEA导入已创建的【交易】平台工程
    web_import_1
  • 引用刚刚创建的【支付】服务RPC,帮助信息可以参照该文档

web_refer_bean

  • 删除工程中自动生成的index.html
    web_delete_indexhtml
  • 将DEMO范例中的静态文件和模板通过IDE移动进当前工程
    web_move_static_subfolder

web_move_template

  • 删除工程中自动生成的主类,并通过IDE移动DEMO范例代码中对应的主类至对应目录
    web_delete_applicationmain

web_copy_applicationmain

  • 通过IDE将DEMO范例代码中对应的com.alipay.demo下所有文件移动至项目对应路径
    web_copy_application_subfolders
  • 保证下列依赖包在工程中被正确引入
    image
  • 设置金融云上环境(参数含义参照支付服务创建过程)
    web_app_properties
  • 请确认当前工程下test目录已被删除
  • 编译并生成【fat jar】

注意:由于之前修改了主类,所以在编译后的运行时可能会由于IDE原因出现主类无法找到的情况,这时需要重启IDE并重新进行编译,一般即可解决问题

web_compile_done

  • 接下来就是需要在金融云上构建应用,并上传已编译好的jar包

金融云上发布已创建的SOFA Boot应用

  • 登录金融云,选择合适的环境
    core_upload_login_antcloud_workspace
  • 新增支付服务的应用:进入【产品与服务】-【应用管理】,【新建应用】并输入对应的应用信息
    webcore_antcloud_create_app_1

webcore_antcloud_create_app_2

  • 点击【确定】完成新应用的添加
    webcore_antcloud_create_app_done
  • 同样的方式添加支付平台的新应用,【应用名称】设置为“DEMO-web-console”,其他设置与支付服务应用相同(技术栈:sofa-lite2 1.0.1)。
  • 在【产品与服务】-【环境资源管理】中添加2台ECS,分别分配给【DEMO-pay-core】和【DEMO-web-service】
    webcore_antcloud_createecs_bindingapp1

webcore_antcloud_createecs_bindingapp2

webcore_antcloud_createecs

分配给【DEMO-web-service】

  • 在将应用与计算资源分配完毕后,进入【产品与服务】-【发布部署服务】-【发布包管理】,为对应【DEMO-pay-core】和【DEMO-web-service】两个应用添加发布包
    webcore_antcloud_deploymanage_core
  • 上传支付服务fat jar
    webcore_antcloud_deploymanage_core_upload
  • 上传交易平台web的 fat jar
    webcore_antcloud_deploymanage_web_upload
  • 在【产品与服务】-【环境资源管理】中创建负载均衡,并将创建好的负载均衡挂载交易平台web服务的ECS
    image

image

  • 至此,访问该台负载均衡的公网地址,以及开放端口,则可以看到发布的服务,表示【DEMO-pay-core】和【DEMO-web-service】均发布成功,且RPC调用正常
    image

通过中间件微服务产品对已发布的分布式服务进行管理

  • 点击【产品与服务】-【中间件】-【微服务】进入控制台
    image
  • 定位已发布的RPC服务
    image
  • 查看分布式服务之间的调用关系
    image
目录
相关文章
|
1月前
|
存储 Kubernetes 微服务
Dapr:用于构建分布式应用程序的便携式事件驱动运行时
Dapr 是一个可移植、事件驱动的运行时,简化了分布式应用程序的开发。它支持多语言、多框架,适用于云和边缘计算环境,提供服务调用、状态管理、消息发布/订阅等构建模块。通过 sidecar 模式,Dapr 帮助开发者轻松应对微服务架构的复杂性,实现弹性、可扩展的应用部署。
131 8
Dapr:用于构建分布式应用程序的便携式事件驱动运行时
|
2月前
|
监控 Java API
Spring Boot 3.2 结合 Spring Cloud 微服务架构实操指南 现代分布式应用系统构建实战教程
Spring Boot 3.2 + Spring Cloud 2023.0 微服务架构实践摘要 本文基于Spring Boot 3.2.5和Spring Cloud 2023.0.1最新稳定版本,演示现代微服务架构的构建过程。主要内容包括: 技术栈选择:采用Spring Cloud Netflix Eureka 4.1.0作为服务注册中心,Resilience4j 2.1.0替代Hystrix实现熔断机制,配合OpenFeign和Gateway等组件。 核心实操步骤: 搭建Eureka注册中心服务 构建商品
398 3
|
25天前
|
消息中间件 缓存 监控
中间件架构设计与实践:构建高性能分布式系统的核心基石
摘要 本文系统探讨了中间件技术及其在分布式系统中的核心价值。作者首先定义了中间件作为连接系统组件的"神经网络",强调其在数据传输、系统稳定性和扩展性中的关键作用。随后详细分类了中间件体系,包括通信中间件(如RabbitMQ/Kafka)、数据中间件(如Redis/MyCAT)等类型。文章重点剖析了消息中间件的实现机制,通过Spring Boot代码示例展示了消息生产者的完整实现,涵盖消息ID生成、持久化、批量发送及重试机制等关键技术点。最后,作者指出中间件架构设计对系统性能的决定性影响,
|
2月前
|
数据采集 存储 NoSQL
Scrapy 框架实战:构建高效的快看漫画分布式爬虫
Scrapy 框架实战:构建高效的快看漫画分布式爬虫
|
6月前
|
机器学习/深度学习 数据可视化 算法
Ray Flow Insight:让分布式系统调试不再"黑盒"
作为Ray社区的积极贡献者,我们希望将这些实践中沉淀的技术能力回馈给社区,推动Ray生态在实际场景中的应用深度和广度。因此,2024年底我们做了激活AntRay开源社区的决策,AntRay会始终保持与官方Ray版本强同步(即AntRay会紧随Ray官方社区版本而发布),内部Feature亦会加速推向AntRay以开源研发模式及时反哺内部业务,同时会将社区关注的Feature提交至Ray官方社区,实现内外部引擎双向价值流动。后续我们会以系列文章形式同步蚂蚁推向开源的新特性,本文将重点介绍:Ray Flow Insight —— 让分布式系统调试不再"黑盒"。
|
7月前
|
消息中间件 分布式计算 并行计算
Python 高级编程与实战:构建分布式系统
本文深入探讨了 Python 中的分布式系统,介绍了 ZeroMQ、Celery 和 Dask 等工具的使用方法,并通过实战项目帮助读者掌握这些技术。ZeroMQ 是高性能异步消息库,支持多种通信模式;Celery 是分布式任务队列,支持异步任务执行;Dask 是并行计算库,适用于大规模数据处理。文章结合具体代码示例,帮助读者理解如何使用这些工具构建分布式系统。
|
11月前
|
存储 运维 负载均衡
构建高可用性GraphRAG系统:分布式部署与容错机制
【10月更文挑战第28天】作为一名数据科学家和系统架构师,我在构建和维护大规模分布式系统方面有着丰富的经验。最近,我负责了一个基于GraphRAG(Graph Retrieval-Augmented Generation)模型的项目,该模型用于构建一个高可用性的问答系统。在这个过程中,我深刻体会到分布式部署和容错机制的重要性。本文将详细介绍如何在生产环境中构建一个高可用性的GraphRAG系统,包括分布式部署方案、负载均衡、故障检测与恢复机制等方面的内容。
553 4
构建高可用性GraphRAG系统:分布式部署与容错机制
|
12月前
|
运维 供应链 安全
SD-WAN分布式组网:构建高效、灵活的企业网络架构
本文介绍了SD-WAN(软件定义广域网)在企业分布式组网中的应用,强调其智能化流量管理、简化的网络部署、弹性扩展能力和增强的安全性等核心优势,以及在跨国企业、多云环境、零售连锁和制造业中的典型应用场景。通过合理设计网络架构、选择合适的网络连接类型、优化应用流量优先级和定期评估网络性能等最佳实践,SD-WAN助力企业实现高效、稳定的业务连接,加速数字化转型。
SD-WAN分布式组网:构建高效、灵活的企业网络架构
|
人工智能 Linux 云栖大会
看过来!2024 云栖大会操作系统技术 Workshop 怎么玩?
报名倒计时2天啦,欢迎大家来“操作系统技术Workshop”打卡。专家讲解原理、现场实战演练,AI、C++ 20专场任选。
看过来!2024 云栖大会操作系统技术 Workshop 怎么玩?

热门文章

最新文章