小伙伴们有没有觉得学习Golang很有意思？有意思就对了！今天就给大家带来《Envoy WASM 在使用 net/http Go 模块时遇到导入缺失问题，无法加载》，以下内容将会涉及到，若是在学习中对其中部分知识点有疑问，或许看了本文就能帮到你！

我正在尝试运行 wasm go 过滤器以使用 net/http 模块进行外部 http 调用。 envoy 无法加载 wasm 代码。为什么导入失败？

envoy/istio 版本： istio/proxyv2:1.11.4

sdk版本： v0.16.1-0.20220127085108-af57b89bc067

tinygo版本：tinygo版本0.22.0 darwin/amd64（使用go版本go1.17.6和llvm版本13.0.0）

错误日志

2022-01-31t20:34:18.513749z error   envoy wasm  failed to load wasm module due to a missing import: env.time.resettimer
2022-01-31t20:34:18.513794z error   envoy wasm  failed to load wasm module due to a missing import: env.time.stoptimer
2022-01-31t20:34:18.513807z error   envoy wasm  failed to load wasm module due to a missing import: env.time.starttimer
2022-01-31t20:34:18.513817z error   envoy wasm  failed to load wasm module due to a missing import: env.sync/atomic.addint32
2022-01-31t20:34:18.513826z error   envoy wasm  failed to load wasm module due to a missing import: wasi_snapshot_preview1.fd_filestat_get
2022-01-31t20:34:18.513833z error   envoy wasm  failed to load wasm module due to a missing import: wasi_snapshot_preview1.fd_pread
2022-01-31t20:34:18.513840z error   envoy wasm  failed to load wasm module due to a missing import: wasi_snapshot_preview1.fd_prestat_get
2022-01-31t20:34:18.513846z error   envoy wasm  failed to load wasm module due to a missing import: wasi_snapshot_preview1.fd_prestat_dir_name
2022-01-31t20:34:18.513854z error   envoy wasm  failed to load wasm module due to a missing import: wasi_snapshot_preview1.path_open
2022-01-31t20:34:18.513864z error   envoy wasm  wasm vm failed failed to initialize wasm code
2022-01-31t20:34:18.517062z critical    envoy wasm  plugin configured to fail closed failed to load
2022-01-31t20:34:18.517191z warning envoy config    grpc config for type.googleapis.com/envoy.config.core.v3.typedextensionconfig rejected: unable to create wasm http filter

tinygo build -o main.wasm -scheduler=asyncify -target=wasi main.go

实际代码

package main

import (
    "errors"

    "github.com/tetratelabs/proxy-wasm-go-sdk/proxywasm"
    "github.com/tetratelabs/proxy-wasm-go-sdk/proxywasm/types"
    "io/ioutil"
    "time"
    "net/http"
)

const (
    sharedDataKey                 = "hello_world_shared_data_key"
)

func main() {
    proxywasm.SetVMContext(&vmContext{})
}

type (
    vmContext     struct{}
    pluginContext struct {
        // Embed the default plugin context here,
        // so that we don't need to reimplement all the methods.
        types.DefaultPluginContext
    }

    httpContext struct {
        // Embed the default http context here,
        // so that we don't need to reimplement all the methods.
        types.DefaultHttpContext
    }
)

// Override types.VMContext.
func (*vmContext) OnVMStart(vmConfigurationSize int) types.OnVMStartStatus {

    proxywasm.LogInfo("Inside OnVMStart")


    http := http.Client{Timeout: time.Duration(10) * time.Second}
    resp, err := http.Get("http://SOME_URL:8001/echo?message=hello_world")
    if err != nil {
        proxywasm.LogWarnf("Error calling hello_world/echo on OnVMStart: %v", err)
    }

    defer resp.Body.Close()
    
    body, err := ioutil.ReadAll(resp.Body)

    if err != nil {
        proxywasm.LogWarnf("Error parsing hello_world/echo response on OnVMStart: %v", err)
    }


    proxywasm.LogInfof("Response Body : %s", body)
    
    

    initialValueBuf := []byte("body")
    if err := proxywasm.SetSharedData(sharedDataKey, initialValueBuf, 0); err != nil {
        proxywasm.LogWarnf("Error setting shared hello_world data on OnVMStart: %v", err)
    }
    return types.OnVMStartStatusOK
}

