这个框架的目标是作为一个通用的框架，我希望它大而全，在日后可以直接作为我其他项目的基础模板，所以我还想继续给他添加一些功能，就当写一些demo进去吧。这篇文章，我将会添加一个队列的功能。

创新互联2013年至今，先为太康等服务建站，太康等地企业，进行企业商务咨询服务。为太康企业网站制作PC+手机+微官网三网同步一站式服务解决您的所有建站问题。

nsq

队列有很多种，我选择nsq。使用nsq需要知道以下几个概念：

1. nsqd：负责维护队列的组件，接受消息排队和投递；
2. nsqlookupd：管理nsq集群的组件；
3. nsqadmin：nsq的web管理组件；
4. topic：消息的集合。产生消息，需要指定该消息属于哪个topic的；
5. channel：队列消息的副本。nsq消费者与nsqd或者nsqlookupd建立一个channel，并监听channel中的消息，从而实现消费。

了解了一些nsq的基础概念之后，我们先把nsq环境搭建起来，这里我们还是用docker-compose好了，以下是nsq的docker-compose.yaml。

version: '3'
services:
  nsqlookupd:
   image: nsqio/nsq
   command: /nsqlookupd
   networks:
    - nsq-network
   hostname: nsqlookupd
   ports:
    - "4161:4161"
    - "4160:4160"
  nsqd:
   image: nsqio/nsq
   command: /nsqd --lookupd-tcp-address=nsqlookupd:4160 --broadcast-address=nsqd
   depends_on:
    - nsqlookupd
   hostname: nsqd
   networks:
    - nsq-network
   ports:
    - "4151:4151"
    - "4150:4150"
  nsqadmin:
   image: nsqio/nsq
   command: /nsqadmin --lookupd-http-address=nsqlookupd:4161
   depends_on:
    - nsqlookupd
   hostname: nsqadmin
   ports:
    - "4171:4171"
   networks:
    - nsq-network

networks:
  nsq-network:
   driver: bridge

启动了nsq服务之后，我们简单地验证一下，发布一条消息到nsq中：

curl -d 'hello awesome' 'http://127.0.0.1:4151/pub?topic=awesome'

浏览器访问：http://localhost:4171/，我们也可以看到有相应的topic和产生

接着我们修改一下代码，老规矩，先改配置：

"nsq_config":
  "topic": "awesome"
  "channel": "ch"
  "nsqlookupd_addr": "127.0.0.1:4161"

type NsqConfig struct {
   Topic      string `yaml:"topic"`
   Channel     string `yaml:"channel"`
   NsqLookupdAddr string `yaml:"nsqlookupd_addr"`
}

然后在mq.go中添加一个启动mq消费者的函数：

func StartMqServer() {
   conf := nsq.NewConfig()
   q, _ := nsq.NewConsumer(config.GetConfig().NsqConfig.Topic, config.GetConfig().NsqConfig.Channel, conf)
   q.AddHandler(nsq.HandlerFunc(func(message *nsq.Message) error {
     //do something when you receive a message
     logger.GetLogger().Info("receive", zap.String(config.GetConfig().NsqConfig.Topic, string(message.Body)))
     return nil
   }))
   err := q.ConnectToNSQLookupd(config.GetConfig().NsqConfig.NsqLookupdAddr)
   if err != nil {
     logger.GetLogger().Error("connect to nsqlookupd failed.", zap.Error(err))
     os.Exit(-1)
   }
}

同样在入口文件，启动它：

go mq.StartMqServer()

最后，我们写个生产者，生成一条消息，测试一下：

func TestProducer(t *testing.T)  {
   config := nsq.NewConfig()
   p, err := nsq.NewProducer("127.0.0.1:4150", config)

   if err != nil {
     log.Panic(err)
   }

   err = p.Publish("awesome", []byte("hello awesome"))
   if err != nil {
     log.Panic(err)
   }
}

另外有需要云服务器可以了解下创新互联cdcxhl.cn，海内外云服务器15元起步，三天无理由+7*72小时售后在线，公司持有idc许可证，提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案，具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势，专为企业上云打造定制，能够满足用户丰富、多元化的应用场景需求。

网站名称：怎么搭建golang框架-创新互联
网页网址：http://lswzjz.com/article/cdgojo.html