Go支付中台方案：多平台兼容与多项目对接
欢迎点击下方👇关注我，记得星标哟~
文末会有重磅福利赠送
王中阳
专注程序员的就业辅导、简历优化、学习路线规划。私信我666，免费发你价值999元的学习资料。
公众号
一、中台的概念
中台是一种企业级的架构模式，它处于前台应用和后台资源之间，将企业核心能力进行整合、封装，形成一系列可复用的业务能力组件。这些组件就像乐高积木一样，可以被不同的前台业务快速调用，从而避免重复开发，提高业务创新和响应速度。中台的核心思想是数据共享、能力复用，通过将通用的业务逻辑和数据处理抽取出来，为企业的数字化转型提供坚实的架构基础。
二、使用支付中台的意义和价值
（一）提高支付系统的复用性
在企业的业务场景中，往往存在多个需要支付功能的项目，如各种类型的电商应用、游戏项目、企业内部的管理系统等。如果没有支付中台，每个项目都需要独立开发支付模块，这不仅会导致大量的重复工作，而且不同项目中的支付模块可能存在差异，增加了维护成本和难度。而支付中台将支付相关的核心功能进行统一封装，各个项目可以直接复用这些功能，大大提高了开发效率，减少了代码冗余。
（二）提升支付业务的敏捷性和创新能力
市场环境变化迅速，支付方式和业务需求也在不断更新。使用支付中台，企业可以在中台层面快速响应这些变化，对支付功能进行升级和优化，而无需在每个使用支付功能的项目中逐一修改。例如，当新的支付平台出现或者支付安全标准提高时，只需在支付中台进行调整，所有依赖中台的项目都能受益。这种敏捷性使得企业能够更快地推出新的支付业务模式，满足用户多样化的需求，增强市场竞争力。
（三）保障支付数据的一致性和安全性
支付数据的处理和存储是支付系统的关键环节。不同项目独立处理支付数据可能会导致数据不一致的问题，例如订单状态在不同系统中的不同步。支付中台通过统一的数据管理和处理机制，确保支付数据在各个项目中的一致性。同时，中台可以集中实施安全策略，如对支付请求的加密、对支付平台 API 密钥的安全存储和管理等，有效降低支付安全风险，保护用户和企业的利益。
（四）降低系统的复杂性和耦合度
在没有中台的情况下，各个项目与不同支付平台的对接会使整个系统变得非常复杂，项目之间以及项目与支付平台之间的耦合度很高。支付中台作为一个中间层，将项目与支付平台解耦，对外提供统一的支付接口给各个项目，对内负责与不同支付平台的对接和交互。这样，每个项目只需要关注自身的业务逻辑和与支付中台的交互，无需了解支付平台的具体细节，降低了系统的复杂性，提高了系统的可维护性。
三、支付中台的设计目标
（一）多支付平台支持
全面支持微信支付、支付宝支付等主流支付方式。这要求系统能够精确处理不同支付平台的支付请求，包括但不限于参数解析、签名验证、发起支付以及处理支付回调等操作，从而确保支付流程的顺畅性和安全性，为用户提供可靠的支付体验。
（二）多项目对接能力
- 针对其他 Go 应用项目，提供简洁、规范且易于集成的接口。这些接口应充分遵循 Go 语言的编程风格和设计模式，确保代码的可读性、可维护性以及可扩展性，方便 Go 应用快速接入支付功能。
- 对于游戏项目，考虑到游戏内支付具有小额高频、与虚拟货币系统交互等特殊需求，支付中台需具备高度的灵活性，能够在不影响游戏流畅性和用户体验的前提下，高效处理支付事务。
- 在与 Java 管理系统对接时，通过合适的通信协议（如 RESTful API）实现数据的准确交互。确保 Java 系统能够方便地发起支付请求，并及时获取支付结果，实现跨语言项目的协同工作。
（三）高性能与高可靠性
支付中台需要在高并发的支付请求环境下保持高性能运行，确保快速响应。同时，必须保证支付过程的可靠性，避免出现支付失败、数据丢失或不一致等问题，切实保障用户和商家的利益。
四、设计模式的选择
（一）工厂模式
在处理不同支付平台的支付请求时，工厂模式发挥着关键作用。以下是一个简单的工厂模式示例代码：
// PaymentProcessor 是支付处理器接口
type PaymentProcessor interface {
ProcessPayment(paymentRequest PaymentRequest) error
}
// PaymentRequest 包含支付请求的信息
type PaymentRequest struct {
Amount float64
Platform string
// 其他支付相关信息
}
// WeChatPaymentProcessor 微信支付处理器结构体
type WeChatPaymentProcessor struct{}
// ProcessPayment 实现微信支付处理逻辑
func (wp *WeChatPaymentProcessor) ProcessPayment(paymentRequest PaymentRequest) error {
// 微信支付处理逻辑，如调用微信支付 API 等
return nil
}
// AlipayPaymentProcessor 支付宝支付处理器结构体
type AlipayPaymentProcessor struct{}
// ProcessPayment 实现支付宝支付处理逻辑
func (ap *AlipayPaymentProcessor) ProcessPayment(paymentRequest PaymentRequest) error {
// 支付宝支付处理逻辑，如调用支付宝支付 API 等
return nil
}
// PaymentProcessorFactory 支付处理器工厂结构体
type PaymentProcessorFactory struct{}
// CreatePaymentProcessor 根据支付平台类型创建相应的支付处理器
func (f *PaymentProcessorFactory) CreatePaymentProcessor(platform string) PaymentProcessor {
switch platform {
case "wechat":
return &WeChatPaymentProcessor{}
case "alipay":
return &AlipayPaymentProcessor{}
default:
return nil
}
}
通过这种方式，根据支付平台类型（如 “wechat” 或 “alipay”）创建相应的支付处理器对象，将不同支付平台的处理逻辑解耦，便于后续的扩展和维护。当需要添加新的支付平台时，只需在工厂类的CreatePaymentProcessor方法中添加相应的创建逻辑即可。
（二）策略模式
对于不同的支付策略（如扫码支付、APP 内支付等），策略模式是一种理想的选择。
以下是一个简单的策略模式示例：
// PaymentStrategy 支付策略接口
type PaymentStrategy interface {
Pay(paymentInfo PaymentInfo) error
}
// ScanCodePayment 扫码支付策略结构体
type ScanCodePayment struct{}
// Pay 实现扫码支付逻辑
func (s *ScanCodePayment) Pay(paymentInfo PaymentInfo) error {
// 扫码支付处理逻辑
return nil
}
// InAppPayment APP 内支付策略结构体
type InAppPayment struct{}
// Pay 实现 APP 内支付逻辑
func (i *InAppPayment) Pay(paymentInfo PaymentInfo) error {
// APP 内支付处理逻辑
return nil
}
// PaymentContext 支付上下文结构体，用于执行支付策略
type PaymentContext struct {
strategy PaymentStrategy
}
// SetStrategy 设置支付策略
func (pc *PaymentContext) SetStrategy(strategy PaymentStrategy) {
pc.strategy = strategy
}
// ExecutePayment 执行支付操作
func (pc *PaymentContext) ExecutePayment(paymentInfo PaymentInfo) error {
return pc.strategy.Pay(paymentInfo)
}
每个支付策略都实现PaymentStrategy接口，在运行时根据用户选择或业务逻辑选择合适的支付策略。这种设计模式使得支付中台能够灵活应对各种支付场景，并且方便对每个支付策略进行单独的测试和优化。
（三）外观模式
在对接不同类型的项目（Go 应用、游戏项目、Java 管理系统等）时，外观模式可创建一个统一的接口层。以下是一个简单的外观模式示例：
// PaymentFacade 支付外观结构体
type PaymentFacade struct {
paymentProcessorFactory *PaymentProcessorFactory
}
// NewPaymentFacade 创建支付外观实例
func NewPaymentFacade() *PaymentFacade {
return &PaymentFacade{
paymentProcessorFactory: &PaymentProcessorFactory{},
}
}
// ProcessPayment 通过外观模式处理支付请求
func (pf *PaymentFacade) ProcessPayment(paymentRequest PaymentRequest) error {
processor := pf.paymentProcessorFactory.CreatePaymentProcessor(paymentRequest.Platform)
if processor == nil {
return fmt.Errorf("unsupported payment platform")
}
return processor.ProcessPayment(paymentRequest)
}
这个接口层隐藏了支付中台内部复杂的实现细节，对外提供简单、一致的接口。不同类型的项目只需与这个外观接口进行交互，大大降低了项目集成支付功能的难度。
五、开发框架的选择
（一）Go 的 Web 框架：Gin （最主流的框架）
Gin 是一款轻量级且高性能的 Go Web 框架，非常适合构建支付中台的 API 服务。其核心优势在于快速的路由功能和强大的中间件支持。
以下是使用 Gin 构建支付中台 API 的基本示例代码：
package main
import (
"net/http"
"github.com/gin-gonic/gin"
)
func main() {
router := gin.Default()
// 定义支付请求处理路由
router.POST("/payment", func(c *gin.Context) {
var paymentRequest PaymentRequest
if err := c.ShouldBindJSON(&paymentRequest); err!= nil {
c.JSON(http.StatusBadRequest, gin.H{"error": err.Error()})
return
}
// 使用支付外观处理支付请求
paymentFacade := NewPaymentFacade()
if err := paymentFacade.ProcessPayment(paymentRequest); err!= nil {
c.JSON(http.StatusInternalServerError, gin.H{"error": err.Error()})
return
}
c.JSON(http.StatusOK, gin.H{"message": "Payment processed successfully"})
}
router.Run(":8080")
}
咱们仍然使用目前闪送项目的running-server-pro的框架做开发，区别是新启动一个支付中台的项目。
在支付中台开发中，利用 Gin 来处理来自不同项目的支付请求。它可以接收 HTTP 请求、解析请求参数，然后调用相应的支付处理逻辑，并返回结果。通过中间件，可以轻松实现一些通用的功能，如身份验证、请求日志记录、错误处理等。
（二）数据库框架：GORM
支付中台需要妥善存储支付相关的数据，如订单信息、支付记录等。GORM 作为一个功能强大的 Go 语言 ORM 框架，支持多种数据库（如 MySQL、PostgreSQL 等），为数据库操作提供了极大的便利。
以下是使用 GORM 创建订单模型和进行基本数据库操作的示例代码：
package main
import (
"gorm.io/driver/mysql"
"gorm.io/gorm"
)
// Order 订单结构体
type Order struct {
gorm.Model
OrderNumber string `gorm:"unique"`
Amount float64
Status string
// 其他订单相关字段
}
func main() {
// 连接数据库
db, err := gorm.Open(mysql.Open("user:password@tcp(127.0.0.1:3306)/payment_db?charset=utf8mb4&parseTime=True&loc=Local"), &gorm.Config{})
if err!= nil {
panic("failed to connect database")
}
// 自动迁移订单表
db.AutoMigrate(&Order{})
// 创建新订单示例
newOrder := Order{
OrderNumber: "20241117001",
Amount: 100.0,
Status: "pending",
}
db.Create(&newOrder)
// 查询订单示例
var order Order
db.Where("order_number =?", "20241117001").First(&order)
}
使用 GORM 可以方便地进行数据库操作，如创建表、插入数据、查询数据等。同时，GORM 还提供了模型关联、事务处理等高级功能，有助于保证支付数据的完整性和一致性。
六、支付中台的核心功能模块
（一）支付请求处理模块
- 接收来自不同项目的支付请求，通过 Gin 框架解析请求中的支付信息，包括支付金额、支付平台、支付方式、订单编号等。
- 根据支付平台类型，利用工厂模式创建相应的支付处理器，然后调用支付处理器的支付方法，发起支付请求。在这个过程中，要处理可能出现的各种错误，如网络问题、支付平台接口返回错误等，并将错误信息以合适的格式反馈给发起支付请求的项目。
- 以下是支付请求处理模块的简化代码示例：
func handlePaymentRequest(c *gin.Context) {
var paymentRequest PaymentRequest
if err := c.ShouldBindJSON(&paymentRequest); err!= nil {
c.JSON(http.StatusBadRequest, gin.H{"error": err.Error()})
return
}
paymentFacade := NewPaymentFacade()
if err := paymentFacade.ProcessPayment(paymentRequest); err!= nil {
c.JSON(http.StatusInternalServerError, gin.H{"error": err.Error()})
return
}
c.JSON(http.StatusOK, gin.H{"message": "Payment processed successfully"})
}
（二）支付结果回调处理模块
- 接收支付平台的支付结果回调，首先验证回调的合法性，如进行签名验证等操作。
- 根据回调结果更新支付状态，例如将订单状态从 “支付中” 更新为 “已支付” 或 “支付失败”。同时，通过合适的方式（如消息队列、HTTP 通知等）通知相关项目支付结果，以便它们进行后续的业务处理，如发货、更新用户账户余额等。
- 以下是支付结果回调处理模块的部分代码示例：
func handlePaymentCallback(c *gin.Context) {
var callbackData PaymentCallbackData
if err := c.ShouldBindJSON(&callbackData); err!= nil {
c.JSON(http.StatusBadRequest, gin.H{"error": err.Error()})
return
}
if!verifyCallbackSignature(callbackData) {
c.JSON(http.StatusForbidden, gin.H{"error": "Invalid callback signature"})
return
}
// 根据回调数据更新订单状态
updateOrderStatus(callbackData)
// 通知相关项目支付结果
notifyRelatedProjects(callbackData)
c.JSON(http.StatusOK, gin.H{"message": "Callback processed successfully"})
}
（三）订单管理模块
- 负责订单的创建、查询、更新和删除等操作。当接收到支付请求时，创建相应的订单记录，并将订单信息存储到数据库中。可以使用 GORM 框架来实现订单数据的持久化操作。
- 提供订单查询接口，方便其他项目查询订单状态。同时，在支付结果回调处理时，根据支付结果更新订单状态。以下是订单创建和查询的示例代码：
func createOrder(paymentRequest PaymentRequest) (*Order, error) {
newOrder := Order{
OrderNumber: generateOrderNumber(),
Amount: paymentRequest.Amount,
Status: "pending",
}
db.Create(&newOrder)
return &newOrder, nil
}
func getOrderByNumber(orderNumber string) (*Order, error) {
var order Order
db.Where("order_number =?", orderNumber).First(&order)
return &order, nil
}
（四）配置管理模块
- 存储支付中台的配置信息，如各个支付平台的 API 密钥、回调地址、支付参数等。可以将配置信息存储在配置文件（如 JSON 格式或 YAML 格式）中，或者使用环境变量来存储敏感信息。
- 提供配置的读取和更新功能，以便在需要时修改支付平台相关的配置，同时保证配置信息的安全性。对于敏感信息，如 API 密钥，要进行加密存储和安全传输。以下是读取配置文件的示例代码（假设使用 JSON 格式配置文件）：
type PaymentConfig struct {
WeChatConfig WeChatConfig `json:"wechat"`
AlipayConfig AlipayConfig `json:"alipay"`
// 其他配置项
}
type WeChatConfig struct {
AppID string `json:"app_id"`
APIKey string `json:"api_key"`
Callback string `json:"callback"`
// 其他微信支付相关配置
}
type AlipayConfig struct {
AppID string `json:"app_id"`
APIKey string `json:"api_key"`
Callback string `json:"callback"`
// 其他支付宝支付相关配置
}
func readConfig() (*PaymentConfig, error) {
data, err := ioutil.ReadFile("payment_config.json")
if err!= nil {
return nil, err
}
var config PaymentConfig
if err := json.Unmarshal(data, &config); err!= nil {
return nil, err
}
return &config, nil
}
七、与不同项目的对接实现
（一）与 Go 应用项目对接
在 Go 应用项目中，通过引入支付中台的 Go 包，使用 Go 语言的依赖管理工具（如 Go Modules）来管理依赖。以下是对接示例：
package main
import (
"fmt"
"your_payment_middleware_package"
)
func main() {
paymentRequest := your_payment_middleware_package.PaymentRequest{
Amount: 50.0,
Platform: "wechat",
// 其他支付信息，如订单号等
OrderID: "202411170001",
}
paymentFacade := your_payment_middleware_package.NewPaymentFacade()
err := paymentFacade.ProcessPayment(paymentRequest)
if err!= nil {
fmt.Printf("支付失败: %v\n", err)
return
}
fmt.Println("支付成功")
}
（二）与游戏项目对接
- 游戏内支付流程 对于游戏内支付，游戏服务器充当与支付中台交互的桥梁。游戏客户端发起支付请求后，游戏服务器收集支付相关信息，如玩家 ID、支付金额、购买的虚拟物品信息等，并构建支付请求发送给支付中台。
- 代码示例 以下是游戏服务器处理支付请求的简化代码：
package main
import (
"your_payment_middleware_package"
"log"
)
func handleGamePayment(playerID string, itemID string, amount float64) {
paymentRequest := your_payment_middleware_package.PaymentRequest{
Amount: amount,
Platform: "wechat", // 假设游戏主要使用微信支付，可根据玩家选择调整
OrderID: generateOrderID(playerID, itemID), // 根据玩家和物品生成唯一订单号
// 其他游戏相关支付信息，如游戏内订单描述等
Description: fmt.Sprintf("购买游戏物品 %s", itemID),
}
paymentFacade := your_payment_middleware_package.NewPaymentFacade()
err := paymentFacade.ProcessPayment(paymentRequest)
if err!= nil {
log.Printf("玩家 %s 支付失败: %v", playerID, err)
// 通知游戏客户端支付失败，可回滚游戏内相关操作，如不扣除虚拟货币
notifyGameClient(playerID, false)
return
}
// 支付成功，更新游戏内玩家数据，如增加虚拟物品、扣除虚拟货币
updatePlayerData(playerID, itemID)
notifyGameClient(playerID, true)
}
（三）与 Java 管理系统对接
- 通过 RESTful API 实现对接 支付中台提供一组 RESTful 接口，Java 管理系统通过 HTTP 请求调用这些接口来发起支付请求和获取支付结果。在 Java 端，可以使用 Java 的 HTTP 客户端库（如 Apache HttpClient 或 OkHttp 等）来发送请求，并处理支付中台返回的 JSON 格式的结果数据。
- 代码示例（使用 Apache HttpClient）
import org.apache.http.HttpEntity;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.util.EntityUtils;
import com.google.gson.Gson;
public class PaymentClient {
public static void main(String[] args) {
try {
CloseableHttpClient httpClient = HttpClients.createDefault();
HttpPost httpPost = new HttpPost("http://your_payment_middleware_server/payment");
PaymentRequest paymentRequest = new PaymentRequest();
paymentRequest.setAmount(100.0);
paymentRequest.setPlatform("alipay");
paymentRequest.setOrderID("202411170002");
Gson gson = new Gson();
String json = gson.toJson(paymentRequest);
StringEntity entity = new StringEntity(json);
httpPost.setEntity(entity);
httpPost.setHeader("Content-Type", "application/json");
CloseableHttpResponse response = httpClient.execute(httpPost);
HttpEntity responseEntity = response.getEntity();
if (response.getStatusLine().getStatusCode() == 200) {
String result = EntityUtils.toString(responseEntity);
PaymentResponse paymentResponse = gson.fromJson(result, PaymentResponse.class);
if (paymentResponse.isSuccess()) {
System.out.println("支付成功");
} else {
System.out.println("支付失败: " + paymentResponse.getErrorMessage());
}
} else {
System.out.println("请求支付中台失败");
}
} catch (Exception e) {
e.printStackTrace();
}
}
}
class PaymentRequest {
private double amount;
private String platform;
private String orderID;
// 生成对应的getter和setter方法
public double getAmount() {
return amount;
}
public void setAmount(double amount) {
this.amount = amount;
}
public String getPlatform() {
return platform;
}
public void setPlatform(String platform) {
this.platform = platform;
}
public String getOrderID() {
return orderID;
}
public void setOrderID(String orderID) {
this.orderID = orderID;
}
}
class PaymentResponse {
private boolean success;