tcp server 用于给andriod 客户端定时发送消息
liuxiaolong
2020-06-18 da943234de5539f0e995c3f500a5778a4ccaafdb
set EsUrl
2个文件已修改
7 ■■■■ 已修改文件
controllers/EsController.go 4 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
server.go 3 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
controllers/EsController.go
@@ -33,8 +33,8 @@
    })
}
var EsUrl string
func getVideoUrlById(_id string) string {
    url := ""
    jsonDSL:= `{
        "query": {
            "bool": {
@@ -51,7 +51,7 @@
            "videoUrl"
        ]
    }`
    body, err := esutil.EsReq("POST", url, []byte(jsonDSL))
    body, err := esutil.EsReq("POST", EsUrl, []byte(jsonDSL))
    if err != nil {
        return ""
    }
server.go
@@ -1,6 +1,7 @@
package main
import (
    "andriodServer/controllers"
    "andriodServer/router"
    "flag"
    "fmt"
@@ -37,6 +38,8 @@
    config.Init(*env, *confPath)
    fmt.Println(*port)
    controllers.EsUrl = *Eurl
    mqAddr := "amqp://" + *mqUser + ":" + *mqPass + "@" + *mqIp + ":" + strconv.Itoa(*mqPort)+"/"
    conn, err := amqp.Dial(mqAddr)