wechat_pusher

Github

• https://github.com/hundredlee...

• 欢迎star && fork

功能列表

• 消息推送

  • 模板消息推送

    • model -> message.go

    • task -> template_task.go

  • 图片推送(TODO)

  • 文字推送(TODO)

  • 图文推送(TODO)

• 日志存储

• 计划任务

如何开始?

第一步:当然是go get

• go get github.com/hundredlee/wechat_pusher.git

• 项目结构如下:

├── README.md
├── config
│  └── config.go
├── config.conf
├── config.conf.example
├── enum
│  └── task_type.go
├── glide.lock
├── glide.yaml
├── hlog
│  ├── filelog.go
│  ├── filelog_test.go
│  └── hlog.go
├── main.go
├── main.go.example
├── models
│  ├── message.go
│  └── token.go
├── redis
│  ├── redis.go
│  └── redis_test.go
├── statics
│  └── global.go
├── task
│  ├── task.go
│  └── template_task.go
├── utils
│  ├── access_token.go
│  ├── crontab.go
│  └── push.go
└── vendor
 └── github.com

第二步:创建一个项目

创建配置文件

• 项目根目录有一个config.conf.example,重命名为config.conf即可

• 内容如下:

[WeChat]
APPID=
SECRET=
TOKEN=
[Redis]
POOL_SIZE=
TIMEOUT=
HOST=
PASS=
DB=
[Log]
LOG_PATH=

• WeChat部分

  • APPID && SECRET && TOKEN 这些是微信开发者必须了解的东西。不细讲

• Redis部分

  • POOL_SIZE 连接池大小 ,整型 int

  • TIMEOUT 连接超时时间 ,整型 int

  • HOST 连接的IP 字符串 string

  • PASS 密码 字符串 string

  • DB 数据库选择 整型 int

• Log部分

  • LOG_PATH 日志存放文件夹,例如值为wechat_log,那么完整的目录应该是 GOPATH/wechat_log

• 调用的时候这么写:

conf := config.Instance()
//例如wechat 的 appid
appId := conf.ConMap["WeChat.APPID"]

模板怎么配置

• 以模板消息作为例子说明:

• message.go 是模板消息的结构

• template_task.go 是将一个模板消息封装成任务(template_task.go 是实现了接口task.go的)

mess := models.Message{
 ToUser: "openid",
 TemplateId: "templateid",
 Url: "url",
 Data: models.Data{
 First: models.Raw{"xxx", "#173177"},
 Subject: models.Raw{"xxx", "#173177"},
 Sender: models.Raw{"xxx", "#173177"},
 Remark: models.Raw{"xxx", "#173177"}}}
//封装成一个任务,TemplateTask表示模板消息任务
task := task.TemplateTask{}
task.SetTask(mess)

• 以上代码是模板消息的配置,这个微信开发者应该都能看懂。

如何创建一个任务

• 例如我们要创建一个模板消息定时推送任务

  • 第一步,封装任务

  • 第二步,添加任务,并设置任务类型、并发执行的个数、失败尝试次数等。

  • 第三步,启动任务

• 我们用示例代码演示整个完整的过程

package main
import (
 "github.com/hundredlee/wechat_pusher/enum"
 "github.com/hundredlee/wechat_pusher/models"
 "github.com/hundredlee/wechat_pusher/task"
 "github.com/hundredlee/wechat_pusher/utils"
 "runtime"
)
func main() {
 runtime.GOMAXPROCS(runtime.NumCPU())
 var tasks []task.Task
 tasks = make([]task.Task, 100)
 mess := models.Message{
 ToUser: "oBv9cuLU5zyI27CtzI4VhV6Xabms",
 TemplateId: "UXb6s5dahNC5Zt-xQIxbLJG1BdP8mP73LGLhNXl68J8",
 Url: "http://baidu.com",
 Data: models.Data{
 First: models.Raw{"xxx", "#173177"},
 Subject: models.Raw{"xxx", "#173177"},
 Sender: models.Raw{"xxx", "#173177"},
 Remark: models.Raw{"xxx", "#173177"}}}
 task := task.TemplateTask{}
 task.SetTask(mess)
 for i := 0; i < 100; i++ {
 tasks[i] = &task
 }
 utils.NewPush(&utils.Push{
 Tasks:tasks,
 TaskType:enum.TASK_TYPE_TEMPLATE,
 Retries:4,
 BufferNum:10,
 }).Add("45 * * * * *")
 utils.StartCron()
}

• Add方法里面填写的是执行的时间

  • ("10 *") 表示每分钟的第十秒钟执行一次。

  • ("@hourly") 每小时执行一次

• 具体请参照 https://github.com/robfig/cro...

• 本推送服务的计划任务是由 https://github.com/robfig/cron 实现的。

Run

• 很简单,当你组装好所有的task以后,直接运行一句话就可以了。

 utils.NewPush(&utils.Push{
 Tasks:tasks,
 TaskType:enum.TASK_TYPE_TEMPLATE,
 Retries:4,
 BufferNum:10,
 }).Add("45 * * * * *")
 utils.StartCron()

本文来自:Segmentfault

感谢作者:Hundred_Lee

查看原文:wechat_pusher - 基于Golang开发的微信消息定时推送框架

• 编辑
• 预览