Web服务器和同时监听的NAT

Golang不知道大家是否熟悉？今天我将给大家介绍《Web服务器和同时监听的NAT》，这篇文章主要会讲到等等知识点，如果你在看完本篇文章后，有更好的建议或者发现哪里有问题，希望大家都能积极评论指出，谢谢！希望我们能一起加油进步！

我的代码从终端读取输入并将这些值发送到 nats，同时它需要有一个 http 端点。

单独它可以工作，但是当我将它们全部组合起来时，它不会从nats读取。如果您能为我指明正确的方向，我将不胜感激。

package main

import (
    "bufio"
    "fmt"
    nats "github.com/nats-io/nats.go"
    "html/template"
    "log"
    "net/http"
    "os"
)


func main() {
    wd, err := os.Getwd()
    if err != nil {
        log.Fatal(err)
    }

    tmpl := template.Must(template.ParseFiles(wd + "/template/main.html"))
    http.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {
        data := TodoPageData{
            PageTitle: "Demo",          
        }
        tmpl.Execute(w, data)
    })
    http.ListenAndServe(":8081", nil)

    type message struct {
        content string
    }
    var messages []message

    nc, err := nats.Connect(
        nats.DefaultURL,
    )

    if err != nil {
        log.Fatal(err)
    }
    defer nc.Close()

    // Subscribe
    if _, err := nc.Subscribe("updates", func(m *nats.Msg) {
        fmt.Printf("Received a message: %s\n", string(m.Data))
    }); err != nil {
        log.Fatal(err)
    }

    // io r/w
    scanner := bufio.NewScanner(os.Stdin)
    for scanner.Scan() {
        if err := nc.Publish("updates", []byte(scanner.Text())); err != nil {
            log.Fatal(err)
        }
        messages = append(messages, message{scanner.Text()})
        for _, message := range messages {
            fmt.Println(message.content)
        }
    }

    if scanner.Err() != nil {
        // handle error.
    }
}

解决方案

http.ListenAndServe 是阻塞调用。在一个新的 goroutine 上启动它：

go http.ListenAndServe(":8081", nil)

今天关于《Web服务器和同时监听的NAT》的内容就介绍到这里了，是不是学起来一目了然！想要了解更多关于的内容请关注golang学习网公众号！