# golang 部分
参考 https://geektutu.com/post/quick-go-wasm.html
# 开发
package main
import "syscall/js" // goland可能会报错,忽略即可
func main() {
alert := js.Global().Get("alert")
alert.Invoke("Hello World!")
}
# 编译
不能用 go build
直接编译
windows 下面可以在 git bash 窗口编译
GOOS=js GOARCH=wasm go build -o static/main.wasm |
编译后,会在项目目录下生成 static/main.wasm
# vue 部分
# 创建项目
npm init vite vue-wasm | |
cd vue-wasm | |
npm install | |
npm run dev |
# 引入 wasm
- 把 wasm_exec.js (注意有不同的版本,报错了可以换版本) 以及 main.wasm 文件复制到 vue 项目下 /static
// Copyright 2018 The Go Authors. All rights reserved. | |
// Use of this source code is governed by a BSD-style | |
// license that can be found in the LICENSE file. | |
(() => { | |
// Map multiple JavaScript environments to a single common API, | |
// preferring web standards over Node.js API. // // Environments considered: // - Browsers // - Node.js // - Electron // - Parcel // - Webpack | |
if (typeof global !== "undefined") { | |
// global already exists | |
} else if (typeof window !== "undefined") { | |
window.global = window; | |
} else if (typeof self !== "undefined") { | |
self.global = self; | |
} else { | |
throw new Error("cannot export Go (neither global, window nor self is defined)"); | |
} | |
if (!global.require && typeof require !== "undefined") { | |
global.require = require; | |
} | |
if (!global.fs && global.require) { | |
const fs = require("fs"); | |
if (typeof fs === "object" && fs !== null && Object.keys(fs).length !== 0) { | |
global.fs = fs; | |
} | |
} | |
const enosys = () => { | |
const err = new Error("not implemented"); | |
err.code = "ENOSYS"; | |
return err; | |
}; | |
if (!global.fs) { | |
let outputBuf = ""; | |
global.fs = { | |
constants: { O_WRONLY: -1, O_RDWR: -1, O_CREAT: -1, O_TRUNC: -1, O_APPEND: -1, O_EXCL: -1 }, // unused | |
writeSync(fd, buf) { | |
outputBuf += decoder.decode(buf); | |
const nl = outputBuf.lastIndexOf("\n"); | |
if (nl != -1) { | |
console.log(outputBuf.substr(0, nl)); | |
outputBuf = outputBuf.substr(nl + 1); | |
} | |
return buf.length; | |
}, | |
write(fd, buf, offset, length, position, callback) { | |
if (offset !== 0 || length !== buf.length || position !== null) { | |
callback(enosys()); | |
return; } | |
const n = this.writeSync(fd, buf); | |
callback(null, n); | |
}, | |
chmod(path, mode, callback) { callback(enosys()); }, | |
chown(path, uid, gid, callback) { callback(enosys()); }, | |
close(fd, callback) { callback(enosys()); }, | |
fchmod(fd, mode, callback) { callback(enosys()); }, | |
fchown(fd, uid, gid, callback) { callback(enosys()); }, | |
fstat(fd, callback) { callback(enosys()); }, | |
fsync(fd, callback) { callback(null); }, | |
ftruncate(fd, length, callback) { callback(enosys()); }, | |
lchown(path, uid, gid, callback) { callback(enosys()); }, | |
link(path, link, callback) { callback(enosys()); }, | |
lstat(path, callback) { callback(enosys()); }, | |
mkdir(path, perm, callback) { callback(enosys()); }, | |
open(path, flags, mode, callback) { callback(enosys()); }, | |
read(fd, buffer, offset, length, position, callback) { callback(enosys()); }, | |
readdir(path, callback) { callback(enosys()); }, | |
readlink(path, callback) { callback(enosys()); }, | |
rename(from, to, callback) { callback(enosys()); }, | |
rmdir(path, callback) { callback(enosys()); }, | |
stat(path, callback) { callback(enosys()); }, | |
symlink(path, link, callback) { callback(enosys()); }, | |
truncate(path, length, callback) { callback(enosys()); }, | |
unlink(path, callback) { callback(enosys()); }, | |
utimes(path, atime, mtime, callback) { callback(enosys()); }, | |
}; | |
} | |
if (!global.process) { | |
global.process = { | |
getuid() { return -1; }, | |
getgid() { return -1; }, | |
geteuid() { return -1; }, | |
getegid() { return -1; }, | |
getgroups() { throw enosys(); }, | |
pid: -1, | |
ppid: -1, | |
umask() { throw enosys(); }, | |
cwd() { throw enosys(); }, | |
chdir() { throw enosys(); }, | |
} | |
} | |
if (!global.crypto && global.require) { | |
const nodeCrypto = require("crypto"); | |
global.crypto = { | |
getRandomValues(b) { | |
nodeCrypto.randomFillSync(b); | |
}, | |
}; | |
} | |
if (!global.crypto) { | |
throw new Error("global.crypto is not available, polyfill required (getRandomValues only)"); | |
} | |
if (!global.performance) { | |
global.performance = { | |
now() { | |
const [sec, nsec] = process.hrtime(); | |
return sec * 1000 + nsec / 1000000; | |
}, | |
}; | |
} | |
if (!global.TextEncoder && global.require) { | |
global.TextEncoder = require("util").TextEncoder; | |
} | |
if (!global.TextEncoder) { | |
throw new Error("global.TextEncoder is not available, polyfill required"); | |
} | |
if (!global.TextDecoder && global.require) { | |
global.TextDecoder = require("util").TextDecoder; | |
} | |
if (!global.TextDecoder) { | |
throw new Error("global.TextDecoder is not available, polyfill required"); | |
} | |
// End of polyfills for common API. | |
const encoder = new TextEncoder("utf-8"); | |
const decoder = new TextDecoder("utf-8"); | |
global.Go = class { | |
constructor() { | |
this.argv = ["js"]; | |
this.env = {}; | |
this.exit = (code) => { | |
if (code !== 0) { | |
console.warn("exit code:", code); | |
} | |
}; | |
this._exitPromise = new Promise((resolve) => { | |
this._resolveExitPromise = resolve; | |
}); | |
this._pendingEvent = null; | |
this._scheduledTimeouts = new Map(); | |
this._nextCallbackTimeoutID = 1; | |
const setInt64 = (addr, v) => { | |
this.mem.setUint32(addr + 0, v, true); | |
this.mem.setUint32(addr + 4, Math.floor(v / 4294967296), true); | |
} | |
const getInt64 = (addr) => { | |
const low = this.mem.getUint32(addr + 0, true); | |
const high = this.mem.getInt32(addr + 4, true); | |
return low + high * 4294967296; | |
} | |
const loadValue = (addr) => { | |
const f = this.mem.getFloat64(addr, true); | |
if (f === 0) { | |
return undefined; | |
} | |
if (!isNaN(f)) { | |
return f; | |
} | |
const id = this.mem.getUint32(addr, true); | |
return this._values[id]; | |
} | |
const storeValue = (addr, v) => { | |
const nanHead = 0x7FF80000; | |
if (typeof v === "number" && v !== 0) { | |
if (isNaN(v)) { | |
this.mem.setUint32(addr + 4, nanHead, true); | |
this.mem.setUint32(addr, 0, true); | |
return; } | |
this.mem.setFloat64(addr, v, true); | |
return; } | |
if (v === undefined) { | |
this.mem.setFloat64(addr, 0, true); | |
return; } | |
let id = this._ids.get(v); | |
if (id === undefined) { | |
id = this._idPool.pop(); | |
if (id === undefined) { | |
id = this._values.length; | |
} | |
this._values[id] = v; | |
this._goRefCounts[id] = 0; | |
this._ids.set(v, id); | |
} | |
this._goRefCounts[id]++; | |
let typeFlag = 0; | |
switch (typeof v) { | |
case "object": | |
if (v !== null) { | |
typeFlag = 1; | |
} | |
break; | |
case "string": | |
typeFlag = 2; | |
break; case "symbol": | |
typeFlag = 3; | |
break; case "function": | |
typeFlag = 4; | |
break; } | |
this.mem.setUint32(addr + 4, nanHead | typeFlag, true); | |
this.mem.setUint32(addr, id, true); | |
} | |
const loadSlice = (addr) => { | |
const array = getInt64(addr + 0); | |
const len = getInt64(addr + 8); | |
return new Uint8Array(this._inst.exports.mem.buffer, array, len); | |
} | |
const loadSliceOfValues = (addr) => { | |
const array = getInt64(addr + 0); | |
const len = getInt64(addr + 8); | |
const a = new Array(len); | |
for (let i = 0; i < len; i++) { | |
a[i] = loadValue(array + i * 8); | |
} | |
return a; | |
} | |
const loadString = (addr) => { | |
const saddr = getInt64(addr + 0); | |
const len = getInt64(addr + 8); | |
return decoder.decode(new DataView(this._inst.exports.mem.buffer, saddr, len)); | |
} | |
const timeOrigin = Date.now() - performance.now(); | |
this.importObject = { | |
go: { | |
// Go's SP does not change as long as no Go code is running. Some operations (e.g. calls, getters and setters) | |
// may synchronously trigger a Go event handler. This makes Go code get executed in the middle of the imported // function. A goroutine can switch to a new stack if the current stack is too small (see morestack function). // This changes the SP, thus we have to update the SP used by the imported function. | |
// func wasmExit(code int32) "runtime.wasmExit": (sp) => { | |
sp >>>= 0; | |
const code = this.mem.getInt32(sp + 8, true); | |
this.exited = true; | |
delete this._inst; | |
delete this._values; | |
delete this._goRefCounts; | |
delete this._ids; | |
delete this._idPool; | |
this.exit(code); | |
}, | |
// func wasmWrite(fd uintptr, p unsafe.Pointer, n int32) | |
"runtime.wasmWrite": (sp) => { | |
sp >>>= 0; | |
const fd = getInt64(sp + 8); | |
const p = getInt64(sp + 16); | |
const n = this.mem.getInt32(sp + 24, true); | |
fs.writeSync(fd, new Uint8Array(this._inst.exports.mem.buffer, p, n)); | |
}, | |
// func resetMemoryDataView() | |
"runtime.resetMemoryDataView": (sp) => { | |
sp >>>= 0; | |
this.mem = new DataView(this._inst.exports.mem.buffer); | |
}, | |
// func nanotime1() int64 | |
"runtime.nanotime1": (sp) => { | |
sp >>>= 0; | |
setInt64(sp + 8, (timeOrigin + performance.now()) * 1000000); | |
}, | |
// func walltime() (sec int64, nsec int32) | |
"runtime.walltime": (sp) => { | |
sp >>>= 0; | |
const msec = (new Date).getTime(); | |
setInt64(sp + 8, msec / 1000); | |
this.mem.setInt32(sp + 16, (msec % 1000) * 1000000, true); | |
}, | |
// func scheduleTimeoutEvent(delay int64) int32 | |
"runtime.scheduleTimeoutEvent": (sp) => { | |
sp >>>= 0; | |
const id = this._nextCallbackTimeoutID; | |
this._nextCallbackTimeoutID++; | |
this._scheduledTimeouts.set(id, setTimeout( | |
() => { | |
this._resume(); | |
while (this._scheduledTimeouts.has(id)) { | |
// for some reason Go failed to register the timeout event, log and try again | |
// (temporary workaround for https://github.com/golang/go/issues/28975) console.warn("scheduleTimeoutEvent: missed timeout event"); | |
this._resume(); | |
} | |
}, | |
getInt64(sp + 8) + 1, // setTimeout has been seen to fire up to 1 millisecond early | |
)); | |
this.mem.setInt32(sp + 16, id, true); | |
}, | |
// func clearTimeoutEvent(id int32) | |
"runtime.clearTimeoutEvent": (sp) => { | |
sp >>>= 0; | |
const id = this.mem.getInt32(sp + 8, true); | |
clearTimeout(this._scheduledTimeouts.get(id)); | |
this._scheduledTimeouts.delete(id); | |
}, | |
// func getRandomData(r []byte) | |
"runtime.getRandomData": (sp) => { | |
sp >>>= 0; | |
crypto.getRandomValues(loadSlice(sp + 8)); | |
}, | |
// func finalizeRef(v ref) | |
"syscall/js.finalizeRef": (sp) => { | |
sp >>>= 0; | |
const id = this.mem.getUint32(sp + 8, true); | |
this._goRefCounts[id]--; | |
if (this._goRefCounts[id] === 0) { | |
const v = this._values[id]; | |
this._values[id] = null; | |
this._ids.delete(v); | |
this._idPool.push(id); | |
} | |
}, | |
// func stringVal(value string) ref | |
"syscall/js.stringVal": (sp) => { | |
sp >>>= 0; | |
storeValue(sp + 24, loadString(sp + 8)); | |
}, | |
// func valueGet(v ref, p string) ref | |
"syscall/js.valueGet": (sp) => { | |
sp >>>= 0; | |
const result = Reflect.get(loadValue(sp + 8), loadString(sp + 16)); | |
sp = this._inst.exports.getsp() >>> 0; // see comment above | |
storeValue(sp + 32, result); | |
}, | |
// func valueSet(v ref, p string, x ref) | |
"syscall/js.valueSet": (sp) => { | |
sp >>>= 0; | |
Reflect.set(loadValue(sp + 8), loadString(sp + 16), loadValue(sp + 32)); | |
}, | |
// func valueDelete(v ref, p string) | |
"syscall/js.valueDelete": (sp) => { | |
sp >>>= 0; | |
Reflect.deleteProperty(loadValue(sp + 8), loadString(sp + 16)); | |
}, | |
// func valueIndex(v ref, i int) ref | |
"syscall/js.valueIndex": (sp) => { | |
sp >>>= 0; | |
storeValue(sp + 24, Reflect.get(loadValue(sp + 8), getInt64(sp + 16))); | |
}, | |
// valueSetIndex(v ref, i int, x ref) | |
"syscall/js.valueSetIndex": (sp) => { | |
sp >>>= 0; | |
Reflect.set(loadValue(sp + 8), getInt64(sp + 16), loadValue(sp + 24)); | |
}, | |
// func valueCall(v ref, m string, args []ref) (ref, bool) | |
"syscall/js.valueCall": (sp) => { | |
sp >>>= 0; | |
try { | |
const v = loadValue(sp + 8); | |
const m = Reflect.get(v, loadString(sp + 16)); | |
const args = loadSliceOfValues(sp + 32); | |
const result = Reflect.apply(m, v, args); | |
sp = this._inst.exports.getsp() >>> 0; // see comment above | |
storeValue(sp + 56, result); | |
this.mem.setUint8(sp + 64, 1); | |
} catch (err) { | |
sp = this._inst.exports.getsp() >>> 0; // see comment above | |
storeValue(sp + 56, err); | |
this.mem.setUint8(sp + 64, 0); | |
} | |
}, | |
// func valueInvoke(v ref, args []ref) (ref, bool) | |
"syscall/js.valueInvoke": (sp) => { | |
sp >>>= 0; | |
try { | |
const v = loadValue(sp + 8); | |
const args = loadSliceOfValues(sp + 16); | |
const result = Reflect.apply(v, undefined, args); | |
sp = this._inst.exports.getsp() >>> 0; // see comment above | |
storeValue(sp + 40, result); | |
this.mem.setUint8(sp + 48, 1); | |
} catch (err) { | |
sp = this._inst.exports.getsp() >>> 0; // see comment above | |
storeValue(sp + 40, err); | |
this.mem.setUint8(sp + 48, 0); | |
} | |
}, | |
// func valueNew(v ref, args []ref) (ref, bool) | |
"syscall/js.valueNew": (sp) => { | |
sp >>>= 0; | |
try { | |
const v = loadValue(sp + 8); | |
const args = loadSliceOfValues(sp + 16); | |
const result = Reflect.construct(v, args); | |
sp = this._inst.exports.getsp() >>> 0; // see comment above | |
storeValue(sp + 40, result); | |
this.mem.setUint8(sp + 48, 1); | |
} catch (err) { | |
sp = this._inst.exports.getsp() >>> 0; // see comment above | |
storeValue(sp + 40, err); | |
this.mem.setUint8(sp + 48, 0); | |
} | |
}, | |
// func valueLength(v ref) int | |
"syscall/js.valueLength": (sp) => { | |
sp >>>= 0; | |
setInt64(sp + 16, parseInt(loadValue(sp + 8).length)); | |
}, | |
// valuePrepareString(v ref) (ref, int) | |
"syscall/js.valuePrepareString": (sp) => { | |
sp >>>= 0; | |
const str = encoder.encode(String(loadValue(sp + 8))); | |
storeValue(sp + 16, str); | |
setInt64(sp + 24, str.length); | |
}, | |
// valueLoadString(v ref, b []byte) | |
"syscall/js.valueLoadString": (sp) => { | |
sp >>>= 0; | |
const str = loadValue(sp + 8); | |
loadSlice(sp + 16).set(str); | |
}, | |
// func valueInstanceOf(v ref, t ref) bool | |
"syscall/js.valueInstanceOf": (sp) => { | |
sp >>>= 0; | |
this.mem.setUint8(sp + 24, (loadValue(sp + 8) instanceof loadValue(sp + 16)) ? 1 : 0); | |
}, | |
// func copyBytesToGo(dst []byte, src ref) (int, bool) | |
"syscall/js.copyBytesToGo": (sp) => { | |
sp >>>= 0; | |
const dst = loadSlice(sp + 8); | |
const src = loadValue(sp + 32); | |
if (!(src instanceof Uint8Array || src instanceof Uint8ClampedArray)) { | |
this.mem.setUint8(sp + 48, 0); | |
return; } | |
const toCopy = src.subarray(0, dst.length); | |
dst.set(toCopy); | |
setInt64(sp + 40, toCopy.length); | |
this.mem.setUint8(sp + 48, 1); | |
}, | |
// func copyBytesToJS(dst ref, src []byte) (int, bool) | |
"syscall/js.copyBytesToJS": (sp) => { | |
sp >>>= 0; | |
const dst = loadValue(sp + 8); | |
const src = loadSlice(sp + 16); | |
if (!(dst instanceof Uint8Array || dst instanceof Uint8ClampedArray)) { | |
this.mem.setUint8(sp + 48, 0); | |
return; } | |
const toCopy = src.subarray(0, dst.length); | |
dst.set(toCopy); | |
setInt64(sp + 40, toCopy.length); | |
this.mem.setUint8(sp + 48, 1); | |
}, | |
"debug": (value) => { | |
console.log(value); | |
}, | |
} | |
}; | |
} | |
async run(instance) { | |
if (!(instance instanceof WebAssembly.Instance)) { | |
throw new Error("Go.run: WebAssembly.Instance expected"); | |
} | |
this._inst = instance; | |
this.mem = new DataView(this._inst.exports.mem.buffer); | |
this._values = [ // JS values that Go currently has references to, indexed by reference id | |
NaN, | |
0, | |
null, true, false, global, | |
this, ]; | |
this._goRefCounts = new Array(this._values.length).fill(Infinity); // number of references that Go has to a JS value, indexed by reference id | |
this._ids = new Map([ // mapping from JS values to reference ids | |
[0, 1], | |
[null, 2], | |
[true, 3], | |
[false, 4], | |
[global, 5], | |
[this, 6], | |
]); | |
this._idPool = []; // unused ids that have been garbage collected | |
this.exited = false; // whether the Go program has exited | |
// Pass command line arguments and environment variables to WebAssembly by writing them to the linear memory. let offset = 4096; | |
const strPtr = (str) => { | |
const ptr = offset; | |
const bytes = encoder.encode(str + "\0"); | |
new Uint8Array(this.mem.buffer, offset, bytes.length).set(bytes); | |
offset += bytes.length; | |
if (offset % 8 !== 0) { | |
offset += 8 - (offset % 8); | |
} | |
return ptr; | |
}; | |
const argc = this.argv.length; | |
const argvPtrs = []; | |
this.argv.forEach((arg) => { | |
argvPtrs.push(strPtr(arg)); | |
}); | |
argvPtrs.push(0); | |
const keys = Object.keys(this.env).sort(); | |
keys.forEach((key) => { | |
argvPtrs.push(strPtr(`${key}=${this.env[key]}`)); | |
}); | |
argvPtrs.push(0); | |
const argv = offset; | |
argvPtrs.forEach((ptr) => { | |
this.mem.setUint32(offset, ptr, true); | |
this.mem.setUint32(offset + 4, 0, true); | |
offset += 8; | |
}); | |
this._inst.exports.run(argc, argv); | |
if (this.exited) { | |
this._resolveExitPromise(); | |
} | |
await this._exitPromise; | |
} | |
_resume() { | |
if (this.exited) { | |
throw new Error("Go program has already exited"); | |
} | |
this._inst.exports.resume(); | |
if (this.exited) { | |
this._resolveExitPromise(); | |
} | |
} | |
_makeFuncWrapper(id) { | |
const go = this; | |
return function () { | |
const event = { id: id, this: this, args: arguments }; | |
go._pendingEvent = event; | |
go._resume(); | |
return event.result; | |
}; | |
} | |
} | |
if ( | |
typeof module !== "undefined" && | |
global.require && | |
global.require.main === module && | |
global.process && | |
global.process.versions && | |
!global.process.versions.electron | |
) { | |
if (process.argv.length < 3) { | |
console.error("usage: go_js_wasm_exec [wasm binary] [arguments]"); | |
process.exit(1); | |
} | |
const go = new Go(); | |
go.argv = process.argv.slice(2); | |
go.env = Object.assign({ TMPDIR: require("os").tmpdir() }, process.env); | |
go.exit = process.exit; | |
WebAssembly.instantiate(fs.readFileSync(process.argv[2]), go.importObject).then((result) => { | |
process.on("exit", (code) => { // Node.js exits if no event handler is pending | |
if (code === 0 && !go.exited) { | |
// deadlock, make Go print error and stack traces | |
go._pendingEvent = { id: 0 }; | |
go._resume(); | |
} | |
}); | |
return go.run(result.instance); | |
}).catch((err) => { | |
console.error(err); | |
process.exit(1); | |
}); | |
} | |
})(); | |
2. 在index.html中引入wasm_exec.js | |
```js | |
<head> | |
<meta charset="UTF-8" /> | |
<link rel="icon" type="image/svg+xml" href="/vite.svg" /> | |
<meta name="viewport" content="width=device-width, initial-scale=1.0" /> | |
<script src="static/wasm_exec.js"></script> | |
<title>Vite + Vue + TS</title> | |
</head> |
# 调用 go 代码
在 HelloWorld.vue 组件中调用 wasm 函数
<script setup lang="ts">
import { ref,defineProps } from 'vue'
defineProps<{ msg: string }>()
const run = ()=>{
const go = new window.Go();
WebAssembly.instantiateStreaming(fetch("../../static/main.wasm"),go.importObject).
then((result)=>go.run(result.instance));
}
</script>
<template>
<h1>{{ msg }}</h1>
<div class="card-body">
<p class="text-muted">
点击“运行”,在控制台输出日志 <code>Hello, WebAssembly!</code>
</p> <div class="live-preview">
<button @click="run()"
class="btn btn-success"
id="runButton"
>
运行
</button>
</div> </div>
</template>
<style scoped>
.read-the-docs {
color: #888;
}
</style>
# 问题
# 是否支持跨域
不能
func main() { | |
alert := js.Global().Get("alert") | |
alert.Invoke("Hello World!") | |
url := "https://www.baidu.com/" // 要获取数据的 URL | |
response, err := http.Get(url) | |
if err != nil { | |
fmt.Printf("获取URL数据时出错:%s", err) | |
return | |
} | |
defer response.Body.Close() | |
body, err := ioutil.ReadAll(response.Body) | |
if err != nil { | |
fmt.Printf("读取响应内容时出错:%s", err) | |
return | |
} | |
fmt.Println(string(body)) | |
} |
浏览器报了跨域错误
# 是否支持多协程
支持
func main() { | |
alert := js.Global().Get("alert") | |
alert.Invoke("Hello World!") | |
sleep := func(x int, wg *sync.WaitGroup) { | |
defer wg.Done() | |
time.Sleep(time.Second * time.Duration(x)) | |
fmt.Printf("我是coroutine:%d\n", x) | |
} | |
var wg sync.WaitGroup | |
fmt.Println("开启两个协程") | |
wg.Add(1) | |
go sleep(1, &wg) | |
wg.Add(1) | |
go sleep(2, &wg) | |
wg.Wait() | |
fmt.Println("All workers done") | |
} |