package nsqclient
|
|
import (
|
"bytes"
|
"fmt"
|
"io/ioutil"
|
"net/http"
|
)
|
|
const nsqWebApi = "http://121.31.232.83:9080/api/nsq/pub"
|
|
// http接口 http://121.31.232.83:9080/api/nsq/pub?topic=your_topic
|
func HttpPost(topic string, data []byte) bool {
|
uri := nsqWebApi + "?topic=" + topic
|
|
request, err := http.NewRequest(http.MethodPost, uri, bytes.NewReader(data))
|
if err != nil {
|
return false
|
}
|
|
request.Header.Set("Content-Type", "application/json;charset=UTF-8")
|
|
response, err := http.DefaultClient.Do(request)
|
if err != nil {
|
fmt.Printf(err.Error())
|
return false
|
}
|
defer response.Body.Close()
|
|
body, _ := ioutil.ReadAll(response.Body)
|
|
fmt.Println("response:", string(body))
|
|
return true
|
}
|
