Server酱加云函数实现留言监控-Wega's Blog

本博客的留言板功能过于简单，只能留言，无法做到消息提醒

由于是纯静态网站，想再增强下留言板功能还是有办法的，可以实现有新留言推送到自己的微信上，需要用到 Server 酱和腾讯云的云函数

Server 酱：利用微信服务号的模板消息做消息推送的服务，免费

云函数：腾讯云的无服务器云函数服务，支持各种语言，支持多种触发方式，免费

Bmob 云：云数据库，本博客在用的，免费

准备

注册腾讯云，阅读下云函数的文档和部署流程

代码

这里使用 Go 实现

在使用云服务的时候发现外部传参无法获取到，只好将参数在代码硬编码

先安装下云函数的 SDK

go get -u github.com/tencentyun/scf-go-lib/cloudfunction

// 参数定义
// BmobTableName : 表名
// Period : 查询多少分钟前的数据
const (
	BmobAPIURL    = "https://api2.bmob.cn/1/classes/"
	BmobTableName = "Comment"
	BmobAPPId     = "****************"
	BmobAppKey    = "**********************************"
	PushURL       = "https://sc.ftqq.com/********.send"
	Period        = 5
)

使用 Server 酱推送消息到微信，一个 Post 请求

func notice(title, text string) error {
	resp, err := http.PostForm(PushURL, url.Values{"desp": {text}, "text": {title}})
	if err != nil {
		return err
	}
	defer resp.Body.Close()
	return nil
}

获取多少分钟内的留言，使用 Bmob 的 REST API 实现

因为要自定义请求和解析 Json 代码有点长，另外吐槽下 Go 的异常处理

部署的过程中出现了 8 小时差的 BUG，统一时区就解决了

func getRecentComment() ([]string, error) {
	resultList := make([]string, 0)
	req, _ := http.NewRequest("GET", BmobAPIURL+BmobTableName, nil)

	// 请求头
	req.Header.Add("Content-Type", "application/json")
	req.Header.Add("X-Bmob-Application-Id", BmobAPPId)
	req.Header.Add("X-Bmob-REST-API-Key", BmobAppKey)

	// 请求参数
	q := req.URL.Query()
	q.Add("order", "-createdAt")
	// 统一时区，避免8小时差的BUG
	var cstSh, _ = time.LoadLocation("Asia/Shanghai")
	// 当前时间减去parms.Period分钟
	sDate := time.Now().In(cstSh).Add(-1 * time.Duration(Period) * time.Minute).Format("2006-01-02 15:04:05")
	q.Add("where", `{"createdAt":{"$gte":{"__type": "Date", "iso": "`+sDate+`"}}}`)
	req.URL.RawQuery = q.Encode()

	client := &http.Client{}
	resp, err := client.Do(req)
	if err != nil {
		return resultList, err
	}
	defer resp.Body.Close()
	body, err := ioutil.ReadAll(resp.Body)
	if err != nil {
		return resultList, err
	}

	var result map[string]interface{}
	json.Unmarshal(body, &result)
	if result["error"] != nil {
		return resultList, errors.New("返回错误结果:" + result["error"].(string))
	}
	list := result["results"].([](interface{}))
	for _, v := range list {
		detail := v.(map[string]interface{})
		resultList = append(resultList, detail["content"].(string)+"@"+detail["nickName"].(string))
	}
	return resultList, nil
}

最后的 main 函数

func main() {
	cloudfunction.Start(func(ctx context.Context) (string, error) {
		comments, err := getRecentComment()
		if err != nil {
			return "", err
		}
		if len(comments) == 0 {
			return "没有新消息", nil
		}

		err = notice("您有新的留言", fmt.Sprintf("%v", comments))
		if err != nil {
			return "", err
		}
		return fmt.Sprintf("%v", comments), nil
	})
}

打包部署

使用 Go 的交叉编译打包 linux 版本，然后打包上传到腾讯云函数上

测试通过

最后设置定时任务，每隔五分钟检测一次，然后把留言推送到我的微信

总结

想要为静态博客加点功能真的是麻烦