NSQ(https://github.com/bitly/nsq)是一個(gè)基于Go語(yǔ)言的分布式實(shí)時(shí)消息平臺(tái)。
下面是我使用的一個(gè)nsq producer的源碼例子。希望幫到需要的朋友。

package main

import (

    "fmt"
    "flag"

    "github.com/crackcomm/nsqueue/producer"
)

var (
    nsqdAddr        = flag.String("nsqd", "127.0.0.1:4150", "nsqd http address")
)

// UploadMsg represent the msg sent to download task.
type UploadMsg struct {
    Bucket       string
    Object       string
    ContentType  string
    Author       string
    Size         int64

    SrcFilePath     string   //源路徑
    DstFilePath    string   //目標(biāo)路徑
}

// SendTask - to send upload task to nsq.
func SendTask(msg *UploadMsg) error {
    myProducer := producer.New()
    myProducer.Connect(*nsqdAddr)

    myProducer.PublishJSON("latency-test", msg)
    myProducer.Stop()
    return nil
}

func main() {
    flag.Parse()
    var msg UploadMsg
    msg.Bucket = "new_bucket"
    msg.Object = "new_object"
    msg.ContentType = "type"
    msg.Author = "bary"
    msg.Size = 666
    msg.SrcFilePath = "/tmp/qidong"
    msg.DstFilePath = "/raid/qidong"
    err := SendTask(&msg)
    if err != nil {
        fmt.Println(err.Error())
    }
    fmt.Println("Done !")
}