前阵子想做一个网站来放一些 referral 链接，研究了一下各种框架/现成的类 CMS 开源程序，Astro 又一次出现在视野中，于是决定试试看 Astro 到底是个什么东西。

最开始是找各种模板，先是用别人的模板搭了一个摄影集：https://splash.yian.me，当时觉得风格还不错，但是构建后的静态资源路径（Image 组件会对图片做处理，然后放在 /_astro/ 下）有点让强迫症不爽，然后因为各种原因暂时搁置了建站计划。

后来有点想找个静态博客替换掉 Typecho（单纯是不想再维护 PHP 环境了），恰好有人找我做网站，就决定要不自己亲自写一套 Astro 模板，也当是顺便熟悉一下 Astro，于是就有了一个新的技术博客：https://notes.yian.me。后面技术类的文章应该都会发在那边了，现在这个 Typecho 短期内还会继续维护。

然后过年期间又 vibe coding 了一个页面，至此最开始想做的 referral 的网站总算上线了：https://uses.yian.me，欢迎各位看官看看有没有被种草的东西，然后用我的链接注册一个😄

体验下来 Astro 是真棒，然后再托管在 Cloudflare Pages 简直完美。谢谢 Astro！

在做词焙查词接口时，如果词库不存在这个单词，则需要调用外部 API 更新词库，而目前用的大模型 API 调用时长较长（超过 5 秒）且不可控，故需要异步去做这件事。

这种场景很适合使用消息队列（RabbitMQ、Kafka、Redis PUB/SUB 等等），但为了使架构尽可能简单，不想轻易引入中间件，加上考虑到 Go channel 很适合在不同协程之间传递消息，于是使用 channel 封装了一个简易的消息队列：支持多队列、支持多消费者，而且整个封装才不到 300 行代码。

消息定义

消息队列，首先要有消息。最简单的一个消息就是 ID + 数据：

type Msg struct {
    ID   uint64
    Data any
}

消息 ID 用一个 uint64 类型的自增序列足矣。

队列定义

有了消息，接下来就可以定义队列了。

最简单的队列用一个 slice 用于保存消息，然再加上 Enqueue 和 Dequeue 即可：

type Queue struct {
    msgs []*Msg
}

func (q *Queue) Enqueue(msg *Msg) error
func (q *Queue) Dequeue() *Msg

但这样在并发的时候会出现问题，你可能会想到用一个 sync.Lock 来加锁，可行，但可以利用 chan 来实现无锁队列，具体原理是：新增 in 和 out 两个 chan，然后在同一个协程里将 in 接收到的消息放入 msgs，用 out 来发送出队消息。

Queue 的定义如下：

- 阅读剩余部分 -

Go 在使用 os/exec 执行外部命令的时候，假如外部命令是持续输出的，该如何实时、持续获取外部命令的输出呢？

其实很简单，只需要通过 StdoutPipe() 创建一个管道接收外部命令的标准输出即可。

先来准备一个外部命令程序 ./hello/main.cc：

#include "iostream"
#include <thread>

int main() {
    while (true) {
        auto now = std::chrono::system_clock::now();
        std::time_t now_c = std::chrono::system_clock::to_time_t(now);
        std::cout << "Current time is: " << std::ctime(&now_c) << std::flush;
        // sleep for a second
        std::this_thread::sleep_for(std::chrono::seconds(1));
    }
}

然后用 g++ 编译：g++ -o hello main.cc 得到 ./hello/hello，这个程序会每隔一秒输出当前时间。

接下来开始写我们的 Go 程序：

package main

import (
    "fmt"
    "os/exec"
    "strings"
)

func main() {
    cmd := exec.Command("./hello/hello")

    cmdStdout, err := cmd.StdoutPipe() // 创建一个管道接收外部命令的标准输出
    if err != nil {
        fmt.Println("Error creating StdoutPipe:", err)
        return
    }

    if err := cmd.Start(); err != nil {
        fmt.Println("Error starting command:", err)
        return
    }

    // 用协程非阻塞接收外部命令的流式输出
    go func() {
        for {
            buf := make([]byte, 1024)
            n, err := cmdStdout.Read(buf)
            if err != nil {
                fmt.Println("Error reading from stdout:", err)
                break
            }

            if n == 0 {
                continue
            }

            // 按需把尾部的换行符、或者是 '\0' （在 Go 里是 "\x00"）去除掉
            output := strings.TrimSuffix(string(buf[:n]), "\n")
            fmt.Println("Output:", output)
        }
    }()

    if err := cmd.Wait(); err != nil {
        fmt.Println("Error waiting for command:", err)
        return
    }
}

问题出现

在做词焙词库更新的时候遇到一个问题：如果某一个单词是一个非法的单词，那就需要进行标记，之后再次遇到的时候可以直接跳过。

这个方案要实现的话，可能第一时间会想到用 Redis 的 Set；或者数据库里加一张表，一行一个非法单词。

但是词焙本身是没有用到 Redis 的，如果要用还得配置下内存淘汰策略；这么简单的需求放数据库的话又有点杀鸡用牛刀了。

所以我选择了直接使用内存 + 定期持久化到文件，整个技术方案不难，加起来就一百行左右的代码。

- 阅读剩余部分 -

微信小程序的 WXML 目前（2025.07）是不支持 <svg> 标签的，所以没办法直接使用 Lucide 这一类的图标，但小程序提供了 <image> 标签，是支持 SVG 格式的，但！直接用 <image> 引入 SVG 就没办法自定义颜色了。

有解决方案吗？有的，因为 <image> 是支持 base64 格式的，那我们动态创建 SVG 图标即可。

怎么动态创建呢，把图标的 SVG 字符串中的颜色熟悉（stroke）提取出来，将整个 SVG 字符串作为图标模板，然后用字符串的 replace() 替换即可。

本文的代码是 React + Taro，其他框架的思路是一样的，只是写法略有差异。这里需要用到 js-base64 这个库，记得先 npm 安装一下。

以 Lucide 的 book 图标为例，它的 SVG 是这样的：

- 阅读剩余部分 -

在 Go 里可以通过 CGO 调用 C 函数，最简单的写法就是直接在 import "C" 前一行写 C 函数：

package main

/*
int sum(int a, int b) { return a + b; }
*/
import "C"
import "fmt"

func main() {
    fmt.Println(C.sum(C.int(1), C.int(2)))
}

但，如果是那么简单的函数，也不需要用到 CGO，直接 Go 实现就行了，真要用到 CGO 了，大概率就是你需要调用一些比较复杂的 C 代码，可以用下面两种方式实现：

- 阅读剩余部分 -