<ruby id="bdb3f"></ruby>

    <p id="bdb3f"><cite id="bdb3f"></cite></p>

      <p id="bdb3f"><cite id="bdb3f"><th id="bdb3f"></th></cite></p><p id="bdb3f"></p>
        <p id="bdb3f"><cite id="bdb3f"></cite></p>

          <pre id="bdb3f"></pre>
          <pre id="bdb3f"><del id="bdb3f"><thead id="bdb3f"></thead></del></pre>

          <ruby id="bdb3f"><mark id="bdb3f"></mark></ruby><ruby id="bdb3f"></ruby>
          <pre id="bdb3f"><pre id="bdb3f"><mark id="bdb3f"></mark></pre></pre><output id="bdb3f"></output><p id="bdb3f"></p><p id="bdb3f"></p>

          <pre id="bdb3f"><del id="bdb3f"><progress id="bdb3f"></progress></del></pre>

                <ruby id="bdb3f"></ruby>

                ??碼云GVP開源項目 12k star Uniapp+ElementUI 功能強大 支持多語言、二開方便! 廣告
                運行Nsq服務集群 首先啟動nsqlookud,在一個shell中,開始nsqlookupd: $ nsqlookupd 在另一個shell中,開始nsqd: $ nsqd --lookupd-tcp-address=127.0.0.1:4160 在另一個shell中,開始nsqadmin: $ nsqadmin --lookupd-http-address=127.0.0.1:4161 發布初始消息(也在集群中創建主題): $ curl -d 'hello world 1' 'http://127.0.0.1:4151/pub?topic=test' 最后,在另一個shell中,開始nsq_to_file: $ nsq_to_file --topic=test --output-dir=/tmp --lookupd-http-address=127.0.0.1:4161 驗證事物按預期工作,在Web瀏覽器中打開http://127.0.0.1:4171/ 以查看nsqadminUI并查看統計信息。另外,檢查test.*.log寫入的日志文件()的內容/tmp。 鏈接nsq 并創建生產者: ~~~ package main import ( "fmt" nsq "github.com/nsqio/go-nsq" ) func main() { // 定義nsq生產者 var producer *nsq.Producer // 初始化生產者 // producer, err := nsq.NewProducer("地址:端口", nsq.*Config ) producer, err := nsq.NewProducer("127.0.0.1:4150", nsq.NewConfig()) if err != nil { panic(err) } err = producer.Ping() if nil != err { // 關閉生產者 producer.Stop() producer = nil } fmt.Println("ping nsq success") } ~~~ 生產者創建topic并寫入nsq: ~~~ package main import ( "fmt" nsq "github.com/nsqio/go-nsq" ) func main() { // 定義nsq生產者 var producer *nsq.Producer // 初始化生產者 // producer, err := nsq.NewProducer("地址:端口", nsq.*Config ) producer, err := nsq.NewProducer("127.0.0.1:4150", nsq.NewConfig()) if err != nil { panic(err) } err = producer.Ping() if nil != err { // 關閉生產者 producer.Stop() producer = nil } // 生產者寫入nsq,10條消息,topic = "test" topic := "test" for i := 0; i < 10; i++ { message := fmt.Sprintf("message:%d", i) if producer != nil && message != "" { //不能發布空串,否則會導致error err = producer.Publish(topic, []byte(message)) // 發布消息 if err != nil { fmt.Printf("producer.Publish,err : %v", err) } fmt.Println(message) } } fmt.Println("producer.Publish success") } ~~~
                  <ruby id="bdb3f"></ruby>

                  <p id="bdb3f"><cite id="bdb3f"></cite></p>

                    <p id="bdb3f"><cite id="bdb3f"><th id="bdb3f"></th></cite></p><p id="bdb3f"></p>
                      <p id="bdb3f"><cite id="bdb3f"></cite></p>

                        <pre id="bdb3f"></pre>
                        <pre id="bdb3f"><del id="bdb3f"><thead id="bdb3f"></thead></del></pre>

                        <ruby id="bdb3f"><mark id="bdb3f"></mark></ruby><ruby id="bdb3f"></ruby>
                        <pre id="bdb3f"><pre id="bdb3f"><mark id="bdb3f"></mark></pre></pre><output id="bdb3f"></output><p id="bdb3f"></p><p id="bdb3f"></p>

                        <pre id="bdb3f"><del id="bdb3f"><progress id="bdb3f"></progress></del></pre>

                              <ruby id="bdb3f"></ruby>

                              哎呀哎呀视频在线观看