rocketmq


本小节主要介绍如何使用pan快速完成rocketmq消息的生产,在此不再对rocketmq做相关的介绍,不太了解rocketmq的可以去rocketmq官网阅读相关文档。

1、启动NameServer

  1. sh mqnamesrv

2、启动Broker

  1. sh mqbroker -n localhost:9876 autoCreateTopicEnable=true

3、修改pan中rocketmq相关配置

  1. [RocketmqProxy]
  2. enable=false
  3. producerGroup=test
  4. nameServer=127.0.0.1:9876
  5. producerRetry=2
  6. valid=TopicTest
  7. failMode=retry/save/discard(无限次重试、保存到redis、丢弃)

配置文档请点击这里

4、编译

  1. make

5、运行

  1. ./bin/pan -c ../conf/conf.ini

6、业务代码

业务方往pan中发消息,需要引入rocketmqutil,具体使用方法如下

使用方法

  1. package main
  2. import (
  3. "fmt"
  4. "time"
  5. "github.com/tal-tech/xtools/rocketmqutil"
  6. )
  7. func main() {
  8. t := time.Tick(5 * time.Second)
  9. count := 0
  10. for {
  11. select {
  12. case <-t:
  13. count++
  14. s := fmt.Sprintf("rocketmq %d", count)
  15. err := rocketmqutil.Send2Proxy("TopicTest", "stu_test_0", []byte(s))
  16. if err != nil {
  17. fmt.Println(err)
  18. }
  19. err = rocketmqutil.Send2Proxy("TopicTest", "stu_test_1", []byte(s))
  20. if err != nil {
  21. fmt.Println(err)
  22. }
  23. continue
  24. }
  25. }
  26. }

使用配置

  1. [RocketmqProxy]
  2. unix=/home/www/pan.xesv5.com/pan.sock //pan的sock文件地址
  3. host=localhost:9999 //mqproxy的ip:port地址

注意事项

注意go.mod文件中替换包

  1. replace github.com/henrylee2cn/teleport v5.0.0+incompatible => github.com/hhtlxhhxy/github.com_henrylee2cn_teleport v1.0.0
  2. replace github.com/henrylee2cn/teleport v0.0.0 => github.com/hhtlxhhxy/github.com_henrylee2cn_teleport v1.0.0