// Override types.DefaultVMContext.
func (*vmContext) NewPluginContext(contextID uint32) types.PluginContext {
    return &pluginContext{}
}

// Override types.DefaultPluginContext.
func (*pluginContext) NewHttpContext(contextID uint32) types.HttpContext {
    return &httpContext{}
}

// Override types.DefaultHttpContext.
func (ctx *httpContext) OnHttpRequestHeaders(numHeaders int, endOfStream bool) types.Action {
    for {
        value, err := ctx.getSharedData()
        if err == nil {
            proxywasm.LogInfof("shared data value: %s", value)
        } else if errors.Is(err, types.ErrorStatusCasMismatch) {
            continue
        }
        break
    }
    return types.ActionContinue
}

func (ctx *httpContext) getSharedData() (string, error) {
    value, cas, err := proxywasm.GetSharedData(sharedDataKey)
    if err != nil {
        proxywasm.LogWarnf("error getting shared data on OnHttpRequestHeaders with cas %d: %v ", cas, err)
        return "error", err
    }

    shared_value := string(value)
    
    return shared_value, err
}

正确答案

不幸的是，这并不那么容易。

tinygo 可能支持该模块，但在为 envoy 使用 wasm 模块时，您不能“仅仅”调用某些任意 api。

更准确地说，wasm 模块在沙箱中运行，并且只能进行运行时明确允许的调用。对于 envoy，wasm 代理 sdk 提供了一种简单的机制来调用这些 api。

proxy-wasm-go-sdk 提供了您可以使用的 api 调用。

有一个函数proxywasm.DispatchHttpCall。但是，你必须“使用envoy方式”进行http调用。

请注意，该调用中的“集群”不是一个简单的 url，而是一个 Envoy Cluster。您也可以尝试使用 istio 定义的集群，例如 outbound|80||some-service.some-namespace.svc.cluster。 local 如果您有任何使用 istio 代理定义的服务。

您可以使用 istioctl 查找代理配置，例如入口网关：

istioctl proxy-config all istio-ingressgateway-your-pod -o json | less

在 istio 中添加 ServiceEntries 时，您的网格中也可能会得到这样的“集群”。请注意，服务条目还可以引用外部主机，而不仅仅是集群内的服务。

否则，您可以尝试添加手动集群，例如 Envoy-based rate limiting，尽管这也很容易出错。

- applyto: cluster
  match:
    cluster:
      service: ratelimit.default.svc.cluster.local
  patch:
    operation: add
    # adds the rate limit service cluster for rate limit service defined in step 1.
    value:
      name: rate_limit_cluster
      type: strict_dns
      connect_timeout: 10s
      lb_policy: round_robin
      http2_protocol_options: {}
      load_assignment:
        cluster_name: rate_limit_cluster
        endpoints:
        - lb_endpoints:
          - endpoint:
              address:
                 socket_address:
                  address: ratelimit.default.svc.cluster.local
                  port_value: 8081

在 this description of Envoy Lua Filters 中，您会看到一些示例。虽然不是wasm，但原理是一样的

对于 go，你可以尝试类似的方法

headers := [][2]string{
    {":method", "GET"},
    {":path", "/echo?message=hello_world"},
    {":authority", "SOME_HOST"},
    {":scheme", "http"},
}

_, err := proxywasm.DispatchHttpCall("CLUSTER",
    headers,
    nil,
    nil,
    1000,
    func(numHeaders, bodySize, numTrailers int) {
        resp, _ := proxywasm.GetHttpCallResponseBody(0, 10000)
        r := string(resp)
        proxywasm.LogDebugf("RESPONSE %v", r)
    },
)

好了，本文到此结束，带大家了解了《Envoy WASM 在使用 net/http Go 模块时遇到导入缺失问题，无法加载》，希望本文对你有所帮助！关注golang学习网公众号，给大家分享更多Golang知识！