GoREST服务中URL查询参数的正确处理方法

method:"GET" path:"/WEB/service.wfs?{param:string}" output:"string"

method:"GET" path:"/WEB/service.wfs" output:"string"

package main

import (
    "github.com/emicklei/go-restful" // 假设使用go-restful作为GoREST的基础库
    "net/http"
    "net/url"
)

// MyService 定义一个GoREST服务
type MyService struct {
    restful.Service
}

// Register 注册服务路由
func (s MyService) Register(container *restful.Container) {
    ws := new(restful.WebService)
    ws.Path("/WEB")
    ws.Consumes(restful.MIME_JSON).Produces(restful.MIME_JSON)

    ws.Route(ws.GET("/service.wfs").To(s.HandleWFSRequest).
        Doc("处理WFS服务请求").
        Param(ws.QueryParameter("param1", "第一个参数").DataType("string")). // 示例：可以在这里描述查询参数，但GoREST不会自动解析到方法参数
        Writes("string"))

    container.Add(ws)
}

// HandleWFSRequest 处理WFS服务的请求
func (s MyService) HandleWFSRequest(request *restful.Request, response *restful.Response) {
    // 获取原始的http.Request对象
    r := request.Request

    // 解析URL以获取查询参数
    u, err := url.Parse(r.URL.String())
    if err != nil {
        response.WriteErrorString(http.StatusInternalServerError, "URL解析失败: "+err.Error())
        return
    }

    // 获取查询参数映射
    q := u.Query()

    // 从查询参数中获取特定参数的值
    // q是一个map[string][]string，因为同一个参数名可能出现多次
    param1Values, ok := q["param1"]
    var param1 string
    if ok && len(param1Values) > 0 {
        param1 = param1Values[0] // 通常我们只取第一个值
    } else {
        param1 = "未提供param1"
    }

    // 也可以直接使用Get方法获取第一个值
    param2 := q.Get("param2") // 如果param2不存在，Get方法返回空字符串

    result := "成功处理请求！"
    result += "\nParam1: " + param1
    result += "\nParam2: " + param2

    response.WriteEntity(result)
}

package main

import (
    "fmt"
    "log"
    "net/http"
    "net/url"

    "github.com/emickael/go-restful" // 确保导入正确的GoREST库
)

// MyService 定义一个GoREST服务
type MyService struct {
    restful.Service
}

// Register 注册服务路由
func (s MyService) Register(container *restful.Container) {
    ws := new(restful.WebService)
    ws.Path("/WEB")
    ws.Consumes(restful.MIME_JSON, restful.MIME_XML, restful.MIME_FORM).
        Produces(restful.MIME_JSON, restful.MIME_XML)

    // 定义不包含查询参数的路由
    ws.Route(ws.GET("/service.wfs").To(s.HandleWFSRequest).
        Doc("处理WFS服务请求，手动解析查询参数").
        Param(ws.QueryParameter("param1", "第一个查询参数").DataType("string")).
        Param(ws.QueryParameter("param2", "第二个查询参数").DataType("string")).
        Writes("string")) // 响应类型

    container.Add(ws)
}

// HandleWFSRequest 处理WFS服务的请求
func (s MyService) HandleWFSRequest(request *restful.Request, response *restful.Response) {
    // 获取原始的http.Request对象
    r := request.Request

    // 解析URL以获取查询参数
    u, err := url.Parse(r.URL.String())
    if err != nil {
        log.Printf("URL解析失败: %v", err)
        response.WriteErrorString(http.StatusInternalServerError, "内部服务器错误：URL解析失败")
        return
    }

    // 获取查询参数映射
    q := u.Query()

    // 提取并处理查询参数
    param1 := q.Get("param1") // 使用Get方法获取第一个值，如果不存在则返回空字符串
    param2 := q.Get("param2")

    // 构造响应结果
    result := fmt.Sprintf("成功处理WFS请求！\n接收到的参数:\n  param1: %s\n  param2: %s", param1, param2)

    // 将结果写入响应
    response.WriteEntity(result)
}

func main() {
    // 创建GoREST容器
    container := restful.NewContainer()
    container.EnableContentEncoding(true) // 启用内容编码

    // 注册服务
    myService := MyService{}
    myService.Register(container)

    // 启动HTTP服务器
    log.Printf("服务器正在监听 http://localhost:8080")
    log.Fatal(http.ListenAndServe(":8080", container))
}