github.com/huajiao-tv/dashboard
go get github.com/huajiao-tv/dashboard

github.com/huajiao-tv/dashboard

by huajiao-tv

v0.0.0-20200710091255-8110dd753e63 (see all)License:GPL3
go get github.com/huajiao-tv/dashboard
Readme

dashboard - pepperbus & peppercron 后台

添加系统

  • 首先需要新建一个系统,系统只是根据用户需要而相互之间完全独立,用作标识,系统名称、系统说明可随便填写。 点击 系统-->添加系统:

添加集群

  • 然后需要需要为该系统的集群添加节点,该节点即为运行pepperbus的服务器,可以直接使用pepperbus_main:19840连接默认节点(即为启动pepperbus服务的服务器)。 点击 集群-->pepper_bus-->添加:

  • 状态呈“正常”即为添加成功:

添加存储

  • 接下来需要添加存储节点,用于储存job信息,可以直接使用pepperbus_redis:6379。 点击 Bus总线-->存储-->添加:

  • 状态呈“正常”即为添加成功:

  • 至此pepprebus运行所需服务已配置完成,接下来为一个消费实例。

添加queue

  • queue是用于接收job的队列,各属性可根据需要进行填写. 点击 Bus总线-->队列-->添加Queue:

添加topic

  • topic用于标识queue的子队列,每个topic队列都对应地指定了一个消费文件(可以是php文件,也可以是http),当topic队列接收到job时,pepperbus便会有worker自动执行该消费文件 点击 Bus总线-->队列-->添加Topic:

  • 示例中指定了一个http类型的消费文件,ip即为pepperbus服务器的ip

值得注意的是,由于pepperbus服务运行在docker容器中,此处不能使用127.0.0.1作为ip

运行http server

  • 可使用SDk中封装好的函数运行server,go语言示例:
busworker.NewWorkerRouter("/test/").RegisterJobHandler("testQueue","testTopic",testFunc)
busworker.Serve("192.168.238.141:4443")
  • 处理函数定义:
func testFunc(r *http.Request) *Resp{
    return &Resp{
        ErrorCode:0,
        Code:200,
        Data:"hello",
    }
}

测试

  • 在topic页面点击最右侧的测试按钮可即打开测试窗口

    • 发送ping请求,在右下角"发送"按钮的下拉中选择ping,结果为ok表示可以连通

    • 测试消费请求,可以在输入框中输入想要测试的json数据,点击发送,即可查看返回结果,结果应与自定义的处理函数返回值保持一致

发送job

  • 使用SDK中相应函数进行job的发送,即可使向队列中添加job,pepperbu会自动检测该服务并进行消费,go语言示例:
re := busworker.NewClient("192.168.238.141:12018")
re.AddJobs("testQueue","test",[]string{"test data1","test data2"})

查看消费状态

  • 点击 Bus总线-->队列-->topic(即为队列列表中“topic”列的按钮),即可查看topic队列的当前状态。可看到该job已成功消费

GitHub Stars

12

LAST COMMIT

2yrs ago

MAINTAINERS

0

CONTRIBUTORS

2

OPEN ISSUES

0

OPEN PRs

2
VersionTagPublished
v0.0.0-20200710091255-8110dd753e63
1yr ago
v0.0.0-20191227071245-cf2f4f439eaa
2yrs ago
v0.0.0-20191220022622-7b2e4773fd33
2yrs ago
No alternatives found
No tutorials found
Add a tutorial