如何高效分离Thrift客户端的连接、协议和调用？

package util

import (
    "fmt"
    "net"
    "os"

    "github.com/apache/thrift/lib/go/thrift"
    "your_project/fundinfo" // 替换为你的 fundinfo 包路径
)

func FundInfoServiceClient(ip, port string) (*fundinfo.FundInfoServiceClient, thrift.TTransport, error) {
    transportFactory := thrift.NewTFramedTransportFactory(thrift.NewTTransportFactory())
    protocolFactory := thrift.NewTBinaryProtocolFactoryDefault()

    transportSocket, err := thrift.NewTSocket(net.JoinHostPort(ip, port))
    if err != nil {
        return nil, nil, fmt.Errorf("创建socket失败: %w", err)
    }
    transport, err := transportFactory.GetTransport(transportSocket)
    if err != nil {
        return nil, nil, fmt.Errorf("创建transport失败: %w", err)
    }

    client := fundinfo.NewFundInfoServiceClientFactory(transport, protocolFactory)

    if err := transport.Open(); err != nil {
        return nil, nil, fmt.Errorf("连接服务器失败: %w", err)
    }

    return client, transport, nil
}

package main

import (
    "context"
    "fmt"
    "your_project/util" // 替换为你的 util 包路径
    "your_project/fundinfo" // 替换为你的 fundinfo 包路径
)

func main() {
    ctx := context.Background()
    ip := "your_server_ip" // 替换为你的服务器IP
    port := "your_server_port" // 替换为你的服务器端口
    fundcode := "your_fund_code" // 替换为你的基金代码

    client, transport, err := util.FundInfoServiceClient(ip, port)
    if err != nil {
        fmt.Printf("创建客户端失败: %v\n", err)
        return
    }
    defer transport.Close()

    res, err := client.GetFundInfo(ctx, fundcode)
    if err != nil {
        fmt.Printf("调用GetFundInfo失败: %v\n", err)
        return
    }

    fmt.Printf("基金信息: %+v\n", res)
}