我正在try 使用GO、Protobuf和SQL Server作为我的数据库来创建一个API请求.我的HTTP服务器通过cURL请求启动,返回代码:5

我的main.go代码

package main

import (
    "context"
    "database/sql"
    "encoding/json"
    "fmt"
    "log"
    "net"
    "net/http"

    "github.com/grpc-ecosystem/grpc-gateway/v2/runtime"
    pb "github.com/myorg/nb_nb_nb/proto"
    "google.golang.org/grpc"
    "google.golang.org/grpc/credentials"
    _ "google.golang.org/grpc/grpclog/glogger"

    _ "github.com/denisenkom/go-mssqldb"
)

type appServer struct {
    pb.UnimplementedMyAppServiceServer
    db *sql.DB
}
//mssql
const (
    dbserver = "windows.net"
    port     = 1433
    user     = "reader"
    password = "mypassword"
    database = "dbnm"
)

const sqlQuery = `
my query
`

func (s *appServer) ExecuteQuery(ctx context.Context, req *pb.QueryRequest) (*pb.QueryResponseList, error) {
    log.Printf("received: Start Date - %v, End Date - %v", req.GetReportStartDate(), req.GetReportEndDate())

    rows, err := s.db.Query(sqlQuery, req.ReportStartDate, req.ReportEndDate)
    if err != nil {
        log.Printf("Error executing query: %v", err)
        return nil, fmt.Errorf("failed to execute query: %v", err)
    }
    defer rows.Close()

    var results []*pb.QueryResponse
    for rows.Next() {
        var result pb.QueryResponse
        err := rows.Scan(
            //fields
        )
        if err != nil {
            log.Printf("Error scanning rows: %v", err)
            return nil, fmt.Errorf("failed to scan rows: %v", err)
        }

        results = append(results, &result)
    }

    return &pb.QueryResponseList{Responses: results}, nil
}

func connectDB() (*sql.DB, error) {
    connectionString := fmt.Sprintf("server=%s;user id=%s;password=%s;port=%d;database=%s", dbserver, user, password, port, database)
    db, err := sql.Open("mssql", connectionString)
    if err != nil {
        return nil, fmt.Errorf("failed to connect to the database: %v", err)
    }

    if err := db.Ping(); err != nil {
        return nil, fmt.Errorf("database connection failed: %v", err)
    }

    fmt.Println("Database connection successful")
    return db, nil
}

func main() {
    defer func() {
        if r := recover(); r != nil {
            log.Println("Recovered from panic:", r)
        }
    }()

    db, err := connectDB()
    if err != nil {
        log.Fatalf("Failed to connect to the database: %v", err)
    }
    defer db.Close()

    log.Println("Starting gRPC server...")
    lis, err := net.Listen("tcp", ":7777")
    if err != nil {
        log.Fatalf("TCP connection failed: %v", err)
    } else {
        log.Printf("gRPC Server Listening at %v", lis.Addr())
    }

    size := 1024 * 1024 * 50
    s := grpc.NewServer(grpc.MaxRecvMsgSize(size), grpc.MaxSendMsgSize(size))
    pb.RegisterMyAppServiceServer(s, &appServer{db: db})

    mux := runtime.NewServeMux()
    opts := []grpc.DialOption{grpc.WithTransportCredentials(credentials.NewClientTLSFromCert(nil, ""))}
    err = pb.RegisterMyAppServiceHandlerFromEndpoint(context.Background(), mux, ":7777", opts)
    if err != nil {
        log.Fatalf("Failed to register gRPC gateway: %v", err)
    } else {
        log.Printf("Registered gRPC gateway")
    }

    http.HandleFunc("/api/query", func(w http.ResponseWriter, r *http.Request) {
        startDate := r.URL.Query().Get("startDate")
        endDate := r.URL.Query().Get("endDate")

        req := &pb.QueryRequest{
            ReportStartDate: startDate,
            ReportEndDate:   endDate,
        }
        fmt.Print(req)
        resp, err := (&appServer{db: db}).ExecuteQuery(r.Context(), req)
        if err != nil {
            log.Printf("Error executing query: %v", err)
            http.Error(w, "Internal Server Error", http.StatusInternalServerError)
            return
        }

        w.Header().Set("Content-Type", "application/json")
        json.NewEncoder(w).Encode(resp.Responses)
    })

    go func() {
        log.Println("Starting HTTP server...")
        err := http.ListenAndServe(":7778", mux)
        if err != nil {
            log.Fatalf("HTTP server failed: %v", err)
        } else {
            log.Printf("HTTP server started.")
        }
    }()

    if err := s.Serve(lis); err != nil {
        log.Fatalf("gRPC server failed: %v", err)
    } else {
        log.Printf("gRPC, HTTP, and API server started.")
    }
}

go run server/main.go份退货

Database connection successful
2023/12/24 21:48:23 Starting gRPC server...
2023/12/24 21:48:23 gRPC Server Listening at [::]:7777
2023/12/24 21:48:23 Registered gRPC gateway
2023/12/24 21:48:23 Starting HTTP server...

并且cURL请求(curl -X GET "http://localhost:7778/api/query?startDate=2023-10-01&endDate=2023-10-02")返回:

{"code":5, "message":"Not Found", "details":[]}

我的代码中缺少什么?为什么我不能得到任何结果?我的防火墙关闭了.

推荐答案

看起来路由"/api/query"已经在默认的ServeMux上定义了,但是在监听接口时使用了mux ServeMux.

Go相关问答推荐

有没有更简单的方法在Go中编写这个逻辑?

CGO Linux到Windows交叉编译中的未知类型名称

如何给杜松子wine 的路由加上一个名字,比如Laravel ?

如何在gofiber/websocket/v2中设置状态代码和原因

我可以在Golang中的另一个类型参数的基础上约束一个类型的参数吗?

Golang Gorm Fiber / argon2.Config 未定义

Golang Fiber Render - 将数据发送到多个布局

如何从Go项目连接Microsoft Access数据库?

Exchange Web 服务 - 使用 soap xml 请求查找所有未读邮件

如何使用 go-git 将特定分支推送到远程

使用 unsafe.Pointer 将 struct point直接转换为另一个 struct 是否安全?

在 .go 文件中运行一个函数和在 Go 模板中调用它有什么区别?

grpc-gateway:重定向与定义不匹配(原始文件)

Dockerfile 问题 - 为什么找不到二进制 dlv - 没有这样的文件或目录

来自洪流公告的奇怪同行字段

从 os.stdout 读取

如何 Select 前 N 个元素 Gin-Gorm

无限期运行 Go routine (完成后重新启动)

如何优雅地映射到 Go 中返回可变长度数组的方法?

正确编码 JWT